@在catch块中处理错误和db插入的事务性（Spring Boot）

Question

我希望在出现错误时回滚数据的事务，同时将错误写入数据库。

我不能处理事务注释。

下面的代码生成一个运行时错误（1/0），并且仍然将数据写入数据库。并将数据写入错误表。

在StackOverflow中，我尝试了几种变体，并遵循类似的问题，但没有成功。

谁有一个提示，怎么办？

@Service
public class MyService{

       @Transactional(rollbackFor = Exception.class)
        public void updateData() {
            try{
                processAndPersist();    // <- db operation with inserts
                int i = 1/0; // <- Runtime error
            }catch (Exception e){
                persistError()
                trackReportError(filename, e.getMessage());
            }
        }
    
    
        @Transactional(propagation = Propagation.REQUIRES_NEW)
        public void persistError(String message) {
            persistError2Db(message); // <- db operation with insert
        }

Answer 1

您需要在updateData（）方法中抛出异常的方法来回滚事务。同时不需要回滚事务。

@Transactional(rollbackFor = Exception.class)
        public void updateData() {
            try{
                processAndPersist();    // <- db operation with inserts
                int i = 1/0; // <- Runtime error
            }catch (Exception e){
                persistError()
                trackReportError(filename, e.getMessage());
                throw ex; // if throw error here, will not work

            }
        }

仅仅抛出一个错误是没有用的，因为持久错误（）将具有与updateData（）相同的事务。因为使用此引用（而不是对代理的引用）调用持久性错误（）。

解决方案

1. 使用自我参照。
2. 对事务使用自注入Spring自注入
3. 在updateData（）（和事务）外移动的持久错误（）调用。删除@Transactional从持久性错误（）（它将不工作），并在持久性错误2Db（）中使用仓库的事务。
4. 移动持久错误（）到一个单独的服务器。在这种情况下，将使用代理调用它。
5. 不要使用声明性事务（带有@Transactional注释）。使用程序化事务管理手动设置事务边界https://docs.spring.io/spring-framework/docs/3.0.0.M3/reference/html/ch11s06.html

还要记住，persistError（）也会产生错误（并且很可能会产生错误）。

使用自我参照

您可以使用对MyService的自我引用来进行事务处理，因为您将能够调用的不是MyServiceImpl的方法，而是Spring代理的方法。

@Service
public class MyServiceImpl implements MyService {

    public void doWork(MyService self) {
        DataEntity data = loadData();

        try {
            self.updateData(data);
        } catch (Exception ex) {
            log.error("Error for dataId={}", data.getId(), ex);
            self.persistError("Error");
            trackReportError(filename, ex);
        }
    }

    @Transactional
    public void updateData(DataEntity data) {
        persist(data);    // <- db operation with inserts
    }

    @Transactional
    public void persistError(String message) {
        try {
            persistError2Db(message); // <- db operation with insert
        } catch (Exception ex) {
            log.error("Error for message={}", message, ex);
        }
    }
}

public interface MyService {

    void doWork(MyService self);
    
    void updateData(DataEntity data);

    void persistError(String message);

}

要使用

MyService service = ...;
service.doWork(service);