14. 變數、流程控制與遊標

阿新 • • 發佈：2022-02-05

一、變數

在MySQL資料庫的儲存過程和函式中，可以使用變數來儲存查詢或計算的中間結果資料，或者輸出最終的結果資料。在 MySQL 資料庫中，變數分為系統變數以及使用者自定義變數。

1.1、系統變數

1.1.1、系統變數分類

變數由系統定義，不是使用者定義，屬於伺服器層面。啟動MySQL服務，生成MySQL服務例項期間，MySQL將為MySQL伺服器記憶體中的系統變數賦值，這些系統變數定義了當前MySQL服務例項的屬性、特徵。這些系統變數的值要麼是編譯MySQL時引數的預設值，要麼是配置檔案（例如my.ini等）中的引數值。

系統變數分為全域性系統變數（需要新增global 關鍵字）以及會話系統變數（需要新增 session

關鍵字），有時也把全域性系統變數簡稱為全域性變數，有時也把會話系統變數稱為local變數。如果不寫，預設會話級別。靜態變數（在 MySQL 服務例項執行期間它們的值不能使用 set 動態修改）屬於特殊的全域性系統變數。

每一個MySQL客戶機成功連線MySQL伺服器後，都會產生與之對應的會話。會話期間，MySQL服務例項會在MySQL伺服器記憶體中生成與該會話對應的會話系統變數，這些會話系統變數的初始值是全域性系統變數值的複製。如下圖：

全域性系統變數針對於所有會話（連線）有效，但不能跨重啟
會話系統變數僅針對於當前會話（連線）有效。會話期間，當前會話對某個會話系統變數值的修改，不會影響其他會話同一個會話系統變數的值。

會話1對某個全域性系統變數值的修改會導致會話2中同一個全域性系統變數值的修改。

在MySQL中有些系統變數只能是全域性的，例如 max_connections 用於限制伺服器的最大連線數；有些系統變數作用域既可以是全域性又可以是會話，例如 character_set_client 用於設定客戶端的字符集；有些系統變數的作用域只能是當前會話，例如 pseudo_thread_id 用於標記當前會話的 MySQL 連線 ID。

1.1.2、檢視系統變數

1.1.2.1、檢視所有或部分系統變數

-- 檢視所有全域性變數
SHOW GLOBAL VARIABLES;

-- 檢視所有會話變數
SHOW SESSION VARIABLES;
SHOW VARIABLES;

-- 檢視滿足條件的部分系統變數。
SHOW GLOBAL VARIABLES LIKE '%識別符號%';

-- 檢視滿足條件的部分會話變數
SHOW SESSION VARIABLES LIKE '%識別符號%';

example:

-- 檢視所有全域性變數
SHOW GLOBAL VARIABLES;

-- 檢視所有會話變數
SHOW SESSION VARIABLES;
SHOW VARIABLES;

-- 檢視滿足條件的部分系統變數。
SHOW GLOBAL VARIABLES LIKE '%admin_%';

-- 檢視滿足條件的部分會話變數
SHOW SESSION VARIABLES LIKE '%character_%';

1.1.2.2、檢視指定系統變數

作為 MySQL 編碼規範，MySQL 中的系統變數以兩個“@”開頭，其中“@@global”僅用於標記全域性系統變數，“@@session”僅用於標記會話系統變數。“@@”首先標記會話系統變數，如果會話系統變數不存在，則標記全域性系統變數。

-- 檢視指定的系統變數的值
SELECT @@global.變數名;

-- 檢視指定的會話變數的值
SELECT @@session.變數名;

-- 檢視指定的系統變數：先查詢會話系統變數，如果沒有，在查詢全域性系統變數
SELECT @@變數名;

example:

-- 檢視指定的系統變數的值
SELECT @@global.max_connections;

-- 檢視指定的會話變數的值
SELECT @@session.pseudo_thread_id;

-- 檢視指定的系統變數
SELECT @@character_set_client;

1.1.3、修改系統變數的值

方式1：修改MySQL配置檔案，繼而修改MySQL系統變數的值（該方法需要重啟MySQL服務）
方式2：在MySQL服務執行期間，使用“set”命令重新設定系統變數的值
- 針對當前資料庫例項是有效的，一旦重啟mysql服務或建立新的會話，就失效了

-- 為某個系統變數賦值
SET @@global.變數名=變數值;
SET GLOBAL 變數名=變數值;


-- 為某個會話變數賦值
SET @@session.變數名=變數值;
SET SESSION 變數名=變數值;

