MySql動態行轉列和靜態行轉列

阿新 • • 發佈：2020-09-09

靜態行轉列：

場景：

比如說一個訂單對應多條資料，當狀態（status）=1的時候，數量（num）=25，當狀態（status）=2的時候，數量（num）=45，現在想用一條sql記錄下不同狀態對應的數量為多少，如下圖所示：

sql語句示例：

SELECT trades_id,
MAX(CASE WHEN apply_status=1 THEN pay_change ELSE 0 END) 'num_status1',
MAX(CASE WHEN apply_status=2 THEN pay_change ELSE 0 END) 'num_status2'
FROM b_balance_detail
WHERE site_id=100190
AND apply_status!=4 AND trades_id = 1001901531475622312
//上述sql是查詢了一個訂單的情況，當多個時應當加個group by進行分組查詢 如下：
SELECT trades_id,
MAX(CASE WHEN apply_status=1 THEN pay_change ELSE 0 END) 'num_status1',
MAX(CASE WHEN apply_status=2 THEN pay_change ELSE 0 END) 'num_status2'
FROM b_balance_detail 
group by trades_id

動態行轉列：

三張表：學生表、課程表、成績表

#學生表
CREATE TABLE `student` (
    `stuid` VARCHAR(16) NOT NULL COMMENT '學號',
    `stunm` VARCHAR(20) NOT NULL COMMENT '學生姓名',
    PRIMARY KEY (`stuid`)
)
COLLATE='utf8_general_ci'
ENGINE=InnoDB;

#課程表
CREATE TABLE `courses` (

    `courseno` VARCHAR(20) NOT NULL,
    `coursenm` VARCHAR(100) NOT NULL,
    PRIMARY KEY (`courseno`)
)
COMMENT='課程表'
COLLATE='utf8_general_ci'
ENGINE=InnoDB;

#成績表
CREATE TABLE `score` (
    `stuid` VARCHAR(16) NOT NULL,
    `courseno` VARCHAR(20) NOT NULL,
    `scores` FLOAT NULL DEFAULT NULL,
    PRIMARY KEY (`stuid`, `courseno`)
)
COLLATE='utf8_general_ci'
ENGINE=InnoDB;

以上就是資料庫表的結構，沒有建立外來鍵，但是可以看到成績表中關聯關係。

資料準備：

/*學生表資料*/
Insert Into student (stuid, stunm) Values('1001', '張三');
Insert Into student (stuid, stunm) Values('1002', '李四');
Insert Into student (stuid, stunm) Values('1003', '趙二');
Insert Into student (stuid, stunm) Values('1004', '王五');
Insert Into student (stuid, stunm) Values('1005', '劉青');
Insert Into student (stuid, stunm) Values('1006', '周明');

/*課程表資料*/
Insert Into courses (courseno, coursenm) Values('C001', '大學語文');
Insert Into courses (courseno, coursenm) Values('C002', '新視野英語');
Insert Into courses (courseno, coursenm) Values('C003', '離散數學');
Insert Into courses (courseno, coursenm) Values('C004', '概率論與數理統計');
Insert Into courses (courseno, coursenm) Values('C005', '線性代數');
Insert Into courses (courseno, coursenm) Values('C006', '高等數學(一)');
Insert Into courses (courseno, coursenm) Values('C007', '高等數學(二)');

