1. 程式人生 > >專案上線後,談一下感觸比較深的一點:查詢優化

專案上線後,談一下感觸比較深的一點:查詢優化

前言

  開心一刻

    兒子有道題不會做,喊我過去教他。我推了推一旁的老公:我頭疼,你去吧。老公不動,我:零花錢漲一千。話音剛落,老公就屁顛屁顛跑去兒子房間。進去不到幾分鐘,一聲怒吼伴隨著兒子的哭聲傳來的瞬間,老公從兒子房間出來,邊走邊說:“朽木不可雕也。”兒子從房間探出半個身子,一臉委屈:“爸爸也不會做,他說給我一塊錢,讓我明天早點去學校抄同學的。還讓我不要告訴你,我不肯,他就吼我。”

問題背景

  前段時間,被緊急調到一個新專案,支撐新專案的開發。跌跌撞撞之下,專案也正常上線了,期間收穫頗多,無論是業務上的,還是業務之外的。業務上的就不多說了,不具通用性,意義不大,有一點業務之外的東東給我的感觸比較深,特記錄下來,與大家分享下 : 查詢優化

查詢優化

  完整示例工程:data-init,包括資料庫表的 ddl 和 dml,以及資料批量的生成

  相關表

    涉及的表不多,一共三張:額度表、記錄表 、 存款表

    額度表 t_custmor_credit

CREATE TABLE t_customer_credit (
  id INT(11) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT '自增主鍵',
  login_name VARCHAR(50) NOT NULL COMMENT '名稱',
    credit_type TINYINT(1) NOT NULL COMMENT '額度型別,1:自由資金,2:凍結資金,3:優惠',
    amount DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '額度值',
    create_by VARCHAR(50) NOT NULL COMMENT '建立者',
    create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '建立時間',
    update_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '建立時間',
    update_by VARCHAR(50) NOT NULL COMMENT '修改者',
  PRIMARY KEY (id)
);
View Code

      記錄每個顧客的當前額度,額度一共分三種:自由資金、凍結資金和優惠,也就是說每個顧客會有 3 條記錄來表示他的各個額度。表中資料如下

    額度記錄 t_custmor_credit_record

CREATE TABLE t_customer_credit_record (
  id INT(11) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT '自增主鍵',
  login_name VARCHAR(50) NOT NULL COMMENT '名稱',
    credit_type TINYINT(1) NOT NULL COMMENT '額度型別,參考t_custmor_credit的credit_type',
    bill_no VARCHAR(50) NOT NULL COMMENT '訂單號',
    amount_before DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '前額度值',
    amount_change DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '額度變化值',
    amount_after DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '後額度值',
    create_by VARCHAR(50) NOT NULL COMMENT '建立者',
    create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '建立時間',
    remark VARCHAR(500) NOT NULL DEFAULT '' COMMENT '備註',
  PRIMARY KEY (id)
);
View Code

      記錄顧客額度的每一次變化,只要有額度變化(不管是哪個額度進行了變化),都會新增3條記錄,每個型別的額度都會新增一條記錄。另外,該表只會有資料的插入,不會有資料的刪、改。表中資料如下

    存款表 t_custmor_deposit

CREATE TABLE t_customer_deposit (
  id INT(11) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT '自增主鍵',
  login_name VARCHAR(50) NOT NULL COMMENT '名稱',
    bill_no VARCHAR(50) NOT NULL COMMENT '訂單號',
    amount DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '存款金額',
    deposit_state TINYINT(1) NOT NULL COMMENT '存款狀態: 1成功,2失敗,3未知',
    channal TINYINT(2) NOT NULL COMMENT '存款渠道: 1:銀聯,2支付寶,3微信',
    create_by VARCHAR(50) NOT NULL COMMENT '建立者',
    create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '建立時間',
    remark VARCHAR(500) NOT NULL DEFAULT '' COMMENT '備註',
  PRIMARY KEY (id)
);
View Code

      記錄顧客的每一次存款,該表只會有資料的插入,不會有資料的刪、改。表中資料如下

  產品需求

    分頁展示如下列表(具體的過濾條件就不列了,我們就當是初始狀態,還未輸入過濾條件)

     實現比較簡單,t_custmor_credit_record 左關聯 t_custmor_deposit 就好,但是我們的額度記錄表與需求列表有些許的出入,需要做一下簡單的行轉列。

  需求實現

    我們先來看看最初的SQL查詢,這可能是很多人最容易想到的