example:

-- 為某個系統變數賦值
SELECT @@global.max_connections;
SET @@global.max_connections = 161;
SELECT @@global.max_connections;
SET GLOBAL max_connections = 171;
SELECT @@global.max_connections;

-- 為某個會話變數賦值
SELECT @@session.character_set_client;
SET @@session.character_set_client = 'gbk';
SELECT @@session.character_set_client;
SET SESSION character_set_client = 'utf8';
SELECT @@session.character_set_client;

1.2、使用者變數

1.2.1、使用者變數分類

使用者變數是使用者自己定義的，作為 MySQL 編碼規範，MySQL 中的使用者變數以一個“@”開頭。根據作用範圍不同，又分為會話使用者變數和區域性變數。

會話使用者變數：作用域和會話變數一樣，只對當前連線會話有效。
區域性變數：只在 BEGIN 和 END 語句塊中有效。區域性變數只能在儲存過程和函式中使用。

1.2.2、會話使用者變數

1.2.2.1、變數的定義

-- 方式1：“=”或“:=”
SET @使用者變數 = 值;
SET @使用者變數 := 值;

-- 方式2：“:=” 或 INTO關鍵字
SELECT @使用者變數 := 表示式 [FROM 等子句];
SELECT 表示式 INTO @使用者變數  [FROM 等子句];

example:

CREATE DATABASE IF NOT EXISTS test14;
USE test14;

CREATE TABLE employees
AS
SELECT * FROM atguigudb.employees;

CREATE TABLE departments
AS 
SELECT * FROM atguigudb.departments;

SET @num1 = 1;
SET @num2 := 2;
SET @sum := @num1+@num2;


SELECT @count := COUNT(*) FROM employees;
SELECT AVG(salary) INTO @avg_salary FROM employees;

1.2.2.2、檢視使用者變數的值（檢視、比較、運算等）

SELECT @使用者變數

example:

SELECT @sum;
SELECT @count;
SELECT @avg_salary;

1.2.3、區域性變數

定義：可以使用DECLARE語句定義一個區域性變數
作用域：僅僅在定義它的 BEGIN ... END 中有效，即只能在儲存過程或儲存函式中使用
位置：只能放在 BEGIN ... END 中，而且只能放在第一句

BEGIN
	-- 宣告區域性變數，，必須宣告在首行，如果沒有DEFAULT子句，初始值為NULL
	DECLARE 變數名1 變數資料型別 [DEFAULT 變數預設值];
	DECLARE 變數名2,變數名3,... 變數資料型別 [DEFAULT 變數預設值];

	-- 為區域性變數賦值
	SET 變數名1 = 值;
	SELECT 值 INTO 變數名2 [FROM 子句];

	-- 檢視區域性變數的值
	SELECT 變數1,變數2,變數3;
END

example:

USE test14;

DELIMITER $

CREATE PROCEDURE test_var()
BEGIN
	-- 宣告區域性變數
	DECLARE a,b INT DEFAULT 0;
	DECLARE employee_name VARCHAR(25);
	
	-- 為區域性變數賦值
	SET a = 1;
	SET b := 2;
	SELECT last_name INTO employee_name FROM employees WHERE employee_id = 100;
	
	-- 查詢區域性變數
	SELECT a,b,employee_name;
END $

DELIMITER ;

CALL test_var();

1.2.4、對比會話使用者變數與區域性變數

變數型別	作用域	定義位置	語法
會話使用者變數	當前會話	會話的任何地方	加@符號，不用指定型別
區域性變數	定義它的BEGIN END中	BEGIN END的第一句話	一般不用加@,需要指定型別

二、定義條件與處理程式

定義條件是事先定義程式執行過程中可能遇到的問題，處理程式定義了在遇到問題時應當採取的處理方式，並且保證儲存過程或函式在遇到警告或錯誤時能繼續執行。這樣可以增強儲存程式處理問題的能力，避免程式異常停止執行。

說明：定義條件和處理程式在儲存過程、儲存函式中都是支援的。

2.1、定義條件

DECLARE 錯誤名稱 CONDITION FOR 錯誤碼（或錯誤條件）;

錯誤碼的說明：

MySQL_error_code和sqlstate_value都可以表示MySQL的錯誤。
- MySQL_error_code是數值型別錯誤程式碼。
- sqlstate_value是長度為5的字串型別錯誤程式碼。
例如，在ERROR 1418 (HY000)中，1418是MySQL_error_code，'HY000'是sqlstate_value。
例如，在ERROR 1142（42000）中，1142是MySQL_error_code，'42000'是sqlstate_value。

