文章目錄
- 32.1 存盤程序變數
- 32.2 條件控制陳述句
- 32.2.1 IF 陳述句
- 32.2.2 CASE 陳述句
- 32.3 回圈控制陳述句
- 32.3.1 LOOP 陳述句
- 32.3.2 REPAET 陳述句
- 32.3.3 WHILE 陳述句
- 32.4 錯誤處理
- 32.4.1 定義錯誤條件
- 32.4.2 定義錯誤處理器
- 32.4.3 獲取診斷資訊
- 32.4.4 拋出錯誤條件
- 32.5 游標的使用
- 32.5.1 宣告游標
- 32.5.2 打開游標
- 32.5.3 遍歷游標
- 32.5.4 關閉游標
- 32.6 訪問權限控制
書接上文,本篇我們來詳細介紹一下 MySQL 存盤程序和函式支持的編程功能,
32.1 存盤程序變數
變數(Variable)是存盤程序和函式內部用于存盤中間結果的物件,這些變數屬于區域變數,作用域限定在存盤程序中,在使用存盤程序變數之前需要使用DECLARE陳述句宣告變數:
DECLARE variable_name datatype(size) [DEFAULT default_value];
其中,DECLARE 表達定義變數,必須位于 BEGIN 和 END 之間并且是第一個陳述句;variable_name 是變數名;datatype(size) 是變數的型別和長度;DEFAULT default_value 用于為變數指定一個默認值,否則默認值為 NULL,例如,以下是一些變數的定義:
DECLARE salary DECIMAL(8, 2) DEFAULT 0.0;
DECLARE x, y INTEGER DEFAULT 0;
salary 是 DECIMAL(8, 2) 型別的變數,默認值為 0.0;x 和 y 是 INTEGER 型別變數,默認值為 0,
宣告了變數之后,可以使用SET陳述句進行賦值:
SET variable_name = value;
或者使用SELECT INTO陳述句將查詢的結果賦值給變數:
SELECT expression1, ...
INTO variable1, ...
FROM ...;
SELECT expression1, ...
FROM ...
INTO variable1, ...;
SELECT 回傳的運算式個數和變數的個數相同,查詢陳述句最多只能回傳一行資料,可以使用 LIMIT 1 進行限定,
以下陳述句創建了一個存盤程序 TestProc:
DELIMITER $$
CREATE PROCEDURE TestProc()
BEGIN
DECLARE sal decimal(8, 2) DEFAULT 0.0;
DECLARE x, y integer DEFAULT 0;
SELECT salary
FROM employee
WHERE emp_name = '張飛'
INTO sal;
SET x = 6, y = 9;
SELECT sal, x, y;
END$$
DELIMITER ;
呼叫該存盤程序查看變數的賦值結果:
CALL TestProc();
sal |x|y|
--------|-|-|
24000.00|6|9|
對于存盤程序變數,它的作用域(生命周期)位于存盤程序定義中的 BEGIN 和 END 陳述句之間,如果在嵌套的 BEGIN 和 END 陳述句之間定義的變數,作用域只在這個模塊內部,如果不同作用域中存在同名的變數,在作用域內有效范圍更小的變數優先級更高,例如:
DROP PROCEDURE TestProc;
DELIMITER $$
CREATE PROCEDURE TestProc()
BEGIN
DECLARE x integer DEFAULT 0;
SET x = 6;
SELECT 'outer', x;
BEGIN
DECLARE x integer DEFAULT 0;
SET x = 7;
SELECT 'inner', x;
END;
END$$
DELIMITER ;
存盤程序中先定義了一個個變數 x,然后在嵌套模塊中又定義了同名的變數,呼叫該存盤程序的輸出結果如下:
CALL TestProc();
outer|x|
-----|-|
outer|6|
inner|x|
-----|-|
inner|7|
在嵌套模塊中查詢回傳的是該模塊中的變數 x,雖然 MySQL 支持這種同名變數的使用,但是建議盡量不要這樣使用,避免引起混淆,
📝關于 MySQL 系統變數和用戶變數的介紹,可以參考本教程的第 17 篇,
32.2 條件控制陳述句
MySQL 提供了兩種條件控制陳述句:IF 陳述句和 CASE 陳述句,
32.2.1 IF 陳述句
IF 陳述句可以實作基本的條件判斷結構,語法如下:
IF search_condition THEN statement_list
[ELSEIF other_condition THEN other_statement_list]
...
[ELSE else_statement_list]
END IF;
如果 search_condition 的結果為 true,指定對應 THEN 之后的 statement_list 陳述句串列;否則,如果存在可選的 ELSEIF 并且 other_condition 結果為 true,執行對應的 other_statement_list 陳述句串列;依次類推;否則,如果存在可選的 ELSE,執行對應的 else_statement_list 陳述句串列,
例如:
DROP PROCEDURE TestProc;
DELIMITER $$
CREATE PROCEDURE TestProc()
BEGIN
DECLARE x, y integer DEFAULT 0;
SET x = 5, y = 10;
IF x = 5 THEN
SELECT 'x = 5';
END IF;
IF y < 10 THEN
SELECT 'y < 10';
ELSEIF y > 10 THEN
SELECT 'y > 10';
ELSE
SELECT 'y = 10';
END IF;
END$$
DELIMITER ;
呼叫該存盤程序的輸出結果如下:
CALL TestProc();
x = 5|
-----|
x = 5|
y = 10|
------|
y = 10|
32.2.2 CASE 陳述句
CASE 陳述句可以用于構造復雜的條件判斷結構,支持兩種形式的語法,第一種簡單形式的 CASE 陳述句如下:
CASE case_value
WHEN when_value1 THEN statement_list1
[WHEN when_value2 THEN statement_list2]
...
[ELSE else_statement_list]
END CASE;
其中,case_value 是一個運算式;首先使用該運算式的值和 when_value1 進行比較,如果相等則執行 statement_list1 陳述句串列并結束 CASE 陳述句;否則,如果運算式等于可選的 when_value2,則執行 statement_list2 并結束 CASE 陳述句;依次類推;最后,如果存在可選的 ELSE,執行 else_statement_list 陳述句串列;如果此時沒有定義 ELSE 子句,將會回傳“Case not found for CASE statement”錯誤,
第二種形式的搜索 CASE 陳述句如下:
CASE
WHEN search_condition1 THEN statement_list1
[WHEN search_condition2 THEN statement_list2]
...
[ELSE else_statement_list]
END CASE;
首先,判斷 search_condition1 是否為 true;如果是則執行 statement_list1 陳述句串列;否則,判斷 search_condition2 是否為 true,如果是則執行 statement_list2 陳述句串列;依此類推;最后,如果存在可選的 ELSE,執行 else_statement_list 陳述句串列;如果此時沒有定義 ELSE 子句,將會回傳“Case not found for CASE statement”錯誤,
例如:
DROP PROCEDURE TestProc;
DELIMITER $$
CREATE PROCEDURE TestProc()
BEGIN
DECLARE x integer DEFAULT 0;
SET x = 5;
CASE
WHEN x < 0 THEN
SELECT 'x < 0';
WHEN x = 0 THEN
SELECT 'x = 0';
ELSE
SELECT 'x > 0';
END CASE;
END$$
DELIMITER ;
呼叫該存盤程序的輸出結果如下:
CALL TestProc();
x > 0|
-----|
x > 0|
??第 13 篇我們介紹了 CASE 運算式與 IF 函式,和本篇的 CASE 陳述句和 IF 陳述句是不同的概念,
32.3 回圈控制陳述句
MySQL 支持三種回圈控制陳述句:LOOP、REPEAT 以及 WHILE 陳述句,
32.3.1 LOOP 陳述句
LOOP陳述句用于實作簡單的回圈結構,語法如下:
[begin_label:] LOOP
statement_list
END LOOP [end_label]
LOOP 陳述句重復執行 statement_list 直到回圈被終止,通常使用LEAVE label陳述句退出回圈,或者使用函式的 RETURN 陳述句退出整個函式,begin_label 和 end_label 是該回圈陳述句的標簽,例如:
DELIMITER $$
CREATE PROCEDURE TestLoop()
BEGIN
DECLARE x,sumx integer DEFAULT 0;
label1: LOOP
SET x = x + 1;
IF x > 10 THEN
LEAVE label1;
END IF;
IF x mod 2 THEN
ITERATE label1;
ELSE
SET sumx = sumx + x;
END IF;
END LOOP label1;
SELECT sumx;
END$$
DELIMITER ;
其中,LEAVE 表示 x 大于 10 時退出回圈 label1;ITERATE 類似于 C++ 或者 Java 中的 CONTINUE,表示 x 為奇數則進入下一次回圈,否則將其增加到變數 sumx ,存盤程序的運行結果如下:
CALL TestLoop();
sumx|
----|
30|
??如果 LOOP 回圈陳述句中沒有指定退出條件,將會進入死回圈,
32.3.2 REPAET 陳述句
REPAET陳述句用于重復執行指定陳述句串列直到某個條件為真,語法如下:
[begin_label:] REPEAT
statement_list
UNTIL search_condition
END REPEAT [end_label];
REPEAT 陳述句首先執行 statement_list,然后判斷 search_condition 是否為 true;如果是則終止回圈,否則再次回圈,REPAET 陳述句至少會執行一次,例如,上面的 LOOP 陳述句示例使用 REPAET 實作如下:
DELIMITER $$
CREATE PROCEDURE TestRepeat()
BEGIN
DECLARE x,sumx integer DEFAULT 0;
label1: REPEAT
SET x = x + 1;
IF x mod 2 THEN
ITERATE label1;
ELSE
SET sumx = sumx + x;
END IF;
UNTIL x = 10 END REPEAT label1;
SELECT sumx;
END$$
DELIMITER ;
UNTIL 指定了 x = 10 時退出回圈,執行該存盤程序的結果和上一節相同,
32.3.3 WHILE 陳述句
WHILE陳述句基于某個條件為真時重復執行指定的陳述句串列,語法如下:
[begin_label:] WHILE search_condition DO
statement_list
END WHILE [end_label];
首先,判斷 search_condition 是否為 true;如果是則執行 statement_list 陳述句串列,否則退出回圈陳述句,WHILE 陳述句可能一次也不執行,例如,上面的 LOOP 陳述句示例使用 WHILE 實作如下:
DELIMITER $$
CREATE PROCEDURE TestWhile()
BEGIN
DECLARE x,sumx integer DEFAULT 0;
label1: WHILE x < 10 DO
SET x = x + 1;
IF x mod 2 THEN
ITERATE label1;
ELSE
SET sumx = sumx + x;
END IF;
END WHILE label1;
SELECT sumx;
END$$
DELIMITER ;
32.4 錯誤處理
當存盤程序或者函式在執行程序中出現某種錯誤條件(例如警告或者例外)時,需要進行特殊處理,例如退出當前程式模塊或者繼續執行,同時回傳一個有用的錯誤資訊,
32.4.1 定義錯誤條件
MySQL 提供了定義錯誤條件的DECLARE ... CONDITION陳述句:
DECLARE condition_name CONDITION
FOR { mysql_error_code | SQLSTATE [VALUE] sqlstate_value }
其中,condition_name 是錯誤條件的名稱,可以用于隨后的錯誤處理器宣告;mysql_error_code 表示 MySQL 錯誤碼,例如 1062 代表了唯一鍵重復錯誤;SQLSTATE 表示使用 5 位字串代表的 SQLSTATE 值,例如“42000” 和錯誤碼 1062 一樣代表了唯一鍵重復錯誤,
32.4.2 定義錯誤處理器
定義了錯誤條件之后,我們可以使用DECLARE ... HANDLER陳述句定義處理一個或多個錯誤條件的錯誤處理器:
DECLARE { CONTINUE | EXIT } HANDLER
FOR condition_value [, condition_value] ...
statement;
condition_value: {
mysql_error_code
| SQLSTATE [VALUE] sqlstate_value
| condition_name
| SQLWARNING
| NOT FOUND
| SQLEXCEPTION
}
該陳述句定義了一個錯誤處理器;當某個錯誤條件 condition_value 發生時,執行指定的 statement 陳述句,可以是單個陳述句或者 BEGIN/END 代碼塊;然后執行相應的操作,CONTINUE 表示繼續執行當前程式,EXIT 表示終止執行錯誤處理器所在的 BEGIN/END 模塊,
指定錯誤條件時,mysql_error_code 表示 MySQL 錯誤碼,SQLSTATE 表示使用 5 位字串代表的 SQLSTATE 值,condition_name 是使用 DECLARE … CONDITION 陳述句定義的錯誤條件名稱,SQLWARNING 代表了以“01”開頭的一類 SQLSTATE 值,NOT FOUND 代表了以“02”開頭的一類 SQLSTATE 值,SQLEXCEPTION 代表了以“00”、“01”或者“02”開頭的一類 SQLSTATE 值,
例如:
DELIMITER $$
CREATE PROCEDURE TestError()
BEGIN
DECLARE empid int DEFAULT 1;
DECLARE duplicate_employee CONDITION FOR 1062;
DECLARE EXIT HANDLER
FOR duplicate_employee
BEGIN
ROLLBACK;
SELECT CONCAT('重復的員工資訊!', 'emp_id:', empid) Message;
END;
INSERT INTO employee
VALUES (empid, '劉備', '男', 1, NULL, DATE('2000-01-01'), 1, 30000, 10000, 'liubei@shuguo.com');
END$$
DELIMITER ;
首先,我們定義了一個錯誤條件 duplicate_employee,表示員工資訊重復錯誤;然后定義了一個錯誤處理器,發生該錯誤時回滾資料修改并且輸出一個訊息,使用命名的錯誤條件可以提高代碼的可讀性,執行該存盤程序的結果如下:
CALL TestError();
Message |
---------------------|
重復的員工資訊!emp_id:1|
如果將錯誤處理器執行的陳述句稍加修改,就可以實作第 26 篇中的合并資料操作:
DECLARE EXIT HANDLER
FOR duplicate_employee
BEGIN
UPDATE employee
SET emp_name = '劉備'
...
WHERE emp_id = empid;
END;
📝如果定義了多個錯誤處理器,指定錯誤碼的處理器優先級最高,然后是 SQLSTATE 處理器,然后是 SQLEXCEPTION 處理器,最后是 SQLWARNING 處理器以及 NOT FOUND 處理器,多個優先級相同的錯誤處理器的執行順序不確定,
32.4.3 獲取診斷資訊
MySQL 在發生錯誤時會生成診斷資訊,應用程式可以通過GET DIAGNOSTICS陳述句獲取這些資訊,例如:
mysql> DROP TABLE no_such_table;
ERROR 1051 (42S02): Unknown table 'hrdb.no_such_table'
mysql> GET DIAGNOSTICS CONDITION 1
-> @p1 = RETURNED_SQLSTATE, @p2 = MESSAGE_TEXT;
Query OK, 0 rows affected (0.00 sec)
mysql> SELECT @p1, @p2;
+-------+------------------------------------+
| @p1 | @p2 |
+-------+------------------------------------+
| 42S02 | Unknown table 'hrdb.no_such_table' |
+-------+------------------------------------+
1 row in set (0.00 sec)
另外,我們也可以使用 SHOW WARNINGS 或者 SHOW ERRORS 查看相關的錯誤資訊,
GET DIAGNOSTICS 陳述句的完整語法如下:
GET [CURRENT | STACKED] DIAGNOSTICS {
target = NUMBER | target = ROW_COUNT,
...
}
GET [CURRENT | STACKED] DIAGNOSTICS
CONDITION condition_number {
target = condition_information_item_name,
...
}
condition_information_item_name: {
CLASS_ORIGIN
| SUBCLASS_ORIGIN
| RETURNED_SQLSTATE
| MESSAGE_TEXT
| MYSQL_ERRNO
| CONSTRAINT_CATALOG
| CONSTRAINT_SCHEMA
| CONSTRAINT_NAME
| CATALOG_NAME
| SCHEMA_NAME
| TABLE_NAME
| COLUMN_NAME
| CURSOR_NAME
}
其中,CURRENT 表示回傳當前診斷區域中的資訊,STACKED 表示回傳第二診斷區域的資訊(只能用于 DECLARE HANDLER 陳述句之中),默認回傳當前診斷區域中的資訊,
簡單來說,診斷區域中存盤了兩類資訊:
- 陳述句資訊,包括錯誤條件的編號(NUMBER)和影響的行數(ROW_COUNT),對應上面的第一種語法,
- 條件資訊,例如錯誤碼(MYSQL_ERRNO)和錯誤資訊(MESSAGE_TEXT)等,對應上面的第二種語法,如果一個陳述句觸發了多個錯誤條件,每個錯誤條件都提供了一個條件區域,編號從 1 到 NUMBER,
📝關于 MySQL 診斷區域的詳細介紹,可以參考官方檔案,
以下是一個在存盤程序中獲取診斷資訊的示例:
CREATE TABLE t(id int NOT NULL);
DELIMITER $$
CREATE PROCEDURE do_insert(value INT)
BEGIN
-- 宣告保存診斷資訊的變數
DECLARE cno INT;
DECLARE code CHAR(5) DEFAULT '00000';
DECLARE msg TEXT;
DECLARE nrows INT;
DECLARE result TEXT;
-- 宣告例外錯誤處理器
DECLARE CONTINUE HANDLER FOR SQLEXCEPTION
BEGIN
GET DIAGNOSTICS cno = NUMBER;
GET DIAGNOSTICS CONDITION cno
code = RETURNED_SQLSTATE, msg = MESSAGE_TEXT;
END;
-- 執行插入陳述句
INSERT INTO t(id) VALUES(value);
-- 檢查插入是否成功
IF code = '00000' THEN
GET DIAGNOSTICS nrows = ROW_COUNT;
SET result = CONCAT('insert succeeded, row count = ',nrows);
ELSE
SET result = CONCAT('insert failed, error = ',code,', message = ',msg);
END IF;
-- 回傳錯誤資訊
SELECT result;
END$$
DELIMITER ;
其中,cno 是回傳的錯誤條件編號,code 和 msg 是錯誤編碼和資訊,nrows 是成功插入的行數,運行以下測驗陳述句:
CALL do_insert(1);
result |
-------------------------------|
insert succeeded, row count = 1|
CALL do_insert(NULL);
result |
------------------------------------------------------------------|
insert failed, error = 23000, message = Column 'id' cannot be null|
32.4.4 拋出錯誤條件
除了捕獲和處理錯誤之外,MySQL 還提供了拋出錯誤的SIGNAL和RESIGNAL陳述句,
SIGNAL { SQLSTATE [VALUE] sqlstate_value | condition_name }
[SET condition_information_item_name = simple_value, ...]
condition_information_item_name: {
CLASS_ORIGIN
| SUBCLASS_ORIGIN
| MESSAGE_TEXT
| MYSQL_ERRNO
| CONSTRAINT_CATALOG
| CONSTRAINT_SCHEMA
| CONSTRAINT_NAME
| CATALOG_NAME
| SCHEMA_NAME
| TABLE_NAME
| COLUMN_NAME
| CURSOR_NAME
}
SIGNAL 可以拋出一個 SQLSTATE 值或者命名的錯誤條件,SET 子句可以設定不同的資訊,它們可以在呼叫程式中使用 GET DIAGNOSTICS 陳述句捕獲,例如:
DELIMITER $$
CREATE PROCEDURE p(divisor INT)
BEGIN
IF divisor = 0 THEN
SIGNAL SQLSTATE '22012'
SET MESSAGE_TEXT = 'devided by zero!';
END IF;
END;
DELIMITER ;
存盤程序 p 拋出了一個自定義的錯誤條件,指定了 SQLSTATE 值和錯誤訊息,傳入引數 0,測驗拋出錯誤的結果:
CALL p(0);
ERROR 1644 (22012): devided by zero!
另外,RESIGNAL陳述句也可以拋出錯誤,語法和 SIGNAL 相同,不過,RESIGNAL 和 SIGNAL 存在一些差異:
- RESIGNAL 陳述句只能用于錯誤處理器的處理陳述句中,可以修改某些錯誤資訊后再次拋出;
- RESIGNAL 陳述句的屬性可以忽略,意味著將接收到的錯誤不經修改再次拋出,
32.5 游標的使用
游標(Cursor)可以支持對查詢結果的遍歷,從而實作資料集的逐行處理,MySQL 存盤程序和函式支持游標,它們具有以下特性:
- Asensitive 靈敏性,服務器可能直接遍歷基礎表的資料,也可能復制一份額外的臨時資料;
- 只讀性(Read only),不能通過游標修改基礎表中的資料;
- 不可滾動性(Nonscrollable),只能按照查詢結果的順序訪問資料,不能反向遍歷,也不能跳躍訪問資料行,
使用 MySQL 游標的程序如下:
- 通過
DECLARE陳述句宣告游標; - 使用
OPEN陳述句打開游標; - 回圈使用
FETCH陳述句獲取游標中的資料行; - 使用
CLOSE陳述句關閉游標并釋放資源,
以下是一個使用游標的示例:
DELIMITER $$
CREATE PROCEDURE TestCurosr()
BEGIN
DECLARE done INT DEFAULT FALSE;
DECLARE id int;
DECLARE name varchar(50);
DECLARE namelist varchar(500) default '';
DECLARE cur1 CURSOR FOR
SELECT emp_id, emp_name FROM employee WHERE sex = '女';
DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;
OPEN cur1;
getEmp: LOOP
FETCH cur1 INTO id, name;
IF done THEN
LEAVE getEmp;
ELSE
SET namelist = concat( name, ';', namelist);
END IF;
END LOOP;
CLOSE cur1;
SELECT namelist;
END$$
DELIMITER ;
該存盤程序的執行結果如下:
CALL TestCurosr();
namelist |
------------------|
趙氏;孫丫鬟;孫尚香;|
下面我們基于該示例介紹使用游標程序中的陳述句,
32.5.1 宣告游標
MySQL 使用 DECLARE 陳述句宣告游標:
DECLARE cursor_name CURSOR FOR select_statement;
其中,cursor_name 是游標名稱,select_statement 定義了與游標關聯的查詢陳述句,游標宣告必須在變數和錯誤條件(CONDITION)宣告之后,以及錯誤處理器(HANDLER)宣告之前,在上面的示例中宣告了一個游標 cur1:
DECLARE cur1 CURSOR FOR
SELECT emp_id, emp_name FROM employee WHERE sex = '女';
32.5.2 打開游標
宣告之后,使用 OPEN 陳述句打開游標,也就是執行查詢初始化結果集:
OPEN cur1;
32.5.3 遍歷游標
接下來就是回圈使用 FETCH 陳述句獲取下一行資料,并且移動游標指標:
FETCH cur1 INTO id, name;
同時,在回圈中檢查是否還有更多資料行;如果沒有則退出回圈,變數 done 在預定義的錯誤處理器中進行設定,沒有找到資料(NOT FOUND)時設定為 true,
32.5.4 關閉游標
最后,使用 CLOSE 陳述句關閉游標:
CLOSE cur1;
關閉游標可以釋放相關的資源,
32.6 訪問權限控制
在存盤程序和函式的定義中,可以使用 SQL SECURITY 屬性指定定義者權限(DEFINER )或者呼叫者權限(INVOKER ),
對于 SQL SECURITY DEFINER,存盤程序使用定義者的權限執行,定義者可以通過 DEFINER 屬性進行指定,默認為當前用戶,
對于 SQL SECURITY INVOKER,存盤程序將會使用呼叫者的權限執行,此時 DEFINER 屬性不會對執行產生任何作用,如果呼叫者的權限較低,定義者的權限較高,呼叫者仍然能夠獲得存盤程序內部操作所需的權限,
CSDN認證博客專家
資料庫架構師
轉載請註明出處,本文鏈接:https://www.uj5u.com/shujuku/152653.html
標籤:其他
上一篇:【SSM -MyBatis篇03】MyBatis Generator(MBG)配置屬性詳解(基于MyBatis3) - 逆向生成 - 配置MBG模板
