需要获取的信息
- thread_id
- 打开 mysql 客户端 开始时间
- 关闭 mysql 客户端 结束时间
binlog 匹配流程
- 指定 mysql 客户端 开始时间和结束时间
- 先匹配 thread_id 相同的
- 然后匹配
^BEGIN$行和^COMMIT/*!*/;$行之间的数据 - 当匹配到
^COMMIT/*!*/;$行，需要再次寻找 thread_id 相同的行，匹配到后执行上一个流程 - 直到匹配到文件结尾
具体流程
- 开启一个mysql连接
- 查看当前开始时间
- 查看当前线程 id
- 执行 sql
- 失败处理逻辑
- 查看当前结束时间
- 关闭mysql连接
- mysqlbinlog 命令 截取 指定开始时间和结束时间的 binlog文件
- 用代码匹配binlog信息中的 thread_id
- 匹配到 binlog 中的 thread_id 后 匹配
^BEGIN$行 - 匹配到
^BEGIN$行后将行内容追加至文件 - 匹配到
^COMMIT/*!*/;$行 结束追加 - 在匹配 thread_id 然后执行循环执行 👆三个步骤
- 直到文件结尾
- 用 **MyFlash**工具生成回滚 sql 保存至文件待用
- 需要回滚时 先和业务人员确认 导入文件即可
注意：
- 不同客户端之间会交替追加在 binlog 中，需要通过 👆的 binlog 匹配流程来控制匹配
- 一个线程执行多个 sql 回滚到同一个文件可能带来的问题
- 需要回滚的可能只有一个 sql
- 如何处理这里的逻辑？
- 是否需要每个 sql 开启一个线程？
获取线程 id
sql 获取当前连接的线程 id
对应 binlog 日志中的 thread_id=
select ID from information_schema.processlist where info like 'select id from information_schema.processlist where info like%';
在 binlog 中的线程 ID 记录为 thread_id
# 这是一个完整的事务 # at 1433 #240719 15:19:37 server id 33068094 end_log_pos 1498 CRC32 0xd91f110c GTID last_committed=5 sequence_number=6 rbr_only=yes /*!50718 SET TRANSACTION ISOLATION LEVEL READ COMMITTED*//*!*/; SET @@SESSION.GTID_NEXT= 'c0acf1fe-23b9-11ef-8afa-000c29fa06b9:96490'/*!*/; # at 1498 #240719 15:19:37 server id 33068094 end_log_pos 1570 CRC32 0x16965799 Query thread_id=1837 exec_time=0 error_code=0 # thread_id=1837 这里 SET TIMESTAMP=1721373577/*!*/; BEGIN /*!*/; # at 1570 #240719 15:19:37 server id 33068094 end_log_pos 1615 CRC32 0x5a08aba9 Table_map: `test`.`t1` mapped to number 9257 # at 1615 #240719 15:19:37 server id 33068094 end_log_pos 1665 CRC32 0x6d1db298 Write_rows: table id 9257 flags: STMT_END_F ### INSERT INTO `test`.`t1` ### SET ### @1=1 /* INT meta=0 nullable=1 is_null=0 */ ### INSERT INTO `test`.`t1` ### SET ### @1=1 /* INT meta=0 nullable=1 is_null=0 */ ### INSERT INTO `test`.`t1` ### SET ### @1=1 /* INT meta=0 nullable=1 is_null=0 */ # at 1665 #240719 15:19:37 server id 33068094 end_log_pos 1696 CRC32 0xd51ac516 Xid = 394675 COMMIT/*!*/;
实时查看 binlog 日志
mysqlbinlog -S /mydata/3306/socket/mysql.sock --stop-never -R mysql-bin.000044
