欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

詳解Java的MyBatis框架中的緩存與緩存的使用改進(jìn)

 更新時(shí)間:2016年06月01日 18:42:10   作者:亦山  
很多人在使用MyBatis的緩存后經(jīng)常會(huì)遇到MySQL分頁(yè)查詢的顯示問(wèn)題,針對(duì)于此,這里我們就來(lái)詳解Java的MyBatis框架中的緩存與緩存的使用改進(jìn),首先來(lái)回顧一下MyBatis的緩存機(jī)制與執(zhí)行:

一級(jí)緩存與二級(jí)緩存
MyBatis將數(shù)據(jù)緩存設(shè)計(jì)成兩級(jí)結(jié)構(gòu),分為一級(jí)緩存、二級(jí)緩存:
一級(jí)緩存是Session會(huì)話級(jí)別的緩存,位于表示一次數(shù)據(jù)庫(kù)會(huì)話的SqlSession對(duì)象之中,又被稱之為本地緩存。一級(jí)緩存是MyBatis內(nèi)部實(shí)現(xiàn)的一個(gè)特性,用戶不能配置,默認(rèn)情況下自動(dòng)支持的緩存,用戶沒(méi)有定制它的權(quán)利(不過(guò)這也不是絕對(duì)的,可以通過(guò)開(kāi)發(fā)插件對(duì)它進(jìn)行修改);
二級(jí)緩存是Application應(yīng)用級(jí)別的緩存,它的是生命周期很長(zhǎng),跟Application的聲明周期一樣,也就是說(shuō)它的作用范圍是整個(gè)Application應(yīng)用。
MyBatis中一級(jí)緩存和二級(jí)緩存的組織如下圖所示:

201661182830144.jpg (824×776)

一級(jí)緩存的工作機(jī)制:
一級(jí)緩存是Session會(huì)話級(jí)別的,一般而言,一個(gè)SqlSession對(duì)象會(huì)使用一個(gè)Executor對(duì)象來(lái)完成會(huì)話操作,Executor對(duì)象會(huì)維護(hù)一個(gè)Cache緩存,以提高查詢性能。
二級(jí)緩存的工作機(jī)制:
如上所言,一個(gè)SqlSession對(duì)象會(huì)使用一個(gè)Executor對(duì)象來(lái)完成會(huì)話操作,MyBatis的二級(jí)緩存機(jī)制的關(guān)鍵就是對(duì)這個(gè)Executor對(duì)象做文章。如果用戶配置了"cacheEnabled=true",那么MyBatis在為SqlSession對(duì)象創(chuàng)建Executor對(duì)象時(shí),會(huì)對(duì)Executor對(duì)象加上一個(gè)裝飾者:CachingExecutor,這時(shí)SqlSession使用CachingExecutor對(duì)象來(lái)完成操作請(qǐng)求。CachingExecutor對(duì)于查詢請(qǐng)求,會(huì)先判斷該查詢請(qǐng)求在Application級(jí)別的二級(jí)緩存中是否有緩存結(jié)果,如果有查詢結(jié)果,則直接返回緩存結(jié)果;如果緩存中沒(méi)有,再交給真正的Executor對(duì)象來(lái)完成查詢操作,之后CachingExecutor會(huì)將真正Executor返回的查詢結(jié)果放置到緩存中,然后在返回給用戶。
MyBatis的二級(jí)緩存設(shè)計(jì)得比較靈活,你可以使用MyBatis自己定義的二級(jí)緩存實(shí)現(xiàn);你也可以通過(guò)實(shí)現(xiàn)org.apache.ibatis.cache.Cache接口自定義緩存;也可以使用第三方內(nèi)存緩存庫(kù),如Memcached等。

201661182937460.jpg (755×407)

201661182952328.jpg (544×421)

