关于Mybatis关闭一级二级缓存

 这两天折腾mybatis发现它的缓存内容比较不和谐,原因是底层架构会考虑到分布式,但是Mybatis的各个SqlSession的默认一级缓存PerpetualCache不会在各SqlSession间共享,同时他存储下来sql语句和查询到的对象集,再第二次查询的时候使用他内部的缓存,第二次查询的时候使用他内部的缓存, 是指两次使用的同一个查询语句的时候, 如两次使用的是不同的sql语句那么就不会使用缓存所以我决定要去掉这个缓存,以下为默认一级缓存的源码

public class PerpetualCache implements Cache {private String id;private Map cache = new HashMap();public PerpetualCache(String id) {this.id = id;}@Overridepublic String getId() {return id;}@Overridepublic int getSize() {return cache.size();}@Overridepublic void putObject(Object key, Object value) {cache.put(key, value);}@Overridepublic Object getObject(Object key) {return cache.get(key);}@Overridepublic Object removeObject(Object key) {return cache.remove(key);}@Overridepublic void clear() {cache.clear();}@Overridepublic ReadWriteLock getReadWriteLock() {return null;}@Overridepublic boolean equals(Object o) {if (getId() == null) {throw new CacheException("Cache instances require an ID.");}if (this == o) {return true;}if (!(o instanceof Cache)) {return false;}Cache otherCache = (Cache) o;return getId().equals(otherCache.getId());}@Overridepublic int hashCode() {if (getId() == null) {throw new CacheException("Cache instances require an ID.");}return getId().hashCode();}}

可以看到它内部就是使用的一个HashMap进行缓存

同时我自己的项目里面用的是注解省略配置文件的方式

org.mybatis.spring.SqlSessionFactoryBean sqlSessionFactoryBean = new org.mybatis.spring.SqlSessionFactoryBean(); 

首先注解在类上的CacheNamespace\CacheNamespaceRef是否使用新的缓存内容配置前者配置大小,后者配置指定二级缓存配置name或value, 统统去掉

useCache参数

SqlSessionFactoryBean

这种默认使用的Sqlsession是DefaultSqlSession这个类,该参数只有在Mybatis添加或生成Mapper的时候供CachingExecutor该类使用,但是目前使用还没有找到可以直接使用该类的方式~

默认配置都是使用的BaseExecutor该类所以useCache直接就失效了,在网上看到还有些说使用Sqlsession时主动清空缓存

 void clearCache();

或使用随机数,使上一个查询语句的缓存失效

(int)Math.random()*1000  (int)Math.random()*10000 

where #{randomString}=#{randomString}

然后嫌麻烦,又去翻源码发现以下函数

public  List 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 list;try {queryStack++;list = resultHandler == null ? (List) 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 #601deferredLoads.clear();if (configuration.getLocalCacheScope() == LocalCacheScope.STATEMENT) {// issue #482clearLocalCache();}}return list;}

  private  List queryFromDatabase(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {List list;localCache.putObject(key, EXECUTION_PLACEHOLDER);try {list = doQuery(ms, parameter, rowBounds, resultHandler, boundSql);} finally {localCache.removeObject(key);}localCache.putObject(key, list);if (ms.getStatementType() == StatementType.CALLABLE) {localOutputParameterCache.putObject(key, parameter);}return list;}

可以看到的是如果使用BaseExecutor那么在mybatis在进行数据库查询queryFromDatabase的时候根本没有给任何参数来进行一级缓存的屏蔽,但是在query函数内

if (queryStack == 0 && ms.isFlushCacheRequired()) {clearLocalCache();}

有自动清空本地缓存的一个代码段, 翻到参数flushCache这个参数设置为FlushCachePolicy.TRUE后成功去掉了一级缓存, 这种方式带来了没必要的消耗, 每次都去清空 它还得存进去, 要考虑一下其他的解决方式了,但是这种思路是对的,orm就应该是orm, 业务层使用自己的第三方其他的缓存比较好. 

 因为网上对于mybatis的注解一些细节的解决方案比较少, 所以看看是不是可以直接使用CachingExecutor这个用useCache参数来屏蔽, 感觉mybatis做了好多属于业务之外的事情.

结论: 如使用的是org.mybatis.spring.SqlSessionFactoryBean生成的SqlSessionFactory默认配置的话,在对应Mapper的内使用flushCache可以让mybatis进行查询时每次清空本地缓存,虽然他每次依旧会读取和重新存进去~~

@Options(timeout = 10000,  flushCache = FlushCachePolicy.TRUE)

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！