java - 从一个Mysql数据库插入到另一个数据库

Question

我正在尝试将数据从一个 mysql 数据库传输到另一个数据库。对于一个数据库，我将连接 url 作为数据库名称、用户名和密码(因为这必须存在于远程位置)。对于另一个数据库，我正在使用数据源。

public class errorlog {
     public static void main(String[] args)
        {
            try {
              Class.forName("com.mysql.jdbc.Driver");
        System.out.println("Driver loaded mysql1server");
        Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
        System.out.println("Driver loaded mysql");

            } catch (ClassNotFoundException e) {
                // TODO Auto-generated catch block
                System.out.println("not loaded");
            }
            String connectionUrl = "jdbc:mysql//localhost:3306/db1" ;

              String connectionUrl2="jdbc:odbc:test";
                Connection con=null;
                Connection con2=null;
                Statement stmt = null;
                ResultSet rs = null;
                PreparedStatement pstmt = null;


                try {
                    con = DriverManager.getConnection(connectionUrl,"root","root");
                    System.out.println("CONNECTED1 mysql1");
                 con2 = DriverManager.getConnection(connectionUrl2);
              System.out.println("CONNECTED2 mysql");
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }


                try {
                 stmt = con.createStatement();
                 rs=stmt.executeQuery("select * FROM db1.db1_table");
                  System.out.print("Select executed");
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }


               try {
                    while (rs.next()) {

                        int col1 = rs.getInt("col1");
                        String col2=rs.getString("col2");


Date TimeStamp = rs.getDate("Time Stamp");



                    String insertSql ="Insert into db2.db2_table (`col1`,`col2`) values(?,?)";
                            pstmt = con2.prepareStatement(insertSql);

                             pstmt.setInt(1,col1);
                            pstmt.setString(2,col2);


pstmt.setDate(3,(java.sql.Date) TimeStamp);

                            pstmt.executeUpdate();




                       pstmt.close();
                       System.out.println("insert done");
                    }

                } catch (SQLException e1) {
                    // TODO Auto-generated catch block
                    e1.printStackTrace();
                }

                System.out.println("out insert done");


    }
    }

我收到错误“没有找到适合 jdbc:mysql//localhost:3306/databaseName=db1;user=root;password=root”的驱动程序

请告诉我我错在哪里。

进一步要求 -

我想使用一个配置文件，它将保存一个时间值，并在获取数据时不断更新。Ex-文件保存值2014-03-18 12:00:00，程序将定期运行间隔1小时。我只想在文件保存时间之后获取数据。一旦运行，文件应该更新。

请让我知道我该怎么做。

Answer 1

您没有加载 MySQL 驱动程序。您已获得 ODBC 驱动程序

Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

但是你需要 mysql jdbc 协议(protocol)的一些东西，例如

Class.forName("com.mysql.jdbc.Driver");

然后需要在您的项目中引用/包含 mysql 连接器 jar。