Spring源码解析之编程式事务

什么是编程式事务

编程式事务是通过编写代码来实现事务控制。在编程式事务中，开发者不仅仅需要实现业务逻辑，还需要手动管理事务的开始、提交或回滚。这种方式相对于声明式事务来说，显得更加灵活，但也需要开发者编写更多的代码。

Spring中的编程式事务

Spring框架提供了TransactionTemplate接口和PlatformTransactionManager接口来实现编程式事务。

TransactionTemplate接口包含以下常用方法：

• execute(TransactionCallback<T> action)：执行事务的核心方法，在此方法中，需要传入一个TransactionCallback对象，调用其中的doInTransaction(TransactionStatus status)方法，从而实现事务控制。
• execute(TransactionDefinition definition,TransactionCallback<T> action)：重载版本的execute方法，可以通过TransactionDefinition参数来控制事务的隔离级别、超时时间等参数。

PlatformTransactionManager接口是Spring事务管理器的核心接口。它定义了如下方法：

• getTransaction(TransactionDefinition definition)：根据给定的事务定义，返回一个新的或激活的事务。
• commit(TransactionStatus status)：提交事务。
• rollback(TransactionStatus status)：回滚事务。

在实际应用过程中，我们需要使用一个具体的PlatformTransactionManager实现，例如DataSourceTransactionManager。

示例一：插入数据

接下来，我们来看一个使用编程式事务的示例。假设我们需要向数据库中插入一条新纪录。并且需要采用编程式事务来保证数据插入的原子性。假设我们有一个名为UserDao的类用于访问数据库，代码如下所示：

public class UserDao {
    private JdbcTemplate jdbcTemplate;
    private DataSourceTransactionManager transactionManager;

    public UserDao(JdbcTemplate jdbcTemplate, DataSourceTransactionManager transactionManager) {
        this.jdbcTemplate = jdbcTemplate;
        this.transactionManager = transactionManager;
    }

    public void addUser(User user) {
        TransactionTemplate transactionTemplate = new TransactionTemplate(transactionManager);
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
                jdbcTemplate.update("insert into user(name,age) values(?,?)",user.getName(),user.getAge());
            }
        });
    }
}

在上面的代码示例中，addUser方法的实现过程中，我们使用TransactionTemplate来控制事务的开始、提交或回滚，从而保证在插入数据时，能够保证数据的一致性。

示例二：转帐操作

接下来，我们再看一个稍微复杂一点的例子，假设我们需要实现一个转账的功能，并且需要采用编程式事务来保证转账的原子性。假设我们有一个名为AccountDao的类用于访问数据库，代码如下所示：

public class AccountDao {
    private JdbcTemplate jdbcTemplate;
    private DataSourceTransactionManager transactionManager;

    public AccountDao(JdbcTemplate jdbcTemplate, DataSourceTransactionManager transactionManager) {
        this.jdbcTemplate = jdbcTemplate;
        this.transactionManager = transactionManager;
    }

    public void transfer(int fromUserId,int toUserId,double money) {
        TransactionTemplate transactionTemplate = new TransactionTemplate(transactionManager);
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
                jdbcTemplate.update("update account set balance = balance - ? where user_id = ?",money,fromUserId);
                jdbcTemplate.update("update account set balance = balance + ? where user_id = ?",money,toUserId);
            }
        });
    }
}

在上面的代码示例中，我们使用了两个update语句来模拟转账操作，通过TransactionTemplate和TransactionStatus两个对象来控制事务的开始、提交或回滚，从而保证了转账操作的原子性。