Mybatis3详解（十七）——Mybatis运行原理之SqlSession的构建过程

1、SqlSession的构建过程

在上一章，详细的介绍了SqlSessionFactory的构建过程，它是用来获取SqlSession对象的，所以本章节就主要讲述SqlSession的构建过程。

程序代码的入口:

我们知道SqlSession对象是通过SqlSessionFactory的openSession()方法获取的，所以我们先来看一下SqlSessionFactory接口中的方法：

可以发现SqlSessionFactory接口提供一系列重载的openSession方法，其参数如下(这些参数的意义会在后面介绍)：

boolean autoCommit：是否开启JDBC事务的自动提交，默认为false。
Connection：提供连接。
TransactionIsolationLevel：定义事务隔离级别。
ExecutorType：定义执行器类型。

SqlSessionFactory接口的实现类为DefaultSqlSessionFactory类。所以我们去DefaultSqlSessionFactory实现类中查看重写的openSession()方法：

   //以无参的openSession()方法为例
   public SqlSession openSession() {
    return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);
  }

通过查看其它重写的方法，会发现最终都调用了openSessionFromDataSource方法，所以继续进入方法：

  private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {
    Transaction tx = null;
    try {
	  // 获取Configration全局配置中的environment的配置
      final Environment environment = configuration.getEnvironment();
	  // 通过environment配置构建transactionFactory对象
      final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);
	  // 从工厂中获取一个事务实例
      tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);
	  // 通过configuration构建Executor执行器对象
      final Executor executor = configuration.newExecutor(tx, execType);
	  // 返回SqlSession的默认实现类DefaultSqlSession
      return new DefaultSqlSession(configuration, executor, autoCommit);
    } catch (Exception e) {
      closeTransaction(tx); // may have fetched a connection so lets call close()
      throw ExceptionFactory.wrapException("Error opening session.  Cause: " + e, e);
    } finally {
      ErrorContext.instance().reset();
    }
  }

上面代码中有一行是通过configuration.newExecutor(tx,execType)来构建Executor执行器对象，这一步非常重要，因为MyBatis 中所有的 Mapper 语句的执行都是通过 Executor 来执行的，它负责SQL语句的生成和查询缓存的维护。所以我们看一下它是怎么创建的，这里调用了Configuration类中newExecutor()方法。

   // ====== Configuration 类中的方法 ======
   public Executor newExecutor(Transaction transaction, ExecutorType executorType) {
    executorType = executorType == null ? defaultExecutorType : executorType;
    executorType = executorType == null ? ExecutorType.SIMPLE : executorType;
	// 定义Executor执行器
    Executor executor;
    // 判断执行器的类型，根据传入executorType参数
    // BatchExecutor：批量执行器
    // ReuseExecutor：会执行预处理的执行器
    // SimpleExecutor：简单的执行器
    if (ExecutorType.BATCH == executorType) {
      executor = new BatchExecutor(this, transaction);
    } else if (ExecutorType.REUSE == executorType) {
      executor = new ReuseExecutor(this, transaction);
    } else {
	  // 如果没有配置，默认就为SimpleExecutor
      executor = new SimpleExecutor(this, transaction);
    }
	//如果开启了二级缓存，则使用CachingExecutor 来包装executor，
	//在查询之前都会先查询缓存中是否有对应的数据，包装的过程使用了装饰者模式
    if (cacheEnabled) {
      executor = new CachingExecutor(executor);
    }
	// 最后使用每个拦截器重新包装executor并返回
    executor = (Executor) interceptorChain.pluginAll(executor);
	//返回创建好的Executor执行器
    return executor;
  }

注意(这里了解就好)：executor = (Executor) interceptorChain.pluginAll(executor);这个是Mybatis中的插件，它将构建一层层的代理对象，可以在执行真正的Executor的方法前，执行配置在插件中的方法对核心代码进行修改，所以不要轻易使用插件，这里用的是责任链模式。Mybatis在实例化Executor、ParameterHandler、ResultSetHandler、StatementHandler四大接口对象的时候都是调用interceptorChain.pluginAll() 方法插入进去的。其实就是循环执行拦截器链所有的拦截器的plugin() 方法。

Executor 对象创建完之后会以参数的形式传入DefaultSqlSession的构造方法中，从而完成SqlSession对象的创建并且返回。