mybatis-plus如何禁用一級(jí)緩存的方法

更新時(shí)間：2021年03月17日 09:38:41 作者：linyb極客之路

這篇文章主要介紹了mybatis-plus如何禁用一級(jí)緩存的方法，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

前言

用過(guò)mybatis-plus的朋友可能會(huì)知道，mybatis-plus提供了多租戶(hù)插件的功能，這個(gè)功能可以讓開(kāi)發(fā)人員不用手動(dòng)寫(xiě)租戶(hù)語(yǔ)句，由該插件自動(dòng)幫你加上租戶(hù)語(yǔ)句。今天的素材來(lái)源就是取自業(yè)務(wù)開(kāi)發(fā)人員使用多租戶(hù)插件時(shí)，遇到的一個(gè)神奇的問(wèn)題

問(wèn)題重現(xiàn)

業(yè)務(wù)開(kāi)發(fā)人員要實(shí)現(xiàn)根據(jù)手機(jī)號(hào)碼更新租戶(hù)的密碼功能，其代碼形如下

 for(Tenant t : tenantList){
      ApplicationChainContext.getCurrentContext().put(ApplicationChainContext.TENANT_ID,t.getId()+"");
      Optional<SaasUser> user = this.findByUserPhone(req.getUserPhone());
      user.ifPresent(u -> {
        count.getAndSet(count.get() + 1);
        LambdaUpdateWrapper<SaasUser> wrapper = new LambdaUpdateWrapper<>();
        String md5Pwd = Md5Utils.hash(req.getNewUserPwd());
        wrapper.eq(SaasUser::getId,user.get().getId());
        wrapper.set(SaasUser::getUserPwd,md5Pwd);
        this.update(wrapper);
      });
    }

從代碼上看起來(lái)沒(méi)啥問(wèn)題，因?yàn)槭褂昧硕嘧鈶?hù)插件，當(dāng)我們執(zhí)行this.findByUserPhone(req.getUserPhone());就會(huì)自動(dòng)帶上租戶(hù)的信息。但在執(zhí)行的時(shí)候發(fā)現(xiàn)一個(gè)問(wèn)題，如下圖

從圖中我們可以發(fā)現(xiàn)，當(dāng)查詢(xún)不到用戶(hù)信息時(shí)，后續(xù)的查詢(xún)操作，都沒(méi)有sql語(yǔ)句出現(xiàn)。這說(shuō)明2點(diǎn)，sql語(yǔ)句要么被系統(tǒng)吃了，要么系統(tǒng)沒(méi)有執(zhí)行sql

問(wèn)題分析

前面說(shuō)了sql語(yǔ)句沒(méi)有打印出來(lái)，說(shuō)明sql要么沒(méi)執(zhí)行，要么就sql語(yǔ)句被系統(tǒng)吃了。到底是哪種，與其猜測(cè)，倒不如去官方找找問(wèn)題的答案，很遺憾在mybatis-plus官網(wǎng)或者issue上并沒(méi)找到答案，于是只好跟蹤源碼進(jìn)行分析。最后發(fā)現(xiàn)mybatis-plus果然如他官網(wǎng)介紹的只做增強(qiáng)不做改變，他最終調(diào)用查詢(xún)的邏輯，走的是原生mybatis的查詢(xún)邏輯。其查詢(xún)的核心代碼如下

public <E> List<E> 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 (this.closed) {
      throw new ExecutorException("Executor was closed.");
    } else {
      if (this.queryStack == 0 && ms.isFlushCacheRequired()) {
        this.clearLocalCache();
      }

      List list;
      try {
        ++this.queryStack;
        list = resultHandler == null ? (List)this.localCache.getObject(key) : null;
        if (list != null) {
          this.handleLocallyCachedOutputParameters(ms, key, parameter, boundSql);
        } else {
          list = this.queryFromDatabase(ms, parameter, rowBounds, resultHandler, key, boundSql);
        }
      } finally {
        --this.queryStack;
      }

      if (this.queryStack == 0) {
        Iterator var8 = this.deferredLoads.iterator();

        while(var8.hasNext()) {
          BaseExecutor.DeferredLoad deferredLoad = (BaseExecutor.DeferredLoad)var8.next();
          deferredLoad.load();
        }

        this.deferredLoads.clear();
        if (this.configuration.getLocalCacheScope() == LocalCacheScope.STATEMENT) {
          this.clearLocalCache();
        }
      }

      return list;
    }
  }

從代碼我們可以得出一個(gè)重要的信息，如下

 list = resultHandler == null ? (List)this.localCache.getObject(key) : null;
        if (list != null) {
          this.handleLocallyCachedOutputParameters(ms, key, parameter, boundSql);
        } else {
          list = this.queryFromDatabase(ms, parameter, rowBounds, resultHandler, key, boundSql);
        }

當(dāng)resultHandler為空，list的取值是this.localCache.getObject(key)，即會(huì)走本地緩存，而不會(huì)進(jìn)行數(shù)據(jù)庫(kù)查詢(xún)

問(wèn)題破解

從源碼可以得知，原生的mybatis默認(rèn)會(huì)走本地緩存，即所謂的一級(jí)緩存，而mybatis-plus作為mybatis的增強(qiáng)版，其邏輯和mybatis原生邏輯是一樣的。那如何禁用mybatis-plus的一級(jí)緩存呢，從源碼分析，我們可以得知，當(dāng)list為空時(shí)，則不會(huì)走緩存，而會(huì)查詢(xún)數(shù)據(jù)。而list的緩存取值，來(lái)源于
this.localCache.getObject(key)。因此禁用緩存的逆向思維就是要么清空l(shuí)ocalCache，要么就是變更key，使this.localCache.getObject(key)取到的值為null。因此解決方案至少有以下兩種

