【Java】已解决：org.springframework.transaction.UnexpectedRollbackException

屿小夏

发布于 2024-09-11 15:46:28

2390

发布于 2024-09-11 15:46:28

文章被收录于专栏：IT杂谈学习

已解决：org.springframework.transaction.UnexpectedRollbackException

一、分析问题背景

在使用Spring框架进行事务管理时，有时会遇到org.springframework.transaction.UnexpectedRollbackException报错。该异常通常发生在事务处理的过程中，某个操作失败导致整个事务被回滚，而事务的调用者没有意识到这个回滚的发生。这个异常提示了一个关键问题，即在事务被回滚后继续执行了后续操作。以下是一个可能的场景和代码片段：

场景描述

在一个Spring应用中，我们有两个数据库操作：插入新用户和更新用户账户信息。这两个操作被包装在一个事务中。如果插入用户成功但更新账户信息失败，整个事务会回滚，并抛出UnexpectedRollbackException异常。

代码片段

@Service
public class UserService {

    @Autowired
    private UserRepository userRepository;

    @Autowired
    private AccountRepository accountRepository;

    @Transactional
    public void createUserAndAccount(User user, Account account) {
        userRepository.save(user);
        accountRepository.update(account);
    }
}

二、可能出错的原因

导致UnexpectedRollbackException的原因有以下几点：

事务传播行为错误：嵌套事务中的传播行为设置不当，导致回滚时出现意外。
未捕获的异常：在事务中发生了未捕获的运行时异常，导致事务回滚。
手动触发的回滚：在事务中使用了TransactionStatus.setRollbackOnly()方法手动标记事务为仅回滚状态。

三、错误代码示例

以下是一个可能导致该报错的代码示例，并解释其错误之处：

@Service
public class UserService {

    @Autowired
    private UserRepository userRepository;

    @Autowired
    private AccountRepository accountRepository;

    @Transactional
    public void createUserAndAccount(User user, Account account) {
        try {
            userRepository.save(user);
            // 模拟一个更新操作失败的情况
            accountRepository.update(account);
        } catch (Exception e) {
            // 处理异常，但未抛出，导致事务标记为回滚
            System.out.println("Error updating account: " + e.getMessage());
        }
    }
}

错误分析：

异常未正确处理：在catch块中捕获了异常，但没有重新抛出，导致Spring框架认为事务可以继续提交，但实际已被标记为回滚状态。

四、正确代码示例

为了正确解决该报错问题，我们需要确保在捕获异常后重新抛出，以便Spring事务管理器能正确处理事务回滚。以下是修正后的代码示例：

@Service
public class UserService {

    @Autowired
    private UserRepository userRepository;

    @Autowired
    private AccountRepository accountRepository;

    @Transactional
    public void createUserAndAccount(User user, Account account) {
        try {
            userRepository.save(user);
            // 模拟一个更新操作失败的情况
            accountRepository.update(account);
        } catch (Exception e) {
            // 处理异常后重新抛出
            System.out.println("Error updating account: " + e.getMessage());
            throw e;
        }
    }
}

通过上述代码，异常被正确捕获并重新抛出，使得Spring事务管理器能正确识别事务失败并进行回滚。