/*成績表資料*/
Insert Into score(stuid, courseno, scores) Values('1001', 'C001', 67);
Insert Into score(stuid, courseno, scores) Values('1002', 'C001', 68);
Insert Into score(stuid, courseno, scores) Values('1003', 'C001', 69);
Insert Into score(stuid, courseno, scores) Values('1004', 'C001', 70);
Insert Into score(stuid, courseno, scores) Values('1005', 'C001', 71);
Insert Into score(stuid, courseno, scores) Values('1006', 'C001', 72);
Insert Into score(stuid, courseno, scores) Values('1001', 'C002', 87);
Insert Into score(stuid, courseno, scores) Values('1002', 'C002', 88);
Insert Into score(stuid, courseno, scores) Values('1003', 'C002', 89);
Insert Into score(stuid, courseno, scores) Values('1004', 'C002', 90);
Insert Into score(stuid, courseno, scores) Values('1005', 'C002', 91);
Insert Into score(stuid, courseno, scores) Values('1006', 'C002', 92);
Insert Into score(stuid, courseno, scores) Values('1001', 'C003', 83);
Insert Into score(stuid, courseno, scores) Values('1002', 'C003', 84);
Insert Into score(stuid, courseno, scores) Values('1003', 'C003', 85);
Insert Into score(stuid, courseno, scores) Values('1004', 'C003', 86);
Insert Into score(stuid, courseno, scores) Values('1005', 'C003', 87);
Insert Into score(stuid, courseno, scores) Values('1006', 'C003', 88);
Insert Into score(stuid, courseno, scores) Values('1001', 'C004', 88);
Insert Into score(stuid, courseno, scores) Values('1002', 'C004', 89);
Insert Into score(stuid, courseno, scores) Values('1003', 'C004', 90);
Insert Into score(stuid, courseno, scores) Values('1004', 'C004', 91);
Insert Into score(stuid, courseno, scores) Values('1005', 'C004', 92);
Insert Into score(stuid, courseno, scores) Values('1006', 'C004', 93);
Insert Into score(stuid, courseno, scores) Values('1001', 'C005', 77);
Insert Into score(stuid, courseno, scores) Values('1002', 'C005', 78);
Insert Into score(stuid, courseno, scores) Values('1003', 'C005', 79);
Insert Into score(stuid, courseno, scores) Values('1004', 'C005', 80);
Insert Into score(stuid, courseno, scores) Values('1005', 'C005', 81);
Insert Into score(stuid, courseno, scores) Values('1006', 'C005', 82);
Insert Into score(stuid, courseno, scores) Values('1001', 'C006', 77);
Insert Into score(stuid, courseno, scores) Values('1002', 'C006', 78);
Insert Into score(stuid, courseno, scores) Values('1003', 'C006', 79);
Insert Into score(stuid, courseno, scores) Values('1004', 'C006', 80);
Insert Into score(stuid, courseno, scores) Values('1005', 'C006', 81);
Insert Into score(stuid, courseno, scores) Values('1006', 'C006', 82);

為什麼要行轉列？？？？

上面是進行成績查詢的時候看到的縱列的結果，但是我們想要的是下面的結果：

那麼需要這樣的結果就要進行行轉列來操作了。

Select st.stuid, st.stunm, 
    MAX(CASE c.coursenm WHEN '大學語文' THEN s.scores ELSE 0 END ) '大學語文',
    MAX(CASE c.coursenm WHEN '新視野英語' THEN ifnull(s.scores,0) ELSE 0 END ) '新視野英語', 
    MAX(CASE c.coursenm WHEN '離散數學' THEN ifnull(s.scores,0) ELSE 0 END ) '離散數學',
    MAX(CASE c.coursenm WHEN '概率論與數理統計' THEN ifnull(s.scores,0) ELSE 0 END ) '概率論與數理統計',
    MAX(CASE c.coursenm WHEN '線性代數' THEN ifnull(s.scores,0) ELSE 0 END ) '線性代數',
    MAX(CASE c.coursenm WHEN '高等數學(一)' THEN ifnull(s.scores,0) ELSE 0 END ) '高等數學(一)',
    MAX(CASE c.coursenm WHEN '高等數學(二)' THEN ifnull(s.scores,0) ELSE 0 END ) '高等數學(二)'
From Student  st
Left Join score s On st.stuid = s.stuid
Left Join courses c On c.courseno = s.courseno
Group by st.stuid

看上面的語句可以看出，我們是在知道固定的幾門課程之後，可以使用：

MAX(CASE c.coursenm WHEN '線性代數' THEN ifnull(s.scores,0) ELSE 0 END ) '線性代數',

