Mybatis源码(3) - Executor执行过程 | 一级缓存 | 二级缓存

0. 前言：

• Mybatis源码(1) - SpringBoot整合Mybatis的核心原理  | Mybatis源码(2) - SqlSessionTemplate的介绍及创建过程
• 之前的文章介绍之后，我们知道SQL语句最终通过DefaultSqlSession的执行器Executor进行操作，默认是CachingExecutor

• 接下来看看如何进行JDBC数据库操作的

1. CachingExecutor#query：

1.1. BoundSql：

• 自动配置的时候会将Mapper.xml的映射文件的语句解析成BoundSql封装到MappedStatement里
• BoundSql里的SQL是已经占位符替换了的，并且记录由参数映射关系以及入参值

1.2. CacheKey：

• 作为一级缓存的key，主要包含MappedStatementId，分页Offset，分页Limit，boundSql语句，sql语句参数值

1.3. 二级缓存：

• 如果在Mapper.xml中配置了，也就是配置二级缓存，那么会先查二级缓存，再查一级缓存
• 二级缓存是namespace级别，也就是Mapper级别的，默认是不开启的，也很少会用到二级缓存，就不多赘述

1.4. 一级缓存：

• CachingExecutor是装饰了Executor，默认Executor的实现是BaseExecutor，针对不同场景又有三种子类，默认SimpleExecutor

• BaseExecutor持有真正储存的一级缓存LocalCache（基于PerpetualCache的HasMap<CacheKey,结果List>）

• 没有命中一级缓存则取去查询数据库，调用子类SimpleExecutor的doQuery实现方法

2. JDBC过程执行：

• SimpleExecutor的doQuery方法，就会进行JDBC的相关操作
• 如建立Connection，创建Statement语句，然后执行，处理结果等

public <E> List<E> doQuery(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) throws SQLException {Statement stmt = null;try {// 获取配置对象Configuration configuration = ms.getConfiguration();// 创建StatementHandler对象，实际返回的是RoutingStatementHandler对象StatementHandler handler = configuration.newStatementHandler(wrapper, ms, parameter, rowBounds, resultHandler, boundSql);// 完成Statement的创建和初始化stmt = prepareStatement(handler, ms.getStatementLog());// 调用query方法执行sql语句，并通过ResultSetHandler完成结果集的映射return handler.query(stmt, resultHandler);} finally {// 关闭Statement对象closeStatement(stmt);}
}public <E> List<E> query(Statement statement, ResultHandler resultHandler) throws SQLException {PreparedStatement ps = (PreparedStatement) statement;//执行SQLps.execute();//处理返回结果return resultSetHandler.handleResultSets(ps);}

3. 结果集处理：

• 根据ResultMap的类型找到对应的类型处理handler，然后根据返回结果类型调用 constructor.newInstance()创建结果对象
• 然后解析属性名，利用反射不同字段对应的value设置到Java对象中

public List<Object> handleResultSets(Statement stmt) throws SQLException {ErrorContext.instance().activity("handling results").object(mappedStatement.getId());// 该集合用于保存映射结果得到的结果对象final List<Object> multipleResults = new ArrayList<>();int resultSetCount = 0;// 获取第一个ResultSet对象ResultSetWrapper rsw = getFirstResultSet(stmt);// 获取MappedStatement.resultMaps集合List<ResultMap> resultMaps = mappedStatement.getResultMaps();int resultMapCount = resultMaps.size();// 如果集合集不为空，则resultMaps集合不能为空，否则抛出异常validateResultMapsCount(rsw, resultMapCount);// 遍历resultMaps集合while (rsw != null && resultMapCount > resultSetCount) {// 获取该结果集对应的ResultMap对象ResultMap resultMap = resultMaps.get(resultSetCount);// 根据ResultMap中定义的映射规则对ResultSet进行映射，并将映射的结果对象添加到multipleResult集合中保存handleResultSet(rsw, resultMap, multipleResults, null);// 获取下一个结果集rsw = getNextResultSet(stmt);// 清空nestedResultObjects集合cleanUpAfterHandlingResultSet();// 递增resultSetCountresultSetCount++;}// 获取MappedStatement.resultSets属性，该属性对多结果集的情况使用，该属性将列出语句执行后返回的结果集，并给每个结果集一个名称，名称是逗号分隔的，String[] resultSets = mappedStatement.getResultSets();if (resultSets != null) {while (rsw != null && resultSetCount < resultSets.length) {// 根据resultSet的名称，获取未处理的ResultMappingResultMapping parentMapping = nextResultMaps.get(resultSets[resultSetCount]);if (parentMapping != null) {String nestedResultMapId = parentMapping.getNestedResultMapId();ResultMap resultMap = configuration.getResultMap(nestedResultMapId);// 根据ResultMap对象映射结果集handleResultSet(rsw, resultMap, null, parentMapping);}// 获取下一个结果集rsw = getNextResultSet(stmt);// 清空nestedResultObjects集合cleanUpAfterHandlingResultSet();// 递增resultSetCountresultSetCount++;}}return collapseSingleResultList(multipleResults);
}

4. Mybatis的一级缓存、二级缓存区别：

• 一二级缓存都是基于PerpetualCache的 HashMap 本地缓存，一级缓存是SqlSession级别的，二级缓存是Mapper(Namespace)级别
• 默认关闭二级缓存的，但是查询的时候会先查有没有开启二级缓存，有的话先查二级缓存再查一级缓存

• 主要实现是SqlSession持有Executor，Executor的实现BaseExecutor，持有一级缓存LocalCache
• 然后有个CachingExecutor会装饰Executor，也就是装饰一级缓存，查询时如果开启二级缓存，CachingExecutor会通过tcm去二级缓存查询，之后再查一级缓存