MyBatisPlus中事务处理的实现

<!-- 数据源配置 -->
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
    <!-- 数据库连接信息 -->
    <property name="driverClassName" value="com.mysql.cj.jdbc.Driver" />
    <property name="url" value="jdbc:mysql://localhost:3306/mydatabase" />
    <property name="username" value="root" />
    <property name="password" value="password" />
</bean>

<!-- MyBatis Plus配置 -->
<bean id="sqlSessionFactory" class="com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean">
    <property name="dataSource" ref="dataSource" />
</bean>

<!-- 事务管理器配置 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource" />
</bean>

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapper userMapper;

    @Transactional
    @Override
    public void updateUser(User user) {
        // 更新用户信息
        userMapper.updateById(user);

        // 模拟抛出异常，触发事务回滚
        if (user.getUsername().equals("rollback")) {
            throw new RuntimeException("Simulated exception for rollback");
        }
    }
}

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapper userMapper;

    @Autowired
    private PlatformTransactionManager transactionManager;

    @Override
    public void updateUser(User user) {
        // 创建事务定义
        DefaultTransactionDefinition definition = new DefaultTransactionDefinition();
        // 设置事务的隔离级别
        definition.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
        // 设置事务的传播行为
        definition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);

        // 获取事务对象
        TransactionStatus status = transactionManager.getTransaction(definition);

        try {
            // 更新用户信息
            userMapper.updateById(user);

            // 模拟抛出异常，触发事务回滚
            if (user.getUsername().equals("rollback")) {
                throw new RuntimeException("Simulated exception for rollback");
            }

            // 提交事务
            transactionManager.commit(status);
        } catch (Exception e) {
            // 发生异常，回滚事务
            transactionManager.rollback(status);
            throw e;
        }
    }
}