MyBatis拦截器的执行顺序引发的MyBatis源码分析

你猜一下哪个先执行？反正不要按常规来。

<plugins>
    <plugin interceptor="com.Interceptor1"></plugin>
    <plugin interceptor="com.Interceptor2"></plugin>
</plugins>

之前看有的博客分析源码，都没提到这一点。之前我只是用一下而已，这个顺序测试一下其实结论也很容易获得，但是我有一种看源码的屎命感。MyBatis还算人性化提供了拦截器，iBatis里面就没有了，不过也可以实现。这里要探究拦截器的源码就不得不提到MyBatis的源码，也就是执行流程了。这要是摊开说就有点大了，为了写好这篇，我决定今天晚上回去不打dota了，贡献真实够大的了。

MyBatis的作用

名义上来说MyBatis是一个半ORM框架，用了一个半字是因为MyBatis并没有完全起到一个ORM框架的作用（比如Hibernate），还有一半工作是需要我们参与进来——编写SQL语句。MyBatis替我们干的活是啥？帮我们把参数和配置化SQL语句映射成数据库中真正执行的SQL，然后把结果帮我们封装好，并返回回来。好处很容已说明，配置灵活，增强开发人员对SQL语句的控制，减少了冗余的对象封装工作。

官方的说法如下：

MyBatis 是一款优秀的持久层框架，它支持定制化 SQL、存储过程以及高级映射。MyBatis 避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集。MyBatis 可以使用简单的 XML 或注解来配置和映射原生信息，将接口和 Java 的 POJOs(Plain Old Java Objects,普通的 Java对象)映射成数据库中的记录。

MyBatis的架构

沿着上面说到的，我们接下来可以看一下MyBatis用了什么架构来完成上面的工作。要注意，talk is cheap，实际上的话还要牵涉很多工作（比如Session，事务等）。在网上看了一些描述MyBatis架构的图，看来一晚上不打dota是不可能了呀。

功能上的架构：

源码中的结构：

架构看上去并不复杂，按三层来分的。之前看的很少，如果你是和我一样的小白话可以一起来看下，从头看起吧，接口和配置文件先开始。

最简单的方式开始MyBatis

这里最简单的意思是，我们先抛开Spring，只在一个简单的Maven项目中使用MyBatis，看看它是如何运行的。先起一个简单的Maven项目并加上MyBatis的依赖。

已经做好了但是，额，写起来估计可以新开一篇了。

单独使用MyBatis代码

其实核心代码只有两个，第一个是SessionUtils用于提供Session，第二个是使用Session进行CRUD操作的代码