緩存的改造
問(wèn)題:
最容易出現(xiàn)的問(wèn)題是開(kāi)啟cache后,分頁(yè)查詢時(shí)無(wú)論查詢哪一頁(yè)都返回第一頁(yè)的數(shù)據(jù)。另外,使用sql自動(dòng)生成插件生成get方法的sql時(shí),傳入的參數(shù)不起作用,無(wú)論傳入的參數(shù)是多少,都返回第一個(gè)參數(shù)的查詢結(jié)果。

為什么出現(xiàn)這些問(wèn)題:
在之前講解Mybatis的執(zhí)行流程的時(shí)候提到,在開(kāi)啟cache的前提下,Mybatis的executor會(huì)先從緩存里讀取數(shù)據(jù),讀取不到才去數(shù)據(jù)庫(kù)查詢。問(wèn)題就出在這里,sql自動(dòng)生成插件和分頁(yè)插件執(zhí)行的時(shí)機(jī)是在statementhandler里,而statementhandler是在executor之后執(zhí)行的,無(wú)論sql自動(dòng)生成插件和分頁(yè)插件都是通過(guò)改寫sql來(lái)實(shí)現(xiàn)的,executor在生成讀取cache的key(key由sql以及對(duì)應(yīng)的參數(shù)值構(gòu)成)時(shí)使用都是原始的sql,這樣當(dāng)然就出問(wèn)題了。

解決問(wèn)題:
找到問(wèn)題的原因后,解決起來(lái)就方便了。只要通過(guò)攔截器改寫executor里生成key的方法,在生成可以時(shí)使用自動(dòng)生成的sql(對(duì)應(yīng)sql自動(dòng)生成插件)或加入分頁(yè)信息(對(duì)應(yīng)分頁(yè)插件)就可以了。

攔截器簽名:

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

從簽名里可以看出,要攔截的目標(biāo)類型是Executor(注意:type只能配置成接口類型),攔截的方法是名稱為query的方法。

intercept的實(shí)現(xiàn):

public Object intercept(Invocation invocation) throws Throwable { 
    Executor executorProxy = (Executor) invocation.getTarget(); 
    MetaObject metaExecutor = MetaObject.forObject(executorProxy, DEFAULT_OBJECT_FACTORY, DEFAULT_OBJECT_WRAPPER_FACTORY); 
    // 分離代理對(duì)象鏈 
    while (metaExecutor.hasGetter("h")) { 
      Object object = metaExecutor.getValue("h"); 
      metaExecutor = MetaObject.forObject(object, DEFAULT_OBJECT_FACTORY, DEFAULT_OBJECT_WRAPPER_FACTORY); 
    } 
    // 分離最后一個(gè)代理對(duì)象的目標(biāo)類 
    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(); 
    // 解決自動(dòng)生成SQL,SQL語(yǔ)句為空導(dǎo)致key生成錯(cuò)誤的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)); 
          } 
        } 
      } 
    } 
    // 當(dāng)需要分頁(yè)查詢時(shí),將page參數(shù)里的當(dāng)前頁(yè)和每頁(yè)數(shù)加到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的實(shí)現(xiàn):

public Object plugin(Object target) { 
  // 當(dāng)目標(biāo)類是CachingExecutor類型時(shí),才包裝目標(biāo)類,否者直接返回目標(biāo)本身,減少目標(biāo)被代理的 
  // 次數(shù) 
  if (target instanceof CachingExecutor) { 
    return Plugin.wrap(target, this); 
  } else { 
    return target; 
  } 
} 

