如何从MySQL主库筛选唯一库名并循环执行更新脚本？

当然可以！这其实是多租户独立数据库场景下批量更新的标准操作思路，完全能解决你手动更新数百个库的困扰。下面我给你拆解具体的实现步骤和注意事项：

核心逻辑 #

从存储客户配置的主数据库中提取唯一且有效的客户数据库名称，然后通过脚本循环遍历这个列表，逐个对目标数据库执行更新脚本。

具体实现方案 #

1. 先从主数据库拉取唯一库名 #

首先写一条SQL查询，从主库中获取去重后的客户数据库名称，建议加上过滤条件（比如只更新活跃客户的库）：

-- 假设主库的配置表是`customer_settings`，存储库名的字段为`customer_db_name`
SELECT DISTINCT customer_db_name 
FROM customer_settings 
WHERE customer_status = 'active'; -- 仅筛选活跃客户，避免无效更新

2. 编写循环执行的自动化脚本 #

根据你日常使用的工具，这里提供两种常用的脚本示例：

示例1：Shell脚本（适配MySQL/MariaDB）

#!/bin/bash

# 主数据库连接信息
MASTER_HOST="你的主库地址"
MASTER_USER="数据库用户名"
MASTER_PASS="数据库密码"
MASTER_DB="主库名称"

# 获取去重后的客户库名列表
DB_LIST=$(mysql -h$MASTER_HOST -u$MASTER_USER -p$MASTER_PASS $MASTER_DB -N -e "SELECT DISTINCT customer_db_name FROM customer_settings WHERE customer_status = 'active';")

# 遍历每个客户库执行更新
for DB_NAME in $DB_LIST; do
    echo "=== 开始更新数据库: $DB_NAME ==="
    # 执行你的更新脚本（假设更新脚本是update_schema.sql）
    mysql -h$MASTER_HOST -u$MASTER_USER -p$MASTER_PASS $DB_NAME < update_schema.sql
    
    # 记录执行结果
    if [ $? -eq 0 ]; then
        echo "$DB_NAME 更新成功" >> update_success.log
    else
        echo "$DB_NAME 更新失败" >> update_error.log
    fi
done

示例2：Python脚本（更灵活，适配多种数据库）

import psycopg2  # 如果是PostgreSQL用这个，MySQL用pymysql

# 主数据库配置
master_db_config = {
    "host": "你的主库地址",
    "user": "数据库用户名",
    "password": "数据库密码",
    "dbname": "主库名称"
}

# 读取更新脚本内容（也可以直接写在代码里）
with open("update_script.sql", "r") as f:
    update_sql = f.read()

try:
    # 连接主库获取客户库名
    with psycopg2.connect(**master_db_config) as master_conn:
        with master_conn.cursor() as master_cursor:
            master_cursor.execute("SELECT DISTINCT customer_db_name FROM customer_settings WHERE customer_status = 'active';")
            customer_dbs = master_cursor.fetchall()

            # 逐个更新客户库
            for (db_name,) in customer_dbs:
                print(f"正在处理数据库: {db_name}")
                # 连接当前客户库
                customer_config = master_db_config.copy()
                customer_config["dbname"] = db_name
                try:
                    with psycopg2.connect(**customer_config) as customer_conn:
                        with customer_conn.cursor() as customer_cursor:
                            customer_cursor.execute(update_sql)
                            customer_conn.commit()
                    print(f"{db_name} 更新完成")
                    with open("update_success.log", "a") as log_f:
                        log_f.write(f"{db_name} - 更新成功\n")
                except Exception as e:
                    print(f"{db_name} 更新失败: {str(e)}")
                    with open("update_error.log", "a") as log_f:
                        log_f.write(f"{db_name} - 更新失败: {str(e)}\n")
except Exception as e:
    print(f"获取客户库列表失败: {str(e)}")

必须注意的细节 #

• 去重是关键：一定要用DISTINCT确保每个客户库只被更新一次，避免重复执行脚本浪费资源
• 过滤无效库：通过主库的状态字段（比如customer_status）跳过已停用、测试类的数据库
• 异常与日志：一定要记录每个库的更新结果，方便后续排查失败的情况，避免遗漏更新
• 先测试再批量：先在测试环境选几个客户库验证脚本逻辑，确认没问题再全量执行
• 性能优化：如果客户库数量超过几百个，可以考虑分批执行（比如每次处理20个），避免一次性占用过多数据库连接资源

内容的提问来源于stack exchange，提问作者Six of Eighteen