<!-- 數(shù)據(jù)源配置 -->
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
    <!-- 數(shù)據(jù)庫(kù)連接信息 -->
    <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>

<!-- 事務(wù)管理器配置 -->
<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) {
        // 更新用戶(hù)信息
        userMapper.updateById(user);

        // 模擬拋出異常，觸發(fā)事務(wù)回滾
        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) {
        // 創(chuàng)建事務(wù)定義
        DefaultTransactionDefinition definition = new DefaultTransactionDefinition();
        // 設(shè)置事務(wù)的隔離級(jí)別
        definition.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
        // 設(shè)置事務(wù)的傳播行為
        definition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);

        // 獲取事務(wù)對(duì)象
        TransactionStatus status = transactionManager.getTransaction(definition);

        try {
            // 更新用戶(hù)信息
            userMapper.updateById(user);

            // 模擬拋出異常，觸發(fā)事務(wù)回滾
            if (user.getUsername().equals("rollback")) {
                throw new RuntimeException("Simulated exception for rollback");
            }

            // 提交事務(wù)
            transactionManager.commit(status);
        } catch (Exception e) {
            // 發(fā)生異常，回滾事務(wù)
            transactionManager.rollback(status);
            throw e;
        }
    }
}