SpringBoot手动提交/回滚事务实现方式

@Configuration  
@EnableTransactionManagement  
public class TransactionConfig {  
  
    @Autowired  
    private PlatformTransactionManager transactionManager;  
  
    @Bean  
    public TransactionTemplate transactionTemplate() {  
        return new TransactionTemplate(transactionManager);  
    }  
}

@Service  
public class YourService {  
  
    @Autowired  
    private TransactionTemplate transactionTemplate;  
  
    @Autowired  
    private YourRepository yourRepository; // 假设你有一个Repository  
  
    public void performDatabaseOperations() {  
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {  
            @Override  
            protected void doInTransactionWithoutResult(TransactionStatus status) {  
                try {  
                    // 在这里执行数据库操作  
                    yourRepository.saveSomething();  
                    // 可以继续执行其他数据库操作...  
  
                    // 如果一切正常，TransactionTemplate会自动提交事务  
                    // 不需要手动调用status.commit();  
  
                } catch (RuntimeException ex) {  
                    // 如果捕获到异常，可以选择回滚事务  
                    // 注意：在TransactionCallbackWithoutResult中，通常不需要显式调用status.rollback();  
                    // 因为TransactionTemplate默认会在回调方法抛出异常时回滚事务  
                    // 但如果你想在回滚之前执行一些清理操作，可以在这里处理  
                    // 然后重新抛出异常，让TransactionTemplate知道需要回滚  
                    throw ex; // 重新抛出异常  
                }  
            }  
        });  
    }  
}

@Service  
public class YourService {  
  
    @Autowired  
    private PlatformTransactionManager transactionManager;  
  
    @Autowired  
    private YourRepository yourRepository; // 假设你有一个Repository  
  
    public void yourMethod() {  
        DefaultTransactionDefinition def = new DefaultTransactionDefinition();  
        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);  
  
        TransactionStatus status = transactionManager.getTransaction(def);  
  
        try {  
            // 执行数据库操作  
            yourRepository.someDatabaseOperation();  
  
            // 提交事务  
            transactionManager.commit(status);  
        } catch (RuntimeException e) {  
            // 回滚事务  
            transactionManager.rollback(status);  
            throw e; // 可以选择重新抛出异常  
        }  
    }  
}