// 早期編程式事務(wù)示例（繁瑣?。?
public void transfer() {
    // 1. 定義事務(wù)屬性
    DefaultTransactionDefinition def = new DefaultTransactionDefinition();
    def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
    // 2. 獲取事務(wù)狀態(tài)
    TransactionStatus status = transactionManager.getTransaction(def);
    try {
        // 核心業(yè)務(wù)邏輯：扣錢(qián)、加錢(qián)
        accountMapper.decreaseBalance(fromId, amount);
        accountMapper.increaseBalance(toId, amount);
        // 3. 手動(dòng)提交
        transactionManager.commit(status);
    } catch (Exception e) {
        // 4. 手動(dòng)回滾
        transactionManager.rollback(status);
        throw e;
    }
}

@Configuration
public class TransactionConfig {
    // 1. 注入數(shù)據(jù)源（Spring Boot自動(dòng)配置，無(wú)需手動(dòng)編寫(xiě)）
    @Autowired
    private DataSource dataSource;
    // 2. 配置事務(wù)管理器（MyBatis場(chǎng)景）
    @Bean
    public PlatformTransactionManager transactionManager() {
        return new DataSourceTransactionManager(dataSource);
    }
    // 3. 配置TransactionTemplate
    @Bean
    public TransactionTemplate transactionTemplate(PlatformTransactionManager transactionManager) {
        TransactionTemplate template = new TransactionTemplate(transactionManager);
        // 設(shè)置默認(rèn)事務(wù)屬性（可選，不設(shè)置則用Spring默認(rèn)值）
        template.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED); // 隔離級(jí)別：讀已提交
        template.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); // 傳播行為：必須有事務(wù)
        template.setTimeout(30); // 超時(shí)時(shí)間：30秒
        template.setReadOnly(false); // 非只讀（默認(rèn)false）
        return template;
    }
}

┌───────────────┐    1. 傳入回調(diào)函數(shù)    ┌──────────────────┐
│   開(kāi)發(fā)者代碼   │ ────────────────────> │ TransactionTemplate │
└───────────────┘                       └──────────────────┘
                                              │
                                              ▼
┌───────────────┐    6. 返回結(jié)果         ┌──────────────────┐
│   業(yè)務(wù)結(jié)果     │ <──────────────────── ┘                  │
└───────────────┘                       │ 2. 創(chuàng)建事務(wù)      │
                                        ▼                  │
                                  ┌──────────────┐        │
                                  │ PlatformTransactionManager │
                                  └──────────────┘        │
                                        │                  │
                                        ▼                  │
┌───────────────┐    5. 提交/回滾       ┌──────────────────┐
│  數(shù)據(jù)庫(kù)事務(wù)    │ <──────────────────── │                  │
└───────────────┘                       │ 3. 執(zhí)行業(yè)務(wù)邏輯  │
                                        ▼                  │
                                  ┌──────────────┐        │
                                  │  回調(diào)函數(shù)業(yè)務(wù)代碼  │        │
                                  └──────────────┘        │
                                        │                  │
                                        ▼                  │
                                  ┌──────────────┐        │
                                  │  4. 結(jié)果/異常  │ ────────┘
                                  └──────────────┘

@Service
public class TransferService {
    @Autowired
    private TransactionTemplate transactionTemplate;
    @Autowired
    private AccountMapper accountMapper;
    /**
     * 轉(zhuǎn)賬業(yè)務(wù)：從fromId扣錢(qián)，向toId加錢(qián)
     * @return 轉(zhuǎn)賬是否成功
     */
    public boolean transfer(Long fromId, Long toId, BigDecimal amount) {
        // 調(diào)用execute方法，傳入TransactionCallback回調(diào)
        Boolean result = transactionTemplate.execute(status -> {
            try {
                // 1. 扣減轉(zhuǎn)出方余額
                int rows1 = accountMapper.decreaseBalance(fromId, amount);
                if (rows1 == 0) {
                    throw new RuntimeException("轉(zhuǎn)出賬戶(hù)不存在或余額不足");
                }
                // 2. 增加轉(zhuǎn)入方余額（模擬異常：若toId不存在，會(huì)拋異常觸發(fā)回滾）
                int rows2 = accountMapper.increaseBalance(toId, amount);
                if (rows2 == 0) {
                    throw new RuntimeException("轉(zhuǎn)入賬戶(hù)不存在");
                }
                // 3. 無(wú)異常，返回成功
                return true;
            } catch (Exception e) {
                // 手動(dòng)標(biāo)記回滾（可選，拋出RuntimeException會(huì)自動(dòng)回滾）
                status.setRollbackOnly();
                log.error("轉(zhuǎn)賬失敗", e);
                return false;
            }
        });
        return Boolean.TRUE.equals(result);
    }
}

