手写实现迁移系统：3步搞定数据库平滑升级不宕机

凌晨两点，生产环境突然报警。数据库连接池打满，业务接口全部超时。运维拉出日志，满屏红色的 SQLException 和复杂的 StackTrace，看着那串让人头皮发麻的调用堆栈，你瞬间懵了。明明只是改了一个字段，为什么整个系统像瘫痪了一样？这时候，靠看报错猜原因已经来不及了，你需要真正理解数据迁移底层的逻辑。

很多人对迁移系统的理解还停留在 mysqldump 或者简单的 INSERT INTO 上。但在高并发、大表结构的互联网业务中，这种暴力操作无异于自杀。今天我们就通过手写实现一个极简但核心的迁移引擎，把那些藏在框架背后的“黑盒”拆开揉碎。别再被那些晦涩的 StackTrace 吓住，读懂了原理，你才能从“被动救火”变成“主动防御”。

入口定位：谁在负责搬运数据？

在主流的企业级迁移方案中，比如阿里开源的 DTS 或者 Canal，核心逻辑其实并不神秘。它们本质上都是“监听 + 转发 + 补偿”的三段式架构。

我们要剖析的核心，是一个典型的基于 Binlog 的增量同步引擎。为了便于理解，我们将其抽象为一个 MigrationEngine。它的入口并不在 SQL 层，而在日志层。

想象一下，数据库每写入一条数据，都会往 Binlog 里记一笔账。我们的迁移系统，就是一个拿着放大镜盯着这本账本看的会计。它不需要去问数据库“你现在有多少数据”，而是直接去读“刚才发生了什么变化”。

这就是迁移系统最核心的入口定位：基于日志的捕获（Capture）。

很多初学者容易陷入一个误区，认为迁移就是 SELECT * FROM table。这是静态快照，不是动态迁移。真正的生产级迁移，必须包含全量初始化（Snapshot）和增量同步（Replication）两个阶段。前者解决“存量”问题，后者解决“增量”问题。如果只懂前者，你永远无法实现零停机迁移。

核心片段：拆解主循环逻辑

让我们直接看代码。下面这段代码是一个简化版的增量同步主循环，它模拟了如何从 Binlog 中解析事件并写入目标库。这里我们使用 Java 语言，因为 JVM 生态中此类工具最为丰富。

// MigrationEngine.java
public class MigrationEngine {private final SourceDataSource source;private final TargetDataSource target;private volatile boolean running = true;// 核心循环：不断轮询 Binlog 事件public void start() {while (running) {try {// 1. 获取下一个 Binlog 事件BinlogEvent event = source.readNextEvent();// 2. 如果发生 DDL 变更，需特殊处理if (event.isDDL()) {handleDDL(event);continue;}// 3. 如果是 DML 变更，执行幂等写入if (event.isDML()) {// 关键点：使用 Replace Into 或 On Duplicate Key Update// 保证重复消费时数据一致性target.execute(event.getSql(), event.isUpdate() ? "REPLACE" : "INSERT");}// 4. 记录位点，用于故障恢复source.commitCheckpoint(event.getPosition());} catch (Exception e) {// 异常处理：不能直接退出，需重试或告警logger.error("Migration failed at position: " + source.getPosition(), e);pauseAndRetry();}}}// 处理 DDL：这是最危险的环节private void handleDDL(BinlogEvent event) {// 在迁移过程中，DDL 通常需要人工确认或自动重放// 注意：目标库的表结构必须与源库保持严格同步target.executeDDL(event.getSql());}
}

逐行解析：

source.readNextEvent()：这是整个系统的咽喉。它不是查询数据库，而是读取二进制日志文件。如果这里阻塞，整个迁移就停滞了。
event.isDDL()：DDL（如 ALTER TABLE）是迁移中的“地雷”。如果在增量同步过程中源库加了字段，目标库没加，后续的 INSERT 就会报 Unknown column 错误。这就是为什么很多 StackTrace 里充满了元数据不匹配的错误。
target.execute(..., "REPLACE")：这里用了 REPLACE 而不是 INSERT。为什么？因为 Binlog 可能存在重放机制（比如网络抖动导致消息重发）。如果用 INSERT，主键冲突直接报错；用 REPLACE，则先删后插，保证了幂等性。这是手写实现迁移系统时最容易被忽视的细节。
source.commitCheckpoint(...)：这是断点续传的关键。如果进程挂了，重启后从上次成功的位点继续读，而不是从头开始。没有这个机制，一旦出错，整个迁移就得推倒重来。

设计思想：为什么是“双写”与“校验”？

看明白了代码，你可能还会问：为什么不能直接 INSERT？为什么非要搞这么复杂？

这就要说到迁移系统的设计灵魂：最终一致性（Eventual Consistency）。

在高可用架构中，我们通常采用“双写”策略。应用层同时向旧库和新库写入数据。但这并不保险，因为网络抖动、主从延迟都可能导致数据不一致。因此，迁移系统必须包含一个校验模块。

在掘金技术社区的不少高赞文章中，作者们分享过一个惨痛的教训：某次大促前迁移，数据看似同步成功，但上线后发现 0.01% 的数据金额不对。排查后发现，是因为源库的事务提交顺序和 Binlog 的解析顺序出现了细微的乱序，而校验脚本只做了总量对比，没做逐行 Hash 比对。

