Java PreparedStatement批量插入Oracle遇异常时如何继续执行？

这个问题我之前帮不少开发者解决过——Oracle JDBC默认的批量处理行为确实有点“一刀切”：只要batch里有一条记录违反约束或者出错，整个批次就会立刻中止，剩下的记录都不会执行。要实现“出错一条不影响其他”的效果，有两种靠谱的方案，我给你详细拆解下：

方案1：开启Oracle JDBC的逐行异常模式（最直接） #

Oracle的JDBC驱动提供了一个专属属性，能让批量操作执行完所有记录，再汇总错误，而不是中途停掉。你只需要在建立连接时设置这个属性就行：

两种设置方式 #

1. 在JDBC URL中添加参数
   直接把属性拼在URL后面，比如：

   String url = "jdbc:oracle:thin:@//你的主机:端口/服务名?oracle.jdbc.batchUpdateExceptionBehavior=EXCEPTION_PER_ROW";
   Connection conn = DriverManager.getConnection(url, "用户名", "密码");
   

2. 通过Connection对象动态设置
   如果你的URL不好修改，也可以在获取连接后设置：

   conn.setClientInfo("oracle.jdbc.batchUpdateExceptionBehavior", "EXCEPTION_PER_ROW");
   

异常处理的正确姿势 #

当开启这个模式后，即使batch里有错误，驱动也会执行完所有记录，然后抛出BatchUpdateException。此时你可以通过e.getUpdateCounts()拿到每条记录的执行结果：

• 成功的记录会返回对应的影响行数（一般是1，因为INSERT）
• 失败的记录会返回Statement.EXECUTE_FAILED

示例代码：

PreparedStatement pstmt = null;
try {
    String insertSql = "INSERT INTO your_table (col1, col2) VALUES (?, ?)";
    pstmt = conn.prepareStatement(insertSql);

    // 批量添加500条记录
    for (int i = 0; i < 500; i++) {
        pstmt.setString(1, "test_val_" + i);
        pstmt.setInt(2, i);
        pstmt.addBatch();
    }

    pstmt.executeBatch();
} catch (BatchUpdateException e) {
    int[] resultCounts = e.getUpdateCounts();
    // 遍历结果，标记失败的记录
    for (int idx = 0; idx < resultCounts.length; idx++) {
        if (resultCounts[idx] == Statement.EXECUTE_FAILED) {
            System.out.println("第" + (idx + 1) + "条记录插入失败（违反约束或其他错误）");
            // 这里可以把失败的记录存下来，后续重试或者排查
        } else {
            System.out.println("第" + (idx + 1) + "条记录插入成功");
        }
    }
    // 划重点：此时所有能插入的记录已经成功写入数据库了！
} catch (SQLException e) {
    // 处理其他非批量相关的SQL异常
    e.printStackTrace();
} finally {
    // 别忘了关闭资源
    if (pstmt != null) pstmt.close();
    if (conn != null) conn.close();
}

这个属性还有另外两个可选值，你可以按需选择：

• ALL_SUCCESS：默认行为，遇到第一个错误就中止，只返回之前成功的记录计数
• NO_EXCEPTION：执行所有记录，不抛出异常，失败的记录同样标记为EXECUTE_FAILED，适合不想中断流程的场景

方案2：拆分大批次为小批次（跨数据库通用） #

如果你不想依赖Oracle的专属属性，或者以后可能切换数据库，那把500条的大批次拆成多个小批次（比如每50条一批）是更通用的方案。这样某个小批次出错，其他小批次依然能正常执行：

示例代码：

int batchSize = 50; // 每个小批次的大小
List<YourDataModel> dataList = // 你的500条待插入数据列表
PreparedStatement pstmt = null;

try {
    String insertSql = "INSERT INTO your_table (col1, col2) VALUES (?, ?)";
    pstmt = conn.prepareStatement(insertSql);

    for (int i = 0; i < dataList.size(); i++) {
        YourDataModel data = dataList.get(i);
        pstmt.setString(1, data.getCol1());
        pstmt.setInt(2, data.getCol2());
        pstmt.addBatch();

        // 达到批次大小，或者到最后一条时执行
        if ((i + 1) % batchSize == 0 || i == dataList.size() - 1) {
            try {
                pstmt.executeBatch();
                System.out.println("完成第" + ((i + 1)/batchSize) + "个小批次插入");
            } catch (BatchUpdateException e) {
                // 处理当前小批次里的错误记录
                int[] batchResults = e.getUpdateCounts();
                for (int j = 0; j < batchResults.length; j++) {
                    if (batchResults[j] == Statement.EXECUTE_FAILED) {
                        // 计算原始数据的索引
                        int failedDataIndex = i - batchResults.length + 1 + j;
                        System.out.println("第" + (failedDataIndex + 1) + "条记录插入失败");
                    }
                }
                // 捕获异常后继续执行下一个小批次
            }
            pstmt.clearBatch(); // 清空当前批次，准备下一批
        }
    }
} catch (SQLException e) {
    e.printStackTrace();
} finally {
    // 关闭资源
    if (pstmt != null) pstmt.close();
    if (conn != null) conn.close();
}

总结 #

• 如果你只针对Oracle数据库，优先用方案1，代码更简洁，能精准知道每条记录的执行情况
• 如果你需要跨数据库兼容，或者想降低单批次失败的影响范围，选方案2更稳妥

内容的提问来源于stack exchange，提问作者user6258696