相關(guān)文章

  • Java I/O深入學(xué)習(xí)之File和RandomAccessFile

    Java I/O深入學(xué)習(xí)之File和RandomAccessFile

    這篇文章主要介紹了Java I/O深入學(xué)習(xí)之File和RandomAccessFile, I/O系統(tǒng)即輸入/輸出系統(tǒng),對(duì)于一門程序語(yǔ)言來(lái)說(shuō),創(chuàng)建一個(gè)好的輸入/輸出系統(tǒng)并非易事。在充分理解Java I/O系統(tǒng)以便正確地運(yùn)用之前,我們需要學(xué)習(xí)相當(dāng)數(shù)量的類。,需要的朋友可以參考下
    2019-06-06
  • java 單例模式的實(shí)例詳解

    java 單例模式的實(shí)例詳解

    這篇文章主要介紹了java 單例模式的實(shí)例詳解的相關(guān)資料,希望通過(guò)本文能幫助大家徹底理解掌握這部分內(nèi)容,需要的朋友可以參考下
    2017-10-10
  • MyBatis?超詳細(xì)講解動(dòng)態(tài)SQL的實(shí)現(xiàn)

    MyBatis?超詳細(xì)講解動(dòng)態(tài)SQL的實(shí)現(xiàn)

    動(dòng)態(tài)?SQL?是?MyBatis?的強(qiáng)大特性之一。如果你使用過(guò)?JDBC?或其它類似的框架,你應(yīng)該能理解根據(jù)不同條件拼接?SQL?語(yǔ)句有多痛苦,例如拼接時(shí)要確保不能忘記添加必要的空格,還要注意去掉列表最后一個(gè)列名的逗號(hào)。利用動(dòng)態(tài)?SQL,可以徹底擺脫這種痛苦
    2022-03-03
  • SpringBoot使用PageHelper分頁(yè)詳解

    SpringBoot使用PageHelper分頁(yè)詳解

    這篇文章主要介紹了SpringBoot使用PageHelper分頁(yè)詳解,我們?cè)谌魏蔚南到y(tǒng)中,分頁(yè)功能是必不可少的,然而,對(duì)于這個(gè)功能如果有一種快速開(kāi)發(fā)的實(shí)現(xiàn)方式,當(dāng)然可以節(jié)省我們很多的時(shí)間了,接下來(lái),我就給大家基于不同的環(huán)境來(lái)說(shuō)說(shuō)如何使用一個(gè)分頁(yè)插件,需要的朋友可以參考下
    2023-10-10
  • prometheus監(jiān)控springboot應(yīng)用簡(jiǎn)單使用介紹詳解

    prometheus監(jiān)控springboot應(yīng)用簡(jiǎn)單使用介紹詳解

    這篇文章主要介紹了prometheus監(jiān)控springboot應(yīng)用簡(jiǎn)單使用介紹詳解,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
    2019-05-05
  • 詳解使用批處理方式配置Java環(huán)境

    詳解使用批處理方式配置Java環(huán)境

    這篇文章主要介紹了詳解使用批處理方式配置Java環(huán)境,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2019-09-09
  • Java中sort排序函數(shù)實(shí)例詳解

    Java中sort排序函數(shù)實(shí)例詳解

    我們經(jīng)常使用java中的sort排序,確實(shí)好用,但是其中原理大多數(shù)人都是不了解的,下面這篇文章主要給大家介紹了關(guān)于Java中sort排序函數(shù)的相關(guān)資料,文中通過(guò)實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下
    2022-06-06
  • java.lang.IllegalStateException異常解決

    java.lang.IllegalStateException異常解決

    異常是程序在執(zhí)行過(guò)程中遇到的錯(cuò)誤或異常情況,本文就來(lái)介紹一下java.lang.IllegalStateException異常解決,感興趣的可以了解一下
    2023-11-11
  • Java Spring @Autowired的這些騷操作,你都知道嗎

    Java Spring @Autowired的這些騷操作,你都知道嗎

    這篇文章主要介紹了徹底搞明白Spring中的自動(dòng)裝配和Autowired注解的使用,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
    2021-09-09
  • SpringBoot執(zhí)行異步任務(wù)Async介紹

    SpringBoot執(zhí)行異步任務(wù)Async介紹

    這篇文章主要為大家介紹了SpringBoot執(zhí)行異步任務(wù)Async示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-09-09

最新評(píng)論