聊聊Mybatis的Executor之CachingExecutor

淩亂°似流年 2024-04-08 11:36 69阅读 0赞

### CachingExecutor ###

先看一下CachingExecutor类：

public class CachingExecutor implements Executor {
    
      private final Executor delegate;
    
      @Override
      public int update(MappedStatement ms, Object parameterObject) throws SQLException {
        flushCacheIfRequired(ms);
        return delegate.update(ms, parameterObject);
      }

CachingExecutor的成员变量有个Executor实例，这显然是个 **装饰器模式** ，这的类就是在其他Executor实例的方法进行了flushCacheIfRequired(),也就是刷新缓存，所以这个类在其他类上添加了缓存的功能，从query()方法中也能看出先查找缓存，缓存没有再进行调用Executor实例的query()进行数据的查询

#### 二级缓存 ####

这里的缓存是二级缓存，我们通过它的query()方法具体看一下二级缓存的逻辑：

@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, boundSql);
            @SuppressWarnings("unchecked")
            List<E> list = (List<E>) tcm.getObject(cache, key);
            if (list == null) {
              list = delegate.query(ms, parameterObject, rowBounds, resultHandler, key, boundSql);
              tcm.putObject(cache, key, list);
            }
            return list;
          }
        }
        return delegate.query(ms, parameterObject, rowBounds, resultHandler, key, boundSql);
      }

1.  获取二级缓存对象
2.  如果对象不为空，表明开启了二级缓存，根据select标签的flushCache配置决定是否清空二级缓存，将其设置为 true 后，只要语句被调用，都会导致本地缓存和二级缓存被清空，默认值：false。
3.  然后检测select标签的useCache 属性，将其设置为 true 后，将会导致本条语句的结果被二级缓存缓存起来，默认值：对 select 元素为 true
4.  调用TransactionalCacheManager的getObject()方法获取二级缓存
5.  如果二级缓存为空就查询数据库，并把结果写入缓存中
6.  最后返回list

从代码中可以看出TransactionalCacheManager管理着缓存，他有个成员变量是map集合：Map<Cache, TransactionalCache> transactionalCaches = new HashMap<>();

获取缓存的方法是先获取到map中的TransactionalCache对象，再调用TransactionalCache的getObject(key)方法，那我们需要重点看一下TransactionalCache类了

#### 事务缓存类TransactionalCache ####

TransactionalCache实现了Cache接口，用来记录事务中的二级缓存的数据

public class TransactionalCache implements Cache {
      private final Map<Object, Object> entriesToAddOnCommit;
    
      @Override
      public void putObject(Object key, Object object) {
        entriesToAddOnCommit.put(key, object);
      }
    
    }

entriesToAddOnCommit是用来赞存二级缓存中的数据的，也是说在调用查询方法的时候，只是把二级缓存的数据缓存到entriesToAddOnCommit这个map集合中，在调用CachingExecutor的commit()方法的时候，才会遍历集合把数据保存到二级缓存Cache中

@Override
      public void commit(boolean required) throws SQLException {
        delegate.commit(required);
        tcm.commit();
      }

#### 总结 ####

对于Executor的CachingExecutor实现类就说这么多，它的作用就是实现二级缓存的，由它的成员变量TransactionalCacheManager来进行管理二级缓存的数据，值得一提的是，二级缓存数据真正的提交是在事务提交之后进行，这能防止出现脏读现象。

来源：[https://blog.51cto.com/u\_15460453/5611611][https_blog.51cto.com_u_15460453_5611611]

[https_blog.51cto.com_u_15460453_5611611]: https://blog.51cto.com/u_15460453/5611611?utm_source=tuicool&utm_medium=referral