java - insert 跳过记录集中的最后一条记录

Question

我正在编写一个程序，从一个模式中提取数据，重组数据以适应新模式，然后将数据插入到具有新模式的新数据库中。问题是，在我的测试代码中，最后一条记录没有被插入到新数据库中。

我附上了下面代码的一个大大简化的版本，它仍然重现了这个问题。谁能告诉我如何解决以下问题，以便将记录集中的所有记录都插入到目标数据库中？目前，下面确实正确地打印出了 system.out.println 中的最后一条记录，但是最后一条记录之后并不存在于目标表中:

static void migrateDataTest(){
    try {
        Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
        Connection sourceConn = DriverManager.getConnection("jdbc:odbc:source_data_test");
        Statement st = sourceConn.createStatement();
        Connection destinationConn = DriverManager.getConnection("jdbc:odbc:receive_data_test");
        int ClientNumber; String ClientsLastName; String ClientsFirstName;
        ResultSet rest = st.executeQuery("SELECT ClientNumber, ClientsLastName, ClientsFirstName FROM sourceTable");
        PreparedStatement ps5 = null;
        while(rest.next()){
            ClientNumber = rest.getInt(1);
            ClientsLastName = rest.getString(2);
            ClientsFirstName = rest.getString(3);
            System.out.println(ClientNumber+", "+ClientsLastName+", "+ClientsFirstName);
            ps5 = destinationConn.prepareStatement(
                "INSERT INTO destinationTable ("
                + "ClientNumber, FirstName, LastName) VALUES (?, ?, ?)"
            );
            ps5.setInt(1, ClientNumber);
            ps5.setString(2, ClientsFirstName);
            ps5.setString(3, ClientsLastName);
            ps5.executeUpdate();
            destinationConn.commit();
        }
        ps5.close();
    }
catch (ClassNotFoundException cnfe){cnfe.printStackTrace();}
catch (SQLException e) {e.printStackTrace();}
}  

编辑:

根据 Lokesh 的要求，我将导致此错误的整个代码块放在下面。我只是再次运行它以确认它正在 system.out.println 中打印记录 30，但目标表不包含记录号 30。跳过的记录正在使用 system.out.println 打印出来的事实使我相信下面的代码包含错误:

static void migrateDataTest(){
    try {
        Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
        Connection sourceConn = DriverManager.getConnection("jdbc:odbc:source_test");
        Statement st = sourceConn.createStatement();
        Connection destinationConn = DriverManager.getConnection("jdbc:odbc:receive_data_test");
        int ClientNumber;
        String ClientsLastName;
        String ClientsFirstName;
        String ClientsMiddleInitial;
        Date DOB;
        int GenderNumber;
        int RaceNumber;
        ResultSet rest = st.executeQuery("SELECT ClientNumber, ClientsLastName, ClientsFirstName, ClientsMiddleInitial, DOB, GenderNumber, RaceNumber FROM sourceTable");
        PreparedStatement ps5 = null;
        while(rest.next()){
            ClientNumber = rest.getInt(1);
            ClientsLastName = rest.getString(2);
            ClientsFirstName = rest.getString(3);
            ClientsMiddleInitial = rest.getString(4);
            DOB = rest.getDate(5);
            GenderNumber = rest.getInt(6);
            RaceNumber = rest.getInt(7);
            System.out.println(ClientNumber+", "+ClientsLastName+", "+ClientsFirstName+", "+ClientsMiddleInitial+", "+DOB+", "+GenderNumber+", "+RaceNumber);  
            ps5 = destinationConn.prepareStatement(
                "INSERT INTO destinationTable ("
                + "ClientNumber, FirstName, MiddleInitial, LastName, DOB, GenderNumber, RaceNumber) "
                +"VALUES (?, ?, ?, ?, ?, ?, ?)"
            );
            ps5.setInt(1, ClientNumber);
            ps5.setString(2, ClientsFirstName);
            ps5.setString(3, ClientsMiddleInitial);
            ps5.setString(4, ClientsLastName);
            ps5.setDate(5, DOB);
            ps5.setInt(6, GenderNumber);
            ps5.setInt(7, RaceNumber);
            ps5.executeUpdate();
            destinationConn.commit();
        }
        ps5.close();
    }
    catch (ClassNotFoundException cnfe){cnfe.printStackTrace();}
    catch (SQLException e) {e.printStackTrace();}
}

Answer 1

奇怪的是，解决方案是在未能将最终值插入其记录集中的语句之后创建并执行一个额外的准备语句。一旦我之后添加了一个额外的准备好的语句，第一个开始一致地插入它的所有值。

我在上面的原始帖子中发布的代码示例中似乎缺少 java 代码中的一些细微差别。