java实现两个mysql数据库表同步

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DatabaseSync {
    public static void main(String[] args) {
        // 连接源数据库
        try (Connection sourceConn = DriverManager.getConnection("jdbc:mysql://source_host:source_port/source_db", "source_user", "source_password");
             Statement sourceStmt = sourceConn.createStatement();
             ResultSet sourceRs = sourceStmt.executeQuery("SELECT * FROM source_table")) {

            // 连接目标数据库
            try (Connection targetConn = DriverManager.getConnection("jdbc:mysql://target_host:target_port/target_db", "target_user", "target_password");
                 Statement targetStmt = targetConn.createStatement()) {

                // 清空目标表数据
                targetStmt.executeUpdate("TRUNCATE TABLE target_table");

                // 插入源表数据到目标表
                while (sourceRs.next()) {
                    // 获取源表数据
                    int id = sourceRs.getInt("id");
                    String name = sourceRs.getString("name");
                    // ...

                    // 插入到目标表
                    String insertQuery = "INSERT INTO target_table (id, name) VALUES (" + id + ", '" + name + "')";
                    targetStmt.executeUpdate(insertQuery);
                }
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}