SELECT MIN(tcd.channal) channal, MAX(tccr.id) mId,tccr.login_name,tccr.bill_no,tccr.create_time,
    IF(credit_type=1,amount_before,0) AS freeBefore,
    IF(credit_type=1,amount_change,0) AS freeChange,
    IF(credit_type=1,amount_after,0) AS freeAfter,
    IF(credit_type=2,amount_before,0) AS freezeBefore,
    IF(credit_type=2,amount_change,0) AS freezeChange,
    IF(credit_type=2,amount_after,0) AS freezeAfter,
    IF(credit_type=3,amount_before,0) AS promotionBefore,
    IF(credit_type=3,amount_change,0) AS promotionChange,
    IF(credit_type=3,amount_after,0) AS promotionAfter
FROM t_customer_credit_record tccr
LEFT JOIN t_customer_deposit tcd ON tccr.bill_no = tcd.bill_no
GROUP BY tccr.bill_no,tccr.login_name,tccr.create_time
ORDER BY mId desc
LIMIT 0, 10;
View Code

    資料量少的時候,也許能在我們接受的時間內查出我們需要的結果,一旦資料量多了,這個SQL就跑不動了;我們先看下 60w 資料的情況下,我們只進行 t_custmor_credit_record 單表查詢

SELECT MAX(id) mId,login_name,bill_no,create_time,
    IF(credit_type=1,amount_before,0) AS freeBefore,
    IF(credit_type=1,amount_change,0) AS freeChange,
    IF(credit_type=1,amount_after,0) AS freeAfter,
    IF(credit_type=2,amount_before,0) AS freezeBefore,
    IF(credit_type=2,amount_change,0) AS freezeChange,
    IF(credit_type=2,amount_after,0) AS freezeAfter,
    IF(credit_type=3,amount_before,0) AS promotionBefore,
    IF(credit_type=3,amount_change,0) AS promotionChange,
    IF(credit_type=3,amount_after,0) AS promotionAfter
FROM t_customer_credit_record
GROUP BY bill_no,login_name,create_time
ORDER BY mId desc
LIMIT 0, 10;
View Code

    效果如下

    花了近 8 秒,這還只是單表,如果執行上面的聯表SQL,那時間又得增加不少(我試驗的結果是直接卡住了,看不到查詢結果);

  優化處理

    加索引

      查詢慢的時候,我們最容易想到的優化方式往往就是加索引;上述SQL執行的時候,t_custmor_credit_record 和 t_custmor_deposit都沒有建索引(主鍵索引除外),那麼我們就加索引唄。我的專案中加的是唯一索引,做了唯一約束,那我這裡也加唯一索引

ALTER TABLE t_customer_credit_record ADD UNIQUE uk_unique (bill_no,login_name,create_time,credit_type);
ALTER TABLE t_customer_deposit ADD UNIQUE uk_billno (bill_no);

      此時我們看下SQL執行效果

      我們發現,t_custmor_credit_record 單表查詢的效率幾乎沒變,將近 8 秒,但 t_custmor_credit_record 與 t_custmor_deposit 聯表的查詢卻在 11 秒內有結果了。加了索引為什麼還這麼慢了? 難道沒走索引?

      我們是不是發現了什麼? IF函式對聯表查詢是否走索引有影響,也對單表的查詢速度有影響。上圖中的 t_custmor_credit_record 單表查詢,有IF函式,查詢時間近 8 秒,沒有IF函式,查詢時間 2 秒左右;t_custmor_credit_record 與 t_custmor_deposit 聯表查,有IF函式,t_custmor_credit_record 走的是全表查,查詢時間近 11 秒,沒有IF函式,t_custmor_credit_record 走的是索引,查詢時間 3 秒不到。那麼我們有沒有什麼辦法拿掉這個IF函式呢?

    使用 CASE...WHEN....THEN 代替 IF

