浅析MyBatis执行器原理

文章目录

一、执行器在什么位置
二、执行器生成源码解析
- 2.1、生成默认执行器
三、执行器的结构分析
四、完整查询分析
- 4.1、二级缓存
- 4.2、一级缓存
- 4.3、数据库查询
- 4.4、大致执行结构图
五、手写代码还原基本骨架

本文大部分代码来自MyBatis源码，你可以对照着源码一起看

一、执行器在什么位置

初学MyBatis时，我们都知道MyBatis是拥有一级和二级两种缓存，并且默认开启一级缓存，二级缓存我们只需要在映射文件中手动配置即可。

<!--开启全局缓存，默认是开启的MyBatis-config.xml-->
<setting name="cacheEnabled" value="true"/><!-- XXXmapper.xml-->
<cache/>

补充一张我初学MyBatis时的图：

此处直接略过缓存相关的特性…

这里主要谈一点，就是我们学习MyBatis时常说的：SQL查询的顺序是，先二级缓存找，再一级缓存找，还是没有，最后再去数据库中查找

那么为什么呢？它背后是怎样利用代码完成的呢？

这里就要引入本文的主角——执行器（Executor）。多线程阶段学习时，也有一个执行器，当然我们这里所说的是MyBatis中的执行器。

基本的查询代码：

public class Demo01 {public static void main(String[] args) throws IOException {//1.根据配置文件构建sqlSessionFactoryString resource = "resources/mybatis-config.xml";InputStream inputStream = Resources.getResourceAsStream(resource);SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);//2.通过sqlSessionFactory构建SqlSessionSqlSession sqlSession = sqlSessionFactory.openSession();//3.执行对应的SQLsqlSession.selectOne("org.apache.ibatis.demo.dao.BlogMapper.selectBlog");//4.关闭资源sqlSession.close();}
}

执行器在第二步生成

//2.通过sqlSessionFactory构建SqlSession
SqlSession sqlSession = sqlSessionFactory.openSession();

执行器提供了查询，修改，提交事务，回滚事务，清理一级缓存，FlashStatement接口。
一个执行器对应一个SqlSession，由Configuration创建
它和SQL处理器是一对多的关系

二、执行器生成源码解析

SqlSessionFactory 接口方法

public interface SqlSessionFactory {//默认SqlSession openSession();SqlSession openSession(boolean autoCommit);SqlSession openSession(Connection connection);SqlSession openSession(TransactionIsolationLevel level);//设置指定类型执行器SqlSession openSession(ExecutorType execType);SqlSession openSession(ExecutorType execType, boolean autoCommit);SqlSession openSession(ExecutorType execType, TransactionIsolationLevel level);SqlSession openSession(ExecutorType execType, Connection connection);Configuration getConfiguration();}

这是SqlSessionFactory接口，就执行器部分的讲解，我们可以将接口中的方法分为3类

默认方法
手动设置执行器类型
其他方法

顺便补充执行器的类型：即我们能够设置的执行器的类型参数，是来自下面的枚举类。从这个枚举类可以看出，我们有三种执行器

public enum ExecutorType {//MyBatis有三种执行器，分别是：简单、复用、批量处理。默认使用简单的，来一条处理一条SIMPLE, REUSE, BATCH
}

2.1、生成默认执行器

public class Configuration {...protected ExecutorType defaultExecutorType = ExecutorType.SIMPLE;...public ExecutorType getDefaultExecutorType() {return defaultExecutorType;}
}

使用Configuration类中的默认值，作为我们执行器类型，即简单执行器是我们的默认执行器。

拥有默认参数后的后续操作

如果我们需要生成其他的执行器，传入不同参数即可。

然后把生成的执行器作为参数放入到我们的CachingExecutor中，初始化delegate参数

这里先记牢，delegate这个参数的值是我们生成的真实的执行器，后文还会出现

至此，一个被CachingExecutor包裹着的SimpleExecutor创建完成

三、执行器的结构分析

我们已经看到执行器是如何产生的了，接下来就是本文的重点，执行器之间的关系，以及他们和缓存结构之间的联系。

这里涉及的类或接口共6个，先说结论：

最底层的三个子类，分别是我们的批量执行器、简单执行器、复用执行器
BaseExecutor中包含一级缓存的查询，不包含真实的数据库中的查询
CachingExecutor中包含二级缓存，通过delegate变量延展
每个类只完成一件事情

我们都知道，想要查询数据，我们可以直接去数据库中查询，但是总是进行磁盘IO十分影响效率，所以引出缓存查询。由于不同执行器去缓存中查询特性相同，我们就可以把这部分代码抽取出来，放到BaseExecutor抽象父类中。时间久了由于缓存的局限性，我们又引入了一个级别的缓存，并且称它为——二级缓存。MyBatis的开发者使用一个装饰者模式，让两者衔接起来。

我有想过为什么一定要这样写呢？写一个父类，不也可以？

四、完整查询分析

第二步已经生成了对应的执行器，现在我们需要开始执行对应的SQL查询

// 3.执行对应的SQ
sqlSession.selectList("org.apache.ibatis.demo.dao.BlogMapper.selectBlog");

我们调用的selectList方法，他们根据我们传入的参数的多少，不断完善默认值，最终执行query方法。

4.1、二级缓存

我们会发现，这个query方法是有两个实现类。

根据执行器生成的过程我们可以明确，此时我们会进入CachingExecutor，因为我们的执行器是一个被CachingExecutor包裹着的SimpleExecutor

前文让你牢记的delegate变量，这里出现了。她是在创建基本的执行器成功时，将自己作为参数放入到CachingExecutor中完成赋值的。即默认情况下，这里的delegate就是new SimpleExecutor()。

4.2、一级缓存

第二节分析执行器结构时，说到基本的执行器都有一个公共的父类BaseExecutor，所以我们这里虽然调用的简单执行器，但是会先经过父类的查询方法，自然父类中就可以完成我们的一级缓存的查询。

4.3、数据库查询

自此，我们两重缓存的执行流程已经都走完了，接下来就是去简单执行器中查询对应的SQL。当然如果我们在前面的任何一级缓存中能查询到对应的数据，那么此次查询就会提前返回

4.4、大致执行结构图

五、手写代码还原基本骨架

手写一个测试类，完成上述查询的基本功能，具体代码如下：