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

Posted 2023-03-04 做猪呢，最重要的是开森啦

• • • 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<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;
  //执行SQL
    ps.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();
    // 递增resultSetCount
    resultSetCount++;
  

  // 获取MappedStatement.resultSets属性，该属性对多结果集的情况使用，该属性将列出语句执行后返回的结果集，并给每个结果集一个名称，名称是逗号分隔的，
  String[] resultSets = mappedStatement.getResultSets();
  if (resultSets != null) 
    while (rsw != null && resultSetCount < resultSets.length) 
      // 根据resultSet的名称，获取未处理的ResultMapping
      ResultMapping 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();
      // 递增resultSetCount
      resultSetCount++;
    
  

  return collapseSingleResultList(multipleResults);

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

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

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