Mysql 儲存過程以及 python callproc調用

一、存儲過程（stored procedure）

　　 存儲過程將存入的一系列SQL語句進行預編譯，執行並存放在數據庫中，之后如果需要使用sql語句對這一組sql進行訪問時可以直接提取（很好理解 存儲過程就是將sql執行過程存儲在數據庫中，來方便提取）。

　　 　　優點：1.多次提取，減少編譯時間，2.因為每次提取都需要傳入sql語句，如果用存儲過程名來調用的話，就減少了訪問流量3.增加了重用（可以相較之與（函數對編程的影響））
　　　　 缺點：1.存儲過程將會占用內存空間，並且復雜的過程操作需要一定的cpu 2.存儲過程難以調試，如果存儲過程太過復雜，不有利於業務邏輯3.存儲過程高級，難以維護

　　

DELIMITER $$   // 設置注釋
CREATE PROCEDURE CountOrderByStatus(
 IN orderStatus VARCHAR(25),     //需要給定存入使用的參數
 OUT total INT)                 //需要給定輸出的參數
BEGIN
 SELECT count(orderNumber)
 INTO total
 FROM orders
 WHERE status = orderStatus;
END$$
DELIMITER ;

　　這個存儲過程接受兩個過程參數 一個是輸入參數orderStatus，另一個是輸出參數 total 最后可以使用Call CountOrderByStatus('23',@title)來進行調用，變量前面要加@.

參數類型

IN 參數名 參數類型 :表示該參數需要在創建存儲類型時給出，以便在下面的語句中使用

官方樣例:

　　

DELIMITER //
CREATE PROCEDURE GetOfficeByCountry(IN countryName VARCHAR(255))
 BEGIN
 SELECT * 
 FROM offices
 WHERE country = countryName;
 END //
DELIMITER ;


CALL GetOfficeByCountry('USA')//調用

OUT 參數名 參數類型:該參數在執行完所有的參數語句后可以返回.

INOUT 參數名 參數類型: 該參數的不同之處在於它傳入的參數需要賦值，並且在callprogram之后他的參數值將會被修改返回給變量值.

DELIMITER $$
CREATE PROCEDURE set_counter(INOUT count INT(4),IN inc INT(4))//傳入一個Inout參數和一個in參數
BEGIN
 SET count = count + inc;
END$$
DELIMITER ;

現在嘗試調用此儲存過程

SET @counter = 1;
CALL set_counter(@counter,1); -- 2  
CALL set_counter(@counter,1); -- 3  //@count的值已經被修改
CALL set_counter(@counter,5); -- 8
SELECT @counter; -- 8

謂詞邏輯：

IF（基本）

IF if_expression THEN commands
   [ELSEIF elseif_expression THEN commands]
   [ELSE commands]
   END IF;

While loop

WHILE expression DO
   Statements
END WHILE

　REPEAT
　　　Statements;
　UNTIL expression
　　　END REPEAT

 

Case

CASE  case_expression
   WHEN when_expression_1 THEN commands
   WHEN when_expression_2 THEN commands
   ...
   ELSE commands
END CASE;

注意事項：能用Case用Case，能簡化就簡化

重點

如何python調用 callproc 進行調用儲存過程

1.創建完整的Mysql數據庫連接

2.使用cursor()初始化數據庫游標

3.使用游標來調用callproc函數 里面添加 需要傳入的變量 例如 callproc(name,args) name="proc_user",args=['21',syh];

3.cursor可以傳遞出一系列的結果集，使用storeresult來獲取一系列的iterator指向結果集

4.用fetchall方法獲取結果

callproc 無法直接獲得out和INOUT變量 ，但是變量存在server中，可以通過@_procname_n 來獲取變量值，可以按照傳入參數的位置獲取，如第1個 SELECT @_procname_0

from mysql.connector import MySQLConnection, Error
from python_mysql_dbconfig import read_db_config
 
def call_find_all_sp():
    try:
        db_config = read_db_config()
        conn = MySQLConnection(**db_config)
        cursor = conn.cursor()
 
        cursor.callproc('find_all')
 
        # print out the result
        for result in cursor.stored_results():
            print(result.fetchall())
 
    except Error as e:
        print(e)
 
    finally:
        cursor.close()
        conn.close()
 
if __name__ == '__main__':
    call_find_all_sp()