example:

-- 方式1：使用MySQL_error_code
DECLARE Field_Not_Be_Null CONDITION FOR 1048;
-- 方式2：使用sqlstate_value
DECLARE command_not_allowed CONDITION FOR SQLSTATE '42000';

2.3 定義處理程式

DECLARE 處理方式 HANDLER FOR 錯誤型別 處理語句;

處理方式：處理方式有3個取值：CONTINUE、EXIT、UNDO。
- CONTINUE：表示遇到錯誤不處理，繼續執行。
- EXIT：表示遇到錯誤馬上退出。
- UNDO：表示遇到錯誤後撤回之前的操作。MySQL中暫時不支援這樣的操作。
錯誤型別（即條件）可以有如下取值：
- SQLSTATE '字串錯誤碼'：表示長度為5的sqlstate_value型別的錯誤程式碼；
- MySQL_error_code：匹配數值型別錯誤程式碼；
- 錯誤名稱：表示DECLARE ... CONDITION定義的錯誤條件名稱。
- SQLWARNING：匹配所有以01開頭的SQLSTATE錯誤程式碼；
- NOT FOUND：匹配所有以02開頭的SQLSTATE錯誤程式碼；
- SQLEXCEPTION：匹配所有沒有被SQLWARNING或NOT FOUND捕獲的SQLSTATE錯誤程式碼；
處理語句：如果出現上述條件之一，則採用對應的處理方式，並執行指定的處理語句。語句可以是像“SET 變數 = 值”這樣的簡單語句，也可以是使用BEGIN ... END編寫的複合語句。

example:

-- 方法1：捕獲sqlstate_value
DECLARE CONTINUE HANDLER FOR SQLSTATE '42S02' SET @info = 'NO_SUCH_TABLE';

-- 方法2：捕獲mysql_error_value
DECLARE CONTINUE HANDLER FOR 1146 SET @info = 'NO_SUCH_TABLE';

-- 方法3：先定義條件，再呼叫
DECLARE no_such_table CONDITION FOR 1146;
DECLARE CONTINUE HANDLER FOR NO_SUCH_TABLE SET @info = 'NO_SUCH_TABLE';

-- 方法4：使用SQLWARNING
DECLARE EXIT HANDLER FOR SQLWARNING SET @info = 'ERROR';

-- 方法5：使用NOT FOUND
DECLARE EXIT HANDLER FOR NOT FOUND SET @info = 'NO_SUCH_TABLE';

-- 方法6：使用SQLEXCEPTION
DECLARE EXIT HANDLER FOR SQLEXCEPTION SET @info = 'ERROR';

2.4、案例解決

在儲存過程中，定義處理程式，捕獲sqlstate_value值，當遇到MySQL_error_code值為1048時，執行CONTINUE操作，並且將@proc_value的值設定為-1。

USE test14;

DELIMITER //

CREATE PROCEDURE UpdateDataNoCondition()
BEGIN
	-- 定義處理程式
	-- 處理方式1
	-- DECLARE CONTINUE HANDLER FOR 1048 SET @proc_value = -1;
	-- 處理方式2
	-- DECLARE CONTINUE HANDLER FOR SQLSTATE '2300' SET @proc_value = -1;
	-- 處理方式3
	DECLARE Field_Not_Be_Null CONDITION FOR 1048;
	DECLARE EXIT HANDLER FOR Field_Not_Be_Null SET @proc_value = -1;
	
	SET @x = 1;
	UPDATE employees SET email = NULL WHERE last_name = 'Abel';
	SET @x = 2;
	UPDATE employees SET email = 'aabbel' WHERE last_name = 'Abel';
	SET @x = 3;
END //

DELIMITER ;

CALL UpdateDataNoCondition();
SELECT @x,@proc_value;

三、流程控制

解決複雜問題不可能通過一個 SQL 語句完成，我們需要執行多個 SQL 操作。流程控制語句的作用就是控制儲存過程中 SQL 語句的執行順序，是我們完成複雜操作必不可少的一部分。只要是執行的程式，流程就分為三大類：

順序結構：程式從上往下依次執行
分支結構：程式按條件進行選擇執行，從兩條或多條路徑中選擇一條執行
迴圈結構：程式滿足一定條件下，重複執行一組語句

針對於MySQL 的流程控制語句主要有 3 類。注意：只能用於儲存程式。

