MySQL GTID 自动定位复制断点：等待函数、超时与回滚判断

MySQL 主从切换后，最容易误判的不是复制线程是否显示为运行，而是新主库到底有没有执行到指定事务。把人工猜时间改成 GTID 集合校验，再用 WAIT_FOR_EXECUTED_GTID_SET 等待一个明确的复制断点，才能在超时后决定继续观察、回滚切换，还是进入人工核对。

先从旧主库记录目标 GTID_SET，在新主库等待它进入已执行集合；返回 0 才代表断点已追上，返回 1 只能说明等待超时，不能当成复制失败。

为什么复制线程正常，切换仍可能丢最后一批事务

线上切换时常见的判断是看 SHOW REPLICA STATUS 里的线程状态，或者比较两个库的最新自增 ID。这两个信号都不够稳：线程可以保持运行但仍有延迟，自增 ID 也可能来自不同表、不同写入路径，无法表达事务顺序。

GTID 的价值在于把“已经执行过哪些事务”写成集合。旧主库在停止写入或进入只读窗口后，先取出它最后确认的集合；新主库只需要判断自己的执行集合是否覆盖这个目标，不必猜 binlog 文件名和 position。

把旧主库的 GTID_SET 固定成可核对的断点

在切换编排器中，断点应和切换批次一起保存。下面的命令只读取状态，不修改复制配置：

SELECT @@GLOBAL.gtid_executed AS target_gtid_set;
SHOW BINARY LOG STATUS;

如果实例运行的是兼容版本，也可以用 SHOW MASTER STATUS 查看来源端信息，但真正用于等待的是 @@GLOBAL.gtid_executed 返回的集合。把结果原样写入切换记录，例如字段 target_gtid_set，不要先拆成一个 UUID 和一个数字再自行拼接。

在新主库等待 WAIT_FOR_EXECUTED_GTID_SET

将旧主库的集合传给新主库，等待时间要小于业务切换窗口，但不能短到只够一次网络抖动。示例中的 target_gtid_set 是上一步保存的原文：

SET @target_gtid_set = '3E11FA47-71CA-11E1-9E33-C80AA9429562:1-421';
SELECT WAIT_FOR_EXECUTED_GTID_SET(@target_gtid_set, 30) AS wait_result;

这里的真实调用链是：target_gtid_set 进入 WAIT_FOR_EXECUTED_GTID_SET，函数检查新主库的 @@GLOBAL.gtid_executed，覆盖后返回 wait_result=0。如果 30 秒内没有覆盖，返回 wait_result=1；这个结果只代表等待窗口结束，不能直接推出事务丢失。

超时以后先区分复制延迟和断点本身错误

超时后先保留原始断点，再在新主库执行：

SHOW REPLICA STATUS\G
SELECT @@GLOBAL.gtid_executed AS replica_gtid_set;

若 IO 线程或 SQL 线程仍有错误，先处理错误再重试同一个断点；若线程没有错误但集合持续不变，重点检查来源端是否仍在写入、网络链路是否抖动，以及中继日志是否积压。不要为了让返回值变成 0 而改写 target_gtid_set。

如果结果是 NULL，应检查 GTID 字符串是否为空、语句是否在正确实例执行，以及账号是否有读取所需状态的权限。它不是“等待失败但可以继续切换”的安全信号。

什么时候继续观察，什么时候回滚切换

wait_result=0 后仍要做一次读验证，例如读取切换前写入的业务流水号或订单状态，确认应用连接已经指向新主库。GTID 只证明事务集合覆盖，不替代业务数据核对。

wait_result=1 时，如果复制线程无错误且 replica_gtid_set 正在增长，可以延长观察窗口；如果线程报错、集合长时间不变，或者业务窗口已经无法承受不确定性，则保留现场并走预案中的回滚路径。回滚动作要回到旧主库的可写性、应用连接池和重复写入风险逐项确认，不能只执行一条切换命令。

常见问题

WAIT_FOR_EXECUTED_GTID_SET 返回 1 是不是事务丢失？

不是。返回 1 表示在指定超时时间内没有等到集合覆盖，可能是延迟、线程错误或断点仍在增长，需要结合复制状态判断。

为什么不直接比较自增 ID？

自增 ID 只描述某个表的编号，无法覆盖多表事务、不同写入路径和事务提交顺序，不能替代 GTID 集合。

同一个 GTID 断点可以重复等待吗？

可以。只要断点原文没有变化，重复等待是在延长观察窗口；不要为了重试而生成新的目标集合。

发布前的最小核对清单

• 切换记录保存了原始 target_gtid_set。
• 新主库执行了 WAIT_FOR_EXECUTED_GTID_SET，并记录返回值。
• 超时或异常时保留 SHOW REPLICA STATUS 和 replica_gtid_set。
• 返回 0 后完成一次业务读验证，返回 1 或 NULL 不自动宣布切换成功。