内部事务(REQUIRES_NEW)引发异常时外部事务回滚

Question

我有办法：

  @Transactional
  public void importChargesRequest() {
  ...
   for (Charge charge : charges) {

      try {
        Charge savedCharge = saveCharge(charge);
      } catch (Exception e) {
        log.error(e.getMessage());
      }
    }
}

@Transactional(propagation = Propagation.REQUIRES_NEW)
  public Charge saveCharge(Charge charge) {
    return chargesRepository.saveAndFlush(charge);
  }

Transaction was marked for rollback only; cannot commit; nested exception is org.hibernate.TransactionException: Transaction was marked for rollback only; cannot commit

@Service
public class TestService {

  private final TestDao testDao;

  public TestService(TestDao testDao) {
    this.testDao = testDao;
  }

  @Transactional
  public void saveTest() {
    for (int i = 0; i < 100; i++) {
      Test test = new Test();
      if (i == 10 || i == 20) {
        test.setName("123");
      } else {
        test.setName(UUID.randomUUID().toString());
      }
      testDao.save(test);
    }
  }
} 

和每个内部事务的另一个bean：

@Slf4j
@Component
@Repository
public class TestDao {

  @PersistenceContext
  private EntityManager entityManager;

  @Transactional(propagation = Propagation.REQUIRES_NEW)
  public void save(Test test) {
    entityManager.persist(test);
  }
}

当我第一次尝试保存时，我有20行DB。每次下一次保存，我得到+10行。名称具有约束。当我得到错误时，事务是提交而不是继续。每次保存后我都会等待98行。

Answer 1

如果SaveCharge是与ImportChargesRequest相同bean中的方法，则忽略@Transactional注释，并且saveAndFlush在相同（外部）事务中工作。（我敢肯定，当您使用代理/拦截器来管理事务时，情况就是如此。我敢肯定，当使用基于AspectJ的事务拦截时，情况也是如此）。

通常，只有当异常一直冒泡到外部方法（标记@transaction的方法）时，事务才会被标记为回滚，但我怀疑存储库或事务管理器本身（hibernate会话）由于违反约束而直接将事务标记为回滚。

解决方案是将saveCharge移动到另一个bean，并使用importChargesRequest-method将该bean注入到该bean中。

@Service
public class ChargesDataService{

  @Autowire
  private ChargesRepository chargesRepository;

  @Transactional(propagation = Propagation.REQUIRES_NEW)
  public Charge saveCharge(Charge charge) {
    return chargesRepository.saveAndFlush(charge);
  }
}

@RestController
html" target="_blank">public class ChargesController{

  @Autowire
  private ChargesDataService chargesDataService;

  @Transactional
  public void importChargesRequest() {

   for (Charge charge : charges) {

      try {
        Charge savedCharge = chargesDataService.saveCharge(charge);
      } catch (Exception e) {
        log.error(e.getMessage());
      }
    }
  }
}

补遗：注释被忽略，因为您不再通过bean实例的代理，这意味着没有拦截器被调用，这意味着没有地方处理新事务。您可以通过在saveCharge方法中设置断点并查看StackTrace^来检查是否存在这种情况。寻找类似事务拦截器invokeWithIntransaction的方法。

^您还可以创建一个新异常，调用fillInStacktrace，然后记录/打印异常（包括其StackTrace）。