如何将同一份MySQL脚本批量应用至多个数据库？

嘿，我完全懂你现在的烦恼——手动写一堆几乎一模一样的CREATE TABLE语句实在太冗余了！你提到用存储过程加USE dbname的思路确实可行，但还有更灵活高效的方式，尤其是当你的数据库和表命名有规律的时候。

方案一：利用动态SQL+循环处理规律命名的库和表 #

如果你的数据库是dbname1、dbname2...dbnameN，表是aaa、bbb这类基础名，可以直接用存储过程循环生成并执行SQL，不用手动写每一行：

DELIMITER //

CREATE PROCEDURE CloneTablesAcrossDBs()
BEGIN
    -- 定义需要处理的基础表名（逗号分隔）
    DECLARE table_names TEXT DEFAULT 'aaa,bbb';
    DECLARE current_table VARCHAR(255);
    DECLARE db_suffix INT DEFAULT 1;
    DECLARE max_db_suffix INT DEFAULT 3; -- 替换成你的实际数据库数量
    DECLARE done INT DEFAULT 0;
    
    -- 游标遍历表列表
    DECLARE table_cursor CURSOR FOR 
        SELECT TRIM(SUBSTRING_INDEX(SUBSTRING_INDEX(table_names, ',', n), ',', -1)) 
        FROM (SELECT 1 n UNION ALL SELECT 2 UNION ALL SELECT 3) numbers 
        WHERE n <= LENGTH(table_names) - LENGTH(REPLACE(table_names, ',', '')) + 1;
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;

    OPEN table_cursor;
    table_loop: LOOP
        FETCH table_cursor INTO current_table;
        IF done THEN
            LEAVE table_loop;
        END IF;

        -- 循环处理每个数据库后缀
        SET db_suffix = 1;
        db_loop: LOOP
            IF db_suffix > max_db_suffix THEN
                LEAVE db_loop;
            END IF;

            -- 动态生成克隆表的SQL
            SET @sql = CONCAT(
                'CREATE TABLE ', current_table, db_suffix, ' AS SELECT * FROM dbname', db_suffix, '.', current_table
            );
            PREPARE stmt FROM @sql;
            EXECUTE stmt;
            DEALLOCATE PREPARE stmt;

            SET db_suffix = db_suffix + 1;
        END LOOP db_loop;
    END LOOP table_loop;
    CLOSE table_cursor;
END //

DELIMITER ;

这个存储过程的优势： #

• 只需修改table_names和max_db_suffix就能适配你的实际需求
• 自动遍历所有指定表和数据库，省去重复编写代码的麻烦
• 结构清晰，后续维护（比如新增表/数据库）只需要调整参数

方案二：适配非规律命名的数据库列表 #

如果你的数据库名称不是数字后缀（比如db_alpha、db_beta），可以把数据库列表存入临时表，再循环处理：

DELIMITER //

CREATE PROCEDURE CloneTablesFromDBList()
BEGIN
    DECLARE table_names TEXT DEFAULT 'aaa,bbb';
    DECLARE current_table VARCHAR(255);
    DECLARE current_db VARCHAR(255);
    DECLARE done_tables INT DEFAULT 0;
    DECLARE done_dbs INT DEFAULT 0;
    
    -- 创建临时表存储目标数据库列表
    CREATE TEMPORARY TABLE IF NOT EXISTS target_dbs (db_name VARCHAR(255));
    TRUNCATE target_dbs;
    INSERT INTO target_dbs VALUES ('dbname1'), ('dbname2'), ('dbname3'); -- 替换成你的实际数据库名
    
    -- 游标遍历表列表
    DECLARE table_cursor CURSOR FOR 
        SELECT TRIM(SUBSTRING_INDEX(SUBSTRING_INDEX(table_names, ',', n), ',', -1)) 
        FROM (SELECT 1 n UNION ALL SELECT 2 UNION ALL SELECT 3) numbers 
        WHERE n <= LENGTH(table_names) - LENGTH(REPLACE(table_names, ',', '')) + 1;
    -- 游标遍历数据库列表
    DECLARE db_cursor CURSOR FOR SELECT db_name FROM target_dbs;
    
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done_tables = 1;

    OPEN table_cursor;
    table_loop: LOOP
        FETCH table_cursor INTO current_table;
        IF done_tables THEN
            LEAVE table_loop;
        END IF;
        
        SET done_dbs = 0;
        OPEN db_cursor;
        db_loop: LOOP
            FETCH db_cursor INTO current_db;
            IF done_dbs THEN
                LEAVE db_loop;
            END IF;
            
            -- 提取数据库名称中的后缀（比如从dbname1中拿到1）
            SET @suffix = SUBSTRING(current_db, LOCATE('dbname', current_db) + LENGTH('dbname'));
            -- 生成克隆SQL
            SET @sql = CONCAT(
                'CREATE TABLE ', current_table, @suffix, ' AS SELECT * FROM ', current_db, '.', current_table
            );
            PREPARE stmt FROM @sql;
            EXECUTE stmt;
            DEALLOCATE PREPARE stmt;
        END LOOP db_loop;
        CLOSE db_cursor;
    END LOOP table_loop;
    CLOSE table_cursor;
    DROP TEMPORARY TABLE IF EXISTS target_dbs;
END //

DELIMITER ;

关于你提到的USE dbname方案 #

其实这个思路也能实现，只是灵活性稍差，适合表数量较少的场景：

DELIMITER //

CREATE PROCEDURE CloneTablesWithUSE()
BEGIN
    DECLARE db_suffix INT DEFAULT 1;
    DECLARE max_db_suffix INT DEFAULT 3;
    
    db_loop: LOOP
        IF db_suffix > max_db_suffix THEN
            LEAVE db_loop;
        END IF;
        
        -- 切换到目标数据库
        SET @db = CONCAT('dbname', db_suffix);
        SET @use_sql = CONCAT('USE ', @db);
        PREPARE stmt FROM @use_sql;
        EXECUTE stmt;
        DEALLOCATE PREPARE stmt;
        
        -- 逐个克隆表
        SET @sql1 = CONCAT('CREATE TABLE aaa', db_suffix, ' AS SELECT * FROM aaa');
        PREPARE stmt FROM @sql1;
        EXECUTE stmt;
        DEALLOCATE PREPARE stmt;
        
        SET @sql2 = CONCAT('CREATE TABLE bbb', db_suffix, ' AS SELECT * FROM bbb');
        PREPARE stmt FROM @sql2;
        EXECUTE stmt;
        DEALLOCATE PREPARE stmt;
        
        SET db_suffix = db_suffix + 1;
    END LOOP db_loop;
END //

DELIMITER ;

注意事项 #

• 确保执行存储过程的用户拥有创建表和访问所有源数据库的权限
• 如果源表有更新需求，这个方案是全量克隆，增量同步需要额外处理（比如用触发器或定时同步脚本）
• 执行前可以先测试单条SQL是否正常，避免批量执行出错

内容的提问来源于stack exchange，提问作者user2610861