使用MySQL的Binlog进行数据回滚的完整流程

SHOW VARIABLES LIKE 'log_bin';

SHOW BINARY LOGS;

    -- 用于查看 MySQL 服务器的二进制日志文件的基本文件名。
    SHOW VARIABLES LIKE 'log_bin_basename';

    -- 用于查看 MySQL 服务器的二进制日志索引文件的名称。
    SHOW VARIABLES LIKE 'log_bin_index'; 

mysqlbinlog --no-defaults --start-datetime="2024-07-16 14:00:00" --stop-datetime="2024-07-16 15:00:00" binlog.000034 | grep -i 'item_code_distributor_rel'

mysqlbinlog --no-defaults --start-datetime="2024-07-16 14:50:27" --stop-datetime="2024-07-16 14:50:28" --base64-output=DECODE-ROWS --verbose binlog.000034 | less

--base64-output=DECODE-ROWS --verbose 
字段命令的作用是base64解码：是因为binlog是Base64 编码的二进制数据，需要解码

mysqlbinlog --no-defaults --start-datetime="2024-07-16 14:50:27" --stop-datetime="2024-07-16 14:50:28" --base64-output=DECODE-ROWS --verbose binlog.000034 > cjh_get_parsed_binlog_2024-07-16-17-05.sql

    UPDATE 数据库.表名 SET @4的字段名 = @4,@16的字段名 = @16 WHERE @1的字段名 = @1;

package pers.chenjiahao.util;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

/**
 * @author ChenJiahao(五条)
 * @date 2024/7/16 17:36
 */
public class MySQLBinaryLogParser {
    public static void main(String[] args) {
        String filePath = "D:工作文件技术文档cjh_get_parsed_binlog_2024-07-16-17-05.sql";
        String document = readFileContent(filePath);
        List<String> updateStatements = parseDocument(document);
        for (String statement : updateStatements) {
            System.out.println(statement);
        }
    }

    /**
     * 读取文本内容
     */
    private static String readFileContent(String filePath) {
        StringBuilder content = new StringBuilder();
        try (BufferedReader reader = new BufferedReader(new FileReader(new File(filePath)))) {
            String line;
            while ((line = reader.readLine()) != null) {
                content.append(line).append("
");
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        return content.toString();
    }

    /**
     * 解析文本内容
     */
    private static List<String> parseDocument(String document) {
        List<String> updateStatements = new ArrayList<>();

		// 每个"### UPDATE "是一条更新语句
        String[] sections = document.split("### UPDATE ");
        for (int i = 1; i < sections.length; i++) {
            String section = sections[i];
            String[] lines = section.split("
");

			// 待拼接的WHERE条件
            String whereClause = "";
            // 待拼接的SET
            StringBuilder sb = new StringBuilder();

            for (String line : lines) {
                if (line.startsWith("###   @1=")) {
                    whereClause = "id = " + line.split("=")[1];
                }else if (line.startsWith("###   @4=")) {
                    sb.append("item_code = " + line.split("=")[1]);
                }else if (line.startsWith("###   @16=")) {
                    sb.append(",order_channel_id = " + line.split("=")[1]);
                }

				// 不需要读取日志文件中SET的内容，跳过即可
                if (line.startsWith("### SET")){
                    break;
                }
            }

			// 拼接SQL
            String updateStatement = "UPDATE hm_product.item_code_distributor_rel " + "SET " + sb + " WHERE " + whereClause + ";";

            updateStatements.add(updateStatement);
        }

        return updateStatements;
    }
}

UPDATE hm_product.item_code_distributor_rel SET item_code = 'Ot2djSzc8e',order_channel_id = NULL WHERE id = 1;
..........省略N多条.......