做网站商标分类,杭州 高端网站建设,做搜狗手机网站点,广州seo学徒根据binlog日志获取回滚sql的一个开发思路
需要获取的信息 thread_id 打开 mysql 客户端 开始时间 关闭 mysql 客户端 结束时间
binlog 匹配流程 指定 mysql 客户端 开始时间和结束时间 先匹配 thread_id 相同的 然后匹配 ^BEGIN$行和 ^COMMIT/*!*/;$行之间的数据 当匹…根据binlog日志获取回滚sql的一个开发思路
需要获取的信息 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_committed5 sequence_number6 rbr_onlyyes
/*!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_id1837 exec_time0 error_code0 # thread_id1837 这里
SET TIMESTAMP1721373577/*!*/;
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
### 11 /* INT meta0 nullable1 is_null0 */
### INSERT INTO test.t1
### SET
### 11 /* INT meta0 nullable1 is_null0 */
### INSERT INTO test.t1
### SET
### 11 /* INT meta0 nullable1 is_null0 */
# 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
