无需显式事务管理，如何回滚JPA会话中的数据库变更？

首先明确：JPA本身没有完全脱离事务管理就能实现批量操作原子性的内置功能，因为事务是保证数据一致性的核心机制。但可以通过声明式事务或调整事务范围来简化事务管理，避免手动重复写begin/commit/rollback代码，同时实现你要的批量回滚需求。

当前代码的核心问题 #

你现在的insertOrUpdateEntity方法会为每个实体操作单独开启并提交事务，这意味着entityObject1、entityObject2、entityObject3的变更会被分别提交到数据库。哪怕entityObject4操作失败，前三个的变更已经持久化，无法回滚——因为它们属于独立的已完成事务。

方案一：使用声明式事务（推荐，无需手动管理事务） #

如果你的项目使用Spring（或Spring Boot），可以用@Transactional注解实现声明式事务，让框架自动处理事务的生命周期。

修改步骤： #

1. 移除insertOrUpdateEntity中的手动事务代码，只保留核心的实体操作：

public void insertOrUpdateEntity(final Object entityObject) throws SQLException {
    this.session.merge(entityObject);
}

2. 在批量操作的方法performDatabaseUpdate上添加@Transactional注解，框架会自动为该方法开启一个事务，所有内部的数据库操作都在同一个事务中执行。一旦方法内抛出未捕获的异常，事务会自动回滚：

import org.springframework.transaction.annotation.Transactional;

@Transactional
private void performDatabaseUpdate() {
    DataBaseOperations dbOperations = null;
    DataBaseConfigurator dbConfiguration = this.databaseConnectionDetails.getDatabaseConnection();

    try {
        dbOperations = dbConfiguration.getSession();

        dbOperations.insertOrUpdateEntity(entityObject1);
        dbOperations.insertOrUpdateEntity(entityObject2);
        dbOperations.insertOrUpdateEntity(entityObject3);
        dbOperations.insertOrUpdateEntity(entityObject4);
        
    } catch (Exception e) {
        // 这里可以添加日志记录，异常会被Spring捕获并触发回滚
        throw new RuntimeException("数据库更新失败", e);
    } finally {
        if (dbOperations != null) {
            dbOperations.close();
        }
    }
}

注意：要确保你的Spring上下文已经配置了事务管理器（比如JpaTransactionManager），注解才能生效。

方案二：手动调整事务范围（无Spring依赖） #

如果不使用Spring，你可以把事务的开启、提交/回滚逻辑提到批量操作的方法中，让所有实体操作共享同一个事务：

修改后的insertOrUpdateEntity（去掉事务代码）： #

public void insertOrUpdateEntity(final Object entityObject) throws SQLException {
    this.session.merge(entityObject);
}

修改后的performDatabaseUpdate（统一管理事务）： #

private void performDatabaseUpdate() {
    DataBaseOperations dbOperations = null;
    DataBaseConfigurator dbConfiguration = this.databaseConnectionDetails.getDatabaseConnection();
    Transaction transaction = null;

    try {
        dbOperations = dbConfiguration.getSession();
        transaction = dbOperations.getSession().beginTransaction(); // 开启全局事务

        dbOperations.insertOrUpdateEntity(entityObject1);
        dbOperations.insertOrUpdateEntity(entityObject2);
        dbOperations.insertOrUpdateEntity(entityObject3);
        dbOperations.insertOrUpdateEntity(entityObject4);

        transaction.commit(); // 所有操作成功后提交事务
    } catch (Exception e) {
        if (transaction != null && transaction.isActive()) {
            transaction.rollback(); // 任何异常触发回滚
        }
        // 记录异常信息
        System.err.println("数据库更新失败：" + e.getMessage());
    } finally {
        if (dbOperations != null) {
            dbOperations.close();
        }
    }
}

关于你尝试代码的纠正 #

你之前在catch块中调用this.session.flush()是不必要的：事务回滚后，会话中的变更已经被撤销，flush操作只会强制同步未提交的变更，反而可能引发异常，建议移除这行代码。

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