如何从 Oracle 中的 JDBC 批量插入中获取生成的密钥?

Posted

技术标签:

【中文标题】如何从 Oracle 中的 JDBC 批量插入中获取生成的密钥?【英文标题】:How to get generated keys from JDBC batch insert in Oracle? 【发布时间】:2013-03-19 00:52:03 【问题描述】:

我正在使用 JDBC 批量插入插入许多记录。 有什么方法可以获取每条记录的生成密钥吗? 我可以将ps.getGeneratedKeys() 与批量插入一起使用吗?

我正在使用oracle.jdbc.OracleDriver

final String insert = "Insert into Student(RollNumber, Name, Age) values(StudentSEQ.nextval, ? , ?)";
final int BATCH_SIZE = 998;
int count = 0;
Connection con = null;
PreparedStatement ps =  null;
try 
    con = getConnection();
    ps = con.prepareStatement(insert);
    for (Student s : students) 
        ps.setString(1, s.getName());
        ps.setInt(2, s.getAge());
        ps.addBatch();
        count++;
        if (count % BATCH_SIZE == 0) 
        // Insert records in batches
            ps.executeBatch();
        
    
    // Insert remaining records
    ps.executeBatch();
 finally 
    if(ps != null)
        ps.close();
    release(con);

我正在考虑在循环内使用ps.executeUpdate()ps.getGeneratedKeys() 来获得所需的结果。还有其他解决方案吗?

【问题讨论】:

您在批量插入中使用序列吗? 是的,StudentSEQ 是表格的序列。 【参考方案1】:

JDBC 4.1 specification,第 13.6 节 检索自动生成的值 说:

getGeneratedKeys 是否返回由实现定义 调用executeBatch 方法后生成的值。

因此,您需要检查您的驱动程序是否真的支持批量更新。如the answer by Philip O. 中所述,不支持通过Oracle 12 JDBC Standards Support 中记录的批量更新检索生成的密钥:

您不能将自动生成的密钥与批量更新结合使用。

在任何情况下,如果您的驱动程序支持,那么您的语句 prepare 应更改为以下代码,以指示驱动程序检索生成的密钥:

ps = con.prepareStatement(insert, Statement.RETURN_GENERATED_KEYS);

注意:您可能需要使用其他生成的密钥准备方法之一(prepareStatement(sql, columnIndexes)prepareStatement(sql, columnNames)),因为 Oracle 将使用我示例中的方法返回 ROW_ID

【讨论】:

太棒了! prepareStatement(sql, columnNames) 用于非批量插入以返回特定列! :)(但是有列索引的那个却没有……)【参考方案2】:

根据以下页面,Oracle 12c 似乎不支持将自动生成的密钥与批量更新相结合:

http://docs.oracle.com/cd/E16655_01/java.121/e17657/jdbcvers.htm

请参阅“检索自动生成的密钥”部分下标有“限制”的小节

【讨论】:

以上是关于如何从 Oracle 中的 JDBC 批量插入中获取生成的密钥?的主要内容,如果未能解决你的问题,请参考以下文章

如何优化 Oracle 11g 和 Hibernate 的批量插入?

如果一条记录在 oracle 中插入失败,则避免 jdbc 批量插入失败

Spring JDBC - 针对多个表的批量插入

使用 JDBC 进行批量插入的有效方法

在 Python 中使用 cx_Oracle 中的 executemany() 从批量插入数据加载中查找错误记录

批量从Dataframe插入到DB,忽略Pyspark中的失败行