條件判斷語句：IF 語句和 CASE 語句
迴圈語句：LOOP、WHILE 和 REPEAT 語句
跳轉語句：ITERATE 和 LEAVE 語句

3.1、分支結構之 IF

IF 表示式1 THEN 操作1
[ELSEIF 表示式2 THEN 操作2]……
[ELSE 操作N]
END IF

根據表示式的結果為TRUE或FALSE執行相應的語句。這裡“[]”中的內容是可選的。
特點：① 不同的表示式對應不同的操作 ② 使用在begin end中

example:

USE test14;

DELIMITER $

CREATE PROCEDURE test_if()
BEGIN
	DECLARE age INT DEFAULT 20;
	
	IF age > 40
		THEN SELECT '中老年';
	ELSEIF age >18
		THEN SELECT '青壯年';
	ELSE 
		SELECT '嬰幼兒';
	END IF;
END $

DELIMITER ;

CALL test_if();

3.2、分支結構之 CASE

CASE 語句的語法結構1：

CASE 表示式
WHEN 值1 THEN 結果1或語句1(如果是語句，需要加分號) 
WHEN 值2 THEN 結果2或語句2(如果是語句，需要加分號)
...
ELSE 結果n或語句n(如果是語句，需要加分號)
END [case]（如果是放在begin end中需要加上case，如果放在select後面不需要）

example:

USE test14;

DELIMITER $

CREATE PROCEDURE test_case01()
BEGIN
	DECLARE var INT DEFAULT 2;
	
	CASE var 
		WHEN 1 THEN SELECT 'var = 1';
		WHEN 2 THEN SELECT 'var = 2';
		WHEN 3 THEN SELECT 'var = 3';
		ELSE SELECT 'other value';
	END CASE;
END $

DELIMITER ;

CALL test_case01();

CASE 語句的語法結構2：

CASE 
WHEN 條件1 THEN 結果1或語句1(如果是語句，需要加分號) 
WHEN 條件2 THEN 結果2或語句2(如果是語句，需要加分號)
...
ELSE 結果n或語句n(如果是語句，需要加分號)
END [case]（如果是放在begin end中需要加上case，如果放在select後面不需要）

example:

USE test14;

DELIMITER $

CREATE PROCEDURE test_case02()
BEGIN
	DECLARE var INT DEFAULT 10;
	
	CASE 
		WHEN var > 100 THEN SELECT '三位數';
		WHEN var >= 10 THEN SELECT '兩位數';
		ELSE SELECT '個位數';
	END CASE;
END $

DELIMITER ;

CALL test_case02();

3.3、迴圈結構之LOOP

LOOP迴圈語句用來重複執行某些語句。LOOP內的語句一直重複執行直到迴圈被退出（使用LEAVE子句），跳出迴圈過程。

[loop_label:] LOOP
	迴圈執行的語句
END LOOP [loop_label]

其中，loop_label表示LOOP語句的標註名稱，該引數可以省略。

example:

USE test14;

DELIMITER //

CREATE PROCEDURE test_loop()
BEGIN
	DECLARE num INT DEFAULT 1;
	
	loop_label:LOOP
		SET num = num+1;
		IF num >= 10 THEN LEAVE loop_label;
		END IF;
	END LOOP loop_label;
	
	SELECT num;
		
END //

DELIMITER ;

CALL test_loop();

3.4、迴圈結構之WHILE

WHILE語句建立一個帶條件判斷的迴圈過程。WHILE在執行語句執行時，先對指定的表示式進行判斷，如果為真，就執行迴圈內的語句，否則退出迴圈。

[while_label:] WHILE 迴圈條件  DO
	迴圈體
END WHILE [while_label];

while_label為WHILE語句的標註名稱；如果迴圈條件結果為真，WHILE語句內的語句或語句群被執行，直至迴圈條件為假，退出迴圈。

example:

USE test14;

DELIMITER $

CREATE PROCEDURE test_while()
BEGIN
	DECLARE num INT DEFAULT 1;
	
	WHILE num <= 10 DO
		SET num = num+1;
	END WHILE;
	
	SELECT num;
END $

DELIMITER ;

CALL test_while();

3.5、迴圈結構之REPEAT

REPEAT語句建立一個帶條件判斷的迴圈過程。與WHILE迴圈不同的是，REPEAT 迴圈首先會執行一次迴圈，然後在 UNTIL 中進行表示式的判斷，如果滿足條件就退出，即 END REPEAT；如果條件不滿足，則會就繼續執行迴圈，直到滿足退出條件為止。