方案一：清空l(shuí)ocalCache

那要怎么清空？

通過(guò)源碼我們可以看到清空l(shuí)ocalCache的地方有兩處，一處是

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

另外一處是

if (configuration.getLocalCacheScope() == LocalCacheScope.STATEMENT) {
    // issue #482
    clearLocalCache();
   }

因此我們可以通過(guò)變更c(diǎn)onfiguration.getLocalCacheScope()為STATEMENT進(jìn)行清空。可以通過(guò)在yml做如下配置

mybatis-plus:
  configuration:
    local-cache-scope: statement

方案二：變更localcache的key，使this.localCache.getObject(key)取到的值為null

我們先看下key的構(gòu)成

public CacheKey createCacheKey(MappedStatement ms, Object parameterObject, RowBounds rowBounds, BoundSql boundSql) {
    if (this.closed) {
      throw new ExecutorException("Executor was closed.");
    } else {
      CacheKey cacheKey = new CacheKey();
      cacheKey.update(ms.getId());
      cacheKey.update(rowBounds.getOffset());
      cacheKey.update(rowBounds.getLimit());
      cacheKey.update(boundSql.getSql());
      List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
      TypeHandlerRegistry typeHandlerRegistry = ms.getConfiguration().getTypeHandlerRegistry();
      Iterator var8 = parameterMappings.iterator();

      while(var8.hasNext()) {
        ParameterMapping parameterMapping = (ParameterMapping)var8.next();
        if (parameterMapping.getMode() != ParameterMode.OUT) {
          String propertyName = parameterMapping.getProperty();
          Object value;
          if (boundSql.hasAdditionalParameter(propertyName)) {
            value = boundSql.getAdditionalParameter(propertyName);
          } else if (parameterObject == null) {
            value = null;
          } else if (typeHandlerRegistry.hasTypeHandler(parameterObject.getClass())) {
            value = parameterObject;
          } else {
            MetaObject metaObject = this.configuration.newMetaObject(parameterObject);
            value = metaObject.getValue(propertyName);
          }

          cacheKey.update(value);
        }
      }

      if (this.configuration.getEnvironment() != null) {
        cacheKey.update(this.configuration.getEnvironment().getId());
      }

      return cacheKey;
    }
  }

從源碼可以看出key是由statementId+原生sql+value（查詢(xún)出來(lái)的對(duì)象）+ sqlsession.hashcode組成。

因此變更key，我們可以從原生sql入手?？吹竭@邊可能有朋友會(huì)說(shuō)，租戶(hù)id正常不都不一樣嗎，既然mybatis-plus通過(guò)多租戶(hù)插件，其產(chǎn)生的sql語(yǔ)句不都不一樣嗎，進(jìn)而產(chǎn)生的key不就都不一樣了嗎。如果跟蹤源碼就會(huì)發(fā)現(xiàn)其原生的sql是沒(méi)有加上租戶(hù)信息的。因此我們可以取巧在查詢(xún)的sql語(yǔ)句中添加一個(gè)隨機(jī)數(shù)，形如下

 public Optional<SaasUser> findByUserPhone(String userPhone) {
    LambdaQueryWrapper<SaasUser> wrapper = new LambdaQueryWrapper<>();
    wrapper.eq(SaasUser::getUserPhone,userPhone);
    wrapper.apply("{0} = {0}",UUID.randomUUID().toString());
    SaasUser saasUser = getBaseMapper().selectOne(wrapper);
    return Optional.ofNullable(saasUser);
  }

即在原先的查詢(xún)代碼語(yǔ)句多加

wrapper.apply("{0} = {0}",UUID.randomUUID().toString());

此時(shí)sql語(yǔ)句如下

Preparing: SELECT id, user_code, user_name, main_accout_flag, user_pwd, user_phone, admin_flag, user_status, last_login_time, login_ip, pwd_update_time, tenant_id, create_date, created_by, created_by_id, last_updated_by, last_updated_by_id, last_update_date, object_version_number, delete_flag FROM saas_user WHERE delete_flag = 0 AND (user_phone = ? AND ? = ?) AND tenant_id = 424210194470490118
==> Parameters: 111111(String), edcda7fe-ee43-481a-90f7-8b41cb51a3d1(String), edcda7fe-ee43-481a-90f7-8b41cb51a3d1(String)

這樣每次產(chǎn)生的sql就會(huì)不一樣，導(dǎo)致取到不一樣key，進(jìn)而使this.localCache.getObject(key)為空，這樣就可以讓mybatis每次都進(jìn)行數(shù)據(jù)庫(kù)查詢(xún)，從而達(dá)到禁用一級(jí)緩存的目的

總結(jié)

方案一的配置是基于全局配置，方案二是基于局部配置。就個(gè)人而言，是比較推薦方案二，即通過(guò)添加隨機(jī)值的方式。因?yàn)閙ybatis配置一級(jí)緩存的意義，本身就是出于提供性能考慮。不過(guò)方案要站在業(yè)務(wù)的視角進(jìn)行考慮，為了確保功能能正確運(yùn)行，有時(shí)候犧牲一些性能也無(wú)傷大雅

到此這篇關(guān)于mybatis-plus如何禁用一級(jí)緩存的方法的文章就介紹到這了,更多相關(guān)mybatis-plus 禁用一級(jí)緩存內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: