JDBC PreparedStatement，批量更新和生成的密钥

我在批量使用jdbc preparedStatement时遇到问题，并尝试从此创建生成的密钥。JDBC PreparedStatement，批量更新和生成的密钥

的代码：

 PreparedStatement stmt = null; 
    ... 
    connection.setAutoCommit(false); 
    stmt = connection.prepareStatement(insertSuspiciousElement,new String[] {"external_id","element_id"}); 
final int elementBatchSize = 5000; 
    int elementCount =0; 
     for(BlSuspiciousElement element : elements){ 
     externalIds.add(element.getExternalId()); 
     stmt.setInt(1, element.getBlElementType().getElementTypeId()); 
     stmt.setString(2, element.getFirstname()); 
     stmt.addBatch(); 
     elementCount++; 
     if(elementCount % elementBatchSize == 0){ 
      System.out.println("Running query with batch size for suspiciousElement"); 
      stmt.executeBatch(); 

      ResultSet keys = stmt.getGeneratedKeys(); 
      while(keys.next()){ 
       externalIdElementIdMapping.put(keys.getInt("external_id"),keys.getInt("element_id")); 
      } 
      keys.close(); 
      stmt.clearBatch(); 
      stmt.clearParameters(); 
      stmt.clearWarnings(); 
      System.out.println("Done query with batch size for suspiciousElement"); 
     } 
     }

它未能在第一stmt.executeBatch（）方法。

错误：

[30/01/12 15:54:41:684 CET] 00000029 RemoteExcepti E CNTR0020E: EJB threw an unexpected (non-declared) exception during invocation of method "processFullFeedForPepAndRelationUpdateOnly" on bean "BeanId(CoRelateEar#AmlKycToolBO.jar#FactivaDBUpdater, null)". Exception data: java.lang.ArrayIndexOutOfBoundsException 
at oracle.jdbc.driver.T4CNumberAccessor.unmarshalOneRow(T4CNumberAccessor.java:201) 
at oracle.jdbc.driver.T4C8Oall.readRXD(T4C8Oall.java:696) 
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:340) 
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:192) 
at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:531) 
at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:207) 
at oracle.jdbc.driver.T4CPreparedStatement.executeForRows(T4CPreparedStatement.java:1044) 
at oracle.jdbc.driver.OraclePreparedStatement.executeForRowsWithTimeout(OraclePreparedStatement.java:10143) 
at oracle.jdbc.driver.OraclePreparedStatement.executeBatch(OraclePreparedStatement.java:10249) 
at oracle.jdbc.driver.OracleStatementWrapper.executeBatch(OracleStatementWrapper.java:230) 
at com.ibm.ws.rsadapter.jdbc.WSJdbcStatement.executeBatch(WSJdbcStatement.java:748)

我都不明显...

看来，它不适合批量更新工作？仅用于陈述或准备陈述。在这种情况下，我想我应该尽我批量插入，然后运行另一个查询查找每个创建的元素生成的密钥...

感谢您的帮助，

˚F

来源

2012-01-30 Farid

我相信你应该告诉Oracle JDBC驱动程序你会检索生成的密钥。

查看以下问题的接受答案以获取详细信息：PreparedStatement with Statement.RETURN_GENERATED_KEYS。

编辑1/31/12：如果这种方法不能用于批处理（而且我没有用批处理方式），你可以代替批处理，只需关闭自动提交，插入所有数据，然后提交。在我的实验中，这种方法的性能损失仅为3％。我还在SO上发现了另一个类似的建议：MySQL batch stmt with Statement.RETURN_GENERATED_KEYS。

来源

2012-01-30 16:29:29 Olaf

这个链接是关于只使用preparedStatement。我的问题是当我试图检索批处理执行的preparedStatement中生成的密钥...稍有不同。 – Farid 2012-01-31 07:48:11

@Farid：你在准备陈述时是否尝试过指定RETURN_GENERATED_KEYS？就像：stmt = connection.prepareStatement（sql，Statement.RETURN_GENERATED_KEYS）; – Olaf 2012-01-31 14:17:38

是的，同样的错误。 – Farid 2012-01-31 15:52:46

JDBC PreparedStatement，批量更新和生成的密钥

回答

相关问题