SELECT MAX(id) mId,login_name,bill_no,create_time,
    CASE credit_type WHEN 1 THEN amount_before ELSE 0 END AS freeBefore,
    CASE credit_type WHEN 1 THEN amount_change ELSE 0 END AS freeChange,
    CASE credit_type WHEN 1 THEN amount_after ELSE 0 END AS freeAfter,
    CASE credit_type WHEN 2 THEN amount_before ELSE 0 END AS freeChange,
    CASE credit_type WHEN 2 THEN amount_change ELSE 0 END AS freeChange,
    CASE credit_type WHEN 2 THEN amount_after ELSE 0 END AS freeChange,
    CASE credit_type WHEN 3 THEN amount_before ELSE 0 END AS promotionBefore,
    CASE credit_type WHEN 3 THEN amount_change ELSE 0 END AS promotionChange,
    CASE credit_type WHEN 3 THEN amount_after ELSE 0 END AS promotionAfter
FROM t_customer_credit_record
GROUP BY bill_no,login_name,create_time
ORDER BY mId desc
LIMIT 0, 10;

SELECT MIN(tcd.channal) channal, MAX(tccr.id) mId,tccr.login_name,tccr.bill_no,tccr.create_time,
    CASE credit_type WHEN 1 THEN amount_before ELSE 0 END AS freeBefore,
    CASE credit_type WHEN 1 THEN amount_change ELSE 0 END AS freeChange,
    CASE credit_type WHEN 1 THEN amount_after ELSE 0 END AS freeAfter,
    CASE credit_type WHEN 2 THEN amount_before ELSE 0 END AS freeChange,
    CASE credit_type WHEN 2 THEN amount_change ELSE 0 END AS freeChange,
    CASE credit_type WHEN 2 THEN amount_after ELSE 0 END AS freeChange,
    CASE credit_type WHEN 3 THEN amount_before ELSE 0 END AS promotionBefore,
    CASE credit_type WHEN 3 THEN amount_change ELSE 0 END AS promotionChange,
    CASE credit_type WHEN 3 THEN amount_after ELSE 0 END AS promotionAfter
FROM t_customer_credit_record tccr
LEFT JOIN t_customer_deposit tcd ON tccr.bill_no = tcd.bill_no
GROUP BY tccr.bill_no,tccr.login_name,tccr.create_time
ORDER BY mId desc
LIMIT 0, 10;
View Code

      我們可以看到,執行時間與 IF 所差無幾,執行計劃也是與 IF 的一致,這也就反映出不是 IF的問題,應該是 GROUP BY 的問題。我們用 GROUP BY 結合 IF(或 CASE...WHEN....THEN),就是為了將 3 條額度記錄合併成一條、行轉列之後輸出我們想要的結果,那有沒有不用 GROUP BY、又能實現我們需求的方式了?

    自聯代替 GROUP BY

      我們再仔細琢磨下這個需求,咋一看,確實需要行轉列,那麼就需要用到 GROUP BY,那麼效率也就低了,這似乎是無解了? 真的非要行轉列嗎,假設我們將額度記錄拆分成 3 張表:一張表只存自由資金的額度變化、一張表只存凍結資金的額度變化、一張表只存優惠的額度變化,這樣是不是隻需要聯表查而不要用 GROUP BY 來進行行轉列了? 有小夥伴有可能會問:t_custmor_credit_record 表已經定了,資料都跑了不少了,再將其進行拆分,既要改表(同時還要遷移資料),還要改程式碼,工程量會很大! 我們換個角度來看 t_custmor_credit_record ,目前它是 3 中額度記錄的一個總和表,我們能不能從它的身上做文章,變化出我們想要的那 3 張表,然後進行聯表查詢呢? 肯定可以的,類似如下

-- 自由資金額度記錄表
SELECT * FROM t_customer_credit_record WHERE credit_type = 1;
-- 凍結資金額度記錄表
SELECT * FROM t_customer_credit_record WHERE credit_type = 2;
-- 優惠額度記錄表
SELECT * FROM t_customer_credit_record WHERE credit_type = 3;

      接下來的 SQL 怎麼寫,我想大家都知道了吧,自聯就行了,寫法有很多種,常見的寫法有如下 4 種

