如何正确使用 @Transactional 实现级联删除的事务一致性

在 spring 中为删除操作添加 @transactional 时,若涉及多表级联清理(如先删子表记录再删主表),因 hibernate 默认延迟刷新(flush)可能导致外键约束失败;需显式调用 `flush()` 确保子表变更同步到数据库,才能安全提交事务。

当你为 removeById 方法添加 @Transactional 后出现 NULL value in column "car_id" violates NOT NULL constraint 错误,根本原因并非事务本身有问题,而是 JPA/Hibernate 的 flush 时机与数据库外键约束之间的冲突

? 问题还原

假设数据模型中 Violations 表通过 car_id 外键关联 Cars 表(NOT NULL 约束)。你的业务逻辑是:

  1. 先调用 violationService.removeByCarId(id) 删除所有相关违规记录;
  2. 再调用 repository.deleteById(id) 删除车辆主记录。

无 @Transactional 时,两次操作各自开启并立即提交独立事务,物理删除即时生效,故无外键冲突。
但加上 @Transactional 后,整个方法运行在同一个事务中,Hibernate 默认采用 FlushMode.AUTO —— 即仅在事务提交前或执行查询前才触发 flush。这意味着:

  • removeByCarId(id) 执行后,子表记录仅被标记为“待删除”,尚未真正发出 DELETE SQL;
  • 当紧接着执行 deleteById(id) 时,Hibernate 尝试删除主表记录,但此时数据库仍看到子表中 car_id = id 的脏数据;
  • 更关键的是:某些 JPA 实现(尤其配合 PostgreSQL 或严格外键检查时)会在主表 DELETE 语句执行前验证外键完整性,发现子表仍有引用即抛出 NOT NULL / foreign key violation 异常(此处报错提示略有误导,实际是外键残留导致约束校验失败)。

✅ 正确解法:显式 flush

在子表删除操作后、主表删除前,强制刷新一级缓存与待执行 SQL:

@Transactional
@Override
public void removeById(Long id) {
    violationService.removeByCarId(id); // 删除 Violations 记录
    violationService.flush();            // ← 关键:立即同步到 DB,释放外键引用
    repository.deleteById(id);           /

/ 此时 car_id 在 violations 表中已不存在,可安全删除 Cars }

对应地,ViolationService 需暴露 flush() 方法:

@Service
public class ViolationService {

    @PersistenceContext
    private EntityManager entityManager;

    public void removeByCarId(Long carId) {
        String jpql = "DELETE FROM Violation v WHERE v.car.id = :carId";
        entityManager.createQuery(jpql)
                .setParameter("carId", carId)
                .executeUpdate();
    }

    @Transactional(propagation = Propagation.MANDATORY) // 确保在已有事务内执行
    public void flush() {
        entityManager.flush(); // 强制将 pending delete 操作刷入数据库
    }
}
? 替代方案说明: 使用 @Modifying(clearAutomatically = true) + @Query 的 JPQL 删除时,默认不自动 flush,仍需手动干预; 若使用 CrudRepository.deleteAllByCarId() 等基于实体的删除,需确保 saveAll(…) 或 deleteAll(…) 后调用 flush(); 避免仅靠 @Transactional 依赖默认行为——对多步 DML 且存在外键依赖的操作,显式控制 flush 是健壮性的必要实践。

⚠️ 注意事项

  • entityManager.flush() 不会提交事务,只同步变更至数据库(仍可回滚);
  • 切勿在非事务上下文中调用 flush(),否则抛 TransactionRequiredException;
  • 若服务方法已标注 @Transactional,其内部 flush() 无需额外事务传播配置(MANDATORY 即可);
  • 生产环境建议配合日志(如 LOG.debug("Flushed {} violation records", count))便于追踪数据清理状态。

通过精准控制 flush 时机,你既能享受声明式事务的原子性保障,又能规避数据库层面的约束冲突,真正实现「全成功或全回滚」的一致性删除。