详解Java的MyBatis框架中的缓存与缓存的使用改进

@Intercepts({@Signature(type = Executor.class, method = "query", args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class})}) 
public class CacheInterceptor implements Interceptor { 
... 
} 

public Object intercept(Invocation invocation) throws Throwable { 
    Executor executorProxy = (Executor) invocation.getTarget(); 
    MetaObject metaExecutor = MetaObject.forObject(executorProxy, DEFAULT_OBJECT_FACTORY, DEFAULT_OBJECT_WRAPPER_FACTORY); 
    // 分离代理对象链 
    while (metaExecutor.hasGetter("h")) { 
      Object object = metaExecutor.getValue("h"); 
      metaExecutor = MetaObject.forObject(object, DEFAULT_OBJECT_FACTORY, DEFAULT_OBJECT_WRAPPER_FACTORY); 
    } 
    // 分离最后一个代理对象的目标类 
    while (metaExecutor.hasGetter("target")) { 
      Object object = metaExecutor.getValue("target"); 
      metaExecutor = MetaObject.forObject(object, DEFAULT_OBJECT_FACTORY, DEFAULT_OBJECT_WRAPPER_FACTORY); 
    } 
    Object[] args = invocation.getArgs(); 
    return this.query(metaExecutor, args); 
  } 
 
  public <E> List<E> query(MetaObject metaExecutor, Object[] args) throws SQLException { 
    MappedStatement ms = (MappedStatement) args[0]; 
    Object parameterObject = args[1]; 
    RowBounds rowBounds = (RowBounds) args[2]; 
    ResultHandler resultHandler = (ResultHandler) args[3]; 
    BoundSql boundSql = ms.getBoundSql(parameterObject); 
    // 改写key的生成 
    CacheKey cacheKey = createCacheKey(ms, parameterObject, rowBounds, boundSql); 
    Executor executor = (Executor) metaExecutor.getOriginalObject(); 
    return executor.query(ms, parameterObject, rowBounds, resultHandler, cacheKey, boundSql); 
  } 
 
  private CacheKey createCacheKey(MappedStatement ms, Object parameterObject, RowBounds rowBounds, BoundSql boundSql) { 
    Configuration configuration = ms.getConfiguration(); 
    pageSqlId = configuration.getVariables().getProperty("pageSqlId"); 
    if (null == pageSqlId || "".equals(pageSqlId)) { 
      logger.warn("Property pageSqlId is not setted,use default '.*Page$' "); 
      pageSqlId = defaultPageSqlId; 
    } 
    CacheKey cacheKey = new CacheKey(); 
    cacheKey.update(ms.getId()); 
    cacheKey.update(rowBounds.getOffset()); 
    cacheKey.update(rowBounds.getLimit()); 
    List<ParameterMapping> parameterMappings = boundSql.getParameterMappings(); 
    // 解决自动生成SQL，SQL语句为空导致key生成错误的bug 
    if (null == boundSql.getSql() || "".equals(boundSql.getSql())) { 
      String id = ms.getId(); 
      id = id.substring(id.lastIndexOf(".") + 1); 
      String newSql = null; 
      try { 
        if ("select".equals(id)) { 
          newSql = SqlBuilder.buildSelectSql(parameterObject); 
        } 
        SqlSource sqlSource = buildSqlSource(configuration, newSql, parameterObject.getClass()); 
        parameterMappings = sqlSource.getBoundSql(parameterObject).getParameterMappings(); 
        cacheKey.update(newSql); 
      } catch (Exception e) { 
        logger.error("Update cacheKey error.", e); 
      } 
    } else { 
      cacheKey.update(boundSql.getSql()); 
    } 
 
    MetaObject metaObject = MetaObject.forObject(parameterObject, DEFAULT_OBJECT_FACTORY, DEFAULT_OBJECT_WRAPPER_FACTORY); 
 
    if (parameterMappings.size() > 0 && parameterObject != null) { 
      TypeHandlerRegistry typeHandlerRegistry = ms.getConfiguration().getTypeHandlerRegistry(); 
      if (typeHandlerRegistry.hasTypeHandler(parameterObject.getClass())) { 
        cacheKey.update(parameterObject); 
      } else { 
        for (ParameterMapping parameterMapping : parameterMappings) { 
          String propertyName = parameterMapping.getProperty(); 
          if (metaObject.hasGetter(propertyName)) { 
            cacheKey.update(metaObject.getValue(propertyName)); 
          } else if (boundSql.hasAdditionalParameter(propertyName)) { 
            cacheKey.update(boundSql.getAdditionalParameter(propertyName)); 
          } 
        } 
      } 
    } 
    // 当需要分页查询时，将page参数里的当前页和每页数加到cachekey里 
    if (ms.getId().matches(pageSqlId) && metaObject.hasGetter("page")) { 
      PageParameter page = (PageParameter) metaObject.getValue("page"); 
      if (null != page) { 
        cacheKey.update(page.getCurrentPage()); 
        cacheKey.update(page.getPageSize()); 
      } 
    } 
    return cacheKey; 
}  

public Object plugin(Object target) { 
  // 当目标类是CachingExecutor类型时，才包装目标类，否者直接返回目标本身,减少目标被代理的 
  // 次数 
  if (target instanceof CachingExecutor) { 
    return Plugin.wrap(target, this); 
  } else { 
    return target; 
  } 
}