使用java将数据从数据库加载到另一个数据库



我有一个旧数据库,我想用java代码每小时将该数据库中的新数据加载到一个新数据库(我创建的(中。。

我使用这段代码在两个简单的数据库中测试了它,但它对我不起作用,你们中的任何人能帮助我或给我一些想法吗:

import java.sql.*;
class DB{
public static void main(String args[]) {
try {
//loading the jdbc driver
Class.forName("com.mysql.jdbc.Driver").newInstance();
// Class.forName("com.mysql.jdbc.Driver");
Connection con = DriverManager.getConnection("jdbc:mysql://localhost/b", "root", "");
Statement stmt = con.createStatement();
//int rows = stmt.executeUpdate("INSERT INTO b.table2 SELECT * FROM a.table1");
ResultSet rs = stmt.executeQuery("INSERT INTO b.table2 SELECT * FROM a.table1");
while (rs.next())
System.out.println(rs.getInt(1) + "  " + rs.getString(2) + "  " + rs.getString(3) + " " + rs.getString(4));
con.close();
} catch (Exception e) {
System.out.println(e);
}
}}

打印出来的代码将正常工作。INSERT语句不返回结果集;它们返回一个数字,表示受影响的行数。因此,您注释掉的代码是正确的;您的未注释行(使用.executeQuery(在这里没有用处,可能也不起作用。

最新更新