程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> JAVA編程 >> 關於JAVA >> 詳解Java的MyBatis框架中的緩存與緩存的應用改良

詳解Java的MyBatis框架中的緩存與緩存的應用改良

編輯:關於JAVA

詳解Java的MyBatis框架中的緩存與緩存的應用改良。本站提示廣大學習愛好者:(詳解Java的MyBatis框架中的緩存與緩存的應用改良)文章只能為提供參考,不一定能成為您想要的結果。以下是詳解Java的MyBatis框架中的緩存與緩存的應用改良正文


一級緩存與二級緩存
MyBatis將數據緩存設計成兩級構造,分為一級緩存、二級緩存:
一級緩存是Session會話級其余緩存,位於表現一次數據庫會話的SqlSession對象當中,又被稱之為當地緩存。一級緩存是MyBatis外部完成的一個特征,用戶不克不及設置裝備擺設,默許情形下主動支撐的緩存,用戶沒有定制它的權力(不外這也不是相對的,可以經由過程開辟插件對它停止修正);
二級緩存是Application運用級其余緩存,它的是性命周期很長,跟Application的聲明周期一樣,也就是說它的感化規模是全部Application運用。
MyBatis中一級緩存和二級緩存的組織以下圖所示:

一級緩存的任務機制:
一級緩存是Session會話級其余,普通而言,一個SqlSession對象會應用一個Executor對象來完成會話操作,Executor對象會保護一個Cache緩存,以進步查詢機能。
二級緩存的任務機制:
如上所言,一個SqlSession對象會應用一個Executor對象來完成會話操作,MyBatis的二級緩存機制的症結就是對這個Executor對象做文章。假如用戶設置裝備擺設了"cacheEnabled=true",那末MyBatis在為SqlSession對象創立Executor對象時,會對Executor對象加上一個裝潢者:CachingExecutor,這時候SqlSession應用CachingExecutor對象來完成操作要求。CachingExecutor關於查詢要求,會先斷定該查詢要求在Application級其余二級緩存中能否有緩存成果,假如有查詢成果,則直接前往緩存成果;假如緩存中沒有,再交給真實的Executor對象來完成查詢操作,以後CachingExecutor會將真正Executor前往的查詢成果放置到緩存中,然後在前往給用戶。
MyBatis的二級緩存設計得比擬靈巧,你可使用MyBatis本身界說的二級緩存完成;你也能夠經由過程完成org.apache.ibatis.cache.Cache接口自界說緩存;也能夠應用第三方內存緩存庫,如Memcached等。

緩存的改革
成績:
最輕易湧現的成績是開啟cache後,分頁查詢時不管查詢哪一頁都前往第一頁的數據。別的,應用sql主動生成插件生成get辦法的sql時,傳入的參數不起感化,不管傳入的參數是若干,都前往第一個參數的查詢成果。

為何湧現這些成績:
在之前講授Mybatis的履行流程的時刻提到,在開啟cache的條件下,Mybatis的executor會先從緩存裡讀取數據,讀取不到才去數據庫查詢。成績就出在這裡,sql主動生成插件和分頁插件履行的機會是在statementhandler裡,而statementhandler是在executor以後履行的,不管sql主動生成插件和分頁插件都是經由過程改寫sql來完成的,executor在生成讀取cache的key(key由sql和對應的參數值組成)時應用都是原始的sql,如許固然就出成績了。

處理成績:
找到成績的緣由後,處理起來就便利了。只需經由過程攔阻器改寫executor裡生成key的辦法,在生成可以時應用主動生成的sql(對應sql主動生成插件)或參加分頁信息(對應分頁插件)便可以了。

攔阻器簽名:

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

從簽名裡可以看出,要攔阻的目的類型是Executor(留意:type只能設置裝備擺設成接口類型),攔阻的辦法是稱號為query的辦法。

intercept的完成:

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; 
}  

plugin的完成:

public Object plugin(Object target) { 
  // 當目的類是CachingExecutor類型時,才包裝目的類,否者直接前往目的自己,削減目的被署理的 
  // 次數 
  if (target instanceof CachingExecutor) { 
    return Plugin.wrap(target, this); 
  } else { 
    return target; 
  } 
} 

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved