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

SpringBoot使用 druid 連接池來優(yōu)化分頁語句

 更新時間：2020年11月06日 09:48:24   作者：如夢技術  
這篇文章主要介紹了SpringBoot使用 druid 連接池來優(yōu)化分頁語句,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

一、前言

一個老系統(tǒng)隨著數(shù)據(jù)量越來越大，我們察覺到部分分頁語句拖慢了我們的速度。

鑒于老系統(tǒng)的使用方式，不打算使用pagehelper和mybatis-plus來處理，加上系統(tǒng)里使用得是druid連接池，考慮直接使用druid來優(yōu)化。

二、老代碼

老代碼是使用得一個mybatis插件進行的分頁，分頁的核心代碼如下：

// 記錄統(tǒng)計的 sql
String countSql = "select count(0) from (" + sql+ ") tmp_count";
PreparedStatement countStmt = connection.prepareStatement(countSql);
BoundSql countBS = new BoundSql(mappedStatement.getConfiguration(), countSql, boundSql.getParameterMappings(), parameterObject);
setParameters(countStmt, mappedStatement, countBS,parameterObject);

在原始的 sql 外面包裝了一個 count sql，當然很多插件都是這樣做的。

三、druid 的 PagerUtil

示例 sql(有比較復雜的坐標計算)

SELECT g.*
  , ROUND(6378.138 * 2 * ASIN(SQRT(POW(SIN((? * PI() / 180 - t.latitude * PI() / 180) / 2), 2) + COS(? * PI() / 180) * COS(t.latitude * PI() / 180) * POW(SIN((? * PI() / 180 - t.longitude * PI() / 180) / 2), 2))), 2) AS distancecd
  , t.agentname, t.agentlogo, t.compaddress
FROM t_bas_integral_goods g
  LEFT JOIN t_bas_agent t ON g.agentid = t.AGENTID
WHERE t.AGENTTYPE = '2'
  AND t.pass = '0'
  AND t.dl_type = '4'
  AND g.type = 0
ORDER BY distancecd ASC

使用 Druid 生成 count sql：

String countSql = PagerUtils.count(sql, DbType.mysql);
System.out.println(countSql);

輸出：

SELECT COUNT(*)
FROM t_bas_integral_goods g
 LEFT JOIN t_bas_agent t ON g.agentid = t.AGENTID
WHERE t.AGENTTYPE = '2'
 AND t.pass = '0'
 AND t.dl_type = '4'
 AND g.type = 0

我們可以看到優(yōu)化后的 count sql 變得十分簡潔，坐標計算的都已經(jīng)丟棄掉。 注意：PagerUtil還有l(wèi)imit方法用來生成limit語句，感興趣的同學可以自行試驗。

四、改造mybatis分頁插件

4.1 踩坑之路

看到上面 druid PagerUtils count 的優(yōu)化效果，立馬開始改造起來，起初只改掉了countSql，

String countSql = PagerUtils.count(sql, dbType);
PreparedStatement countStmt = connection.prepareStatement(countSql);
BoundSql countBS = new BoundSql(mappedStatement.getConfiguration(), countSql, boundSql.getParameterMappings(), parameterObject);
setParameters(countStmt, mappedStatement, countBS,parameterObject);

啟動起來測試一番就發(fā)現(xiàn)報錯了，因為原始 sql 中含有?變量，優(yōu)化后的 sql 已經(jīng)沒有變量了，插件還會繼續(xù)給他設置變量。 我們要怎么解決這個問題呢？

我們再回頭看看pagehelper和mybatis-plus是怎么實現(xiàn)的！它倆都是基于jsqlparser對 sql 進行解析，然后處理。

要多加一個jsqlparser？沒必要沒必要，druid 的 sql 解析功能也是很強大的，我看了看PagerUtils.count方法的源碼，大不了用 druid 的 sql 解析實現(xiàn)一遍。

看了看源碼之后我陷入了沉思，有必要搞這么復雜么？有沒有更好的方法？我反復 debug 發(fā)現(xiàn)了，DynamicSqlSource中有帶#{xxx}這樣的原始 sql，

那么我是否可以使用 druid 先對這種 mybatis 占位符的 sql 進行優(yōu)化呢？我們來試試：

示例 sql：

select * from xxx where type = #{type} order by xx

