// 早期編程式事務(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ù)邏輯：扣錢、加錢
        accountMapper.decreaseBalance(fromId, amount);
        accountMapper.increaseBalance(toId, amount);
        // 3. 手動提交
        transactionManager.commit(status);
    } catch (Exception e) {
        // 4. 手動回滾
        transactionManager.rollback(status);
        throw e;
    }
}

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

┌───────────────┐    1. 傳入回調(diào)函數(shù)    ┌──────────────────┐
│   開發(fā)者代碼   │ ────────────────────> │ TransactionTemplate │
└───────────────┘                       └──────────────────┘
                                              │
                                              ▼
┌───────────────┐    6. 返回結(jié)果         ┌──────────────────┐
│   業(yè)務(wù)結(jié)果     │ <──────────────────── ┘                  │
└───────────────┘                       │ 2. 創(chuàng)建事務(wù)      │
                                        ▼                  │
                                  ┌──────────────┐        │
                                  │ PlatformTransactionManager │
                                  └──────────────┘        │
                                        │                  │
                                        ▼                  │
┌───────────────┐    5. 提交/回滾       ┌──────────────────┐
│  數(shù)據(jù)庫事務(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扣錢，向toId加錢
     * @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)出賬戶不存在或余額不足");
                }
                // 2. 增加轉(zhuǎn)入方余額（模擬異常：若toId不存在，會拋異常觸發(fā)回滾）
                int rows2 = accountMapper.increaseBalance(toId, amount);
                if (rows2 == 0) {
                    throw new RuntimeException("轉(zhuǎn)入賬戶不存在");
                }
                // 3. 無異常，返回成功
                return true;
            } catch (Exception e) {
                // 手動標記回滾（可選，拋出RuntimeException會自動回滾）
                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;
    /**
     * 批量插入用戶，確保要么全部成功，要么全部失敗
     */
    public void batchInsertUser(List<User> userList) {
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus status) {
                try {
                    for (User user : userList) {
                        // 模擬部分插入失?。ㄈ缬脩羰謾C號重復）
                        if (StringUtils.isEmpty(user.getPhone())) {
                            throw new RuntimeException("用戶手機號不能為空");
                        }
                        userMapper.insert(user);
                    }
                } catch (Exception e) {
                    status.setRollbackOnly();
                    log.error("批量插入用戶失敗", e);
                    throw new BusinessException("批量插入失敗，請檢查數(shù)據(jù)");
                }
            }
        });
    }
}

/**
 * 查詢所有用戶（只讀事務(wù)，優(yōu)化性能）
 */
public List<User> queryAllUser() {
    // 1. 定義臨時事務(wù)屬性（覆蓋默認配置）
    TransactionDefinition readOnlyDef = new DefaultTransactionDefinition() {
        @Override
        public int getPropagationBehavior() {
            return TransactionDefinition.PROPAGATION_SUPPORTS; // 支持事務(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; // 超時時間10秒
        }
    };
    // 2. 傳入動態(tài)事務(wù)屬性執(zhí)行
    return transactionTemplate.execute(readOnlyDef, status -> {
        return userMapper.selectList(null);
    });
}

@Configuration
public class MultiDataSourceTxConfig {
    // 主庫數(shù)據(jù)源（寫操作）
    @Autowired
    @Qualifier("masterDataSource")
    private DataSource masterDataSource;
    // 從庫數(shù)據(jù)源（讀操作）
    @Autowired
    @Qualifier("slaveDataSource")
    private DataSource slaveDataSource;
    // 主庫事務(wù)管理器
    @Bean("masterTxManager")
    public PlatformTransactionManager masterTxManager() {
        return new DataSourceTransactionManager(masterDataSource);
    }
    // 從庫事務(wù)管理器
    @Bean("slaveTxManager")
    public PlatformTransactionManager slaveTxManager() {
        return new DataSourceTransactionManager(slaveDataSource);
    }
    // 主庫TransactionTemplate（寫操作）
    @Bean("masterTxTemplate")
    public TransactionTemplate masterTxTemplate(@Qualifier("masterTxManager") PlatformTransactionManager txManager) {
        TransactionTemplate template = new TransactionTemplate(txManager);
        template.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
        return template;
    }
    // 從庫TransactionTemplate（讀操作，默認只讀）
    @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 {
    // 主庫模板（寫操作）
    @Autowired
    @Qualifier("masterTxTemplate")
    private TransactionTemplate masterTxTemplate;
    // 從庫模板（讀操作）
    @Autowired
    @Qualifier("slaveTxTemplate")
    private TransactionTemplate slaveTxTemplate;
    // 寫操作（主庫）
    public void saveOrder(Order order) {
        masterTxTemplate.execute(status -> {
            orderMapper.insert(order);
            return null;
        });
    }
    // 讀操作（從庫）
    public Order getOrderById(Long orderId) {
        return slaveTxTemplate.execute(status -> {
            return orderMapper.selectById(orderId);
        });
    }
}