当循环在 ResultSet.execute 之后终止时

Question

我试图通过基于Table COMPA对Table COMPB的更新和删除操作使TABLE COMPB等同于TABLE COMPA。在生成正确的SQL时，代码运行良好。问题是，当我把执行语句放到下面的时候，而循环在第一次迭代本身中终止。无法理解 Java 中 ResultSet 的这种行为。这里有任何帮助吗？我哪里出错了？

//Comparision between Minus Table(seta) and COMPB (setc)
        //ID Contains Primary Key of COMPB Table
        ResultSet seta=stmt.executeQuery("select * from COMPA minus select * from COMPB");

        while(seta.next())
        { 
            String insert="";
            String update="";
            boolean contains=ArrayUtils.contains(ID, seta.getInt(1));
            if (contains==true)
             { 
                update="Update COMPB SET COMPB.EMPNAME='"+seta.getString(2)+"',COMPB.EMAILID='"+seta.getString(3)+"' where "+seta.getInt(1)+"=COMPB.EMPID";
                stmt.executeUpdate(update);
                System.out.println(update);
             }
            else 
             {
            insert="Insert INTO COMPB values ("+seta.getInt(1)+" , '"+seta.getString(2)+"' , '"+seta.getString(3)+"')";
              stmt.executeUpdate(insert);
              System.out.println(insert);
             }  

        }

Answer 1

这可能有两个原因：

• 重用相同的stmt对象：结果集对象映射到返回它的语句（通过executeQuery方法），在迭代过程中重用相同的语句对象将使结果集无效。您应该创建一个新的语句对象并使用它执行这些查询。
• 使用 CONCUR_READ_ONLY resultSet（默认）：这是 Oracle 关于结果集的文档。默认情况下，它不可修改。如果记录需要修改，则可能需要使用CONCUR_UPDATABLE结果集。这是一个例子。

Answer 2

无法理解 Java 中 ResultSet 的这种行为。

您可以使用同一PreparedStatement stmt实例来执行更新：

ResultSet seta=stmt.executeQuery("select * from COMPA minus select * from COMPB");
while(seta.next()){ 
    ...
   update="Update COMPB SET COMPB.EMPNAME='"+seta.getString(2)+"',COMPB.EMAILID='"+seta.getString(3)+"'    where "+seta.getInt(1)+"=COMPB.EMPID";
   stmt.executeUpdate(update);
   System.out.println(update);
   ...
  }

您的ResultSet seta来自PreparedStatement stmt实例。
因此，我认为在PreparedStatement实例上调用另一个执行方法会对PreparedStatement实例返回的先前 ResultSet 对象产生副作用。

您应该创建一个新的 PreparedStatement 实例来执行其他查询。

Answer 3

根据下面的建议，我通过创建 prepared语句对象来更改循环。

         while(seta.next())
        { 
            boolean contains=ArrayUtils.contains(ID, seta.getInt(1));
            if (contains==true)
             { 

                PreparedStatement update_stmt =con.prepareStatement("Update COMPB SET COMPB.EMPNAME=?,COMPB.EMAILID=? where COMPB.EMPID=?");
                update_stmt.setInt(3,seta.getInt(1));
                update_stmt.setString(1,seta.getString(2));
                update_stmt.setString(2,seta.getString(3));
                int k=update_stmt.executeUpdate();  
                System.out.println(k+" records updated");
             }
            else 
             {
            PreparedStatement insert_stmt =con.prepareStatement("insert into COMPB values(?,?,?)");
            insert_stmt.setInt(1,seta.getInt(1));
            insert_stmt.setString(2,seta.getString(2));
            insert_stmt.setString(3,seta.getString(3));
            int k=insert_stmt.executeUpdate();  
            System.out.println(k+" records inserted"); 
             }  

        }