[repeat_label:] REPEAT
　　　　迴圈體的語句
UNTIL 結束迴圈的條件表示式
END REPEAT [repeat_label]

repeat_label為REPEAT語句的標註名稱，該引數可以省略；REPEAT語句內的語句或語句群被重複，直至expr_condition為真。

example:

USE test14;

DELIMITER //

CREATE PROCEDURE test_repeat()
BEGIN 
	DECLARE num INT DEFAULT 1;
	
	REPEAT 
		SET num = num+1;
		UNTIL num >= 10
	END REPEAT;
	
	SELECT num; 
END //

DELIMITER ;

CALL test_repeat();

對比三種迴圈結構：

這三種迴圈都可以省略名稱，但如果迴圈中添加了迴圈控制語句（LEAVE或ITERATE）則必須新增名稱。
LOOP：一般用於實現簡單的"死"迴圈
WHILE：先判斷後執行
REPEAT：先執行後判斷，無條件至少執行一次

3.6、跳轉語句之LEAVE語句

LEAVE語句：可以用在迴圈語句內，或者以 BEGIN 和 END 包裹起來的程式體內，表示跳出迴圈或者跳出程式體的操作。

LEAVE 標記名;

其中，label引數表示迴圈的標誌。LEAVE和BEGIN ... END或迴圈一起被使用。

example:

USE test14;

DELIMITER //

CREATE PROCEDURE leave_begin(IN num INT)
begin_label:BEGIN
	IF num <= 0 
		THEN LEAVE begin_label;
	ELSEIF num = 1
		THEN SELECT AVG(salary) FROM employees;
	ELSEIF num = 2
		THEN SELECT MIN(salary) FROM employees;
	ELSE
		SELECT MAX(salary) FROM employees;
	END IF;
	
	SELECT COUNT(*) FROM employees;
END //

DELIMITER ;

CALL leave_begin(1);

USE test14;

DELIMITER //

CREATE PROCEDURE leave_while(OUT num INT)
BEGIN 
	DECLARE avg_sal DOUBLE;
	DECLARE while_count INT DEFAULT 0;
	
	SELECT AVG(salary) INTO avg_sal FROM employees;
	
	while_label:WHILE TRUE DO
		IF avg_sal <= 3500
			THEN LEAVE while_label;
		END IF;
		
		UPDATE employees SET salary = salary * 0.9;
		SET while_count = while_count + 1;
		SELECT AVG(salary) INTO avg_sal FROM employees;
	END WHILE;
	
	SET num = while_count;
END //

DELIMITER ;

SELECT AVG(salary) FROM employees;
CALL leave_while(@num)
SELECT @num;
SELECT AVG(salary) FROM employees;

3.7、跳轉語句之ITERATE語句

ITERATE語句：只能用在迴圈語句（LOOP、REPEAT和WHILE語句）內，表示重新開始迴圈，將執行順序轉到語句段開頭處。

ITERATE label

label引數表示迴圈的標誌。ITERATE語句必須跟在迴圈標誌前面。

example:

USE test14;

DELIMITER //

CREATE PROCEDURE test_iterate()
BEGIN 
	DECLARE num INT DEFAULT 0;
	DECLARE number INT DEFAULT 0;
	
	loop_label:LOOP
		SET num = num + 1;
		
		IF num > 10 AND num <= 15
			THEN ITERATE loop_label;
		ELSEIF num > 15
			THEN LEAVE loop_label;
		END IF;
		
		SET number = number + 1;
	END LOOP;
	
	SELECT number;
END //

DELIMITER ;

DROP PROCEDURE test_iterate;

CALL test_iterate();

四、遊標

4.1、什麼是遊標（或游標）

雖然我們也可以通過篩選條件 WHERE 和 HAVING，或者是限定返回記錄的關鍵字 LIMIT 返回一條記錄，但是，卻無法在結果集中像指標一樣，向前定位一條記錄、向後定位一條記錄，或者是隨意定位到某一條記錄，並對記錄的資料進行處理。這個時候，就可以用到遊標。遊標，提供了一種靈活的操作方式，讓我們能夠對結果集中的每一條記錄進行定位，並對指向的記錄中的資料進行操作的資料結構。遊標讓 SQL 這種面向集合的語言有了面向過程開發的能力。

在 SQL 中，遊標是一種臨時的資料庫物件，可以指向儲存在資料庫表中的資料行指標。這裡遊標充當了指標的作用，我們可以通過操作遊標來對資料行進行操作。

MySQL中游標可以在儲存過程和函式中使用。

4.2、使用遊標步驟