public class SessionUtils {
    private static SqlSessionFactory sessionFactory;
    static {
        try {
            // 使用MyBatis提供的Resources类加载mybatis的配置文件
            Reader reader = Resources.getResourceAsReader("mybatis-config.xml");
            // 构建sqlSession的工厂
            sessionFactory = new SqlSessionFactoryBuilder().build(reader);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 获取SqlSession
     * @return SqlSession
     */
    public static SqlSession getSession() {
        return sessionFactory.openSession();
    }
}

 

 

@Test
public void testInsert() {
    SqlSession session = null;
    try {
        session = SessionUtils.getSession();
        StudentMapper studentMapper = session.getMapper(StudentMapper.class);
        Long affectedLines = studentMapper.insert(build());
        System.out.println("affectedLines = " + (affectedLines == null ? 0 : affectedLines));
        session.commit();
    } catch (Exception e) {
        e.printStackTrace();
        if(session != null) {
            session.rollback();
        }
    } finally {
        if(session != null) {
            session.close();
        }
    }
}

SqlSessionFactory的生成

观察这两段代码引出了两个核心的类：SqlSessionFactory和Session。

SqlSessionFactoryBuilder：单纯的就是为了创建SqlSessionFactory，功能很单一。

// 这是一个普类, 而不是接口, 这里把方法都隐去了
public class SqlSessionFactoryBuilder {
  public SqlSessionFactory build(Reader reader);
  public SqlSessionFactory build(Reader reader, String environment);
  public SqlSessionFactory build(Reader reader, Properties properties);
  public SqlSessionFactory build(Reader reader, String environment, Properties properties);
  public SqlSessionFactory build(InputStream inputStream);
  public SqlSessionFactory build(InputStream inputStream, String environment);
  public SqlSessionFactory build(InputStream inputStream, Properties properties);
  public SqlSessionFactory build(InputStream inputStream, String environment, Properties properties);
  public SqlSessionFactory build(Configuration config);
}

 通过阅读源码发现生成SqlSessionFactory的简要步骤如下：

通过Reader，XMLConfigBuilder，Configuration和DefaultSqlSessionFactory共同协作把SqlSessionFactory弄出来了。如果正式一点，用时序图画出来就是这样的：

 

承载MySql所有的配置Configuration类

下面重点关注的类是Configuration。在org.apache.ibatis.builder.xml.XMLConfigBuilder#parseConfiguration中解析Configuration的代码如下，看完之后你就会觉得很亲切：

private void parseConfiguration(XNode root) {
  try {
    //issue #117 read properties first
    propertiesElement(root.evalNode("properties"));
    Properties settings = settingsAsProperties(root.evalNode("settings"));
    loadCustomVfs(settings);
    typeAliasesElement(root.evalNode("typeAliases"));
    pluginElement(root.evalNode("plugins"));
    objectFactoryElement(root.evalNode("objectFactory"));
    objectWrapperFactoryElement(root.evalNode("objectWrapperFactory"));
    reflectorFactoryElement(root.evalNode("reflectorFactory"));
    settingsElement(settings);
    // read it after objectFactory and objectWrapperFactory issue #631
    environmentsElement(root.evalNode("environments"));
    databaseIdProviderElement(root.evalNode("databaseIdProvider"));
    typeHandlerElement(root.evalNode("typeHandlers"));
    mapperElement(root.evalNode("mappers"));
  } catch (Exception e) {
    throw new BuilderException("Error parsing SQL Mapper Configuration. Cause: " + e, e);
  }
}

 话说Java的这个着色也太稀烂了。typeAliases，typeHandlers和mappers是不是很熟悉。然后Configuration的类图是：

再返回Configuration的时候，mybatis-config.xml中的各个元素都已经解析出来了：

 

Environment：数据源和事务管理器

Environment就是配置数据源的地方，在mybatis-config.xml中是这样的：

<!-- 配置mybatis运行环境 -->
<environments default="development">
    <environment id="development">
        <!-- type="JDBC" 代表使用JDBC的提交和回滚来管理事务 -->
        <transactionManager type="JDBC" />
        <!-- mybatis提供了3种数据源类型，分别是：POOLED,UNPOOLED,JNDI -->
        <!-- POOLED 表示支持JDBC数据源连接池 -->
        <!-- UNPOOLED 表示不支持数据源连接池 -->
        <!-- JNDI 表示支持外部数据源连接池 -->
        <dataSource type="POOLED">
            <property name="driver" value="${jdbc.driver}" />
            <property name="url" value="${jdbc.url}" />
            <property name="username" value="${jdbc.username}" />
            <property name="password" value="${jdbc.password}" />
        </dataSource>
    </environment>
</environments>

 

private void environmentsElement(XNode context) throws Exception {
  if (context != null) {
    if (environment == null) {
      environment = context.getStringAttribute("default");
    }
    for (XNode child : context.getChildren()) {
      String id = child.getStringAttribute("id");
      if (isSpecifiedEnvironment(id)) {
        TransactionFactory txFactory = transactionManagerElement(child.evalNode("transactionManager"));
        DataSourceFactory dsFactory = dataSourceElement(child.evalNode("dataSource"));
        DataSource dataSource = dsFactory.getDataSource();
        Environment.Builder environmentBuilder = new Environment.Builder(id)
            .transactionFactory(txFactory)
            .dataSource(dataSource);
        configuration.setEnvironment(environmentBuilder.build());
      }
    }
  }
}