java - 如何使用java将批量数据从一个数据库插入到另一个数据库相同结构

Question

我有两个 SQL 服务器运行在两个不同的位置，具有相同的结构但不同的 IP a = 100.0.0.1 和 IP b = 192.0.0.1。我有一个结构相同的表 a.table 和 b.table 。现在我想移动 a 中的所有数据。表从 100.0.0.1 机器到 b.table 机器 192.0.0.1 。我想使用 java 连接或通过 hibernate 传输此数据。目前我正在通过运行 SQL 查询手动执行此操作。

Answer 1

这是您可以使用的代码

import java.sql.*;
import java.io.*;
import java.util.*;

public class test1 
{
public static void main(String[] argv) throws Exception 
{
try
{
Connection con = DriverManager.getConnection( "jdbc:postgresql://localhost:5432/old","user","pass");
Connection con1 = DriverManager.getConnection( "jdbc:postgresql://localhost:5432/new","user","pass");

String sql = "INSERT INTO users("+ "name,"+ "active,"+ "login,"+ "password)"+ "VALUES(?,?,?,?)";

Statement statement = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);  

PreparedStatement pstmt = con1.prepareStatement(sql);

ResultSet rs = statement.executeQuery("SELECT * FROM users"); 
while ( rs.next() )  
{  
String nm = rs.getString(2);
Boolean ac = rs.getBoolean(3);
String log = rs.getString(4);
String pass = rs.getString(5);
pstmt.setString(1, nm);       
pstmt.setBoolean(2, ac);
pstmt.setString(3, log);          
pstmt.setString(4, pass);   
pstmt.executeUpdate();
} 
con.close();
con1.close();
}
catch (SQLException e)
{
System.out.println("could not get JDBC connection: " +e); 
}
}
}