Java中transaction.rollback()无法回滚数据库数据问题求助

1. 检查EntityManagerFactory的连接配置 #

确保数据库连接URL未开启自动提交，MySQL的JDBC URL若包含autoReconnect=true或autocommit=true会直接导致事务失效。正确的URL示例：

jdbc:mysql://localhost:3306/your_db?useSSL=false&serverTimezone=UTC

同时检查persistence.xml（或对应配置文件），确认没有hibernate.connection.autocommit=true这类强制自动提交的配置项。

2. 主键生成策略的影响 #

如果Basket实体主键采用IDENTITY生成策略（MySQL自增主键），调用em.persist()+em.flush()会立即向数据库插入记录，但该操作仍属于当前事务范畴，理论上可回滚。若回滚失效，可尝试：

• 暂时移除em.flush()（persist()会在事务提交前自动同步，除非你需要立即获取主键ID）
• 更换主键生成策略为SEQUENCE或TABLE，测试回滚是否正常

3. 验证事务是否正确开启 #

在transaction.begin()后，打印JDBC连接的自动提交状态，确认事务已禁用自动提交：

// 获取底层JDBC连接
Connection conn = em.unwrap(Connection.class);
System.out.println("AutoCommit status: " + conn.getAutoCommit()); // 预期输出false

若输出为true，说明事务未正确初始化，需检查EntityManager的创建逻辑是否存在问题。

4. 修正异常捕获与回滚逻辑 #

你的代码中回滚逻辑基本正确，但需注意：

• 确保抛出的异常未被其他代码捕获吞掉
• 在finally块中处理回滚时，需捕获可能的异常（比如事务已被回滚的情况）：

finally {
    if (transaction.isActive()) {
        try {
            transaction.rollback();
        } catch (Exception ex) {
            // 记录回滚失败日志
            ex.printStackTrace();
        }
    }
    em.close();
}

5. 数据库层面的最终确认 #

尽管你提到表用InnoDB引擎，仍需执行以下检查：

• 执行SHOW CREATE TABLE basket;，确认表引擎为ENGINE=InnoDB
• 执行SHOW VARIABLES LIKE 'autocommit';，全局值应为ON，但JDBC连接会在事务开启时自动改为OFF

修正后的代码示例 #

调整代码，移除不必要的flush并增加状态日志：

EntityManager em = EMF.getEM();
BasketService basketService = new BasketService();
EntityTransaction transaction = em.getTransaction();

try {
    transaction.begin();
    // 检查自动提交状态
    Connection conn = em.unwrap(Connection.class);
    System.out.println("AutoCommit: " + conn.getAutoCommit());

    Basket basket = new Basket();
    // 设置实体参数
    basketService.insert(em, basket);
    System.out.println("Basket ID: " + basket.getId());
    
    throw new Exception("fake error");
    transaction.commit();
} catch (Exception e) {
    System.err.println("Error occurred: " + e.getMessage());
    if (transaction.isActive()) {
        transaction.rollback();
        System.out.println("Transaction rolled back");
    }
} finally {
    if (transaction.isActive()) {
        try {
            transaction.rollback();
            System.out.println("Final rollback executed");
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }
    em.close();
}

服务类优化（移除非必要的flush）：

public class BasketService {
    public Basket insert(EntityManager em, Basket basket) {
        em.persist(basket);
        // em.flush(); // 无需立即同步时可移除
        return basket;
    }
}

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