遊標必須在宣告處理程式之前被宣告，並且變數和條件還必須在宣告遊標或處理程式之前被宣告。
如果我們想要使用遊標，一般需要經歷四個步驟。不同的 DBMS 中，使用遊標的語法可能略有不同。

第一步，宣告遊標

DECLARE cursor_name CURSOR FOR select_statement;

這個語法適用於 MySQL，SQL Server，DB2 和 MariaDB。如果是用 Oracle 或者 PostgreSQL，需要寫成：

DECLARE cursor_name CURSOR IS select_statement;

要使用 SELECT 語句來獲取資料結果集，而此時還沒有開始遍歷資料，這裡 select_statement 代表的是 SELECT 語句，返回一個用於建立遊標的結果集。

第二步，開啟遊標
當我們定義好遊標之後，如果想要使用遊標，必須先開啟遊標。開啟遊標的時候 SELECT 語句的查詢結果集就會送到遊標工作區，為後面遊標的逐條讀取結果集中的記錄做準備。

OPEN cursor_name

第三步，使用遊標（從遊標中取得資料）

FETCH cursor_name INTO var_name [, var_name] ...

這句的作用是使用 cursor_name 這個遊標來讀取當前行，並且將資料儲存到 var_name 這個變數中，遊標指標指到下一行
如果遊標讀取的資料行有多個列名，則在 INTO 關鍵字後面賦值給多個變數名即可。
var_name必須在宣告遊標之前就定義好。
遊標的查詢結果集中的欄位數，必須跟 INTO 後面的變數數一致，否則，在儲存過程執行的時候，MySQL 會提示錯誤。

第四步，關閉遊標
有 OPEN 就會有 CLOSE，也就是開啟和關閉遊標。當我們使用完遊標後需要關閉掉該遊標。因為遊標會佔用系統資源，如果不及時關閉，遊標會一直保持到儲存過程結束，影響系統執行的效率。而關閉遊標的操作，會釋放遊標佔用的系統資源。關閉遊標之後，我們就不能再檢索查詢結果中的資料行，如果需要檢索只能再次開啟遊標。

CLOSE cursor_name

4.3、舉例

USE test14;

-- 建立儲存過程"get_count_by_limit_total_salary"，
-- 宣告IN引數 limit_total_salary,DOUBLE型別；宣告OUT引數total_count,INT型別
-- 功能可以實現累加薪資最高的幾個員工的薪資值，直到薪資總和達到limit_total_salary引數的值，返回累加的人數給total_count
DELIMITER //

CREATE PROCEDURE get_count_by_limit_total_salary(IN limit_total_salary DOUBLE,OUT total_count INT)
BEGIN
	DECLARE sum_salary DOUBLE DEFAULT 0.0;
	DECLARE emp_salary DOUBLE;
	DECLARE emp_count INT DEFAULT 0;
	
	-- 1.宣告遊標
	DECLARE emp_cursor CURSOR FOR SELECT salary FROM employees ORDER BY salary DESC;
	
	-- 2.開啟遊標
	OPEN emp_cursor;
	
	REPEAT 
		-- 3.使用遊標
		FETCH emp_cursor INTO emp_salary;
		SET sum_salary = sum_salary+emp_salary;
		SET emp_count = emp_count+1;
		UNTIL sum_salary >= limit_total_salary
	END REPEAT; 
	
	SET total_count = emp_count;
	
	-- 4.關閉遊標
	CLOSE emp_cursor;
END //

DELIMITER ;

DROP PROCEDURE get_count_by_limit_total_salary;

CALL get_count_by_limit_total_salary(200000,@total_count);
SELECT @total_count;

4.4、小結

遊標是 MySQL 的一個重要的功能，為逐條讀取結果集中的資料，提供了完美的解決方案。跟在應用層面實現相同的功能相比，遊標可以在儲存程式中使用，效率高，程式也更加簡潔。

但同時也會帶來一些效能問題，比如在使用遊標的過程中，會對資料行進行加鎖，這樣在業務併發量大的時候，不僅會影響業務之間的效率，還會消耗系統資源，造成記憶體不足，這是因為遊標是在記憶體中進行的處理。

建議：養成用完之後就關閉的習慣，這樣才能提高系統的整體效率。

五、MySQL 8.0的新特性—全域性變數的持久化

在MySQL資料庫中，全域性變數可以通過SET GLOBAL語句來設定。使用SET GLOBAL語句設定的變數值只會臨時生效。資料庫重啟後，伺服器又會從MySQL配置檔案中讀取變數的預設值。MySQL 8.0版本新增了SET PERSIST命令。

