mybatis源码学习(三)-一级缓存二级缓存

2023-03-15,,

本文主要是个人学习mybatis缓存的学习笔记,主要有以下几个知识点

1.一级缓存配置信息

2.一级缓存源码学习笔记

3.二级缓存配置信息

4.二级缓存源码

5.一级缓存、二级缓存总结

1.一级缓存配置:

一级缓存是SqlSession级别的,同一个sqlSession执行多次相同的查询语句时,第二次会从缓存中获取数据,不查询数据库;一级缓存是无法关闭的,默认是SESSION级别

mybatis一级缓存默认是开启的,一级缓存有两个配置值,SESSION级别和STATEMENT级别,这两个级别的区别是:

如果是SESSION级别(默认值),那么在同一个sqlSession中,都会共享这个缓存

如果是STATEMENT级别,那么会把一级缓存中的缓存清空,也就是说,同一个sqlSession,多次请求同一个sql,每次都会查询数据库

默认是session级别,此时为开启二级缓存:

如果把一级缓存的级别设置为STATEMENT,那么同一个sqlSession执行多次相同的SQL,都会查询数据库:

那下面,我们来源码中验证

2.一级缓存源码:

1.首先会根据statement等参数,生成缓存中需要用到的key  org.apache.ibatis.executor.CachingExecutor#createCacheKey

2.根据key从一级缓存中获取值,一级缓存是PerpetualCache这个类

org.apache.ibatis.executor.BaseExecutor#query(org.apache.ibatis.mapping.MappedStatement, java.lang.Object, org.apache.ibatis.session.RowBounds, org.apache.ibatis.session.ResultHandler, org.apache.ibatis.cache.CacheKey, org.apache.ibatis.mapping.BoundSql)

3.如果从一级缓存中取到值,就不查询数据库;否则查询数据库

    org.apache.ibatis.executor.BaseExecutor#handleLocallyCachedOutputParameters

  4.如果一级缓存中没有取到值,就从数据库中查询,并将数据库中查询到的数据,存到一级缓存中

    org.apache.ibatis.executor.BaseExecutor#queryFromDatabase

  5.判断缓存级别是否是STATEMENT,如果是,将一级缓存清空

 @SuppressWarnings("unchecked")
@Override
public <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {
ErrorContext.instance().resource(ms.getResource()).activity("executing a query").object(ms.getId());
if (closed) {
throw new ExecutorException("Executor was closed.");
}
if (queryStack == 0 && ms.isFlushCacheRequired()) {
clearLocalCache();
}
List<E> list;
try {
queryStack++;
list = resultHandler == null ? (List<E>) localCache.getObject(key) : null;
if (list != null) {
handleLocallyCachedOutputParameters(ms, key, parameter, boundSql);
} else {
list = queryFromDatabase(ms, parameter, rowBounds, resultHandler, key, boundSql);
}
} finally {
queryStack--;
}
if (queryStack == 0) {
for (DeferredLoad deferredLoad : deferredLoads) {
deferredLoad.load();
}
// issue #601
deferredLoads.clear();
if (configuration.getLocalCacheScope() == LocalCacheScope.STATEMENT) {
// issue #482
clearLocalCache();
}
}
return list;
}

   这段源码中,第14行,是尝试从一级缓存中根据key,取值;如果不为null,就从一级缓存中取值,第18行,是从数据中查询数据;

   在 queryFromDatabase()方法中,会将数据库中查询到的数据,put到一级缓存中

   源码中的第29行,就是对一级缓存是否是STATEMENT级别做判断,如果是,就clear;

  我们再来说,insert、update、delete,这三种操作,都会走update,

  org.apache.ibatis.executor.BaseExecutor#update

  

 @Override
public int update(MappedStatement ms, Object parameter) throws SQLException {
ErrorContext.instance().resource(ms.getResource()).activity("executing an update").object(ms.getId());
if (closed) {
throw new ExecutorException("Executor was closed.");
}
clearLocalCache();
return doUpdate(ms, parameter);
}

可以看到,执行doUpdate()方法之前,会先clear一级缓存

3.二级缓存配置

二级缓存是mapper级别的,需要配置才会开启

需要在mybatis的配置文件中,增加以下配置

 <settings>
<setting name="cacheEnabled" value="true"/>
</settings>

并且在mapper.xml文件中增加

<cache></cache>

这样,二级缓存就开启了

4.二级缓存源码

二级缓存的源码,首先我们要看 org.apache.ibatis.executor.CachingExecutor#query(org.apache.ibatis.mapping.MappedStatement, java.lang.Object, org.apache.ibatis.session.RowBounds, org.apache.ibatis.session.ResultHandler, org.apache.ibatis.cache.CacheKey, org.apache.ibatis.mapping.BoundSql)  这个方法

 @Override
public <E> List<E> query(MappedStatement ms, Object parameterObject, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql)
throws SQLException {
Cache cache = ms.getCache();
if (cache != null) {
flushCacheIfRequired(ms);
if (ms.isUseCache() && resultHandler == null) {
ensureNoOutParams(ms, parameterObject, boundSql);
@SuppressWarnings("unchecked")
List<E> list = (List<E>) tcm.getObject(cache, key);
if (list == null) {
list = delegate.<E> query(ms, parameterObject, rowBounds, resultHandler, key, boundSql);
tcm.putObject(cache, key, list); // issue #578 and #116
}
return list;
}
}
return delegate.<E> query(ms, parameterObject, rowBounds, resultHandler, key, boundSql);
}

在第7行,首先会判断,当前sql,是否开启useCache这个属性,对于select 默认是true;update、insert、delete默认是 false;这个点的源码是在解析xml的时候,最终会把每个select、update、insert、delete节点

build成一个mappedStatement,在build之前,有这么一段代码

 boolean isSelect = sqlCommandType == SqlCommandType.SELECT;
boolean flushCache = context.getBooleanAttribute("flushCache", !isSelect);
boolean useCache = context.getBooleanAttribute("useCache", isSelect);

org.apache.ibatis.builder.xml.XMLStatementBuilder#parseStatementNode

这里的意思是:如果是select,那么useCache就是true,否则就是false

接着上面的说,第10行会尝试从二级缓存中获取数据,这里的调用链是这样的

从源码中,可以看到,二级缓存先于以及缓存,如果二级缓存中没有取到值,会充以及缓存中国取,一级缓存中没有取到,再从数据库查询数据

这个调用链这几个cache,还没有搞明白,具体的作用,后面学习之后,会更新;

二级缓存有一个点,需要明确:二级缓存只有在sqlSession执行commit的时候,才会更新;否则是不生效的

这个是commit的时候,二级缓存Put的调用链

5.总结

一级缓存是sqlSession级别的,二级缓存是mapper级别的,二级缓存的粒度更细,

一级缓存无法关闭,二级缓存可以开启或者关闭

一级缓存如果在分布式的场景下,可能会存在脏数据;

如果使用缓存,感觉还是Redis靠谱吧;

mybatis源码学习(三)-一级缓存二级缓存的相关教程结束。

《mybatis源码学习(三)-一级缓存二级缓存.doc》

下载本文的Word格式文档,以方便收藏与打印。