Java Spring @Transactional 方法没有按预期回滚

Question

下面是我正在尝试做的事情的简要概述。我想通过一个方法调用将一条记录推送到数据库中的两个不同表。如果有任何失败，我希望一切都回滚。因此，如果 insertIntoB 失败，我希望将在 insertIntoA 中提交的所有内容回滚。

public class Service {
    MyDAO dao;

    public void insertRecords(List<Record> records){
        for (Record record : records){
            insertIntoAAndB(record);
        }
    }

    @Transactional (rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)
    public void insertIntoAAndB(Record record){
        insertIntoA(record);
        insertIntoB(record);
    }

    @Transactional(propagation = Propagation.REQUIRED)
    public void insertIntoA(Record record){
        dao.insertIntoA(record);
    }

    @Transactional(propagation = Propagation.REQUIRED)
    public void insertIntoB(Record record){
        dao.insertIntoB(record);
    }

    public void setMyDAO(final MyDAO dao) {
        this.dao = dao;
    }
}

其中MyDAO dao是使用mybatis映射到数据库的接口(interface)，使用Spring注入(inject)设置。

现在，如果 insertIntoB 失败，insertIntoA 中的所有内容仍会被推送到数据库。我该如何纠正这种行为？

编辑:

我修改了类以更准确地描述我要实现的目标。如果我直接运行 insertIntoAAndB，如果有任何问题，回滚会起作用，但如果我从 insertRecords 调用 insertIntoAAndB，回滚不会如果出现任何问题，将无法正常工作。

Answer 1

我找到了解决方案!

显然 Spring 无法拦截对事务方法的内部方法调用。所以我把调用事务方法的方法拿出来，放到一个单独的类中，回滚就可以了。下面是一个粗略的修复示例。

public class Foo {
    public void insertRecords(List<Record> records){
        Service myService = new Service();
        for (Record record : records){
            myService.insertIntoAAndB(record);
        }
    }
}

public class Service {
    MyDAO dao;

    @Transactional (rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)
    public void insertIntoAAndB(Record record){
        insertIntoA(record);
        insertIntoB(record);
    }

    @Transactional(propagation = Propagation.REQUIRED)
    public void insertIntoA(Record record){
        dao.insertIntoA(record);
    }

    @Transactional(propagation = Propagation.REQUIRED)
    public void insertIntoB(Record record){
        dao.insertIntoB(record);
    }

    public void setMyDAO(final MyDAO dao) {
        this.dao = dao;
    }
}