跨多MySQL实例数据合并策略：从客户端到FEDERATED引擎

在企业级应用中，经常会遇到需要整合多个独立MySQL实例数据的场景，比如多地域部署的业务系统、分库分表的 legacy 系统整合等。本文将从最简单的客户端合并方案开始，逐步介绍更高效的服务器端合并方案，重点讲解FEDERATED存储引擎的使用方法。

一、客户端数据合并方案

最直观的跨实例数据合并方式是在应用客户端分别连接不同的MySQL实例，查询数据后在内存中完成整合。这种方式无需修改数据库配置，灵活性高，适合数据量小、合并逻辑简单的场景。

import pymysql

# 定义多个MySQL实例的连接配置
db_configs = [
    {
        "host": "127.0.0.1",
        "port": 3306,
        "user": "root",
        "password": "123456",
        "database": "db_region1"
    },
    {
        "host": "192.168.0.101",
        "port": 3306,
        "user": "root",
        "password": "123456",
        "database": "db_region2"
    }
]

def query_all_user():
    """查询所有实例的用户数据并合并"""
    all_users = []
    for config in db_configs:
        # 建立数据库连接
        conn = pymysql.connect(**config)
        cursor = conn.cursor(pymysql.cursors.DictCursor)
        # 执行查询
        cursor.execute("SELECT id, name, age FROM user")
        result = cursor.fetchall()
        all_users.extend(result)
        # 关闭连接
        cursor.close()
        conn.close()
    return all_users

if __name__ == "__main__":
    users = query_all_user()
    print(f"合并后共查询到{len(users)}条用户数据")

这种方案的缺点也很明显：每次合并都需要客户端发起多次数据库连接，数据量大时网络开销高，且内存占用会随着数据量增长而上升，不适合高频查询或大数据量的场景。

二、基于FEDERATED引擎的服务器端合并方案

FEDERATED是MySQL提供的存储引擎之一，它不存储数据，而是通过网络连接到远程MySQL实例，将远程表的查询请求转发到目标实例，在本地返回查询结果。我们可以在一个统一的MySQL实例中创建多个FEDERATED表映射到不同远程实例的表，再通过视图直接完成数据合并，所有操作都在数据库服务器端完成，减少客户端压力。

2.1 环境准备

首先需要确认MySQL是否支持FEDERATED引擎，登录MySQL后执行以下命令查看：

-- 查看支持的存储引擎，FEDERATED状态为YES表示支持
SHOW ENGINES;

如果FEDERATED引擎未启用，需要修改MySQL配置文件（my.cnf或my.ini），在[mysqld]段添加以下配置后重启MySQL服务：

[mysqld]
federated

2.2 远程实例表准备

假设我们有两个远程MySQL实例，分别有业务表user，结构如下，我们先在远程实例确认表结构一致：

-- 远程实例1（127.0.0.1:3306，数据库db_region1）的user表
CREATE TABLE `user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(50) NOT NULL,
  `age` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

-- 远程实例2（192.168.0.101:3306，数据库db_region2）的user表结构同上

2.3 创建FEDERATED映射表

在我们的汇总实例（比如本地127.0.0.1:3307）中，创建FEDERATED表映射到远程实例的user表，创建语法需要指定连接字符串，格式为：

-- 创建映射到远程实例1的FEDERATED表
CREATE TABLE `user_region1` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(50) NOT NULL,
  `age` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=FEDERATED
CONNECTION='mysql://root:123456@127.0.0.1:3306/db_region1/user';

-- 创建映射到远程实例2的FEDERATED表
CREATE TABLE `user_region2` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(50) NOT NULL,
  `age` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=FEDERATED
CONNECTION='mysql://root:123456@192.168.0.101:3306/db_region2/user';

注意CONNECTION字符串中的密码、地址、端口、数据库名、表名需要根据实际情况修改，如果远程实例的用户名密码包含特殊字符，需要做URL编码处理。

2.4 创建合并视图

创建完FEDERATED映射表后，我们可以通过CREATE VIEW语句创建合并视图，直接查询多个远程实例的数据：

-- 创建合并所有区域用户数据的视图
CREATE VIEW `v_all_user` AS
SELECT * FROM `user_region1`
UNION ALL
SELECT * FROM `user_region2`;

如果需要对合并后的数据做去重，可以把UNION ALL替换为UNION，不过UNION会触发排序去重，性能比UNION ALL低，根据实际需求选择即可。

2.5 使用合并后的数据

之后客户端只需要连接汇总实例，查询视图就可以获取所有远程实例的合并数据，无需关心底层多个实例的细节：

-- 查询所有用户数据
SELECT * FROM `v_all_user`;

-- 按年龄统计用户数
SELECT age, COUNT(*) AS user_count FROM `v_all_user` GROUP BY age;

三、两种方案对比

四、注意事项

• FEDERATED引擎不支持事务，查询远程表时如果远程实例锁表，可能导致查询阻塞。
• 远程表的表结构修改后，本地的FEDERATED映射表不会自动同步，需要手动修改映射表结构。
• CONNECTION字符串中的密码是明文存储的，需要注意汇总实例的权限管理，避免密码泄露。
• 如果远程实例连接失败，查询FEDERATED表会直接返回错误，建议结合监控做好可用性告警。

除了FEDERATED引擎，MySQL 8.0还提供了更强大的联邦查询功能，也可以通过第三方中间件如MyCat、ShardingSphere实现跨实例数据合并，读者可以根据自身业务场景选择合适的方案。

MySQL数据合并FEDERATED引擎跨实例查询数据库视图多数据源整合 本作品最后修改时间：2026-05-21 00:41:54