1. 程式人生 > 資料庫 >MYSQL的儲存過程和函式簡單寫法

MYSQL的儲存過程和函式簡單寫法

什麼是儲存過程

簡單的說,就是一組SQL語句集,功能強大,可以實現一些比較複雜的邏輯功能,類似於JAVA語言中的方法;

ps:儲存過程跟觸發器有點類似,都是一組SQL集,但是儲存過程是主動呼叫的,且功能比觸發器更加強大,觸發器是某件事觸發後自動呼叫;

有哪些特性

有輸入輸出引數,可以宣告變數,有if/else,case,while等控制語句,通過編寫儲存過程,可以實現複雜的邏輯功能;

函式的普遍特性:模組化,封裝,程式碼複用;

速度快,只有首次執行需經過編譯和優化步驟,後續被呼叫可以直接執行,省去以上步驟;

MySQL儲存過程的建立

語法

CREATE PROCEDURE sp_name ([proc_parameter[,...]]) [characteristic ...] routine_body

CREATE PROCEDURE過程名([[IN|OUT|INOUT] 引數名 資料型別[,[IN|OUT|INOUT] 引數名 資料型別…]]) [特性 ...] 過程體

DELIMITER //
 CREATE PROCEDURE myproc(OUT s int)
  BEGIN
   SELECT COUNT(*) INTO s FROM students;
  END
  //
DELIMITER ;

分隔符

MySQL預設以";"為分隔符,如果沒有宣告分割符,則編譯器會把儲存過程當成SQL語句進行處理,因此編譯過程會報錯,所以要事先用“DELIMITER //”聲明當前段分隔符,讓編譯器把兩個"//"之間的內容當做儲存過程的程式碼,不會執行這些程式碼;“DELIMITER ;”的意為把分隔符還原。

引數

儲存過程根據需要可能會有輸入、輸出、輸入輸出引數,如果有多個引數用","分割開。MySQL儲存過程的引數用在儲存過程的定義,共有三種引數型別,IN,OUT,INOUT:

  • IN引數的值必須在呼叫儲存過程時指定,在儲存過程中修改該引數的值不能被返回,為預設值
  • OUT:該值可在儲存過程內部被改變,並可返回
  • INOUT:呼叫時指定,並且可被改變和返回

其中,sp_name引數是儲存過程的名稱;proc_parameter表示儲存過程的引數列表; characteristic引數指定儲存過程的特性;routine_body引數是SQL程式碼的內容,可以用BEGIN…END來標誌SQL程式碼的開始和結束。

  proc_parameter中的每個引數由3部分組成。這3部分分別是輸入輸出型別、引數名稱和引數型別。其形式如下:

  [ IN | OUT | INOUT ] param_name type

  其中,IN表示輸入引數;OUT表示輸出引數; INOUT表示既可以是輸入,也可以是輸出; param_name引數是儲存過程的引數名稱;type引數指定儲存過程的引數型別,該型別可以是MySQL資料庫的任意資料型別。

  characteristic引數有多個取值。其取值說明如下:

  LANGUAGE SQL:說明routine_body部分是由SQL語言的語句組成,這也是資料庫系統預設的語言。

  [NOT] DETERMINISTIC:指明儲存過程的執行結果是否是確定的。DETERMINISTIC表示結果是確定的。每次執行儲存過程時,相同的輸入會得到相同的輸出。NOT DETERMINISTIC表示結果是非確定的,相同的輸入可能得到不同的輸出。預設情況下,結果是非確定的。

  { CONTAINS SQL | NO SQL | READS SQL DATA | MODIFIES SQL DATA }:指明子程式使用SQL語句的限制。CONTAINS SQL表示子程式包含SQL語句,但不包含讀或寫資料的語句;NO SQL表示子程式中不包含SQL語句;READS SQL DATA表示子程式中包含讀資料的語句;MODIFIES SQL DATA表示子程式中包含寫資料的語句。預設情況下,系統會指定為CONTAINS SQL。

  SQL SECURITY { DEFINER | INVOKER }:指明誰有許可權來執行。DEFINER表示只有定義者自己才能夠執行;INVOKER表示呼叫者可以執行。預設情況下,系統指定的許可權是DEFINER。

  COMMENT 'string':註釋資訊。

  技巧:建立儲存過程時,系統預設指定CONTAINS SQL,表示儲存過程中使用了SQL語句。但是,如果儲存過程中沒有使用SQL語句,最好設定為NO SQL。而且,儲存過程中最好在COMMENT部分對儲存過程進行簡單的註釋,以便以後在閱讀儲存過程的程式碼時更加方便。