因此，一个成熟的迁移系统设计思想包含三层：

捕获层：高吞吐地读取变更日志。
转换层：处理表结构映射、字段类型转换、数据清洗。
校验层：这是很多开源工具缺失或做得很弱的部分。必须定期抽样比对源库和目标库的数据 Hash 值。

手写实现这个系统时，你不仅要关注“怎么搬”，更要关注“怎么验”。如果只搬不验，你就是拿着炸弹在走钢丝。

手写简化版：从零构建一个迷你迁移器

为了让你真正理解其中的难点，我们来手写实现一个极简版的同步工具。这里不使用任何框架，只用原生 JDBC 和简单的文件读取逻辑。

场景：源库 MySQL，目标库 MySQL，同步一张 orders 表。

// MiniMigrationTool.java
import java.sql.*;
import java.util.Properties;public class MiniMigrationTool {public static void main(String[] args) throws Exception {String sourceUrl = "jdbc:mysql://localhost:3306/old_db?useSSL=false";String targetUrl = "jdbc:mysql://localhost:3306/new_db?useSSL=false";String user = "root";String pass = "password";// 1. 建立连接Connection sourceConn = DriverManager.getConnection(sourceUrl, user, pass);Connection targetConn = DriverManager.getConnection(targetUrl, user, pass);// 2. 全量迁移：分批次读取，避免 OOMlong lastId = 0;int batchSize = 1000;boolean hasMore = true;while (hasMore) {// 关键：基于 ID 分片查询，避免 OFFSET 性能陷阱String sql = "SELECT * FROM orders WHERE id > ? ORDER BY id LIMIT ?";PreparedStatement stmt = sourceConn.prepareStatement(sql);stmt.setLong(1, lastId);stmt.setInt(2, batchSize);ResultSet rs = stmt.executeQuery();if (!rs.next()) {hasMore = false;break;}// 构建批量插入语句StringBuilder insertSql = new StringBuilder("REPLACE INTO orders (id, amount, status) VALUES ");PreparedStatement targetStmt = targetConn.prepareStatement(insertSql.toString());int count = 0;do {long id = rs.getLong("id");double amount = rs.getDouble("amount");String status = rs.getString("status");if (count > 0) insertSql.append(",");insertSql.append("(?,?,?)");targetStmt.setLong(count * 3 + 1, id);targetStmt.setDouble(count * 3 + 2, amount);targetStmt.setString(count * 3 + 3, status);count++;lastId = id; // 更新游标} while (rs.next() && count < batchSize);targetStmt.addBatch();targetStmt.executeBatch();targetConn.commit();System.out.println("Migrated batch, last ID: " + lastId);}// 3. 增量模拟：轮询变更（实际中应读取 Binlog）// 这里简化为查询最新 N 条记录进行对比System.out.println("Full migration done. Starting incremental check...");incrementalSync(sourceConn, targetConn);sourceConn.close();targetConn.close();}// 简化的增量同步逻辑private static void incrementalSync(Connection sourceConn, Connection targetConn) throws Exception {// 实际项目中，这里应该解析 Binlog// 这里为了演示，我们假设有一个 last_sync_time 字段String checkSql = "SELECT * FROM orders WHERE update_time > ?";// ... 省略具体的增量比对代码，逻辑同全量，但频率更高，数据量更小}
}

代码中的坑点解析：

WHERE id > ? vs OFFSET：很多新手写 LIMIT 1000 OFFSET 100000，这在千万级大表上是性能杀手。必须使用主键索引进行范围扫描。
REPLACE INTO：再次强调，这里用 REPLACE 是为了处理全量迁移过程中可能发生的并发写入。如果源库正在写入，你全量读取时可能会读到部分数据，后续增量再写入时，REPLACE 能确保覆盖旧值。
事务提交频率：代码中每 1000 条提交一次。如果一次提交几十万条，Binlog 会瞬间膨胀，甚至撑爆磁盘。批量大小需要根据网络带宽和目标库负载动态调整。

应用场景：何时该上迁移系统？

迁移系统不是万能的，也不是什么时候都要用的。

数据库内核升级：比如 MySQL 5.7 升到 8.0，由于字符集、排序规则的变化，必须经过数据清洗和迁移。
存储引擎转换：比如从 MyISAM 转 InnoDB，或者从 MySQL 转 TiDB。
分库分表重构：这是最常见的场景。当单表数据量突破千万，需要拆分到多个物理库时，迁移系统是核心工具。
机房容灾切换：同城双活或异地多活架构下，数据的实时同步依赖的就是底层的迁移/同步引擎。

避坑指南：

锁表问题：全量迁移时，尽量使用 pt-osc 或 gh-ost 等无锁工具，或者采用影子表方案。直接 LOCK TABLE 在生产环境是禁忌。
时区陷阱：源库和目标库的时区设置不一致，会导致时间字段数据错位。务必在迁移前统一时区配置。
大字段处理：BLOB 或 TEXT 类型字段会导致 Binlog 解析缓慢。如果业务允许，可以考虑将这些字段剥离到对象存储（如 OSS/S3），数据库中只存 URL。