mysql在多数据库迁移中的数据同步与分布式架构

P粉602998670

P粉602998670

2026-01-23

403人浏览

原创

mysql多库迁移主键冲突需设auto_increment偏移、停写源库或用on duplicate key update;gtid同步须开启一致性校验;分库分表依赖中间件路由;proxysql实现灰度流量调度。

mysql在多数据库迁移中的数据同步与分布式架构

MySQL 多库迁移时主键冲突怎么破

跨数据库迁移最常踩的坑不是数据丢,而是 INSERTDuplicate entry 'X' for key 'PRIMARY'。根源往往是源库和目标库都用自增主键,且没做偏移或范围隔离。

实操建议:

  • 迁移前统一停写源库,或用 mysqldump --skip-triggers --skip-extended-insert 导出,避免触发器干扰
  • 目标库建表时改用 AUTO_INCREMENT = 1000000(设一个远大于源库最大 ID 的起始值)
  • 若需双写过渡,推荐在应用层用 REPLACE INTOINSERT ... ON DUPLICATE KEY UPDATE,但要注意业务语义是否允许覆盖
  • 别依赖 SELECT MAX(id) 动态算偏移——并发下不准,且无法应对已删除 ID 的空洞

binlog + GTID 实现跨实例同步的硬约束

CHANGE REPLICATION SOURCE TO 搭建主从是基础,但多数据库迁移中真正决定同步可靠性的,是 GTID 模式下的三件事:开启、校验、跳过。

关键配置与验证点:

  • 源库必须启用 gtid_mode = ONenforce_gtid_consistency = ON,否则无法保证事务全局唯一
  • 迁移后首次启动从库前,执行 SELECT * FROM performance_schema.replication_applier_status_by_coordinator; 确认 APPLIER_STATUSACTIVE
  • 遇到不兼容 DDL(如 CREATE TEMPORARY TABLE),不能直接 SET GLOBAL sql_slave_skip_counter = 1 —— GTID 下必须用 STOP REPLICA; SET GTID_NEXT = 'xxx'; BEGIN; COMMIT; SET GTID_NEXT = 'AUTOMATIC'; START REPLICA;
  • GTID 不支持跨引擎事务(比如 InnoDB + MyISAM 混用),迁移前务必检查 SHOW CREATE TABLE 中的 ENGINE 一致性

分库分表场景下,如何让读写不绕晕

真分布式架构里,MySQL 本身不负责路由,靠中间件(如 ShardingSphereMyCat)或客户端分片逻辑。但迁移过程中最容易出问题的是「写入新库、读取旧库」这类脏读。

度加AI
度加AI

度加AI官网入口,百度官方 AIGC 创作平台,支持 AI 成片、AI 生文、数字人、声音克隆、配音字幕与智能剪辑等在线创作能力。

下载

落地要点:

  • 禁止在应用代码里硬编码数据库名,所有 USE db_name 必须通过配置中心动态注入
  • 分片键(sharding key)字段必须有索引,否则 WHERE user_id = ? 查询会扫全库;迁移前用 EXPLAIN FORMAT=TREE 验证执行计划
  • 跨分片 JOINUNION 操作,中间件通常不支持或性能极差——要么改查为多次单库查询+内存聚合,要么提前物化宽表到单独汇总库
  • 时间类分片(按月建表)注意 DATE 字段类型和分区表达式匹配,例如 PARTITION BY RANGE (TO_DAYS(create_time)) 要求 create_timeDATEDATETIME,不能是 TIMESTAMP

为什么 ProxySQL 比直连更适配迁移期流量调度

单纯靠 DNS 切换或 VIP 漂移,无法实现灰度、读写分离、故障自动摘除。ProxySQL 的 mysql_serversmysql_query_rules 表才是迁移期的流量阀门。

