sqlserver mysql实时同步

import com.github.shyiko.mysql.binlog.BinaryLogClient;
import com.github.shyiko.mysql.binlog.event.Event;
import com.github.shyiko.mysql.binlog.event.EventType;
import com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer;

import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class MySQLSync {
    public static void main(String[] args) throws IOException, SQLException {
        String sourceHost = "source-mysql-host";
        String sourceUser = "source-user";
        String sourcePassword = "source-password";
        String targetHost = "target-mysql-host";
        String targetUser = "target-user";
        String targetPassword = "target-password";

        BinaryLogClient client = new BinaryLogClient(sourceHost, 3306, sourceUser, sourcePassword);
        EventDeserializer eventDeserializer = new EventDeserializer();
        eventDeserializer.setCompatibilityMode(
                EventDeserializer.CompatibilityMode.CHAR_AND_BINARY,
                EventDeserializer.CompatibilityMode.CHAR_AND_BINARY,
                EventDeserializer.CompatibilityMode.CHAR
        );
        client.setEventDeserializer(eventDeserializer);

        client.registerEventListener(event -> {
            if (event.getHeader().getEventType() == EventType.EXT_WRITE_ROWS) {
                try (Connection targetConn = DriverManager.getConnection("jdbc:mysql://" + targetHost + ":3306/target_db", targetUser, targetPassword)) {
                    PreparedStatement ps = targetConn.prepareStatement("INSERT INTO target_table (column1, column2) VALUES (?, ?)");
                    for (var row : event.getRows()) {
                        ps.setString(1, (String) row.get("column1"));
                        ps.setString(2, (String) row.get("column2"));
                        ps.executeUpdate();
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        });

        client.connect();
    }
}