对于spring-batch事务在异常后不会回滚

Question

public class MyWriter{

@Autowired
private MyService myService;

@Override
public void write(List<? extends MyBO> list) {
  try{
    for(MyBO bo: list){
      myService.insert(bo);
    }
  }
  catch(Exception e){
    log.error("Cant write to DB")
  }
}


public class MyService{
@Autowired
private TableOneDAO tableOneDao;

@Autowired
private TableTwoDAO tableTwoDAO;

@Autowired
private TableThreeDAO tableThreeDAO;

public void insert(MyBO bo){
  try{
      // do other stuff of processing bo and create entity
      MyEntityTableOne myentity1 = getEntityT1(bo);
      MyEntityTableTwo myentity2 = getEntityT2(bo);
      MyEntityTableThree myentity3 = getEntityT3(bo);
      insertToDB(myEntity1,myEntity2,myEntity3);
  }
  catch(Exception e){
    log.error("Error occured.");
    throw new MyException("Error Blah blah occured");
  }
}

@Transactional(value = "txn1")
public void insertToDB(MyEntityTableOne entity1, MyEntityTableTwo entity2, MyEntityTableThree entity3) {
  try{
    tableOneDao.insert(entity1);
    tableTwoDAO.insert(entity2);
    tableThreeDAO.insert(entity3);
  }
  catch(Exception e){
    log.error("Error occured during insert to DB");
    throw new MyException("Error Blah blah occured during DB insert");
  }
}

Answer 1

我试图让它变得简单：为了支持@transactional，spring将实现类包装成一个所谓的代理，并用事务性逻辑围绕方法call/class。

现在您正在同一个类中调用带注释的@transactional方法。因此，代理不被调用，事务不起作用。当将注释移动到insert方法时，您正在从类的外部调用该方法，这意味着您将针对代理调用该方法。

这是Spring AOP的一个限制（？）我想。

public class MyService{
@Ressource
private MyService self;

...

self.insertToDB(myEntity1,myEntity2,myEntity3)