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();
}
}
}
需要注意的是,以上代码仅为示例,实际应用中应根据具体业务需求进行调整和优化。
另外,腾讯云提供了多种与数据库相关的产品和服务,例如:
以上是基于腾讯云提供的产品做出的建议,实际选择还需要根据具体业务需求和预算来进行决策。
企业创新在线学堂
云+社区沙龙online [国产数据库]
云+社区沙龙online [国产数据库]
企业创新在线学堂
云+社区技术沙龙[第20期]
云+社区技术沙龙[第17期]
云+社区沙龙online [国产数据库]
小程序·云开发官方直播课(数据库方向)
DB TALK 技术分享会
DBTalk技术分享会
腾讯云数据库TDSQL训练营
“中小企业”在线学堂
领取专属 10元无门槛券
手把手带您无忧上云