-- 不用group by,做法1, 個人比較推薦, 但此種方式不支援存款表的過濾條件
SELECT d.channal,a.amount_before AS freeBefore,a.amount_change AS freeChange, a.amount_after freeAfter,
    b.amount_before AS freezeBefore,b.amount_change AS freezeChange, b.amount_after freezeAfter,
    c.amount_before AS promotionBefore,c.amount_change AS promotionChange, c.amount_after promotionAfter
FROM (
    SELECT * FROM t_customer_credit_record WHERE credit_type = 1 ORDER BY id DESC LIMIT 0, 10
) a
LEFT JOIN t_customer_credit_record b ON a.bill_no = b.bill_no AND b.credit_type = 2
LEFT JOIN t_customer_credit_record c ON a.bill_no = c.bill_no AND c.credit_type = 3
LEFT JOIN t_customer_deposit d ON a.bill_no = d.bill_no;

-- 不用group by,做法2, 此種方式支援存款表的過濾條件
SELECT a.channal,a.amount_before AS freeBefore,a.amount_change AS freeChange, a.amount_after freeAfter,
    b.amount_before AS freezeBefore,b.amount_change AS freezeChange, b.amount_after freezeAfter,
    c.amount_before AS promotionBefore,c.amount_change AS promotionChange, c.amount_after promotionAfter
FROM (
    SELECT r.*,d.channal FROM t_customer_credit_record r LEFT JOIN t_customer_deposit d ON r.bill_no = d.bill_no
    WHERE r.credit_type = 1 ORDER BY r.id DESC LIMIT 0, 10
) a
LEFT JOIN t_customer_credit_record b ON a.bill_no = b.bill_no AND b.credit_type = 2
LEFT JOIN t_customer_credit_record c ON a.bill_no = c.bill_no AND c.credit_type = 3;

-- 不用group by,做法3, 這是最容易想到的方法
SELECT d.channal,a.amount_before AS freeBefore,a.amount_change AS freeChange, a.amount_after freeAfter,
    b.amount_before AS freezeBefore,b.amount_change AS freezeChange, b.amount_after freezeAfter,
    c.amount_before AS promotionBefore,c.amount_change AS promotionChange, c.amount_after promotionAfter
FROM t_customer_credit_record a
LEFT JOIN t_customer_credit_record b ON a.bill_no = b.bill_no
LEFT JOIN t_customer_credit_record c ON a.bill_no = c.bill_no
LEFT JOIN t_customer_deposit d ON a.bill_no = d.bill_no
WHERE a.credit_type = 1 AND b.credit_type = 2 AND c.credit_type = 3 
ORDER BY a.id DESC LIMIT 0, 10;

-- 不用group by,做法4
SELECT d.channal,a.amount_before AS freeBefore,a.amount_change AS freeChange, a.amount_after freeAfter,
    b.amount_before AS freezeBefore,b.amount_change AS freezeChange, b.amount_after freezeAfter,
    c.amount_before AS promotionBefore,c.amount_change AS promotionChange, c.amount_after promotionAfter
FROM t_customer_credit_record a
LEFT JOIN t_customer_credit_record b ON a.bill_no = b.bill_no AND b.credit_type = 2
LEFT JOIN t_customer_credit_record c ON a.bill_no = c.bill_no AND c.credit_type = 3
LEFT JOIN t_customer_deposit d ON a.bill_no = d.bill_no
WHERE a.credit_type = 1 
ORDER BY a.id DESC LIMIT 0, 10;
View Code

      執行結果如下

      就目前的資料量而言,4 種寫法的效率一樣,但是資料量再往上走,它們之前還是有效能差別的,大家可以仔細看看這 4 個 SQL 的執行計劃,它們之間還是有區別的。最終我的專案中採用的是第一種寫法

    表重新設計

      我們回過頭去看看 t_customer_credit 和 t_custmor_credit_record,是否真的有必要用 3 條記錄來存放顧客的 3 種額度,一條記錄將使用者的 3 種額度都記錄下來不是更好嗎? 如下所示