@Service
public class UserService {
    @Autowired
    private TransactionTemplate transactionTemplate;
    @Autowired
    private UserMapper userMapper;
    /**
     * 批量插入用戶(hù)，確保要么全部成功，要么全部失敗
     */
    public void batchInsertUser(List<User> userList) {
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus status) {
                try {
                    for (User user : userList) {
                        // 模擬部分插入失敗（如用戶(hù)手機(jī)號(hào)重復(fù)）
                        if (StringUtils.isEmpty(user.getPhone())) {
                            throw new RuntimeException("用戶(hù)手機(jī)號(hào)不能為空");
                        }
                        userMapper.insert(user);
                    }
                } catch (Exception e) {
                    status.setRollbackOnly();
                    log.error("批量插入用戶(hù)失敗", e);
                    throw new BusinessException("批量插入失敗，請(qǐng)檢查數(shù)據(jù)");
                }
            }
        });
    }
}

/**
 * 查詢(xún)所有用戶(hù)（只讀事務(wù)，優(yōu)化性能）
 */
public List<User> queryAllUser() {
    // 1. 定義臨時(shí)事務(wù)屬性（覆蓋默認(rèn)配置）
    TransactionDefinition readOnlyDef = new DefaultTransactionDefinition() {
        @Override
        public int getPropagationBehavior() {
            return TransactionDefinition.PROPAGATION_SUPPORTS; // 支持事務(wù)（無(wú)則不創(chuàng)建）
        }
        @Override
        public int getIsolationLevel() {
            return TransactionDefinition.ISOLATION_READ_COMMITTED;
        }
        @Override
        public boolean isReadOnly() {
            return true; // 只讀事務(wù)
        }
        @Override
        public int getTimeout() {
            return 10; // 超時(shí)時(shí)間10秒
        }
    };
    // 2. 傳入動(dòng)態(tài)事務(wù)屬性執(zhí)行
    return transactionTemplate.execute(readOnlyDef, status -> {
        return userMapper.selectList(null);
    });
}

@Configuration
public class MultiDataSourceTxConfig {
    // 主庫(kù)數(shù)據(jù)源（寫(xiě)操作）
    @Autowired
    @Qualifier("masterDataSource")
    private DataSource masterDataSource;
    // 從庫(kù)數(shù)據(jù)源（讀操作）
    @Autowired
    @Qualifier("slaveDataSource")
    private DataSource slaveDataSource;
    // 主庫(kù)事務(wù)管理器
    @Bean("masterTxManager")
    public PlatformTransactionManager masterTxManager() {
        return new DataSourceTransactionManager(masterDataSource);
    }
    // 從庫(kù)事務(wù)管理器
    @Bean("slaveTxManager")
    public PlatformTransactionManager slaveTxManager() {
        return new DataSourceTransactionManager(slaveDataSource);
    }
    // 主庫(kù)TransactionTemplate（寫(xiě)操作）
    @Bean("masterTxTemplate")
    public TransactionTemplate masterTxTemplate(@Qualifier("masterTxManager") PlatformTransactionManager txManager) {
        TransactionTemplate template = new TransactionTemplate(txManager);
        template.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
        return template;
    }
    // 從庫(kù)TransactionTemplate（讀操作，默認(rèn)只讀）
    @Bean("slaveTxTemplate")
    public TransactionTemplate slaveTxTemplate(@Qualifier("slaveTxManager") PlatformTransactionManager txManager) {
        TransactionTemplate template = new TransactionTemplate(txManager);
        template.setPropagationBehavior(TransactionDefinition.PROPAGATION_SUPPORTS);
        template.setReadOnly(true);
        return template;
    }
}

@Service
public class BusinessService {
    // 主庫(kù)模板（寫(xiě)操作）
    @Autowired
    @Qualifier("masterTxTemplate")
    private TransactionTemplate masterTxTemplate;
    // 從庫(kù)模板（讀操作）
    @Autowired
    @Qualifier("slaveTxTemplate")
    private TransactionTemplate slaveTxTemplate;
    // 寫(xiě)操作（主庫(kù)）
    public void saveOrder(Order order) {
        masterTxTemplate.execute(status -> {
            orderMapper.insert(order);
            return null;
        });
    }
    // 讀操作（從庫(kù)）
    public Order getOrderById(Long orderId) {
        return slaveTxTemplate.execute(status -> {
            return orderMapper.selectById(orderId);
        });
    }
}