MySQL技术求助：将3个同构异数据表合并至主表并同步更新

针对你要合并3个结构相似、仅更新不新增记录的表到主表的需求，以下是几种可行方案：

1. 使用视图（View）—— 无数据冗余，实时同步 #

如果你的代码只需要查询合并后的数据，不需要对主表做写入操作，视图是最省心的方案。视图本身不存储数据，每次查询都会实时聚合三个原表的最新数据，完美适配原表仅更新的特性。

创建视图的SQL示例：

-- 假设三个表为table_a、table_b、table_c，结构完全一致
CREATE VIEW main_view AS
SELECT * FROM table_a
UNION ALL
SELECT * FROM table_b
UNION ALL
SELECT * FROM table_c;

• 优势：无需维护数据一致性，原表更新后视图自动同步；无需额外存储资源。
• 注意：如果原表数据量极大，频繁查询视图可能会有性能损耗，建议给原表的常用查询字段添加索引。如果三个表存在重复的唯一标识（如id），需在视图中新增来源标识字段区分：

CREATE VIEW main_view AS
SELECT *, 'table_a' AS source_table FROM table_a
UNION ALL
SELECT *, 'table_b' AS source_table FROM table_b
UNION ALL
SELECT *, 'table_c' AS source_table FROM table_c;

2. 触发器（Trigger）—— 实时同步到物理主表 #

如果代码需要对合并后的主表做写入操作，或者需要更好的查询性能，可以创建物理主表，并用触发器实现原表更新时自动同步主表数据。

步骤： #

1. 初始化主表：先将三个原表的数据导入主表（若主表已存在则跳过）

-- 创建主表（结构与原表一致，可额外添加source_table字段区分来源）
CREATE TABLE main_table LIKE table_a;
ALTER TABLE main_table ADD COLUMN source_table VARCHAR(20) DEFAULT '';

-- 导入初始数据
INSERT INTO main_table
SELECT *, 'table_a' FROM table_a
UNION ALL
SELECT *, 'table_b' FROM table_b
UNION ALL
SELECT *, 'table_c' FROM table_c;

-- 给主表添加唯一键（确保能匹配原表更新的记录）
ALTER TABLE main_table ADD UNIQUE KEY idx_id_source (id, source_table);

2. 创建更新触发器：给每个原表添加AFTER UPDATE触发器，同步更新主表对应记录
   以table_a为例：

DELIMITER //
CREATE TRIGGER sync_table_a_to_main AFTER UPDATE ON table_a
FOR EACH ROW
BEGIN
    UPDATE main_table
    SET col1 = NEW.col1, col2 = NEW.col2, col3 = NEW.col3 -- 列出所有需要同步的字段
    WHERE id = NEW.id AND source_table = 'table_a';
END //
DELIMITER ;

同理给table_b、table_c创建相同逻辑的触发器。

• 优势：主表是物理表，查询性能优于视图；原表更新后主表实时同步。
• 注意：触发器会增加原表更新的开销，若每秒更新频率极高，需评估数据库性能是否能承受；确保主表的唯一键能精准匹配原表记录，避免同步错误。

3. 定期同步—— 低开销的非实时方案 #

如果对同步实时性要求不高（如允许几秒/几分钟延迟），可以用定期同步的方式，通过MySQL事件调度器或外部脚本（Shell/Python）执行同步SQL。

方案A：MySQL事件调度器 #

先开启事件调度器：

SET GLOBAL event_scheduler = ON;

创建每分钟同步一次的事件：

DELIMITER //
CREATE EVENT sync_main_table
ON SCHEDULE EVERY 1 MINUTE
STARTS CURRENT_TIMESTAMP
DO
BEGIN
    -- 用REPLACE INTO或INSERT ... ON DUPLICATE KEY UPDATE同步数据
    REPLACE INTO main_table
    SELECT *, 'table_a' FROM table_a
    UNION ALL
    SELECT *, 'table_b' FROM table_b
    UNION ALL
    SELECT *, 'table_c' FROM table_c;
END //
DELIMITER ;

方案B：外部脚本 #

用Python/Shell脚本定时执行同步SQL，示例Python代码（使用pymysql）：

import pymysql
import time

def sync_tables():
    conn = pymysql.connect(host='your_host', user='user', password='pwd', db='your_db')
    cursor = conn.cursor()
    sync_sql = """
    REPLACE INTO main_table
    SELECT *, 'table_a' FROM table_a
    UNION ALL
    SELECT *, 'table_b' FROM table_b
    UNION ALL
    SELECT *, 'table_c' FROM table_c;
    """
    cursor.execute(sync_sql)
    conn.commit()
    conn.close()

while True:
    sync_tables()
    time.sleep(60) # 每分钟同步一次

• 优势：对原表更新性能影响极小；适合高频率更新的场景。
• 注意：同步间隔需根据业务需求调整；确保同步SQL的幂等性，避免重复执行导致数据异常。

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