Вставка двух таблиц из нескольких баз данных в jdbc

Question

Как вставить две таблицы из двух баз данных в jdbc, возможно ли это?

У меня есть код, но его не работает

public class MergeData { 
static { 
    try { 
     Class.forName("com.mysql.jdbc.Driver"); 
    } catch (ClassNotFoundException e) { 
     e.printStackTrace(); 
    } 
} 
@SuppressWarnings("unchecked") 
public static void main(String[] args) throws SQLException { 
    //"jdbc:mysql://localhost:3306/fhv1", "root", "root" 
    DBDataFetcher database1 = new DBDataFetcher("jdbc:mysql://localhost:3306/fhv1", "root", "root"); 
    List<Object> restDetailsList = (List<Object>) database1.fetchTableRows("restdetails"); 
    database1.closeConnection(); 
    long restid = 0; 
    for(Object obj : restDetailsList) { 
     if (obj instanceof RestDetails) { 
      restid = ((RestDetails) obj).getRest_id(); 
      System.out.print(restid + " "); 
     } 

    } 

    DBDataFetcher database2 = new DBDataFetcher("jdbc:mysql://localhost:3306/test", "root", "root"); 
    List<Object> restLocationList = (List<Object>) database2.fetchTableRows("restlocation"); 
    database2.closeConnection(); 
    for(Object obj : restLocationList) { 
     if (obj instanceof RestLocation) { 
      ((RestLocation) obj).setRest_id(++restid); 
      System.out.print(((RestLocation) obj).getRest_id() + " "); 
      restDetailsList.add(obj); 

     } 

    } 

    DBDataMerger merger = new DBDataMerger("jdbc:mysql://localhost:3306/db", "root", "root"); 
    merger.mergeTable(restDetailsList, "restdetails"); 
    merger.closeConnection(); 
} 
} 

Answer 1

В простом JDBC, вы должны создать два соединения (по одному для каждой базы данных)

public Connection getDbConnection(String dbUrl, String driver, String  user, String psw){ 
Connection conn=null; 
try{ 

Class.forName(driver); 
conn = DriverManager.getConnection(dbUrl,user,psw); 
}catch(SQLException e){ 
//log exception 
} 
return conn; 
} 

и вставлять записи, которые вы можете сделать что-то вроде

public void insertRecord(){ 
//add try and catch/finally 

//inserting into 1st DB 
Connection conn1 = getDBConnection(dbURl1, driver1, user1, psw1); 
Statement stmt = conn1.CreateStatement(); 
String insert1 = "insert into tbl1 (a,b,c) values(1,2,2); 
stmt.executeUpdate(insert1); 

//inserting into 2nd DB 
Connection conn2 = getDBConnection(dbURl2, driver2, user2, psw2); 
stmt = conn2.CreateStatement();//reassing statement or use a new one 
String insert2 = "insert into tbl2 (a,b,c) values(1,2,2); 
stmt.executeUpdate(insert2); 

} 

Как правило, вы должны использовать PreaparedStatement вместо Statement (be потому что это обычно быстрее и безопаснее, чем заявление)