SET PERSIST global max_connections = 1000;

MySQL會將該命令的配置儲存到資料目錄下的mysqld-auto.cnf檔案中，下次啟動時會讀取該檔案，用其中的配置來覆蓋預設的配置檔案。

六、練習題

-- 1.準備工作 
CREATE DATABASE test14_var_cur; 
USE test14_var_cur; 

CREATE TABLE employees 
AS
SELECT * FROM atguigudb.employees; 

CREATE TABLE departments 
AS
SELECT * FROM atguigudb.departments; 

SET GLOBAL log_bin_trust_function_creators = 1;

-- 2. 無參有返回:建立函式get_count(),返回公司的員工個數
DELIMITER //

CREATE FUNCTION get_count() RETURNS INT
BEGIN 
	DECLARE emp_count INT;
	
	SELECT COUNT(*) INTO emp_count FROM employees;
	
	RETURN emp_count;
END //

DELIMITER ;

SELECT get_count();

-- 3. 有參有返回:建立函式ename_salary(),根據員工姓名，返回它的工資 
DELIMITER $

CREATE FUNCTION ename_salary(emp_name VARCHAR(25)) RETURNS DOUBLE
BEGIN
	SET @emp_salary = 0;
	
	SELECT salary INTO @emp_salary FROM employees WHERE last_name = emp_name;
	
	RETURN @emp_salary;
END $

DELIMITER ;

SELECT ename_salary('Abel');
SELECT @emp_salary;

-- 4.. 建立函式dept_salary() ,根據部門名，返回該部門的平均工資 
DELIMITER //

CREATE FUNCTION dept_salary(dept_name VARCHAR(15)) RETURNS DOUBLE
BEGIN
	DECLARE avg_salary DOUBLE;
	
	SELECT AVG(salary) INTO avg_salary
	FROM employees e JOIN departments d
	ON e.department_id = d.department_id
	WHERE d.department_name = dept_name;
	
	RETURN avg_salary;
END //

DELIMITER ;

SELECT dept_salary('Marketing');

-- 5. 建立函式add_float()，實現傳入兩個float，返回二者之和
DELIMITER $

CREATE FUNCTION add_float(value1 FLOAT,value2 FLOAT) RETURNS FLOAT
BEGIN
	DECLARE sum_value FLOAT;
	
	SET sum_value = value1+value2;
	
	RETURN sum_value;
END $

DELIMITER ;

SET @v1 = 13.2;
SET @v2 = 35.7;
SELECT add_float(@v1,@v2);

-- 6. 建立函式test_if()和test_case()，實現傳入成績，如果成績>90,返回A，如果成績>80,返回B，如果成績>60,返回 C，否則返回D 
-- 要求：分別使用if結構和case結構實現 
DELIMITER //

CREATE FUNCTION test_if(score DOUBLE) RETURNS CHAR
BEGIN
	DECLARE score_level CHAR;
	IF score > 90
		THEN SET score_level = 'A';
	ELSEIF score > 80
		THEN SET score_level = 'B';
	ELSEIF score > 60
		THEN SET score_level = 'C';
	ELSE
		SET score_level = 'D';
	END IF;
	
	RETURN score_level;
END //

DELIMITER ;

SELECT test_if(56);

DELIMITER $

CREATE FUNCTION test_case(score DOUBLE) RETURNS CHAR
BEGIN
	DECLARE score_level CHAR;
	CASE 
		WHEN score > 90
			THEN SET score_level = 'A';
		WHEN score > 80
			THEN SET score_level = 'B';
		WHEN score > 60
			THEN SET score_level = 'C';
		ELSE
			SET score_level = 'D';
	END CASE;
	
	RETURN score_level;
END $

DELIMITER ;

SELECT test_case(97);

-- 7. 建立儲存過程test_if_pro()，傳入工資值，
-- 如果工資值<3000,則刪除工資為此值的員工，如果3000 <= 工 資值 <= 5000,則修改此工資值的員工薪資漲1000，否則漲工資500 
DELIMITER //

CREATE PROCEDURE test_if_pro(IN emp_salary DOUBLE)
BEGIN
	IF emp_salary < 3000
		THEN DELETE FROM employees WHERE salary = emp_salary;
	ELSEIF emp_salary <= 5000
		THEN UPDATE employees SET salary = salary + 1000 WHERE salary = emp_salary;
	ELSE 
		UPDATE employees SET salary = salary + 500 WHERE salary = emp_salary;
	END IF;
