如何使用NamedParameterJdbcTemplate batchUpdate捕获MySQL所有错误信息

默认情况下，NamedParameterJdbcTemplate的batchUpdate方法在批量操作中遇到异常时会终止执行，并且仅抛出最后触发的异常，无法获取所有失败请求的错误信息。要收集全部异常，你需要手动拆分批量操作，逐个执行并捕获每个请求的异常，最后统一汇总。

实现步骤 #

1. 定义自定义异常类 #

用来存储所有捕获到的异常和对应的更新计数：

public class BatchUpdateMultiException extends RuntimeException {
    private final List<Throwable> exceptions;
    private final int[] updateCounts;

    public BatchUpdateMultiException(List<Throwable> exceptions, int[] updateCounts) {
        this.exceptions = exceptions;
        this.updateCounts = updateCounts;
    }

    public List<Throwable> getExceptions() {
        return exceptions;
    }

    public int[] getUpdateCounts() {
        return updateCounts;
    }

    @Override
    public String getMessage() {
        StringBuilder sb = new StringBuilder("批量更新共发生").append(exceptions.size()).append("个异常：\n");
        for (int i = 0; i < exceptions.size(); i++) {
            sb.append("第").append(i + 1).append("条数据异常：").append(exceptions.get(i).getMessage()).append("\n");
        }
        return sb.toString();
    }
}

2. 手动遍历执行批量操作 #

放弃使用原生batchUpdate，改为循环执行单条更新，逐个捕获异常并记录：

@Autowired
private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
private static final Logger log = LoggerFactory.getLogger(YourService.class);

public void executeBatchUpdate(List<Map<String, Object>> paramList) {
    String sql = "INSERT INTO your_table (column1, column2) VALUES (:col1, :col2)";
    List<Throwable> exceptionList = new ArrayList<>();
    int[] updateCounts = new int[paramList.size()];
    // 初始化更新计数为执行失败状态
    Arrays.fill(updateCounts, java.sql.Statement.EXECUTE_FAILED);

    for (int i = 0; i < paramList.size(); i++) {
        Map<String, Object> params = paramList.get(i);
        try {
            int count = namedParameterJdbcTemplate.update(sql, params);
            updateCounts[i] = count;
        } catch (DataAccessException e) {
            exceptionList.add(e);
            log.error("第{}条批量更新失败，参数：{}", i + 1, params, e);
        }
    }

    // 如果存在异常，抛出自定义汇总异常
    if (!exceptionList.isEmpty()) {
        throw new BatchUpdateMultiException(exceptionList, updateCounts);
    }
}

3. 捕获并处理自定义异常 #

在调用方捕获自定义异常，即可获取所有异常信息和更新计数：

try {
    yourService.executeBatchUpdate(paramList);
} catch (BatchUpdateMultiException e) {
    // 获取所有异常列表
    List<Throwable> allExceptions = e.getExceptions();
    // 获取每条数据的更新计数（成功为影响行数，失败为EXECUTE_FAILED）
    int[] counts = e.getUpdateCounts();
    // 后续处理逻辑，比如通知、重试失败数据等
}

注意事项 #

• 这种方式会牺牲一定的批量性能，因为每条请求都单独执行。如果数据量极大，可以考虑拆分为多个小批量（比如每50条一组），在小组内执行批量操作并捕获小组内的异常，平衡性能和异常完整性。
• MySQL JDBC驱动的rewriteBatchedStatements=true参数仅用于优化批量SQL的执行效率，不影响异常的捕获逻辑。

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