Spring Boot 技术问题教程：@Transactional注解与事务管理

引言

事务管理在应用程序开发中非常重要，特别是在处理数据库操作时，能够确保数据的一致性和完整性。Spring Boot 提供了强大的事务管理支持，其中 @Transactional 注解是实现事务管理的关键之一。本文将详细介绍如何在 Spring Boot 中使用 @Transactional 注解进行事务管理，并包含一个详细的案例。

@Transactional 注解简介

@Transactional 注解可以应用于类或方法上，用于声明性的事务管理。当方法被该注解修饰时，Spring 将使用声明式事务管理来自动地管理事务。@Transactional 注解的属性包括：

propagation：事务的传播行为，默认值为 REQUIRED。
isolation：事务的隔离级别，默认值为 DEFAULT。
timeout：事务的超时时间，单位为秒，默认值为 -1（表示无超时限制）。
readOnly：标记事务是否为只读的，默认为 false。
rollbackFor 和 noRollbackFor：定义哪些异常会触发事务回滚，哪些不会。

案例讲解

下面是一个详细的案例，展示了如何在 Spring Boot 中使用 @Transactional 注解进行事务管理。

场景描述

我们假设有一个简单的银行账户转账系统，包含以下两个实体类：Account 和 Transaction。Account 类表示账户，包含账户编号和余额等属性；Transaction 类表示转账记录，包含转账金额、转出账户和转入账户等属性。

代码实现

1. 数据模型

    
// Account.java
@Entity
public class Account {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private String number;
    private Double balance;

    // getter 和 setter 方法...
}

// Transaction.java
@Entity
public class Transaction {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private Double amount;
    @ManyToOne
    @JoinColumn(name = "from_account_id")
    private Account fromAccount;
    @ManyToOne
    @JoinColumn(name = "to_account_id")
    private Account toAccount;

    // getter 和 setter 方法...
}

2. Service 类

    
@Service
public class AccountService {

    @Autowired
    private AccountRepository accountRepository;

    @Autowired
    private TransactionRepository transactionRepository;

    @Transactional
    public void transfer(Long fromAccountId, Long toAccountId, Double amount) {
        Account fromAccount = accountRepository.findById(fromAccountId).orElseThrow(() -> new IllegalArgumentException("转出账户不存在"));
        Account toAccount = accountRepository.findById(toAccountId).orElseThrow(() -> new IllegalArgumentException("转入账户不存在"));

        if (fromAccount.getBalance() < amount) {
            throw new IllegalArgumentException("余额不足");
        }

        fromAccount.setBalance(fromAccount.getBalance() - amount);
        toAccount.setBalance(toAccount.getBalance() + amount);

        Transaction transaction = new Transaction();
        transaction.setAmount(amount);
        transaction.setFromAccount(fromAccount);
        transaction.setToAccount(toAccount);

        accountRepository.save(fromAccount);
        accountRepository.save(toAccount);
        transactionRepository.save(transaction);
    }
}

3. 控制器类

    
@RestController
@RequestMapping("/api/accounts")
public class AccountController {

    @Autowired
    private AccountService accountService;

    @PostMapping("/transfer")
    public ResponseEntity<String> transfer(@RequestParam Long fromAccountId, @RequestParam Long toAccountId, @RequestParam Double amount) {
        try {
            accountService.transfer(fromAccountId, toAccountId, amount);
            return ResponseEntity.ok("转账成功");
        } catch (Exception e) {
            return ResponseEntity.badRequest().body("转账失败: " + e.getMessage());
        }
    }
}