Java で書かれたマイクロサービス データ同期およびデータ移行ツール

db.url=jdbc:mysql://localhost:3306/mydatabase db.username=myusername db.password=mypassword

import java.io.FileInputStream; import java.io.IOException; import java.util.Properties; public class DatabaseConfig { private String url; private String username; private String password; public DatabaseConfig() { Properties properties = new Properties(); try { FileInputStream input = new FileInputStream("src/main/resources/config.properties"); properties.load(input); url = properties.getProperty("db.url"); username = properties.getProperty("db.username"); password = properties.getProperty("db.password"); input.close(); } catch (IOException e) { e.printStackTrace(); } } public String getUrl() { return url; } public String getUsername() { return username; } public String getPassword() { return password; } }

import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; public class DataSyncTool { private DatabaseConfig sourceDbConfig; private DatabaseConfig targetDbConfig; public DataSyncTool() { sourceDbConfig = new DatabaseConfig(); targetDbConfig = new DatabaseConfig(); } public void syncData() { try { Class.forName("com.mysql.jdbc.Driver"); Connection sourceConnection = DriverManager.getConnection(sourceDbConfig.getUrl(), sourceDbConfig.getUsername(), sourceDbConfig.getPassword()); Connection targetConnection = DriverManager.getConnection(targetDbConfig.getUrl(), targetDbConfig.getUsername(), targetDbConfig.getPassword()); Statement sourceStatement = sourceConnection.createStatement(); ResultSet resultSet = sourceStatement.executeQuery("SELECT * FROM source_table"); Statement targetStatement = targetConnection.createStatement(); while (resultSet.next()) { // 读取源表中的数据 int id = resultSet.getInt("id"); String name = resultSet.getString("name"); // 将数据插入到目标表中 targetStatement.executeUpdate("INSERT INTO target_table (id, name) VALUES (" + id + ", '" + name + "')"); } resultSet.close(); sourceStatement.close(); targetStatement.close(); sourceConnection.close(); targetConnection.close(); } catch (Exception e) { e.printStackTrace(); } } }

public class Main { public static void main(String[] args) { DataSyncTool dataSyncTool = new DataSyncTool(); dataSyncTool.syncData(); } }