Mybatis源码(3) - Executor执行过程 | 一级缓存 | 二级缓存
迪丽瓦拉
2024-05-26 01:12:19
0

      • 0. 前言:
      • 1. CachingExecutor#query:
        • 1.1. BoundSql:
        • 1.2. CacheKey:
        • 1.3. 二级缓存:
        • 1.4. 一级缓存:
      • 2. JDBC过程执行:
      • 3. 结果集处理:
      • 4. Mybatis的一级缓存、二级缓存区别:

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

在这里插入图片描述

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

在这里插入图片描述

2. JDBC过程执行:

  • SimpleExecutor的doQuery方法,就会进行JDBC的相关操作
  • 如建立Connection,创建Statement语句,然后执行,处理结果等
public  List 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  List 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 handleResultSets(Statement stmt) throws SQLException {ErrorContext.instance().activity("handling results").object(mappedStatement.getId());// 该集合用于保存映射结果得到的结果对象final List multipleResults = new ArrayList<>();int resultSetCount = 0;// 获取第一个ResultSet对象ResultSetWrapper rsw = getFirstResultSet(stmt);// 获取MappedStatement.resultMaps集合List 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去二级缓存查询,之后再查一级缓存

相关内容