@Service
public class UserService {
    // 非public方法，事務(wù)注解失效
    @Transactional
    void updateUser(Long id) { 
        userMapper.updateStatus(id, 1);
    }
}

@Service
public class UserService {
    // 修改為public方法，事務(wù)生效
    @Transactional
    public void updateUser(Long id) { 
        userMapper.updateStatus(id, 1);
    }
}

@Service
public class OrderService {
    @Transactional
    public void createOrder(Order order) {
        try {
            orderMapper.insert(order);
            // 模擬異常
            int i = 1 / 0;
        } catch (Exception e) {
            // 捕獲異常但未拋出，事務(wù)不會(huì)回滾
            log.error("創(chuàng)建訂單失敗", e);
        }
    }
}

@Service
public class OrderService {
    @Transactional
    public void createOrder(Order order) {
        try {
            orderMapper.insert(order);
            // 模擬異常
            int i = 1 / 0;
        } catch (Exception e) {
            log.error("創(chuàng)建訂單失敗", e);
            // 重新拋出異常，觸發(fā)事務(wù)回滾
            throw new RuntimeException("創(chuàng)建訂單失敗", e);
        }
    }
}

@Service
public class OrderService {
    @Transactional
    public void createOrder(Order order) {
        try {
            orderMapper.insert(order);
            // 模擬異常
            int i = 1 / 0;
        } catch (Exception e) {
            log.error("創(chuàng)建訂單失敗", e);
            // 手動(dòng)觸發(fā)事務(wù)回滾
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
        }
    }
}

@Service
public class FileService {
    // 未指定rollbackFor，受檢查異常不會(huì)觸發(fā)回滾
    @Transactional
    public void importData(String filePath) throws IOException {
        // 讀取文件（可能拋出IOException）
        FileReader reader = new FileReader(filePath);
        // 數(shù)據(jù)入庫(kù)操作
        dataMapper.batchInsert(parseData(reader));
    }
}

@Service
public class FileService {
    // 顯式指定rollbackFor包含IOException
    @Transactional(rollbackFor = {IOException.class, RuntimeException.class})
    public void importData(String filePath) throws IOException {
        FileReader reader = new FileReader(filePath);
        dataMapper.batchInsert(parseData(reader));
    }
}

// 更通用的方式：捕獲所有Exception
@Service
public class FileService {
    @Transactional(rollbackFor = Exception.class)
    public void importData(String filePath) throws IOException {
        // 業(yè)務(wù)邏輯不變
    }
}

@Service
public class OrderService {
    @Autowired
    private PaymentService paymentService;
    
    @Transactional
    public void createOrder(Order order) {
        orderMapper.insert(order);
        // 調(diào)用支付服務(wù)（非事務(wù)方式執(zhí)行）
        paymentService.processPayment(order.getId(), order.getAmount());
    }
}

@Service
public class PaymentService {
    // 配置為非事務(wù)方式執(zhí)行
    @Transactional(propagation = Propagation.NOT_SUPPORTED)
    public void processPayment(Long orderId, BigDecimal amount) {
        paymentMapper.insert(new Payment(orderId, amount));
        // 若此處發(fā)生異常，不會(huì)回滾
    }
}

@Service
public class PaymentService {
    // 使用默認(rèn)傳播機(jī)制REQUIRED
    @Transactional
    public void processPayment(Long orderId, BigDecimal amount) {
        paymentMapper.insert(new Payment(orderId, amount));
    }
}

@Service
public class UserService {
    // 方法A（無(wú)事務(wù)）調(diào)用方法B（有事務(wù)）
    public void updateUserInfo(Long id, String name, Integer age) {
        updateUserName(id, name);  // 內(nèi)部調(diào)用，事務(wù)失效
        updateUserAge(id, age);    // 內(nèi)部調(diào)用，事務(wù)失效
    }
    
    @Transactional
    public void updateUserName(Long id, String name) {
        userMapper.updateName(id, name);
    }
    
    @Transactional
    public void updateUserAge(Long id, Integer age) {
        userMapper.updateAge(id, age);
    }
}

// 1. 首先在啟動(dòng)類開(kāi)啟暴露代理
@SpringBootApplication
@EnableAspectJAutoProxy(exposeProxy = true)  // 關(guān)鍵配置
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

// 2. 在Service中通過(guò)代理對(duì)象調(diào)用
@Service
public class UserService {
    public void updateUserInfo(Long id, String name, Integer age) {
        // 通過(guò)AopContext獲取代理對(duì)象
        UserService proxy = (UserService) AopContext.currentProxy();
        proxy.updateUserName(id, name);  // 代理對(duì)象調(diào)用，事務(wù)生效
        proxy.updateUserAge(id, age);    // 代理對(duì)象調(diào)用，事務(wù)生效
    }
    
    @Transactional
    public void updateUserName(Long id, String name) {
        userMapper.updateName(id, name);
    }
    
    @Transactional
    public void updateUserAge(Long id, Integer age) {
        userMapper.updateAge(id, age);
    }
}

-- 使用MyISAM引擎創(chuàng)建表，不支持事務(wù)
CREATE TABLE `user` (
  `id` bigint NOT NULL AUTO_INCREMENT,
  `name` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8mb4;

-- 使用InnoDB引擎創(chuàng)建表，支持事務(wù)
CREATE TABLE `user` (
  `id` bigint NOT NULL AUTO_INCREMENT,
  `name` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

// 未加@Service注解，未被Spring管理
public class ProductService {
    @Autowired
    private ProductMapper productMapper;
    
    @Transactional
    public void updateStock(Long productId, Integer quantity) {
        productMapper.decreaseStock(productId, quantity);
    }
}

// 添加@Service注解，被Spring容器管理
@Service
public class ProductService {
    @Autowired
    private ProductMapper productMapper;
    
    @Transactional
    public void updateStock(Long productId, Integer quantity) {
        productMapper.decreaseStock(productId, quantity);
    }
}

@Service
public class BatchService {
    @Autowired
    private UserMapper userMapper;
    @Autowired
    private LogMapper logMapper;
    
    @Transactional
    public void batchProcess(List<Long> userIds) {
        // 主線程操作
        userMapper.batchUpdateStatus(userIds, 1);
        
        // 新線程執(zhí)行日志記錄（不在當(dāng)前事務(wù)中）
        new Thread(() -> {
            logMapper.insert(new Log("批量處理用戶: " + userIds));
        }).start();
    }
}

@Service
public class BatchService {
    @Autowired
    private UserMapper userMapper;
    @Autowired
    private LogMapper logMapper;
    
    @Transactional
    public void batchProcess(List<Long> userIds) {
        // 主線程操作
        userMapper.batchUpdateStatus(userIds, 1);
        
        // 同一事務(wù)中執(zhí)行日志記錄
        logMapper.insert(new Log("批量處理用戶: " + userIds));
    }
}