這樣的語句來實現行轉列，也就是我們一開始所說的的靜態行轉列示例。

但我們都知道，課程不僅僅這幾門，如果用上面的語句去寫，第一要確定有多少課程，這麼多課程的課程名要再拿出來，那樣的話寫一個查詢語句下來，可是要寫很多了。那麼就想能不能動態進行行轉列的操作？答案當然是肯定的了！

那麼接下來才是我們的想要引出的話題“動態行轉列”，並且親測有效：

那麼如何進行動態行轉列呢？

首先我們要動態獲取這樣的語句：

MAX(CASE c.coursenm WHEN '大學語文' THEN s.scores ELSE 0 END ) '大學語文',
MAX(CASE c.coursenm WHEN '線性代數' THEN ifnull(s.scores,0) ELSE 0 END ) '線性代數', 
MAX(CASE c.coursenm WHEN '離散數學' THEN ifnull(s.scores,0) ELSE 0 END ) '離散數學'

而不是像上面那樣一句句寫出來，那如何得到這樣的語句呢？

這裡就要用到SQL語句拼接了。具體就是下面的語句

SELECT
  GROUP_CONCAT(DISTINCT
    CONCAT(
      'MAX(IF(c.coursenm = ''',
      c.coursenm,
      ''', s.scores, 0)) AS ''',
      c.coursenm, ''''
    )
  )
FROM courses c;

得到的結果就是：

MAX(IF(c.coursenm = '大學語文', s.scores, 0)) AS '大學語文',
MAX(IF(c.coursenm = '新視野英語', s.scores, 0)) AS '新視野英語',
MAX(IF(c.coursenm = '離散數學', s.scores, 0)) AS '離散數學',
MAX(IF(c.coursenm = '概率論與數理統計', s.scores, 0)) AS '概率論與數理統計',
MAX(IF(c.coursenm = '線性代數', s.scores, 0)) AS '線性代數',
MAX(IF(c.coursenm = '高等數學(一)', s.scores, 0)) AS '高等數學(一)',
MAX(IF(c.coursenm = '高等數學(二)', s.scores, 0)) AS '高等數學(二)'

對，沒錯，就是我們上面進行行轉列查詢要用的語句，那樣就不用知道多少課程和這些課程的名字，只要這樣幾行程式碼便可以得到動態的列了。

group_concat()，手冊上說明:該函式返回帶有來自一個組的連線的非NULL值的字串結果。
通俗點理解，其實是這樣的：group_concat()會計算哪些行屬於同一組，將屬於同一組的列顯示出來。要返回哪些列，由函式引數(就是欄位名)決定。分組必須有個標準，就是根據group by指定的列進行分組。

concat() 操作的引數是陣列，那麼新增的是陣列中的元素，而不是陣列。該方法不會改變現有的陣列，而僅僅會返回被連線陣列的一個副本

動態的列是拿到了，那如何再結合SQL語句進行查詢得到結果呢？
這裡要說明一點，因為用到了拼接函式，如果像上面的查詢語句，只是把那幾行語句替換掉，也就是下面這樣：

Select st.stuid, st.stunm, 
(
    SELECT
      GROUP_CONCAT(DISTINCT
        CONCAT(
          'MAX(IF(c.coursenm = ''',
          c.coursenm,
          ''', s.scores, NULL)) AS ',
          c.coursenm
        )
      )
    FROM courses c
)
From Student  st
Left Join score s On st.stuid = s.stuid
Left Join courses c On c.courseno = s.courseno
Group by st.stuid;

然而得到的結果卻是這樣的：

這裡我就不多做贅述了，想必大家也明白。那麼既然這樣不行，那該怎麼做呢？

沒錯，這裡就要像普通的那些語句那樣，進行宣告，將語句拼接完整之後，再執行，也就是下面這樣

SET @sql = NULL;
SELECT
  GROUP_CONCAT(DISTINCT
    CONCAT(
      'MAX(IF(c.coursenm = ''',
      c.coursenm,
      ''', s.scores, 0)) AS ''',
      c.coursenm, ''''
    )
  ) INTO @sql
FROM courses c;
 
SET @sql = CONCAT('Select st.stuid, st.stunm, ', @sql, 
                        ' From Student  st 
                        Left Join score s On st.stuid = s.stuid
                        Left Join courses c On c.courseno = s.courseno
                        Group by st.stuid');
PREPARE stmt FROM @sql;
EXECUTE stmt;
DEALLOCATE PREPARE stmt;

直接執行這些語句，得到如下結果。

MySQL prepare語法：
PREPARE statement_name FROM preparable_SQL_statement; /*定義*/
EXECUTE statement_name [USING @var_name [, @var_name] ...]; /*執行預處理語句*/
{DEALLOCATE | DROP} PREPARE statement_name /*刪除定義*/ ;

當然這個語句拼接中的查詢可以加入條件查詢，比如我們要查詢學號是1003的成績
也就是下面這樣

語句則如下

SET @sql = NULL;
SET @stuid = '1003';
SELECT
  GROUP_CONCAT(DISTINCT
    CONCAT(
      'MAX(IF(c.coursenm = ''',
      c.coursenm,
      ''', s.scores, 0)) AS ''',
      c.coursenm, ''''
    )
  ) INTO @sql
FROM courses c;
 
SET @sql = CONCAT('Select st.stuid, st.stunm, ', @sql, 
                        ' From Student  st 
                        Left Join score s On st.stuid = s.stuid
                        Left Join courses c On c.courseno = s.courseno
                        Where st.stuid = ''', @stuid, '''
                        Group by st.stuid');
PREPARE stmt FROM @sql;
EXECUTE stmt;
DEALLOCATE PREPARE stmt;

對比前面的語句，我們可以看到在第二行的Left join後面我改了一些，還有就是前面的變數加了一個@stuid [ 注：這裡的 @ 符號是在SQL語句定義變數習慣用法，我個人理解應該是用來區分吧！

那麼問題來了，行轉列的查詢已經實現了，怎麼標題中還寫著儲存過程？對，沒錯，就是儲存過程！

像上面的語句，我們如果直接在MySQL中操作是沒問題的，但如果用到專案中，那麼這個語句顯然我們沒法用，而且我這次做的專案是結合使用MyBatis，大家都知道在MyBatis中的XML檔案中可以自己寫SQL語句，但是這樣的很顯然我們沒法放到XML檔案中。

而且最關鍵的是，這裡不能用 If 條件，好比我們要判斷學號是否為空或者等於0再加上條件進行查詢，可是這裡不支援。
沒錯就是下面這樣:

SET @sql = NULL;
SET @stuid = '1003';
SET @courseno = 'C002';
 
SELECT
  GROUP_CONCAT(DISTINCT
    CONCAT(
      'MAX(IF(c.coursenm = ''',
      c.coursenm,
      ''', s.scores, 0)) AS ''',
      c.coursenm, ''''
    )
  ) INTO @sql
FROM courses c;
 
SET @sql = CONCAT('Select st.stuid, st.stunm, ', @sql, 
                        ' From Student  st 
                        Left Join score s On st.stuid = s.stuid
                        Left Join courses c On c.courseno = s.courseno');
                        
IF @stuid is not null and @stuid != 0 then
SET @sql = CONCAT(@sql, ' Where st.stuid = ''', @stuid, '''');
END IF;    
 
SET @sql = CONCAT(@sql, ' Group by st.stuid');
 
PREPARE stmt FROM @sql;
EXECUTE stmt;
DEALLOCATE PREPARE stmt;

對，我就是加上 if 之後人家就是不支援，就是這麼任性。

所以就要用到儲存過程啦，而且用儲存過程的好處是，方便我們呼叫，相當於一個函式，其他可能也是類似的查詢不需再重複寫程式碼，直接調儲存過程就好，還能隨心所欲的加上if條件判斷，多麼美好的事情，哈哈~。

那麼說到儲存過程，這裡該如何寫呢？
建立儲存過程的語句我就不多寫了，這裡呢把上面的查詢語句直接放到建立儲存過程的begin和end直接就可以了，如下：

DELIMITER &&  
drop procedure if exists SP_QueryData;
Create Procedure SP_QueryData(IN stuid varchar(16))
READS SQL DATA 
BEGIN
 
SET @sql = NULL;
SET @stuid = NULL;
SELECT
  GROUP_CONCAT(DISTINCT
    CONCAT(
      'MAX(IF(c.coursenm = ''',
      c.coursenm,
      ''', s.scores, 0)) AS ''',
      c.coursenm, '\''
    )
  ) INTO @sql