輸出：

SELECT COUNT(*)
FROM xxx
WHERE type = #{type}

完美?。?！ 4.2 繼續(xù)踩坑

然而直接在 Mapper 上注解的 sql 還是有問題，拿不到原始的 sql，debug 發(fā)現(xiàn) RawSqlSource 在構造器里就將 sql 處理成了?號掛參的形式。

@Select("select * from xxx where type = #{type} order by xx")
Object test(@Param("type") String type);

那么我只能看看能不能擴展它，我找到了它是在XMLLanguageDriver里進行初始化，這下好辦了，因為我之前擴展過XMLLanguageDriver，它是可以自定義配置的。 于是我重寫了RawSqlSource, 添加上了包含 mybatis 參數(shù)占位符（#{}）的rawSql字段。

/**
 * 原始 sql，用于方便 druid 工具進行分頁
 *
 * @author L.cm
 */
public class MicaRawSqlSource implements SqlSource {
  private final String rawSql;
  private final SqlSource sqlSource;
  public MicaRawSqlSource(Configuration configuration, SqlNode rootSqlNode, Class<?> parameterType) {
    this(configuration, getSql(configuration, rootSqlNode), parameterType);
  }
  public MicaRawSqlSource(Configuration configuration, String sql, Class<?> parameterType) {
    SqlSourceBuilder sqlSourceParser = new SqlSourceBuilder(configuration);
    Class<?> clazz = parameterType == null ? Object.class : parameterType;
    this.rawSql = sql;
    this.sqlSource = sqlSourceParser.parse(sql, clazz, new HashMap<>());
  }
  // ... ...
}

自此全部邏輯已經(jīng)走通，我們再來看看我們的PagePlugin核心代碼：

// 進行分頁
Configuration configuration = mappedStatement.getConfiguration();
SqlSourceBuilder sqlSourceParser = new SqlSourceBuilder(configuration);
Class<?> parameterType = parameterObject.getClass();
Connection connection = (Connection) invocation.getArgs()[0];
// 1. 對 sql 進行判斷，如果沒有 ? 號，則直接處理
String boundRawSql = boundSql.getSql();
if (boundRawSql.indexOf(CharPool.QUESTION_MARK) == -1) {
  // 不包含 ？ 號
  String countSql = PagerUtils.count(boundRawSql, dbType);
  SqlSource newSqlSource = sqlSourceParser.parse(countSql, parameterType, new HashMap<>());
  BoundSql newBoundSql = newSqlSource.getBoundSql(parameterObject);
  int count = getCount(connection, mappedStatement, parameterObject, newBoundSql);
  StringBuilder sqlBuilder = new StringBuilder(boundRawSql);
  Page page = getPageParam(parameterObject, sqlBuilder, count);
  String pageSql = generatePageSql(sqlBuilder.toString(), dbType, page);
  // 將分頁sql語句反射回BoundSql.
  setField(boundSql, "sql", pageSql);
  return invocation.proceed();
}
// 2. 按 SqlSource 進行解析
SqlSource sqlSource = mappedStatement.getSqlSource();
// xml 中的動態(tài) sql
int count;
if (sqlSource instanceof DynamicSqlSource) {
  SqlNode rootSqlNode = PagePlugin.getField(sqlSource, "rootSqlNode");
  DynamicContext context = new DynamicContext(configuration, parameterObject);
  rootSqlNode.apply(context);
  // 生成 count sql，帶 #{xxx} 變量的 sql
  String countSql = PagerUtils.count(context.getSql(), dbType);
  SqlSource newSqlSource = sqlSourceParser.parse(countSql, parameterType, context.getBindings());
  BoundSql newBoundSql = newSqlSource.getBoundSql(parameterObject);
  count = getCount(connection, mappedStatement, parameterObject, newBoundSql);
} else if (sqlSource instanceof MicaRawSqlSource) {
  String rawSql = ((MicaRawSqlSource) sqlSource).getRawSql();
  DynamicContext context = new DynamicContext(configuration, parameterObject);
  // 生成 count sql，帶 #{xxx} 變量的 sql
  String countSql = PagerUtils.count(rawSql, dbType);
  SqlSource newSqlSource = sqlSourceParser.parse(countSql, parameterType, context.getBindings());
  BoundSql newBoundSql = newSqlSource.getBoundSql(parameterObject);
  count = getCount(connection, mappedStatement, parameterObject, newBoundSql);
} else {
  throw new IllegalArgumentException("不支持的 sql 分頁形式，請使用 xml 或者注解");
}

