- 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
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 handler = configuration.newStatementHandler(wrapper, ms, parameter, rowBounds, resultHandler, boundSql);
stmt = prepareStatement(handler, ms.getStatementLog());
return handler.query(stmt, resultHandler);
} finally {
closeStatement(stmt);
}
}
public <E> List<E> query(Statement statement, ResultHandler resultHandler) throws SQLException {
PreparedStatement ps = (PreparedStatement) statement;
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;
ResultSetWrapper rsw = getFirstResultSet(stmt);
List<ResultMap> resultMaps = mappedStatement.getResultMaps();
int resultMapCount = resultMaps.size();
validateResultMapsCount(rsw, resultMapCount);
while (rsw != null && resultMapCount > resultSetCount) {
ResultMap resultMap = resultMaps.get(resultSetCount);
handleResultSet(rsw, resultMap, multipleResults, null);
rsw = getNextResultSet(stmt);
cleanUpAfterHandlingResultSet();
resultSetCount++;
}
String[] resultSets = mappedStatement.getResultSets();
if (resultSets != null) {
while (rsw != null && resultSetCount < resultSets.length) {
ResultMapping parentMapping = nextResultMaps.get(resultSets[resultSetCount]);
if (parentMapping != null) {
String nestedResultMapId = parentMapping.getNestedResultMapId();
ResultMap resultMap = configuration.getResultMap(nestedResultMapId);
handleResultSet(rsw, resultMap, null, parentMapping);
}
rsw = getNextResultSet(stmt);
cleanUpAfterHandlingResultSet();
resultSetCount++;
}
}
return collapseSingleResultList(multipleResults);
}
4. Mybatis的一级缓存、二级缓存区别:
- 一二级缓存都是基于PerpetualCache的 HashMap 本地缓存,一级缓存是SqlSession级别的,二级缓存是Mapper(Namespace)级别
- 默认关闭二级缓存的,但是查询的时候会先查有没有开启二级缓存,有的话先查二级缓存再查一级缓存
- 主要实现是SqlSession持有Executor,Executor的实现BaseExecutor,持有一级缓存LocalCache
- 然后有个CachingExecutor会装饰Executor,也就是装饰一级缓存,查询时如果开启二级缓存,CachingExecutor会通过tcm去二级缓存查询,之后再查一级缓存