FROM courses c;
 
SET @sql = CONCAT('Select st.stuid, st.stunm, ', @sql, 
                        ' From Student  st 
                        Left Join score s On st.stuid = s.stuid
                        Left Join courses c On c.courseno = s.courseno');
                        
IF stuid is not null and stuid <> '' then
SET @stuid = stuid;
SET @sql = CONCAT(@sql, ' Where st.stuid = \'', @stuid, '\'');
END IF;    
 
SET @sql = CONCAT(@sql, ' Group by st.stuid');
 
PREPARE stmt FROM @sql;
EXECUTE stmt;
DEALLOCATE PREPARE stmt;
 
END &&  
 
DELIMITER ;

嗯，對比上面簡單的SQL語句可以看出，這裡使用了 if 語句，對學號進行了判斷

不過這裡要注意一點，這裡的if語句不像我們平時JAVA那種寫法也就是下面:

if(條件)
{
    要執行的語句塊
}

對，在SQL裡面的if語句不一樣，不需要括號啊什麼的，就像直接說英文一樣。

IF @stuid is not null and @stuid != 0 then
SET @sql = CONCAT(@sql, ' Where st.stuid = ''', @stuid, '''');
END IF;

嗯，就是這麼簡單明瞭，如果條件滿足，那麼就怎麼樣，然後結束。

然後我們就可以傳引數呼叫這個儲存過程了：

CALL `SP_QueryData`('1001');

得到如下結果

當然我們也可以直接傳個空串過去：

CALL `SP_QueryData`(' ');

同樣得到我們想要的結果：

好了，以上就是這次我在MYSQL進行動態行轉列的實現過程。

遇到的問題總結：

哦哦，最後順帶提及一句，我寫這個的時候發現Mysql的concat或者concat_ws函式裡可以case when，兒group_concat函式裡case when做判斷會報錯！

還有個問題，就是儲存過程裡有一段程式碼：

PREPARE stmt FROM @sql;
EXECUTE stmt;
DEALLOCATE PREPARE stmt;

如果不讓Mysql預載入執行的話儲存過程不起效果！

MySql動態行轉列和靜態行轉列

資料準備：

MySql動態行轉列和靜態行轉列

動態分配記憶體(malloc)和靜態分配記憶體(陣列)生存期

行內元素和與行內塊元素的margin-top問題

mysql的行轉列和列轉行

Mysql：mysql行轉列(數值行和字元行)

SQL行轉列和列轉行程式碼詳解

hive表實現行轉列和列轉行

行轉列和列轉行，經典案例解析

Hive面試題之連續登入、行轉列和列轉行分析

Oracle行轉列和列轉行的方式

解決Python spyder顯示不全df列和行的問題

XRTable 表新增列和行資料

【轉】一千行MySQL學習筆記

Kettle 列拆分為多行、列轉行、行轉列

MySql中的資料查詢語言（DQL）二：分組函式/聚合函式/多行處理函式和分組查詢

資料庫逗號拼接的字串需去重涉及行轉列去重,list轉pgae

列轉行，行轉列（hivesql）

QTableWidget在單元格中動態新增的控制元件，獲取所在列行

ORACLE 動態註冊和靜態註冊的區別(轉)

Mysql中的表鎖和行鎖

MySql動態行轉列和靜態行轉列

資料準備：

相關推薦