【示例1】 下面建立一個名為num_from_employee的儲存過程。程式碼如下:

CREATE PROCEDURE num_from_employee (IN emp_id INT,OUT count_num INT ) 
     READS SQL DATA 
     BEGIN 
       SELECT COUNT(*) INTO count_num 
       FROM employee 
       WHERE d_id=emp_id ; 
     END

上述程式碼中,儲存過程名稱為num_from_employee;輸入變數為emp_id;輸出變數為count_num。SELECT語句從employee表查詢d_id值等於emp_id的記錄,並用COUNT(*)計算d_id值相同的記錄的條數,最後將計算結果存入count_num中。程式碼的執行結果如下:

mysql> DELIMITER && 
mysql> CREATE PROCEDURE num_from_employee
(IN emp_id INT,OUT count_num INT ) 
  -> READS SQL DATA 
  -> BEGIN 
  -> SELECT COUNT(*) INTO count_num 
  -> FROM employee 
  -> WHERE d_id=emp_id ; 
  -> END && 
Query OK,0 rows affected (0.09 sec) 
mysql> DELIMITER ;

程式碼執行完畢後,沒有報出任何出錯資訊就表示儲存函式已經建立成功。以後就可以呼叫這個儲存過程,資料庫中會執行儲存過程中的SQL語句。

  說明:MySQL中預設的語句結束符為分號(;)。儲存過程中的SQL語句需要分號來 結束。為了避免衝突,首先用"DELIMITER &&"將MySQL的結束符設定為&&。最後再用"DELIMITER ;"來將結束符恢復成分號。這與建立觸發器時是一樣的。

函式

  在MySQL中,建立儲存函式的基本形式如下:

CREATE FUNCTION sp_name ([func_parameter[,...]]) RETURNS type [characteristic ...] routine_body
  其中,sp_name引數是儲存函式的名稱;func_parameter表示儲存函式的引數列表;RETURNS type指定返回值的型別;characteristic引數指定儲存函式的特性,該引數的取值與儲存過程中的取值是一樣的,請讀者參照14.1.1小節的內容;routine_body引數是SQL程式碼的內容,可以用BEGIN…END來標誌SQL程式碼的開始和結束。

  func_parameter可以由多個引數組成,其中每個引數由引數名稱和引數型別組成,其形式如下:param_name type

  其中,param_name引數是儲存函式的引數名稱;type引數指定儲存函式的引數型別,該型別可以是MySQL資料庫的任意資料型別。

【示例2】 下面建立一個名為name_from_employee的儲存函式。程式碼如下:

CREATE FUNCTION name_from_employee (emp_id INT ) 
     RETURNS VARCHAR(20) 
     BEGIN 
       RETURN (SELECT name 
       FROM employee 
       WHERE num=emp_id ); 
     END

上述程式碼中,儲存函式的名稱為name_from_employee;該函式的引數為emp_id;返回值是VARCHAR型別。SELECT語句從employee表查詢num值等於emp_id的記錄,並將該記錄的name欄位的值返回。程式碼的執行結果如下:

mysql> DELIMITER && 
mysql> CREATE FUNCTION name_from_employee (emp_id INT ) 
  -> RETURNS VARCHAR(20) 
  -> BEGIN 
  -> RETURN (SELECT name 
  -> FROM employee 
  -> WHERE num=emp_id ); 
  -> END&& 
Query OK,0 rows affected (0.00 sec) 
mysql> DELIMITER ;

結果顯示,儲存函式已經建立成功。該函式的使用和MySQL內部函式的使用方法一樣。

變數的使用

在儲存過程和函式中,可以定義和使用變數。使用者可以使用DECLARE關鍵字來定義變數。然後可以為變數賦值。這些變數的作用範圍是BEGIN…END程式段中。本小節將講解如何定義變數和為變數賦值。

1.定義變數

  MySQL中可以使用DECLARE關鍵字來定義變數。定義變數的基本語法如下:

DECLARE var_name[,...] type [DEFAULT value]

  其中, DECLARE關鍵字是用來宣告變數的;var_name引數是變數的名稱,這裡可以同時定義多個變數;type引數用來指定變數的型別;DEFAULT value子句將變數預設值設定為value,沒有使用DEFAULT子句時,預設值為NULL。

【示例3】 下面定義變數my_sql,資料型別為INT型,預設值為10。程式碼如下:

DECLARE my_sql INT DEFAULT 10 ;