END //

DELIMITER ;

CALL test_if_pro(24000);

SELECT * FROM employees;

-- 8. 建立儲存過程insert_data(),傳入引數為 IN 的 INT 型別變數 insert_count,實現向admin表中批量插 入insert_count條記錄
CREATE TABLE admin(
	id INT PRIMARY KEY AUTO_INCREMENT,
	user_name VARCHAR(25) NOT NULL,
	user_password VARCHAR(35) NOT NULL
);

SELECT * FROM admin;

DELIMITER $

CREATE PROCEDURE insert_data(IN insert_count INT)
BEGIN 
	DECLARE init_count INT DEFAULT 0;
	
	WHILE init_count <= insert_count DO
		INSERT INTO admin(user_name,user_password) 
		VALUES(CONCAT('sakura-',init_count),ROUND(RAND()*1000000));
		SET init_count = init_count+1;
	END WHILE;
END $

DELIMITER ;

CALL insert_data(100);

SELECT * FROM admin;

-- 9.建立儲存過程update_salary()，
-- 引數1為 IN 的INT型變數dept_id，表示部門id；引數2為 IN的INT型變數change_salary_count，表示要調整薪資的員工個數。
-- 查詢指定id部門的員工資訊，按照salary升序排列，根據hire_date的情況，調整前change_salary_count個員工的薪資。
/*
	hire_date				salary 
	hire_date < 1995			salary = salary*1.2 
	hire_date >=1995 and hire_date <= 1998	salary = salary*1.15 
	hire_date > 1998 and hire_date <= 2001 	salary = salary *1.10 
	hire_date > 2001 			salary = salary * 1.05
*/
DELIMITER //

CREATE PROCEDURE update_salary(IN dept_id INT,IN change_salary_count INT)
BEGIN 
	DECLARE emp_id INT;
	DECLARE emp_hire_date DATE;
	DECLARE init_count INT DEFAULT 1;
	DECLARE add_salary_rate DOUBLE;
	
	DECLARE emp_cursor CURSOR 
	FOR 
	SELECT employee_id,hire_date 
	FROM employees
	WHERE department_id = dept_id 
	ORDER BY salary ASC;
	
	OPEN emp_cursor;
	
	WHILE init_count <= change_salary_count DO
		FETCH emp_cursor INTO emp_id,emp_hire_date;
		
		IF YEAR(emp_hire_date) < 1995
			THEN SET add_salary_rate = 1.2;
		ELSEIF YEAR(emp_hire_date) <= 1998
			THEN SET add_salary_rate = 1.15;
		ELSEIF YEAR(emp_hire_date) <= 2001
			THEN SET add_salary_rate = 1.10;
		ELSE
			SET add_salary_rate = 1.05;
		END IF;
		
		UPDATE employees SET salary = salary * add_salary_rate WHERE employee_id = emp_id;
		SET init_count = init_count+1;
	END WHILE;
	
	CLOSE emp_cursor;
END //

DELIMITER ;

SELECT * FROM employees WHERE department_id = 50 ORDER BY salary ASC;
CALL update_salary(50,3);
SELECT * FROM employees WHERE department_id = 50 ORDER BY salary ASC;

14. 變數、流程控制與遊標

一、變數

1.1、系統變數

1.1.1、系統變數分類

1.1.2、檢視系統變數

1.1.2.1、檢視所有或部分系統變數

1.1.2.2、檢視指定系統變數

1.1.3、修改系統變數的值

1.2、使用者變數

1.2.1、使用者變數分類

1.2.2、會話使用者變數

1.2.2.1、變數的定義

1.2.2.2、檢視使用者變數的值 （檢視、比較、運算等）

1.2.3、區域性變數

1.2.4、對比會話使用者變數與區域性變數

二、定義條件與處理程式

2.1、定義條件

2.3 定義處理程式

2.4、案例解決

三、流程控制

3.1、分支結構之 IF

3.2、分支結構之 CASE

3.3、迴圈結構之LOOP

3.4、迴圈結構之WHILE

3.5、迴圈結構之REPEAT

3.6、跳轉語句之LEAVE語句

3.7、跳轉語句之ITERATE語句

四、遊標

4.1、什麼是遊標（或游標）

4.2、使用遊標步驟

4.3、舉例

4.4、小結

五、MySQL 8.0的新特性—全域性變數的持久化

六、練習題

相關推薦

1.2.2.2、檢視使用者變數的值（檢視、比較、運算等）