典型配置逻辑:

  • 把旧库和新库都加进 mysql_servers,用不同 hostgroup_id(如 10=旧主库,20=新主库)
  • 写请求规则优先匹配 destination_hostgroup = 20,但初期只设 active = 0;灰度时用 weight 控制流量比例
  • 读请求可基于 username 或 SQL 注释(如 /* slave */ SELECT ...)路由到从库组,避免主库压力突增
  • 监控 stats_mysql_connection_pool 表里的 statusConnUsed,发现某节点连接数暴涨或状态为 SHUNNED,立刻查日志定位网络或认证失败原因
UPDATE mysql_servers SET weight=50 WHERE hostgroup_id=20 AND hostname='new-db-01';
LOAD MYSQL SERVERS TO RUNTIME;
SAVE MYSQL SERVERS TO DISK;

迁移不是一次性动作,而是状态切换过程。最常被忽略的是应用连接池的 maxActiveminIdle 参数——切库后若未重启服务,旧连接可能长期滞留,导致新库负载虚高、旧库连接泄漏。

相关专题

更多
数据分析工具有哪些
数据分析工具有哪些

数据分析工具有Excel、SQL、Python、R、Tableau、Power BI、SAS、SPSS和MATLAB等。详细介绍:1、Excel,具有强大的计算和数据处理功能;2、SQL,可以进行数据查询、过滤、排序、聚合等操作;3、Python,拥有丰富的数据分析库;4、R,拥有丰富的统计分析库和图形库;5、Tableau,提供了直观易用的用户界面等等。

2023.10.12

2451

8

SQL中distinct的用法
SQL中distinct的用法

SQL中distinct的语法是“SELECT DISTINCT column1, column2,...,FROM table_name;”。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2023.10.27

448

4

SQL中months_between使用方法
SQL中months_between使用方法

在SQL中,MONTHS_BETWEEN 是一个常见的函数,用于计算两个日期之间的月份差。想了解更多SQL的相关内容,可以阅读本专题下面的文章。

2024.02.23

614

5

SQL出现5120错误解决方法
SQL出现5120错误解决方法

SQL Server错误5120是由于没有足够的权限来访问或操作指定的数据库或文件引起的。想了解更多sql错误的相关内容,可以阅读本专题下面的文章。

2024.03.06

3969

10

sql procedure语法错误解决方法
sql procedure语法错误解决方法

sql procedure语法错误解决办法:1、仔细检查错误消息;2、检查语法规则;3、检查括号和引号;4、检查变量和参数;5、检查关键字和函数;6、逐步调试;7、参考文档和示例。想了解更多语法错误的相关内容,可以阅读本专题下面的文章。

2024.03.06

1345

4

oracle数据库运行sql方法
oracle数据库运行sql方法

运行sql步骤包括:打开sql plus工具并连接到数据库。在提示符下输入sql语句。按enter键运行该语句。查看结果,错误消息或退出sql plus。想了解更多oracle数据库的相关内容,可以阅读本专题下面的文章。

2024.04.07

3561

11

sql中where的含义
sql中where的含义

sql中where子句用于从表中过滤数据,它基于指定条件选择特定的行。想了解更多where的相关内容,可以阅读本专题下面的文章。

2024.04.29

3491

6

sql中删除表的语句是什么
sql中删除表的语句是什么

sql中用于删除表的语句是drop table。语法为drop table table_name;该语句将永久删除指定表的表和数据。想了解更多sql的相关内容,可以阅读本专题下面的文章。

2024.04.29

642

5

sql中删除一列的命令是什么
sql中删除一列的命令是什么

在sql中,使用alter table语句可以删除一列,语法为:alter table table_name drop column column_name。想了解更多sql的相关内容,可以阅读本专题下面的文章。

2024.04.29

526

5

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
PostgreSQL vs MySQL
PostgreSQL vs MySQL

共1课时 | 124人学习

使用phpenv集成环境安装极致CMS
使用phpenv集成环境安装极致CMS

共2课时 | 224人学习

phpEnv手册
phpEnv手册

共0课时 | 0人学习