你了解mysql中的變量、流程控制與游標？下面本篇文章帶大家了解一下mysql中的變量、流程控制與游標，希望對大家有所幫助。
1. 變量
在MySQL數據庫的存儲過程和函數中，可以使用變量來存儲查詢或計算的中間結果數據，或者輸出最終的結果數據。
在 MySQL 數據庫中，變量分為系統變量以及用戶自定義變量。【相關推薦：mysql視頻教程】
1.1 系統變量
1.1.1 系統變量分類
變量由系統定義，不是用戶定義，屬于服務器層面。啟動MySQL服務，生成MySQL服務實例期間，MySQL將為MySQL服務器內存中的系統變量賦值，這些系統變量定義了當前MySQL服務實例的屬性、特征。這些系統變量的值要么是編譯MySQL時參數的默認值，要么是配置文件（例如my.ini等）中的參數值。大家可以通過網址 https://dev.mysql.com/doc/refman/8.0/en/server-system-variables.html 查看MySQL文檔的系統變量。
系統變量分為全局系統變量（需要添加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 查看系統變量
- 查看所有或部分系統變量
#查看所有全局變量 SHOW?GLOBAL?VARIABLES; #查看所有會話變量 SHOW?SESSION?VARIABLES; 或 SHOW?VARIABLES;
#查看滿足條件的部分系統變量。 SHOW?GLOBAL?VARIABLES?LIKE?'%標識符%'; #查看滿足條件的部分會話變量 SHOW?SESSION?VARIABLES?LIKE?'%標識符%';
舉例：
SHOW?GLOBAL?VARIABLES?LIKE?'admin_%';
- 查看指定系統變量
作為 MySQL 編碼規范，MySQL 中的系統變量以兩個“@”開頭，其中“@@global”僅用于標記全局系統變量，“@@session”僅用于標記會話系統變量。“@@”首先標記會話系統變量，如果會話系統變量不存在，則標記全局系統變量。
#查看指定的系統變量的值 select?@@global.變量名; #查看指定的會話變量的值 SELECT?@@session.變量名; #或者 SELECT?@@變量名;
- 修改系統變量的值
有些時候，數據庫管理員需要修改系統變量的默認值，以便修改當前會話或者MySQL服務實例的屬性、特征。具體方法：
方式1：修改MySQL配置文件，繼而修改MySQL系統變量的值（該方法需要重啟MySQL服務）
方式2：在MySQL服務運行期間，使用“set”命令重新設置系統變量的值
#為某個系統變量賦值 #方式1： SET?@@global.變量名=變量值; #方式2： SET?GLOBAL?變量名=變量值; #為某個會話變量賦值 #方式1： SET?@@session.變量名=變量值; #方式2： SET?SESSION?變量名=變量值;
舉例：
SELECT?@@global.autocommit; SET?GLOBAL?autocommit=0;
SELECT?@@session.tx_isolation; SET?@@session.tx_isolation='read-uncommitted';
SET?GLOBAL?max_connections?=?1000; SELECT?@@global.max_connections;
1.2 用戶變量
1.2.1 用戶變量分類
用戶變量是用戶自己定義的，作為 MySQL 編碼規范，MySQL 中的用戶變量以一個“@”開頭。根據作用范圍不同，又分為會話用戶變量和局部變量。
-
會話用戶變量：作用域和會話變量一樣，只對當前連接會話有效。
-
局部變量：只在 BEGIN 和 END 語句塊中有效。局部變量只能在存儲過程和函數中使用。
1.2.2 會話用戶變量
- 變量的定義
#方式1：“=”或“:=” SET?@用戶變量?=?值; SET?@用戶變量?:=?值; #方式2：“:=”?或?intO關鍵字 SELECT?@用戶變量?:=?表達式?[FROM?等子句]; SELECT?表達式?INTO?@用戶變量??[FROM?等子句];
- 查看用戶變量的值 （查看、比較、運算等）
SELECT?@用戶變量
- 舉例
SET?@a?=?1; SELECT?@a;
SELECT?@num?:=?COUNT(*)?FROM?employees; SELECT?@num;
SELECT?AVG(salary)?INTO?@avgsalary?FROM?employees; SELECT?@avgsalary;
SELECT?@big;??#查看某個未聲明的變量時，將得到NULL值
1.2.3 局部變量
定義：可以使用DECLARE語句定義一個局部變量
作用域：僅僅在定義它的 BEGIN … END 中有效
位置：只能放在 BEGIN … END 中，而且只能放在第一句
BEGIN #聲明局部變量 DECLARE?變量名1?變量數據類型?[DEFAULT?變量默認值]; DECLARE?變量名2,變量名3,...?變量數據類型?[DEFAULT?變量默認值]; #為局部變量賦值 SET?變量名1?=?值; SELECT?值?INTO?變量名2?[FROM?子句]; #查看局部變量的值 SELECT?變量1,變量2,變量3; END
1.定義變量
DECLARE?變量名?類型?[default?值];??#?如果沒有DEFAULT子句，初始值為NULL
舉例：
DECLARE myparam INT DEFAULT?100;
2.變量賦值
方式1：一般用于賦簡單的值
SET?變量名=值; SET?變量名:=值;
方式2：一般用于賦表中的字段值
SELECT?字段名或表達式?INTO?變量名?FROM?表;
3.使用變量（查看、比較、運算等）
SELECT?局部變量名;
舉例1：聲明局部變量，并分別賦值為employees表中employee_id為102的last_name和salary
DELIMITER?// CREATE?PROCEDURE?set_value() BEGIN DECLARE?emp_name?VARCHAR(25); DECLARE?sal?double(10,2); SELECT?last_name,salary?INTO?emp_name,sal FROM?employees? WHERE?employee_id?=?102; SELECT?emp_name,sal; END?// DELIMITER?;
舉例2：聲明兩個變量，求和并打印 （分別使用會話用戶變量、局部變量的方式實現）
#方式1：使用用戶變量 SET?@m=1; SET?@n=1; SET?@sum=@m+@n; SELECT?@sum;
#方式2：使用局部變量 DELIMITER?// CREATE?PROCEDURE?add_value() BEGIN #局部變量 DECLARE?m?INT?DEFAULT?1; DECLARE?n?INT?DEFAULT?3; DECLARE?SUM?INT; SET?SUM?=?m+n; SELECT?SUM; END?// DELIMITER?;
舉例3：創建存儲過程“different_salary”查詢某員工和他領導的薪資差距，并用IN參數emp_id接收員工id，用OUT參數dif_salary輸出薪資差距結果。
#聲明 DELIMITER?// CREATE?PROCEDURE?different_salary(IN?emp_id?INT,OUT?dif_salary?DOUBLE) BEGIN #聲明局部變量 DECLARE?emp_sal,mgr_sal?DOUBLE?DEFAULT?0.0; DECLARE?mgr_id?INT; SELECT?salary?INTO?emp_sal?FROM?employees?WHERE?employee_id?=?emp_id; SELECT?manager_id?INTO?mgr_id?FROM?employees?WHERE?employee_id?=?emp_id; SELECT?salary?INTO?mgr_sal?FROM?employees?WHERE?employee_id?=?mgr_id; SET?dif_salary?=?mgr_sal?-?emp_sal; END?// DELIMITER?; #調用 SET?@emp_id?=?102; CALL?different_salary(@emp_id,@diff_sal); #查看 SELECT?@diff_sal;
1.2.4 對比會話用戶變量與局部變量
??作用域 定義位置 ??語法 會話用戶變量 ??當前會話 ???會話的任何地方 加@符號，不用指定類型 局部變量 ???定義它的BEGIN?END中? BEGIN?END的第一句話 ??一般不用加@,需要指定類型
2. 定義條件與處理程序
定義條件是事先定義程序執行過程中可能遇到的問題，處理程序定義了在遇到問題時應當采取的處理方式，并且保證存儲過程或函數在遇到警告或錯誤時能繼續執行。這樣可以增強存儲程序處理問題的能力，避免程序異常停止運行。
說明：定義條件和處理程序在存儲過程、存儲函數中都是支持的。
2.1 案例分析
案例分析： 創建一個名稱為“UpdateDataNoCondition”的存儲過程。代碼如下：
DELIMITER?// CREATE?PROCEDURE?UpdateDataNoCondition() BEGIN 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?;
調用存儲過程：
mysql>?CALL?UpdateDataNoCondition(); Error?1048?(23000):?Column?'email'?cannot?be?null mysql>?SELECT?@x; +------+ |?@x???| +------+ |???1??| +------+ 1?row?in?set?(0.00?sec)
可以看到，此時@x變量的值為1。結合創建存儲過程的SQL語句代碼可以得出：在存儲過程中未定義條件和處理程序，且當存儲過程中執行的SQL語句報錯時，MySQL數據庫會拋出錯誤，并退出當前SQL邏輯，不再向下繼續執行。
2.2 定義條件
定義條件就是給MySQL中的錯誤碼命名，這有助于存儲的程序代碼更清晰。它將一個錯誤名字和指定的錯誤條件關聯起來。這個名字可以隨后被用在定義處理程序的DECLARE HANDLER語句中。
定義條件使用DECLARE語句，語法格式如下：
DECLARE?錯誤名稱?CONDITION?FOR?錯誤碼（或錯誤條件）
錯誤碼的說明：
- MySQL_error_code和sqlstate_value都可以表示MySQL的錯誤。
- 例如，在ERROR 1418 (HY000)中，1418是MySQL_error_code，’HY000’是sqlstate_value。
- 例如，在ERROR 1142（42000）中，1142是MySQL_error_code，’42000’是sqlstate_value。
舉例1： 定義“Field_Not_Be_NULL”錯誤名與MySQL中違反非空約束的錯誤類型是“ERROR 1048 (23000)”對應。
#使用MySQL_error_code DECLARE?Field_Not_Be_NULL?CONDITION?FOR?1048; #使用sqlstate_value DECLARE?Field_Not_Be_NULL?CONDITION?FOR?SQLSTATE?'23000';
舉例2： 定義”ERROR 1148(42000)”錯誤，名稱為command_not_allowed。
#使用MySQL_error_code DECLARE?command_not_allowed?CONDITION?FOR?1148; #使用sqlstate_value DECLARE?command_not_allowed?CONDITION?FOR?SQLSTATE?'42000';
2.3 定義處理程序
可以為SQL執行過程中發生的某種類型的錯誤定義特殊的處理程序。定義處理程序時，使用DECLARE語句的語法如下：
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編寫的復合語句。
定義處理程序的幾種方式，代碼如下：
#方法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。
DELIMITER?// CREATE?PROCEDURE?UpdateDataNoCondition() BEGIN #定義處理程序 DECLARE?CONTINUE?HANDLER?FOR?1048?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?;
調用過程：
mysql>?CALL?UpdateDataWithCondition(); Query?OK,?0?rows?affected?(0.01?sec) mysql>?SELECT?@x,@proc_value; +------+-------------+ |?@x???|?@proc_value?| +------+-------------+ |????3?|??????? ?-1??| +------+-------------+ 1?row?in?set?(0.00?sec)
舉例：
創建一個名稱為“InsertDataWithCondition”的存儲過程，代碼如下。
在存儲過程中，定義處理程序，捕獲sqlstate_value值，當遇到sqlstate_value值為23000時，執行EXIT操作，并且將@proc_value的值設置為-1。
#準備工作 CREATE?TABLE?departments AS SELECT?*?FROM?atguigudb.`departments`; ALTER?TABLE?departments ADD?CONSTRAINT?uk_dept_name?UNIQUE(department_id);
DELIMITER?// CREATE?PROCEDURE?InsertDataWithCondition() BEGIN DECLARE?duplicate_entry?CONDITION?FOR?SQLSTATE?'23000'?; DECLARE?EXIT?HANDLER?FOR?duplicate_entry?SET?@proc_value?=?-1; SET?@x?=?1; INSERT?INTO?departments(department_name)?VALUES('測試'); SET?@x?=?2; INSERT?INTO?departments(department_name)?VALUES('測試'); SET?@x?=?3; END?// DELIMITER?;
調用存儲過程：
mysql>?CALL?InsertDataWithCondition(); Query?OK,?0?rows?affected?(0.01?sec) mysql>?SELECT?@x,@proc_value; +------+-------------+ |?@x???|?@proc_value?| +------+-------------+ |????2?|??????? ?-1??| +------+-------------+ 1?row?in?set?(0.00?sec)
3. 流程控制
解決復雜問題不可能通過一個 SQL 語句完成，我們需要執行多個 SQL 操作。流程控制語句的作用就是控制存儲過程中 SQL 語句的執行順序，是我們完成復雜操作必不可少的一部分。只要是執行的程序，流程就分為三大類：
- 順序結構：程序從上往下依次執行
- 分支結構：程序按條件進行選擇執行，從兩條或多條路徑中選擇一條執行
- 循環結構：程序滿足一定條件下，重復執行一組語句
針對于MySQL 的流程控制語句主要有 3 類。注意：只能用于存儲程序。
- 條件判斷語句：IF 語句和 CASE 語句
- 循環語句：LOOP、while 和 REPEAT 語句
- 跳轉語句：ITERATE 和 LEAVE 語句
3.1 分支結構之 IF
- IF 語句的語法結構是：
IF?表達式1?THEN?操作1 [ELSEIF?表達式2?THEN?操作2]…… [ELSE?操作N] END?IF
根據表達式的結果為TRUE或FALSE執行相應的語句。這里“[]”中的內容是可選的。
-
特點：① 不同的表達式對應不同的操作 ② 使用在begin end中
-
舉例1：
IF?val?IS?NULL? THEN?SELECT?'val?is?null'; ELSE?SELECT?'val?is?not?null'; END?IF;
-
舉例2： 聲明存儲過程“update_salary_by_eid1”，定義IN參數emp_id，輸入員工編號。判斷該員工薪資如果低于8000元并且入職時間超過5年，就漲薪500元；否則就不變。
DELIMITER?// CREATE?PROCEDURE?update_salary_by_eid1(IN?emp_id?INT) BEGIN DECLARE?emp_salary?DOUBLE; DECLARE?hire_year?DOUBLE; SELECT?salary?INTO?emp_salary?FROM?employees?WHERE?employee_id?=?emp_id; SELECT?DATEDIFF(CURDATE(),hire_date)/365?INTO?hire_year FROM?employees?WHERE?employee_id?=?emp_id; IF?emp_salary??5 THEN?UPDATE?employees?SET?salary?=?salary?+?500?WHERE?employee_id?=?emp_id; END?IF; END?// DELIMITER?;
-
舉例3： 聲明存儲過程“update_salary_by_eid2”，定義IN參數emp_id，輸入員工編號。判斷該員工薪資如果低于9000元并且入職時間超過5年，就漲薪500元；否則就漲薪100元。
DELIMITER?// CREATE?PROCEDURE?update_salary_by_eid2(IN?emp_id?INT) BEGIN DECLARE?emp_salary?DOUBLE; DECLARE?hire_year?DOUBLE; SELECT?salary?INTO?emp_salary?FROM?employees?WHERE?employee_id?=?emp_id; SELECT?DATEDIFF(CURDATE(),hire_date)/365?INTO?hire_year FROM?employees?WHERE?employee_id?=?emp_id; IF?emp_salary??5 THEN?UPDATE?employees?SET?salary?=?salary?+?500?WHERE?employee_id?=?emp_id; ELSE? UPDATE?employees?SET?salary?=?salary?+?100?WHERE?employee_id?=?emp_id; END?IF; END?// DELIMITER?;
-
舉例4： 聲明存儲過程“update_salary_by_eid3”，定義IN參數emp_id，輸入員工編號。判斷該員工薪資如果低于9000元，就更新薪資為9000元；薪資如果大于等于9000元且低于10000的，但是獎金比例為NULL的，就更新獎金比例為0.01；其他的漲薪100元。
DELIMITER?// CREATE?PROCEDURE?update_salary_by_eid3(IN?emp_id?INT) BEGIN DECLARE?emp_salary?DOUBLE; DECLARE?bonus?DECIMAL(3,2); SELECT?salary?INTO?emp_salary?FROM?employees?WHERE?employee_id?=?emp_id; SELECT?commission_pct?INTO?bonus?FROM?employees?WHERE?employee_id?=?emp_id; IF?emp_salary?
3.2 分支結構之 CASE
CASE 語句的語法結構1：
#情況一：類似于switch CASE?表達式 WHEN?值1?THEN?結果1或語句1(如果是語句，需要加分號)? WHEN?值2?THEN?結果2或語句2(如果是語句，需要加分號) ... ELSE?結果n或語句n(如果是語句，需要加分號) END?[case]（如果是放在begin?end中需要加上case，如果放在select后面不需要）
CASE 語句的語法結構2：
#情況二：類似于多重if CASE? WHEN?條件1?THEN?結果1或語句1(如果是語句，需要加分號)? WHEN?條件2?THEN?結果2或語句2(如果是語句，需要加分號) ... ELSE?結果n或語句n(如果是語句，需要加分號) END?[case]（如果是放在begin?end中需要加上case，如果放在select后面不需要）
- 舉例1：
使用CASE流程控制語句的第1種格式，判斷val值等于1、等于2，或者兩者都不等。
CASE?val WHEN?1?THEN?SELECT?'val?is?1'; WHEN?2?THEN?SELECT?'val?is?2'; ELSE?SELECT?'val?is?not?1?or?2'; END?CASE;
- 舉例2：
使用CASE流程控制語句的第2種格式，判斷val是否為空、小于0、大于0或者等于0。
CASE WHEN?val?IS?NULL?THEN?SELECT?'val?is?null'; WHEN?val??0?THEN?SELECT?'val?is?greater?than?0'; ELSE?SELECT?'val?is?0'; END?CASE;
- 舉例3： 聲明存儲過程“update_salary_by_eid4”，定義IN參數emp_id，輸入員工編號。判斷該員工薪資如果低于9000元，就更新薪資為9000元；薪資大于等于9000元且低于10000的，但是獎金比例為NULL的，就更新獎金比例為0.01；其他的漲薪100元。
DELIMITER?// CREATE?PROCEDURE?update_salary_by_eid4(IN?emp_id?INT) BEGIN DECLARE?emp_sal?DOUBLE; DECLARE?bonus?DECIMAL(3,2); SELECT?salary?INTO?emp_sal?FROM?employees?WHERE?employee_id?=?emp_id; SELECT?commission_pct?INTO?bonus?FROM?employees?WHERE?employee_id?=?emp_id; CASE WHEN?emp_sal
- 舉例4：聲明存儲過程update_salary_by_eid5，定義IN參數emp_id，輸入員工編號。判斷該員工的入職年限，如果是0年，薪資漲50；如果是1年，薪資漲100；如果是2年，薪資漲200；如果是3年，薪資漲300；如果是4年，薪資漲400；其他的漲薪500。
DELIMITER?// CREATE?PROCEDURE?update_salary_by_eid5(IN?emp_id?INT) BEGIN DECLARE?emp_sal?DOUBLE; DECLARE?hire_year?DOUBLE; SELECT?salary?INTO?emp_sal?FROM?employees?WHERE?employee_id?=?emp_id; SELECT?ROUND(DATEDIFF(CURDATE(),hire_date)/365)?INTO?hire_year?FROM?employees?WHERE?employee_id?=?emp_id; CASE?hire_year WHEN?0?THEN?UPDATE?employees?SET?salary=salary+50?WHERE?employee_id?=?emp_id; WHEN?1?THEN?UPDATE?employees?SET?salary=salary+100?WHERE?employee_id?=?emp_id; WHEN?2?THEN?UPDATE?employees?SET?salary=salary+200?WHERE?employee_id?=?emp_id; WHEN?3?THEN?UPDATE?employees?SET?salary=salary+300?WHERE?employee_id?=?emp_id; WHEN?4?THEN?UPDATE?employees?SET?salary=salary+400?WHERE?employee_id?=?emp_id; ELSE?UPDATE?employees?SET?salary=salary+500?WHERE?employee_id?=?emp_id; END?CASE; END?// DELIMITER?;
3.3 循環結構之LOOP
LOOP循環語句用來重復執行某些語句。LOOP內的語句一直重復執行直到循環被退出（使用LEAVE子句），跳出循環過程。
LOOP語句的基本格式如下：
[loop_label:]?LOOP 循環執行的語句 END?LOOP?[loop_label]
其中，loop_label表示LOOP語句的標注名稱，該參數可以省略。
舉例1：
使用LOOP語句進行循環操作，id值小于10時將重復執行循環過程。
DECLARE?id?INT?DEFAULT?0; add_loop:LOOP SET?id?=?id?+1; IF?id?>=?10?THEN?LEAVE?add_loop; END?IF; END?LOOP?add_loop;
舉例2： 當市場環境變好時，公司為了獎勵大家，決定給大家漲工資。聲明存儲過程“update_salary_loop()”，聲明OUT參數num，輸出循環次數。存儲過程中實現循環給大家漲薪，薪資漲為原來的1.1倍。直到全公司的平均薪資達到12000結束。并統計循環次數。
DELIMITER?// CREATE?PROCEDURE?update_salary_loop(OUT?num?INT) BEGIN DECLARE?avg_salary?DOUBLE; DECLARE?loop_count?INT?DEFAULT?0; SELECT?AVG(salary)?INTO?avg_salary?FROM?employees; label_loop:LOOP IF?avg_salary?>=?12000?THEN?LEAVE?label_loop; END?IF; UPDATE?employees?SET?salary?=?salary?*?1.1; SET?loop_count?=?loop_count?+?1; SELECT?AVG(salary)?INTO?avg_salary?FROM?employees; END?LOOP?label_loop; SET?num?=?loop_count; END?// DELIMITER?;
3.4 循環結構之WHILE
WHILE語句創建一個帶條件判斷的循環過程。WHILE在執行語句執行時，先對指定的表達式進行判斷，如果為真，就執行循環內的語句，否則退出循環。WHILE語句的基本格式如下：
[while_label:]?WHILE?循環條件??DO 循環體 END?WHILE?[while_label];
while_label為WHILE語句的標注名稱；如果循環條件結果為真，WHILE語句內的語句或語句群被執行，直至循環條件為假，退出循環。
舉例1：
WHILE語句示例，i值小于10時，將重復執行循環過程，代碼如下：
DELIMITER?// CREATE?PROCEDURE?test_while() BEGIN DECLARE?i?INT?DEFAULT?0; WHILE?i?<p><strong>舉例2：</strong> 市場環境不好時，公司為了渡過難關，決定暫時降低大家的薪資。聲明存儲過程“update_salary_while()”，聲明OUT參數num，輸出循環次數。存儲過程中實現循環給大家降薪，薪資降為原來的90%。直到全公司的平均薪資達到5000結束。并統計循環次數。</p><pre class="brush:js;toolbar:false;">DELIMITER?// CREATE?PROCEDURE?update_salary_while(OUT?num?INT) BEGIN DECLARE?avg_sal?DOUBLE?; DECLARE?while_count?INT?DEFAULT?0; SELECT?AVG(salary)?INTO?avg_sal?FROM?employees; WHILE?avg_sal?>?5000?DO 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?;
3.5 循環結構之REPEAT
REPEAT語句創建一個帶條件判斷的循環過程。與WHILE循環不同的是，REPEAT 循環首先會執行一次循環，然后在 UNTIL 中進行表達式的判斷，如果滿足條件就退出，即 END REPEAT；如果條件不滿足，則會就繼續執行循環，直到滿足退出條件為止。
REPEAT語句的基本格式如下：
[repeat_label:]?REPEAT 循環體的語句 UNTIL?結束循環的條件表達式 END?REPEAT?[repeat_label]
repeat_label為REPEAT語句的標注名稱，該參數可以省略；REPEAT語句內的語句或語句群被重復，直至expr_condition為真。
舉例1：
DELIMITER?// CREATE?PROCEDURE?test_repeat() BEGIN DECLARE?i?INT?DEFAULT?0; REPEAT? SET?i?=?i?+?1; UNTIL?i?>=?10 END?REPEAT; SELECT?i; END?// DELIMITER?;
舉例2： 當市場環境變好時，公司為了獎勵大家，決定給大家漲工資。聲明存儲過程“update_salary_repeat()”，聲明OUT參數num，輸出循環次數。存儲過程中實現循環給大家漲薪，薪資漲為原來的1.15倍。直到全公司的平均薪資達到13000結束。并統計循環次數。
DELIMITER?// CREATE?PROCEDURE?update_salary_repeat(OUT?num?INT) BEGIN DECLARE?avg_sal?DOUBLE?; DECLARE?repeat_count?INT?DEFAULT?0; SELECT?AVG(salary)?INTO?avg_sal?FROM?employees; REPEAT UPDATE?employees?SET?salary?=?salary?*?1.15; SET?repeat_count?=?repeat_count?+?1; SELECT?AVG(salary)?INTO?avg_sal?FROM?employees; UNTIL?avg_sal?>=?13000 END?REPEAT; SET?num?=?repeat_count; END?// DELIMITER?;
對比三種循環結構：
1、這三種循環都可以省略名稱，但如果循環中添加了循環控制語句（LEAVE或ITERATE）則必須添加名稱。 2、 LOOP：一般用于實現簡單的”死”循環 WHILE：先判斷后執行 REPEAT：先執行后判斷，無條件至少執行一次
3.6 跳轉語句之LEAVE語句
LEAVE語句：可以用在循環語句內，或者以 BEGIN 和 END 包裹起來的程序體內，表示跳出循環或者跳出程序體的操作。如果你有面向過程的編程語言的使用經驗，你可以把 LEAVE 理解為 break。
基本格式如下：
LEAVE?標記名
其中，label參數表示循環的標志。LEAVE和BEGIN … END或循環一起被使用。
**舉例1：**創建存儲過程 “leave_begin()”，聲明INT類型的IN參數num。給BEGIN…END加標記名，并在BEGIN…END中使用IF語句判斷num參數的值。
- 如果num
- 如果num=1，則查詢“employees”表的平均薪資；
- 如果num=2，則查詢“employees”表的最低薪資；
- 如果num>2，則查詢“employees”表的最高薪資。
IF語句結束后查詢“employees”表的總人數。
DELIMITER?// CREATE?PROCEDURE?leave_begin(IN?num?INT) begin_label:?BEGIN IF?num<p><strong>舉例2：</strong></p><p>當市場環境不好時，公司為了渡過難關，決定暫時降低大家的薪資。聲明存儲過程“leave_while()”，聲明OUT參數num，輸出循環次數，存儲過程中使用WHILE循環給大家降低薪資為原來薪資的90%，直到全公司的平均薪資小于等于10000，并統計循環次數。</p><pre class="brush:js;toolbar:false;">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?<h3 data-id="heading-22"><strong>3.7 跳轉語句之ITERATE語句</strong></h3><p>ITERATE語句：只能用在循環語句（LOOP、REPEAT和WHILE語句）內，表示重新開始循環，將執行順序轉到語句段開頭處。如果你有面向過程的編程語言的使用經驗，你可以把 ITERATE 理解為 continue，意思為“再次循環”。</p><p>語句基本格式如下：</p><pre class="brush:js;toolbar:false;">ITERATE?label
label參數表示循環的標志。ITERATE語句必須跟在循環標志前面。
舉例： ?定義局部變量num，初始值為0。循環結構中執行num + 1操作。
- 如果num
- 如果num > 15，則退出循環結構；
DELIMITER?// CREATE?PROCEDURE?test_iterate() BEGIN DECLARE?num?INT?DEFAULT?0; my_loop:LOOP SET?num?=?num?+?1; IF?num??15? THEN?LEAVE?my_loop; END?IF; SELECT?'尚硅谷：讓天下沒有難學的技術'; END?LOOP?my_loop; END?// DELIMITER?;
4. 游標
4.1 什么是游標（或光標）
雖然我們也可以通過篩選條件 WHERE 和 HAVING，或者是限定返回記錄的關鍵字 LIMIT 返回一條記錄，但是，卻無法在結果集中像指針一樣，向前定位一條記錄、向后定位一條記錄，或者是隨意定位到某一條記錄，并對記錄的數據進行處理。
這個時候，就可以用到游標。游標，提供了一種靈活的操作方式，讓我們能夠對結果集中的每一條記錄進行定位，并對指向的記錄中的數據進行操作的數據結構。游標讓 SQL 這種面向集合的語言有了面向過程開發的能力。
在 SQL 中，游標是一種臨時的數據庫對象，可以指向存儲在數據庫表中的數據行指針。這里游標充當了指針的作用，我們可以通過操作游標來對數據行進行操作。
MySQL中游標可以在存儲過程和函數中使用。
比如，我們查詢了 employees 數據表中工資高于15000的員工都有哪些：
SELECT?employee_id,last_name,salary?FROM?employees WHERE?salary?>?15000;
這里我們就可以通過游標來操作數據行，如圖所示此時游標所在的行是“108”的記錄，我們也可以在結果集上滾動游標，指向結果集中的任意一行。
4.2 使用游標步驟
游標必須在聲明處理程序之前被聲明，并且變量和條件還必須在聲明游標或處理程序之前被聲明。
如果我們想要使用游標，一般需要經歷四個步驟。不同的 DBMS 中，使用游標的語法可能略有不同。
第一步，聲明游標
在MySQL中，使用DECLARE關鍵字來聲明游標，其語法的基本形式如下：
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 語句，返回一個用于創建游標的結果集。
比如：
DECLARE?cur_emp?CURSOR?FOR? SELECT?employee_id,salary?FROM?employees;
DECLARE?cursor_fruit?CURSOR?FOR? SELECT?f_name,?f_price?FROM?fruits?;
第二步，打開游標
打開游標的語法如下：
OPEN?cursor_name
當我們定義好游標之后，如果想要使用游標，必須先打開游標。打開游標的時候 SELECT 語句的查詢結果集就會送到游標工作區，為后面游標的逐條讀取結果集中的記錄做準備。
OPEN cur_emp?;
第三步，使用游標（從游標中取得數據）
語法如下：
FETCH?cursor_name?INTO?var_name?[,?var_name]?...
這句的作用是使用 cursor_name 這個游標來讀取當前行，并且將數據保存到 var_name 這個變量中，游標指針指到下一行。如果游標讀取的數據行有多個列名，則在 INTO 關鍵字后面賦值給多個變量名即可。
注意：var_name必須在聲明游標之前就定義好。
FETCH cur_emp?INTO?emp_id,?emp_sal?;
注意：游標的查詢結果集中的字段數，必須跟 INTO 后面的變量數一致，否則，在存儲過程執行的時候，MySQL 會提示錯誤。
第四步，關閉游標
CLOSE?cursor_name
有 OPEN 就會有 CLOSE，也就是打開和關閉游標。當我們使用完游標后需要關閉掉該游標。因為游標會占用系統資源，如果不及時關閉，游標會一直保持到存儲過程結束，影響系統運行的效率。而關閉游標的操作，會釋放游標占用的系統資源。
關閉游標之后，我們就不能再檢索查詢結果中的數據行，如果需要檢索只能再次打開游標。
CLOSE cur_emp;
4.3 舉例
創建存儲過程“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;??#記錄累加的總工資 DECLARE?cursor_salary?DOUBLE?DEFAULT?0;?#記錄某一個工資值 DECLARE?emp_count?INT?DEFAULT?0;?#記錄循環個數 #定義游標 DECLARE?emp_cursor?CURSOR?FOR?SELECT?salary?FROM?employees?ORDER?BY?salary?DESC; #打開游標 OPEN?emp_cursor; REPEAT #使用游標（從游標中獲取數據） FETCH?emp_cursor?INTO?cursor_salary; SET?sum_salary?=?sum_salary?+?cursor_salary; SET?emp_count?=?emp_count?+?1; UNTIL?sum_salary?>=?limit_total_salary END?REPEAT; SET?total_count?=?emp_count; #關閉游標 CLOSE?emp_cursor; END?// DELIMITER?;
4.5 小結
游標是 MySQL 的一個重要的功能，為逐條讀取結果集中的數據，提供了完美的解決方案。跟在應用層面實現相同的功能相比，游標可以在存儲程序中使用，效率高，程序也更加簡潔。
但同時也會帶來一些性能問題，比如在使用游標的過程中，會對數據行進行加鎖，這樣在業務并發量大的時候，不僅會影響業務之間的效率，還會消耗系統資源，造成內存不足，這是因為游標是在內存中進行的處理。
建議：養成用完之后就關閉的習慣，這樣才能提高系統的整體效率。
補充：MySQL 8.0的新特性—全局變量的持久化
在MySQL數據庫中，全局變量可以通過SET GLOBAL語句來設置。例如，設置服務器語句超時的限制，可以通過設置系統變量max_execution_time來實現：
SET?GLOBAL?MAX_EXECUTION_TIME=2000;
使用SET GLOBAL語句設置的變量值只會臨時生效。數據庫重啟后，服務器又會從MySQL配置文件中讀取變量的默認值。 MySQL 8.0版本新增了SET PERSIST命令。例如，設置服務器的最大連接數為1000：
SET?PERSIST?global?max_connections?=?1000;
MySQL會將該命令的配置保存到數據目錄下的mysqld-auto.cnf文件中，下次啟動時會讀取該文件，用其中的配置來覆蓋默認的配置文件。
舉例：
查看全局變量max_connections的值，結果如下：
mysql>?show?variables?like?'%max_connections%'; +------------------------+-------+ |?Variable_name??????????|?Value?| +------------------------+-------+ |?max_connections????????|?151???| |?mysqlx_max_connections?|?100???| +------------------------+-------+ 2?rows?in?set,?1?warning?(0.00?sec)
設置全局變量max_connections的值：
mysql>?set?persist?max_connections=1000; Query?OK,?0?rows?affected?(0.00?sec)
重啟MySQL服務器，再次查詢max_connections的值：
mysql>?show?variables?like?'%max_connections%'; +------------------------+-------+ |?Variable_name??????????|?Value?| +------------------------+-------+ |?max_connections????????|?1000??| |?mysqlx_max_connections?|?100???| +------------------------+-------+ 2?rows?in?set,?1?warning?(0.00?sec)
更多編程相關知識，請訪問：mysql視頻教程！！
