mysql 获取修改记录

CREATE TABLE table_history (
    id INT AUTO_INCREMENT PRIMARY KEY,
    table_name VARCHAR(255),
    operation ENUM('INSERT', 'UPDATE', 'DELETE'),
    old_data TEXT,
    new_data TEXT,
    change_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

DELIMITER //

CREATE TRIGGER after_table_update
AFTER UPDATE ON your_table
FOR EACH ROW
BEGIN
    INSERT INTO table_history (table_name, operation, old_data, new_data)
    VALUES ('your_table', 'UPDATE', OLD.*, NEW.*);
END //

CREATE TRIGGER after_table_insert
AFTER INSERT ON your_table
FOR EACH ROW
BEGIN
    INSERT INTO table_history (table_name, operation, new_data)
    VALUES ('your_table', 'INSERT', NEW.*);
END //

CREATE TRIGGER after_table_delete
AFTER DELETE ON your_table
FOR EACH ROW
BEGIN
    INSERT INTO table_history (table_name, operation, old_data)
    VALUES ('your_table', 'DELETE', OLD.*);
END //

DELIMITER ;

SET GLOBAL log_bin = 'ON';

mysqlbinlog /path/to/binlog-file > changes.sql

docker run -it --rm --name debezium -p 9092:9092 -p 8083:8083 -e DB_VENDOR=mysql -e DB_HOST=mysql-host -e DB_USER=mysql-user -e DB_PASSWORD=mysql-password -e DB_DATABASE=mysql-db debezium/connect:latest

{
  "name": "mysql-connector",
  "config": {
    "connector.class": "io.debezium.connector.mysql.MySqlConnector",
    "tasks.max": "1",
    "database.hostname": "mysql-host",
    "database.port": "3306",
    "database.user": "mysql-user",
    "database.password": "mysql-password",
    "database.server.id": "184054",
    "database.server.name": "dbserver1",
    "database.include.list": "your_table",
    "database.history.kafka.bootstrap.servers": "kafka:9092",
    "database.history.kafka.topic": "schema-changes.mysql"
  }
}