mybatis源码解读：transaction包（事务管理功能）

ゝ一世哀愁。 2022-12-29 06:21 167阅读 0赞

欢迎关注本人公众号：

![20201220181855568.png][]

mybatis的transaction包是负责进行事务管理的包，该包内包含2个子包：jdbc子包中包含基于jdbc进行事务管理的类，managed子包中包含基于容器进行事务管理的类。

1.事务概述

事务即数据库事务，是数据库执行过程中的一个逻辑单元。事务有以下4个特性：

Atomicity（原子性）：事务必须被作为一个整体执行，要么全部执行， 要么全部不执行。不允许只执行其中的一部分。

Consistency(一致性）：事务应该保证数据库从一致性状态转换到另一个一致性状态。一致性状态是指数据库中数据的完整性约束。

Isolation（隔离性）：多个事务并发执行时， 事务不会互相干扰。

Durability(持久性）：一旦事务提交，则其所做的修改就会永久保存到数据库中。

2.事务接口及工厂

整个transaction包采用了工厂方法模式实现，TransactionFactory是所有事务工厂的接口。

public interface TransactionFactory {
         /**   * 配置工厂的属性   * @param props 工厂的属性   */  default void setProperties(Properties props) {
           // NOP  }    /**   * 从给定的连接中获取一个事务   * @param conn 给定的连接   * @return 获取的事务对象   */  Transaction newTransaction(Connection conn);  /**   * 从给定的数据源中获取事务，并对事务进行一些配置   * @param dataSource 数据源   * @param level 数据隔离级别   * @param autoCommit 是否自动提交事务   * @return 获取的事务对象   */  Transaction newTransaction(DataSource dataSource, TransactionIsolationLevel level, boolean autoCommit);}

Transaction是所有事务的接口。

public interface Transaction {
         /**   * 获取该事务对应的数据库连接   * @return 数据库连接   * @throws SQLException   */  Connection getConnection() throws SQLException;    /**   * 提交事务   * @throws SQLException   */  void commit() throws SQLException;    /**   * 回滚事务   * @throws SQLException   */  void rollback() throws SQLException;   /**   * 关闭对应的数据连接   * @throws SQLException   */  void close() throws SQLException;  /**   * 读取设置的事务超时时间   * @return 事务超时时间   * @throws SQLException   */  Integer getTimeout() throws SQLException;}

TransactionFactory接口与Transaction接口都有2套实现，分别在jdbc包和managed包中。

3.jdbc事务

jdbc包中存放的是实现jdbc事务的JdbcTransaction类及其对应的工厂类，

JdbcTransaction类是jdbc事务的管理类，具体的事务操作是由JdbcTransaction类直接调用Connection类提供的事务方法来完成的。

public class JdbcTransaction implements Transaction {
         private static final Log log = LogFactory.getLog(JdbcTransaction.class);  // 数据库连接  protected Connection connection;  // 数据源  protected DataSource dataSource;  // 事务隔离级别  protected TransactionIsolationLevel level;  // 是否自动提交事务  protected boolean autoCommit;  public JdbcTransaction(DataSource ds, TransactionIsolationLevel desiredLevel, boolean desiredAutoCommit) {
           dataSource = ds;    level = desiredLevel;    autoCommit = desiredAutoCommit;  }   /**   * 提交事务   * @throws SQLException   */  @Override  public void commit() throws SQLException {
           // 连接存在且不会自动提交事务    if (connection != null && !connection.getAutoCommit()) {
             if (log.isDebugEnabled()) {
               log.debug("Committing JDBC Connection [" + connection + "]");      }      // 调用connection对象的方法提交事务      connection.commit();    }  }  /**   * 回滚事务   * @throws SQLException   */  @Override  public void rollback() throws SQLException {
           if (connection != null && !connection.getAutoCommit()) {
             if (log.isDebugEnabled()) {
               log.debug("Rolling back JDBC Connection [" + connection + "]");      }      connection.rollback();    }  }  }

JdbcTransactionFactory类负责生产JdbcTransaction对象。

public class JdbcTransactionFactory implements TransactionFactory {
         @Override  public Transaction newTransaction(Connection conn) {
           return new JdbcTransaction(conn);  }  @Override  public Transaction newTransaction(DataSource ds, TransactionIsolationLevel level, boolean autoCommit) {
           return new JdbcTransaction(ds, level, autoCommit);  }}

4.容器事务

managed包中存放的是实现容器事务的ManagedTransaction类及其对应的工厂类。

在ManagedTransaction类中可以看到commit,rollback等方法内都没有任何逻辑操作，这是因为相关的事务操作都委托给了容器进行管理。

public class ManagedTransaction implements Transaction {
         private static final Log log = LogFactory.getLog(ManagedTransaction.class);  // 数据源  private DataSource dataSource;  // 事务隔离级别  private TransactionIsolationLevel level;  // 数据库连接  private Connection connection;  // 是否关闭数据库连接  private final boolean closeConnection;    /**   * 提交事务   * @throws SQLException   */  @Override  public void commit() throws SQLException {
           // Does nothing  }  /**   * 回滚事务   * @throws SQLException   */  @Override  public void rollback() throws SQLException {
           // Does nothing  }  }

比如mybatis和spring集成时，mybatis中拿到的数据库连接对象是spring提供的。spring可以通过xml配置，注解等多种方式来管理事务（即决定事务何时开始，提交，回滚）。当然，这种情况下，事务的最终实现也是由Connection对象的相关方法实现的。整个过程中，mybatis不需要处理任何事务操作，全都委托给spring即可。

[20201220181855568.png]: /images/20221120/f369fb8252fc4a7b98d741d2295842b7.png