Hibernate批量持久化异常后提交问题求助

你的代码逻辑有个关键问题——当循环中抛出异常时，Hibernate的事务已经被标记为rollback-only状态，这时候再调用transaction.commit()根本不会生效，反而会抛出新的异常，所以你想保留报错前已处理对象的需求没法实现。

下面给你几个可行的解决方案，适配不同场景：

方案1：为每个实体单独创建事务 #

这是最直接的实现方式，把事务粒度缩小到单个实体，每个实体处理完成后立即提交，遇到异常时只回滚当前实体的操作，前面的成功操作都会保留到数据库。

代码示例：

private void persist(List<T> entities, boolean isSaveOrUpdate) {
    for (T entity : entities) {
        Transaction tx = null;
        try {
            tx = session.beginTransaction();
            if (isSaveOrUpdate) {
                session.merge(entity);
            } else {
                session.remove(entity);
            }
            tx.commit();
        } catch (Exception e) {
            if (tx != null) {
                tx.rollback();
            }
            // 可记录错误日志，或把失败实体收集起来后续处理
            log.error("处理实体失败: {}", entity, e);
        }
    }
    close();
}

缺点：频繁开启、提交事务会带来性能开销，适合实体数量不多的场景。

方案2：使用保存点（Savepoint）实现部分回滚 #

Hibernate支持数据库保存点，在每个实体处理完成后设置一个保存点，遇到异常时只回滚到上一个保存点，而非整个事务，这样前面的操作依然可以正常提交。

代码示例：

private void persist(List<T> entities, boolean isSaveOrUpdate) {
    Transaction tx = null;
    try {
        tx = session.beginTransaction();
        Savepoint lastSavepoint = null;
        
        for (T entity : entities) {
            // 处理前创建保存点
            lastSavepoint = tx.createSavepoint("savepoint_" + entity.getId());
            try {
                if (isSaveOrUpdate) {
                    session.merge(entity);
                } else {
                    session.remove(entity);
                }
            } catch (Exception e) {
                // 回滚到上一个保存点，跳过当前错误实体
                tx.rollback(lastSavepoint);
                tx.releaseSavepoint(lastSavepoint);
                log.error("处理实体失败，已回滚当前操作: {}", entity, e);
                continue;
            }
            tx.releaseSavepoint(lastSavepoint);
        }
        
        tx.commit();
    } catch (Exception e) {
        if (tx != null) {
            tx.rollback();
        }
        throw e;
    } finally {
        close();
    }
}

注意：需要确认你的数据库支持保存点（MySQL、PostgreSQL等主流数据库都支持）；另外保存点会增加数据库开销，批量处理超大量数据时需谨慎使用。

方案3：分离成功/失败实体，分批次提交 #

先尝试批量处理所有实体，捕获异常时将错误实体从列表中移除，提交剩下的成功实体，再单独处理失败的实体（可重试或人工干预）。

代码示例：

private void persist(List<T> entities, boolean isSaveOrUpdate) {
    List<T> failedEntities = new ArrayList<>();
    Transaction tx = null;
    
    try {
        tx = session.beginTransaction();
        
        for (T entity : entities) {
            try {
                if (isSaveOrUpdate) {
                    session.merge(entity);
                } else {
                    session.remove(entity);
                }
            } catch (Exception e) {
                failedEntities.add(entity);
                log.error("处理实体失败，已加入错误列表: {}", entity, e);
                // 清除当前实体的操作缓存，避免影响后续提交
                session.clear();
            }
        }
        
        tx.commit();
    } catch (Exception e) {
        if (tx != null) {
            tx.rollback();
        }
        throw e;
    } finally {
        close();
    }
    
    // 单独处理失败的实体，可递归调用或其他方式
    if (!failedEntities.isEmpty()) {
        log.info("开始处理{}个失败实体", failedEntities.size());
        persist(failedEntities, isSaveOrUpdate);
    }
}

这种方式兼顾性能和容错性，适合大部分批量处理场景。

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