异步任务中如何解决‘Transaction was marked for rollback only; cannot commit’异常

问题背景 #

你在开发异步文件导入API时，希望完成全量文件处理并将所有错误记录到数据库，但在触发ConstraintViolationException时，遇到了Transaction was marked for rollback only; cannot commit的异常。核心场景是：异步任务循环处理数据，调用带事务的Service方法，当保存实体违反约束时，尝试记录错误日志，但事务被标记为仅回滚，最终导致提交失败。

问题根源 #

Hibernate在捕获到ConstraintViolationException这类底层数据库约束异常时，会自动将当前事务标记为rollback-only——这个行为是Hibernate的底层机制，即使你在方法上配置了@Transactional(noRollbackFor = {CustomException.class, ConstraintViolationException.class})，也无法覆盖这个标记。当事务方法执行完毕后，Spring尝试提交事务，发现事务已被标记为仅回滚，就会抛出你看到的异常。

解决方案 #

核心思路是隔离失败的数据库操作与错误日志记录的事务边界，让失败的保存操作在独立的子事务中执行，避免影响外层事务的提交。

1. 拆分事务：将实体保存操作独立为子事务

在ReferentielCompteurServiceImpl中新增一个带独立事务的保存方法，使用Propagation.REQUIRES_NEW确保每次调用都开启新事务——这样即使子事务失败被标记回滚，也不会污染外层事务：

@Service
@Transactional
public class ReferentielCompteurServiceImpl implements ReferentielCompteurService {
    // ... 其他代码

    // 独立的实体保存方法，使用REQUIRES_NEW传播行为
    @Transactional(propagation = Propagation.REQUIRES_NEW, noRollbackFor = ConstraintViolationException.class)
    private ReferentielCompteur saveEntityInNewTransaction(ReferentielCompteur referentielCompteur) {
        return referentielCompteurRepository.save(referentielCompteur);
    }

    @Override
    @Transactional(noRollbackFor = {CustomException.class, ConstraintViolationException.class})
    public ReferentielCompteurDTO save(ReferentielCompteurDTO referentielCompteurDTO, Long importId) {
        log.debug("Request to save ReferentielCompteur : {}", referentielCompteurDTO);
        if (referentielCompteurDTO.getDateCreation() == null) {
            referentielCompteurDTO.setDateCreation(ZonedDateTime.now());
        }
        referentielCompteurDTO.setDateModification(ZonedDateTime.now());
        ReferentielCompteur referentielCompteur = referentielCompteurMapper.toEntity(referentielCompteurDTO);
        
        try {
            // 调用独立事务的保存方法
            referentielCompteur = saveEntityInNewTransaction(referentielCompteur);
        } catch (ConstraintViolationException cve) {
            // 错误日志记录不受子事务回滚影响
            importFichierTraceService.add(importId, referentielCompteurDTO.getReferenceId().toString(), cve.getMessage());
        }
        
        return referentielCompteurMapper.toDto(referentielCompteur);
    }
}

2. 异步方法的事务补充

你的importReference方法是异步的，默认不会继承调用方的事务。如果需要确保任务的整体事务一致性，可以给该方法添加@Transactional注解，但注意：异步方法的事务是独立的，内部调用的Service方法会根据事务传播行为处理。

@Service
public class ImportFichier {
    @Async("taskExecutor")
    @Transactional // 添加事务注解，确保异步任务的事务上下文
    public void importReference(ImportFichierDTO importFichierDTO, List<Reference> references, Long idEntite, Long currentUserId, boolean update){
        log.debug("Request to importReference pour entite : {}", idEntite);
        for(Reference reference : references) {
            if (update) {
                referentielService.update(idEntite, reference, currentUserId, importFichierDTO.getId());
            } else {
                referentielService.add(idEntite, reference, currentUserId, importFichierDTO.getId());
            }
        }
        importFichierDTO.setDateFin(ZonedDateTime.now());
        importFichierService.save(importFichierDTO);
    }
}

3. 额外注意事项

• 确保importFichierTraceService.add方法的事务是独立的（比如默认的REQUIRED传播行为），这样错误日志的写入不会被任何失败的子事务影响。
• 如果你的add方法中还有其他数据库操作，也建议将错误日志记录的逻辑放在独立的事务中，避免被其他异常触发的回滚影响。

总结 #

通过将失败的实体保存操作隔离到独立的子事务中，可以避免Hibernate标记的rollback-only状态污染外层事务，确保错误日志能正常写入，同时不中断整个文件导入流程。

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