五、結論

整個老服務通過切換到 mica（深度定制）的微服務架構（演示環(huán)境僅僅在單服務低內(nèi)存配置）之后速度提升效果明顯，當然后面我們還會繼續(xù)進行優(yōu)化。

到此這篇關于SpringBoot使用 druid 連接池來優(yōu)化分頁語句的文章就介紹到這了,更多相關SpringBoot druid 連接池分頁內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

相關文章

  • string類和LocalDateTime的相互轉換方式

    string類和LocalDateTime的相互轉換方式

    這篇文章主要介紹了string類和LocalDateTime的相互轉換方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
    2022-02-02
  • 如何將應用的log4j替換成logback詳解

    如何將應用的log4j替換成logback詳解

    無論從設計上還是實現(xiàn)上，Logback相對log4j而言有了相對多的改進。所以下面這篇文章主要給大家介紹了關于如何將應用的log4j換成logback的相關資料，文中介紹的很詳細，需要的朋友可以參考下。
    2017-02-02
  • Java內(nèi)部類及其特點的講解

    Java內(nèi)部類及其特點的講解

    今天小編就為大家分享一篇關于Java內(nèi)部類及其特點的講解，小編覺得內(nèi)容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧
    2019-01-01
  • Netty分布式ByteBuf使用subPage級別內(nèi)存分配剖析

    Netty分布式ByteBuf使用subPage級別內(nèi)存分配剖析

    這篇文章主要為大家介紹了Netty分布式ByteBuf使用subPage級別內(nèi)存分配剖析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
    2022-03-03
  • IDEA如何一鍵部署SpringBoot項目到服務器

    IDEA如何一鍵部署SpringBoot項目到服務器

    文章介紹了如何在IDEA中部署SpringBoot項目到服務器,使用AlibabaCloudToolkit插件進行配置部署,步驟包括設置服務名稱、選擇文件上傳類型、選擇jar文件、添加服務器信息、輸入上傳路徑、選擇上傳后執(zhí)行的腳本以及執(zhí)行前的操作命令
    2024-12-12
  • Java系統(tǒng)中拆分同步和異步詳解

    Java系統(tǒng)中拆分同步和異步詳解

    這篇文章主要給大家介紹了關于Java系統(tǒng)中拆分同步和異步的相關資料，文中通過示例代碼介紹的非常詳細，對大家學習或者使用Java具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧
    2019-06-06
  • JavaWeb三大組件之Filter過濾器詳解

    JavaWeb三大組件之Filter過濾器詳解

    這篇文章主要介紹了JavaWeb三大組件之Filter過濾器詳解,過濾器Filter是Java?Web應用中的一種組件,它在請求到達Servlet或JSP之前或者響應送回客戶端之前,對請求和響應進行預處理和后處理操作,需要的朋友可以參考下
    2023-10-10
  • IntelliJ IDEA創(chuàng)建普通的Java 項目及創(chuàng)建 Java 文件并運行的教程

    IntelliJ IDEA創(chuàng)建普通的Java 項目及創(chuàng)建 Java 文件并運行的教程

    這篇文章主要介紹了IntelliJ IDEA創(chuàng)建普通的Java 項目及創(chuàng)建 Java 文件并運行的教程,本文通過圖文并茂的形式給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
    2021-02-02
  • Java實現(xiàn)輸入流轉化為String

    Java實現(xiàn)輸入流轉化為String

    這篇文章主要介紹了Java實現(xiàn)輸入流轉化為String的相關資料,需要的朋友可以參考下
    2016-12-12
  • Spring事務失效的場景梳理總結

    Spring事務失效的場景梳理總結

    實際項目開發(fā)中,如果涉及到多張表操作時,為了保證業(yè)務數(shù)據(jù)的一致性,大家一般都會采用事務機制,好多小伙伴可能只是簡單了解一下,遇到事務失效的情況,便會無從下手,下面這篇文章主要給大家介紹了關于Spring事務失效場景的相關資料,需要的朋友可以參考下
    2023-02-02

最新評論