-- 自認為更好的表設計
DROP TABLE IF EXISTS t_customer_credit_plus;
CREATE TABLE t_customer_credit_plus (
  id INT(11) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT '自增主鍵',
  login_name VARCHAR(50) NOT NULL COMMENT '登入名',
    free_amount DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '自由資金額度',
    freeze_amount DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '凍結資金額度',
    promotion_amount DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '優惠資金額度',
    create_by VARCHAR(50) NOT NULL COMMENT '建立者',
    create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '建立時間',
    update_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '建立時間',
    update_by VARCHAR(50) NOT NULL COMMENT '修改者',
  PRIMARY KEY (id),
  UNIQUE KEY `uk_login_name` (`login_name`)
);
DROP TABLE IF EXISTS t_customer_credit_record_plus;
CREATE TABLE t_customer_credit_record_plus (
  id INT(11) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT '自增主鍵',
  login_name VARCHAR(50) NOT NULL COMMENT '登入名',
    bill_no VARCHAR(50) NOT NULL COMMENT '訂單號',
    free_amount_before DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '自由資金前額度值',
    free_amount_change DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '自由資金前額度變化值',
    free_amount_after DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '自由資金前後額度值',
    freeze_amount_before DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '凍結資金前額度值',
    freeze_amount_change DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '凍結資金額度變化值',
    freeze_amount_after DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '凍結資金後額度值',
    promotion_amount_before DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '優惠前額度值',
    promotion_amount_change DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '優惠額度變化值',
    promotion_amount_after DECIMAL(22,6) NOT NULL DEFAULT '0.00000' COMMENT '優惠後額度值',
    create_by VARCHAR(50) NOT NULL COMMENT '建立者',
    create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '建立時間',
    remark VARCHAR(500) NOT NULL DEFAULT '' COMMENT '備註',
  PRIMARY KEY (id),
  UNIQUE KEY `uk_unique` (`bill_no`,`login_name`,`create_time`)
);
View Code

      我想很多人都會有相同的感覺吧,但是從拓展性出發,分 3 條記錄的做法更好,為什麼呢? 如果後續新增 1 種或多種另外的額度型別,上述的 1 條記錄的表設計就需要新增欄位來適配了, 但是 3 條記錄的做法,只需要拓展credit_type的值就好了,表無需改動。各有利弊,如何選擇,需要團隊協商之後做出最好的選擇。

      最終專案中採用的還是 3 條記錄存放 3 個額度的方式,沒有采用我說的;原因是:大家都認為效率影響不大,也容易理解,關鍵是拓展性很好,後續很方便就能加入新的額度型別。

    業務上的協調

      最後我們再回到需求上來,這個 存款渠道 真的有必要顯示在額度記錄嗎?

      1、對公司來說,存款記錄越多,那肯定是越好,但我們從實際出發,存款記錄在額度記錄中佔的比例大嗎,這個相信大家也都能想象得到,比例非常低,可能 100 條記錄中會有 1 條;

      2、本來就有單獨的存款頁面展示顧客的存款,去專門的存款記錄頁面看豈不是更直觀?

      最後和產品討論,還真把這一列給拿掉了,那麼我們也就不需要關聯存款表來查了,SQL 更簡單,效率也更高了!

總結

  1、SQL 行轉列,往往是 GROUP BY 配合聚合函式(SUM、MAX、MIN等)來實現,當然也包括 IF 和 CASE...WHEN....THEN;

  2、索引是提高查詢效率的最有效的、也是最常用的方式,我們對查詢的優化都要往索引上靠,EXPLAIN 可以檢視SQL的執行計劃,我們可以從中獲取SQL優化的提示;

  3、一定要結合業務來寫出高效的SQL

    可能很多小夥伴會有這樣的不滿:上述的 3 個額度的例子有點特殊,不具備通用性,上述高效的SQL也只是在你(樓主)的專案中有效。你說的對,但是我們要知道,技術本身就是用來服務業務的,脫離了業務,技術有什麼實際意義? 但是我們回過頭去細看,我舉的例子真的就特殊到獨一無二? 我想還算比較通用吧,還是能套用很多場景的。

  4、要敢於質疑需求

    雖然大多數時候產品都考慮比較周到,但也不能完全保證他沒有不犯迷糊的時候吧。有疑惑就向產品問清楚,我們實現的也更快、更準確。一定不要對疑問藏著掖著,以我親身經歷來講,很多時候開發認為的都是對的,如果藏著掖著,那你就準備返工改成你之前認為的那樣吧!