一、存儲過程(stored procedure)
存儲過程將存入的一系列SQL語句進行預編譯,執行並存放在數據庫中,之後如果需要使用sql語句對這一組sql進行訪問時可以直接提取(很好理解 存儲過程就是將sql執行過程存儲在數據庫中,來方便提取)。
優點:1.多次提取,減少編譯時間,2.因為每次提取都需要傳入sql語句,如果用存儲過程名來調用的話,就減少了訪問流量3.增加了重用(可以相較之與(函數對編程的影響))
缺點:1.存儲過程將會占用內存空間,並且復雜的過程操作需要一定的cpu 2.存儲過程難以調試,如果存儲過程太過復雜,不有利於業務邏輯3.存儲過程高級,難以維護
1 DELIMITER $$ // 設置注釋 2 CREATE PROCEDURE CountOrderByStatus( 3 IN orderStatus VARCHAR(25), //需要給定存入使用的參數 4 OUT total INT) //需要給定輸出的參數 5 BEGIN 6 SELECT count(orderNumber) 7 INTO total 8 FROM orders 9 WHERE status = orderStatus; 10 END$$ 11 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()