2.為變數賦值

  MySQL中可以使用SET關鍵字來為變數賦值。SET語句的基本語法如下:

SET var_name = expr [,var_name = expr] ...

  其中,SET關鍵字是用來為變數賦值的;var_name引數是變數的名稱;expr引數是賦值表示式。一個SET語句可以同時為多個變數賦值,各個變數的賦值語句之間用逗號隔開。

【示例4】 下面為變數my_sql賦值為30。程式碼如下:

SET my_sql = 30 ;

  MySQL中還可以使用SELECT…INTO語句為變數賦值。其基本語法如下:

SELECT col_name[,…] INTO var_name[,…] FROM table_name WEHRE condition
  其中,col_name引數表示查詢的欄位名稱;var_name引數是變數的名稱;table_name引數指表的名稱;condition引數指查詢條件。

【示例5】 下面從employee表中查詢id為2的記錄,將該記錄的d_id值賦給變數my_sql。程式碼如下:

SELECT d_id INTO my_sql FROM employee WEHRE id=2 ;

定義條件和處理程式

  定義條件和處理程式是事先定義程式執行過程中可能遇到的問題。並且可以在處理程式中定義解決這些問題的辦法。這種方式可以提前預測可能出現的問題,並提出解決辦法。這樣可以增強程式處理問題的能力,避免程式異常停止。MySQL中都是通過DECLARE關鍵字來定義條件和處理程式。本小節中將詳細講解如何定義條件和處理程式。

1.定義條件

  MySQL中可以使用DECLARE關鍵字來定義條件。其基本語法如下:

DECLARE condition_name CONDITION FOR condition_value 
condition_value: 
   SQLSTATE [VALUE] sqlstate_value | mysql_error_code 

其中,condition_name引數表示條件的名稱;condition_value引數表示條件的型別;sqlstate_value引數和mysql_error_code引數都可以表示MySQL的錯誤。例如ERROR 1146 (42S02)中,sqlstate_value值是42S02,mysql_error_code值是1146。

【示例6】 下面定義"ERROR 1146 (42S02)"這個錯誤,名稱為can_not_find。可以用兩種不同的方法來定義,程式碼如下:

//方法一:使用sqlstate_value 
DECLARE can_not_find CONDITION FOR SQLSTATE '42S02' ; 
//方法二:使用mysql_error_code 
DECLARE can_not_find CONDITION FOR 1146 ; 

2.定義處理程式

MySQL中可以使用DECLARE關鍵字來定義處理程式。其基本語法如下:

DECLARE handler_type HANDLER FOR 
condition_value[,...] sp_statement 
handler_type: 
  CONTINUE | EXIT | UNDO 
condition_value: 
  SQLSTATE [VALUE] sqlstate_value |
condition_name | SQLWARNING 
    | NOT FOUND | SQLEXCEPTION | mysql_error_code

其中,handler_type引數指明錯誤的處理方式,該引數有3個取值。這3個取值分別是CONTINUE、EXIT和UNDO。CONTINUE表示遇到錯誤不進行處理,繼續向下執行;EXIT表示遇到錯誤後馬上退出;UNDO表示遇到錯誤後撤回之前的操作,MySQL中暫時還不支援這種處理方式。

  注意:通常情況下,執行過程中遇到錯誤應該立刻停止執行下面的語句,並且撤回前面的操作。但是,MySQL中現在還不能支援UNDO操作。因此,遇到錯誤時最好執行EXIT操作。如果事先能夠預測錯誤型別,並且進行相應的處理,那麼可以執行CONTINUE操作。

  condition_value引數指明錯誤型別,該引數有6個取值。sqlstate_value和mysql_error_code與條件定義中的是同一個意思。condition_name是DECLARE定義的條件名稱。SQLWARNING表示所有以01開頭的sqlstate_value值。NOT FOUND表示所有以02開頭的sqlstate_value值。SQLEXCEPTION表示所有沒有被SQLWARNING或NOT FOUND捕獲的sqlstate_value值。sp_statement表示一些儲存過程或函式的執行語句。

【示例7】 下面是定義處理程式的幾種方式。程式碼如下:

//方法一:捕獲sqlstate_value 
DECLARE CONTINUE HANDLER FOR SQLSTATE '42S02'
SET @info='CAN NOT FIND'; 
//方法二:捕獲mysql_error_code 
DECLARE CONTINUE HANDLER FOR 1146 SET @info='CAN NOT FIND'; 
//方法三:先定義條件,然後呼叫 
DECLARE can_not_find CONDITION FOR 1146 ; 
DECLARE CONTINUE HANDLER FOR can_not_find SET 
@info='CAN NOT FIND'; 
//方法四:使用SQLWARNING 
DECLARE EXIT HANDLER FOR SQLWARNING SET @info='ERROR'; 
//方法五:使用NOT FOUND 
DECLARE EXIT HANDLER FOR NOT FOUND SET @info='CAN NOT FIND'; 
//方法六:使用SQLEXCEPTION 
DECLARE EXIT HANDLER FOR SQLEXCEPTION SET @info='ERROR';

上述程式碼是6種定義處理程式的方法。

  第一種方法是捕獲sqlstate_value值。如果遇到sqlstate_value值為42S02,執行CONTINUE操作,並且輸出"CAN NOT FIND"資訊。

  第二種方法是捕獲mysql_error_code值。如果遇到mysql_error_code值為1146,執行CONTINUE操作,並且輸出"CAN NOT FIND"資訊。

  第三種方法是先定義條件,然後再呼叫條件。這裡先定義can_not_find條件,遇到1146錯誤就執行CONTINUE操作。

  第四種方法是使用SQLWARNING。SQLWARNING捕獲所有以01開頭的sqlstate_value值,然後執行EXIT操作,並且輸出"ERROR"資訊。

  第五種方法是使用NOT FOUND。NOT FOUND捕獲所有以02開頭的sqlstate_value值,然後執行EXIT操作,並且輸出"CAN NOT FIND"資訊。

  第六種方法是使用SQLEXCEPTION。SQLEXCEPTION捕獲所有沒有被SQLWARNING或NOT FOUND捕獲的sqlstate_value值,然後執行EXIT操作,並且輸出"ERROR"資訊。

MySQL儲存過程寫法總結

1、建立無參儲存過程。

create procedure product()
begin
    select * from user;
end;

一條簡單的儲存過程建立語句,此時呼叫的語句為:

call procedure();

##注意,如果是在命令列下編寫的話,這樣的寫法會出現語法錯誤,即再select 那一句結束
mysql就會進行解釋了,此時應該先把結尾符換一下:

delimiter //
create procedure product()
begin
    select * from user;
end //

最後再換回來

delimiter ;

2、建立有參儲存過程

有參的儲存包括兩種引數,
一個是傳入引數;
一個是傳出引數;
例如一個儲存過程:

create procedure procedure2(
out p1 decimal(8,2),out p2 decimal(8,in p3 int
)
begin
select sum(uid) into p1 from user where order_name = p3;
select avg(uid) into p2 from user ;
end ;

從上面sql語句可以看出,p1和p2是用來檢索並且傳出去的值,而p3則是必須有呼叫這傳入的具體值。
看具體呼叫過程:

call product(); //無參
call procedure2(@userSum,@userAvg,201708); //有參

當用完後,可以直接查詢userSum和userAvg的值:

select @userSum,@userAvg;

結果如下:

+----------+----------+
| @userSum | @userAvg |
+----------+----------+
| 67.00 | 6.09 |
+----------+----------+
1 row in set (0.00 sec)

3、刪除儲存過程

一條語句: drop procedure product; //沒有括號後面

4、一段完整的儲存過程例項:

-- Name: drdertotal 
-- Parameters : onumber = order number 
--       taxable = 0 if not taxable,1if taxable 
--       ototal = order total variable 
 
create procedure ordertotal( 
in onumber int,in taxable boolean,out ototal decimal(8,2) 
) commit 'Obtain order total,optionally adding tax'  
begin 
  -- Declare variable for total 
  declare total decimal(8,2); 
  -- Declare tax percentage 
  declare taxrate int default 6; 
   
  --Get the order total 
  select Sum(item_price*quantity) 
  from orderitems 
  where order_num = onumber 
  into total; 
   
  --Is this taxable? 
  if taxable then 
    --Yes,so add taxrate to the total 
    select total+(total/100*taxrate) into total; 
  end if; 
   
  --Add finally,save to out variable 
  select total into ototal; 
end;

上面儲存過程類似於高階語言的業務處理,看懂還是不難的,注意寫法細節

commit關鍵字:它不是必需的,但如果給出,將在show procedure status的結果中給出。

if語句:這個例子給出了mysqlif語句的基本用法,if語句還支援elseif和else子句。

通過show procedure status可以列出所有的儲存過程的詳細列表,並且可以在後面加一個

like+指定過濾模式來進行過濾。