python-day48--mysql之視圖、觸發器、事務、存儲過程、函數
阿新 • • 發佈：2017-09-18
3-9 func 部分 負責 lap str1 mar 可執行 sele 
一、視圖（不推薦使用）
1）.視圖是一個虛擬表（非真實存在）
2）.使用視圖我們可以把查詢過程中的臨時表摘出來，用視圖去實現，這樣以後再想操作該臨時表的數據時就無需重寫復雜的sql了，直接去視圖中查找即可，但視圖有明顯地效率問題，並且視圖是存放在數據庫中的，如果我們程序中使用的sql過分依賴數據庫中的視圖，即強耦合，那就意味著擴展sql極為不便，因此並不推薦使用
#兩張有關系的表 mysql> select * from course; +-----+--------+------------+ | cid | cname | teacher_id | +-----+--------+------------+ | 1 | 生物 | 1 | | 2 | 物理 | 2 | | 3 | 體育 | 3 | | 4 | 美術 | 2 | +-----+--------+------------+ rowsView Codein set (0.00 sec) mysql> select * from teacher; +-----+-----------------+ | tid | tname | +-----+-----------------+ | 1 | 張磊老師 | | 2 | 李平老師 | | 3 | 劉海燕老師 | | 4 | 朱雲海老師 | | 5 | 李傑老師 | +-----+-----------------+ rows in set (0.00 sec) #查詢李平老師教授的課程名 mysql> select cname fromcourse where teacher_id = (select tid from teacher where tname=‘李平老師‘); +--------+ | cname | +--------+ | 物理 | | 美術 | +--------+ rows in set (0.00 sec) #子查詢出臨時表，作為teacher_id等判斷依據 select tid from teacher where tname=‘李平老師‘
1 創建視圖
#語法：CREATE VIEW 視圖名稱 AS SQL語句 create view teacher_view as select tid fromView Codeteacher where tname=‘李平老師‘; #於是查詢李平老師教授的課程名的sql可以改寫為 mysql> select cname from course where teacher_id = (select tid from teacher_view); +--------+ | cname | +--------+ | 物理 | | 美術 | +--------+ rows in set (0.00 sec) #！！！註意註意註意： #1. 使用視圖以後就無需每次都重寫子查詢的sql，但是這麽效率並不高，還不如我們寫子查詢的效率高 #2. 而且有一個致命的問題：視圖是存放到數據庫裏的，如果我們程序中的sql過分依賴於數據庫中存放的視圖，那麽意味著，一旦sql需要修改且涉及到視圖的部分，則必須去數據庫中進行修改，而通常在公司中數據庫有專門的DBA負責，你要想完成修改，必須付出大量的溝通成本DBA可能才會幫你完成修改，極其地不方便
2 使用視圖
#修改視圖，原始表也跟著改 mysql> select * from course; +-----+--------+------------+ | cid | cname | teacher_id | +-----+--------+------------+ | 1 | 生物 | 1 | | 2 | 物理 | 2 | | 3 | 體育 | 3 | | 4 | 美術 | 2 | +-----+--------+------------+ rows in set (0.00 sec) mysql> create view course_view as select * from course; #創建表course的視圖 Query OK, 0 rows affected (0.52 sec) mysql> select * from course_view; +-----+--------+------------+ | cid | cname | teacher_id | +-----+--------+------------+ | 1 | 生物 | 1 | | 2 | 物理 | 2 | | 3 | 體育 | 3 | | 4 | 美術 | 2 | +-----+--------+------------+ rows in set (0.00 sec) mysql> update course_view set cname=‘xxx‘; #更新視圖中的數據 Query OK, 4 rows affected (0.04 sec) Rows matched: 4 Changed: 4 Warnings: 0 mysql> insert into course_view values(5,‘yyy‘,2); #往視圖中插入數據 Query OK, 1 row affected (0.03 sec) mysql> select * from course; #發現原始表的記錄也跟著修改了 +-----+-------+------------+ | cid | cname | teacher_id | +-----+-------+------------+ | 1 | xxx | 1 | | 2 | xxx | 2 | | 3 | xxx | 3 | | 4 | xxx | 2 | | 5 | yyy | 2 | +-----+-------+------------+ rows in set (0.00 sec)View Code
我們不應該修改視圖中的記錄，而且在涉及多個表的情況下是根本無法修改視圖中的記錄的，如下圖
3 修改視圖
語法：ALTER VIEW 視圖名稱 AS SQL語句 mysql> alter view teacher_view as select * from course where cid>3; Query OK, 0 rows affected (0.04 sec) mysql> select * from teacher_view; +-----+-------+------------+ | cid | cname | teacher_id | +-----+-------+------------+ | 4 | xxx | 2 | | 5 | yyy | 2 | +-----+-------+------------+ rows in set (0.00 sec)View Code
4 刪除視圖
語法：DROP VIEW 視圖名稱
DROP VIEW teacher_view
View Code
二、觸發器（不推薦使用）
1）.使用觸發器可以定制用戶對表進行【增、刪、改】操作時前後的行為，註意：沒有查詢
一 創建觸發器
# 插入前 CREATE TRIGGER tri_before_insert_tb1 BEFORE INSERT ON tb1 FOR EACH ROW BEGIN ... END # 插入後 CREATE TRIGGER tri_after_insert_tb1 AFTER INSERT ON tb1 FOR EACH ROW BEGIN ... END # 刪除前 CREATE TRIGGER tri_before_delete_tb1 BEFORE DELETE ON tb1 FOR EACH ROW BEGIN ... END # 刪除後 CREATE TRIGGER tri_after_delete_tb1 AFTER DELETE ON tb1 FOR EACH ROW BEGIN ... END # 更新前 CREATE TRIGGER tri_before_update_tb1 BEFORE UPDATE ON tb1 FOR EACH ROW BEGIN ... END # 更新後 CREATE TRIGGER tri_after_update_tb1 AFTER UPDATE ON tb1 FOR EACH ROW BEGIN ... ENDView Code
#準備表 CREATE TABLE cmd ( id INT PRIMARY KEY auto_increment, USER CHAR (32), priv CHAR (10), cmd CHAR (64), sub_time datetime, #提交時間 success enum (‘yes‘, ‘no‘) #0代表執行失敗 ); CREATE TABLE errlog ( id INT PRIMARY KEY auto_increment, err_cmd CHAR (64), err_time datetime ); #創建觸發器 delimiter // CREATE TRIGGER tri_after_insert_cmd AFTER INSERT ON cmd FOR EACH ROW BEGIN IF NEW.success = ‘no‘ THEN #等值判斷只有一個等號 INSERT INTO errlog(err_cmd, err_time) VALUES(NEW.cmd, NEW.sub_time) ; #必須加分號 END IF ; #必須加分號 END// delimiter ; #往表cmd中插入記錄，觸發觸發器，根據IF的條件決定是否插入錯誤日誌 INSERT INTO cmd ( USER, priv, cmd, sub_time, success ) VALUES (‘egon‘,‘0755‘,‘ls -l /etc‘,NOW(),‘yes‘), (‘egon‘,‘0755‘,‘cat /etc/passwd‘,NOW(),‘no‘), (‘egon‘,‘0755‘,‘useradd xxx‘,NOW(),‘no‘), (‘egon‘,‘0755‘,‘ps aux‘,NOW(),‘yes‘); #查詢錯誤日誌，發現有兩條 mysql> select * from errlog; +----+-----------------+---------------------+ | id | err_cmd | err_time | +----+-----------------+---------------------+ | 1 | cat /etc/passwd | 2017-09-14 22:18:48 | | 2 | useradd xxx | 2017-09-14 22:18:48 | +----+-----------------+---------------------+ rows in set (0.00 sec)View Code
特別的：NEW表示即將插入的數據行，OLD表示即將刪除的數據行。
二 使用觸發器
觸發器無法由用戶直接調用，而知由於對表的【增/刪/改】操作被動引發的。
三 刪除觸發器
drop trigger tri_after_insert_cmd;View Code
三 事務（要會）
事務用於將某些操作的多個SQL作為原子性操作，一旦有某一個出現錯誤，即可回滾到原來的狀態，從而保證數據庫數據完整性。
create table user1( id int primary key auto_increment, name char(32), balance int ); insert into user1(name,balance) values (‘龐文廢‘,200), (‘蕭pt‘,200), (‘八哥‘,200); start transaction; update user1 set balance=100 where name=‘龐文廢‘; update user1 set balance=210 where name=‘蕭pt‘; updsate user1 set balance=290 where name=‘八哥‘; rollback; #如果任意一條sql出現異常都應該回滾到初始狀態 commit; #如果所有的sql都正常，應該執行commitView Code
疑問：如何捕捉異常，在下方存儲過程中解決
四 存儲過程（不推薦使用）
一 介紹
存儲過程包含了一系列可執行的sql語句，存儲過程存放於MySQL中，通過調用它的名字可以執行其內部的一堆sql
使用存儲過程的優點：
#1. 用於替代程序寫的SQL語句，實現程序與sql解耦
#2. 基於網絡傳輸，傳別名的數據量小，而直接傳sql數據量大
使用存儲過程的缺點：
#1. 執行效率低
#2. 程序員擴展功能不方便
補充：程序與數據庫結合使用的兩種方式
#方式一：
MySQL：存儲過程
程序：調用存儲過程
#方式二：
MySQL：
程序：純SQL語句
二 創建簡單存儲過程（無參）
delimiter // create procedure p1() BEGIN select * from blog; INSERT into blog(name,sub_time) values("xxx",now()); END // delimiter ; #在mysql中調用 call p1() #在python中基於pymysql調用 cursor.callproc(‘p1‘) print(cursor.fetchall())View Code
三 創建存儲過程（有參）
#=============================================== #創建有參存儲過程之in的使用 delimiter // create procedure p2( in m int, in n int, ) begin select * from test where id between m and n; end // delimiter ; #調用存儲過程 call p2(3,7); #在mysql中調用 cursor.callproc(‘p2‘,args=(3,7)) #在python中通過pymysql模塊調用 #=============================================== #創建有參存儲過程之out的使用 delimiter // create procedure p3( in m int, in n int, out res int ) begin select * from test where id between m and n; set res=1; end // delimiter ; #調用存儲過程 #在mysql中 set @x=11111111111 call p3(3,7,@x); #在mysql中調用, 查看結果：select @x; #在python中 res=cursor.callproc(‘p3‘,args=(3,7,123)) #@_p3_0=3,@_p3_1=7,@_p3_2=123 print(cursor.fetchall()) #只是拿到存儲過程中select的查詢結果 cursor.execute(‘select @_p3_0,@_p3_1,@_p3_2‘) print(cursor.fetchall()) #可以拿到的是返回值 #=============================================== #創建有參存儲過程之inout的使用 delimiter // create procedure p4( inout m int ) begin select * from test where id > m; set m=1; end // delimiter ; #在mysql中 set @x=2; call p4(@x); select @x;View Code
四 刪除存儲過程
drop procedure proc_name;View Code
五 捕捉異常+事務
delimiter // create procedure p5( inout m int ) begin select * from test11111111 where id > m; set m=1; end // delimiter ; set @x=2; call p5(@x); select @x;引子
#====================捕捉異常+事務=========================== delimiter // create PROCEDURE p6( OUT p_return_code tinyint ) BEGIN DECLARE exit handler for sqlexception BEGIN -- ERROR set p_return_code = 1; rollback; END; DECLARE exit handler for sqlwarning BEGIN -- WARNING set p_return_code = 2; rollback; END; START TRANSACTION; insert into test(username,dep_id) values(‘egon‘,1); DELETE from tb1111111; #執行失敗 COMMIT; -- SUCCESS set p_return_code = 0; #0代表執行成功 END // delimiter ; #用python模擬 try: START TRANSACTION; DELETE from tb1; #執行失敗 insert into blog(name,sub_time) values(‘yyy‘,now()); COMMIT; set p_return_code = 0; #0代表執行成功 except sqlexception: set p_return_code = 1; rollback; except sqlwaring: set p_return_code = 2; rollback;View Code
五、函數 （註意，必須在sql語句中執行函數）
MySQL中提供了許多內置函數，例如：
CHAR_LENGTH(str) 返回值為字符串str 的長度，長度的單位為字符。一個多字節字符算作一個單字符。 對於一個包含五個二字節字符集, LENGTH()返回值為 10, 而CHAR_LENGTH()的返回值為5。 CONCAT(str1,str2,...) 字符串拼接 如有任何一個參數為NULL ，則返回值為 NULL。 CONCAT_WS(separator,str1,str2,...) 字符串拼接（自定義連接符） CONCAT_WS()不會忽略任何空字符串。 (然而會忽略所有的 NULL）。 CONV(N,from_base,to_base) 進制轉換 例如： SELECT CONV(‘a‘,16,2); 表示將 a 由16進制轉換為2進制字符串表示 FORMAT(X,D) 將數字X 的格式寫為‘#,###,###.##‘,以四舍五入的方式保留小數點後 D 位， 並將結果以字符串的形式返回。若 D 為 0, 則返回結果不帶有小數點，或不含小數部分。 例如： SELECT FORMAT(12332.1,4); 結果為： ‘12,332.1000‘ INSERT(str,pos,len,newstr) 在str的指定位置插入字符串 pos：要替換位置其實位置 len：替換的長度 newstr：新字符串 特別的： 如果pos超過原字符串長度，則返回原字符串 如果len超過原字符串長度，則由新字符串完全替換 INSTR(str,substr) 返回字符串 str 中子字符串的第一個出現位置。 LEFT(str,len) 返回字符串str 從開始的len位置的子序列字符。 LOWER(str) 變小寫 UPPER(str) 變大寫 LTRIM(str) 返回字符串 str ，其引導空格字符被刪除。 RTRIM(str) 返回字符串 str ，結尾空格字符被刪去。 SUBSTRING(str,pos,len) 獲取字符串子序列 LOCATE(substr,str,pos) 獲取子序列索引位置 REPEAT(str,count) 返回一個由重復的字符串str 組成的字符串，字符串str的數目等於count 。 若 count <= 0,則返回一個空字符串。 若str 或 count 為 NULL，則返回 NULL 。 REPLACE(str,from_str,to_str) 返回字符串str 以及所有被字符串to_str替代的字符串from_str 。 REVERSE(str) 返回字符串 str ，順序和字符順序相反。 RIGHT(str,len) 從字符串str 開始，返回從後邊開始len個字符組成的子序列 SPACE(N) 返回一個由N空格組成的字符串。 SUBSTRING(str,pos) , SUBSTRING(str FROM pos) SUBSTRING(str,pos,len) , SUBSTRING(str FROM pos FOR len) 不帶有len 參數的格式從字符串str返回一個子字符串，起始於位置 pos。帶有len參數的格式從字符串str返回一個長度同len字符相同的子字符串，起始於位置 pos。 使用 FROM的格式為標準 SQL 語法。也可能對pos使用一個負值。假若這樣，則子字符串的位置起始於字符串結尾的pos 字符，而不是字符串的開頭位置。在以下格式的函數中可以對pos 使用一個負值。 mysql> SELECT SUBSTRING(‘Quadratically‘,5); -> ‘ratically‘ mysql> SELECT SUBSTRING(‘foobarbar‘ FROM 4); -> ‘barbar‘ mysql> SELECT SUBSTRING(‘Quadratically‘,5,6); -> ‘ratica‘ mysql> SELECT SUBSTRING(‘Sakila‘, -3); -> ‘ila‘ mysql> SELECT SUBSTRING(‘Sakila‘, -5, 3); -> ‘aki‘ mysql> SELECT SUBSTRING(‘Sakila‘ FROM -4 FOR 2); -> ‘ki‘ TRIM([{BOTH | LEADING | TRAILING} [remstr] FROM] str) TRIM(remstr FROM] str) 返回字符串 str ， 其中所有remstr 前綴和/或後綴都已被刪除。若分類符BOTH、LEADIN或TRAILING中沒有一個是給定的,則假設為BOTH 。 remstr 為可選項，在未指定情況下，可刪除空格。 mysql> SELECT TRIM(‘ bar ‘); -> ‘bar‘ mysql> SELECT TRIM(LEADING ‘x‘ FROM ‘xxxbarxxx‘); -> ‘barxxx‘ mysql> SELECT TRIM(BOTH ‘x‘ FROM ‘xxxbarxxx‘); -> ‘bar‘ mysql> SELECT TRIM(TRAILING ‘xyz‘ FROM ‘barxxyz‘); -> ‘barx‘View Code
#1 基本使用 mysql> SELECT DATE_FORMAT(‘2009-10-04 22:23:00‘, ‘%W %M %Y‘); -> ‘Sunday October 2009‘ mysql> SELECT DATE_FORMAT(‘2007-10-04 22:23:00‘, ‘%H:%i:%s‘); -> ‘22:23:00‘ mysql> SELECT DATE_FORMAT(‘1900-10-04 22:23:00‘, -> ‘%D %y %a %d %m %b %j‘); -> ‘4th 00 Thu 04 10 Oct 277‘ mysql> SELECT DATE_FORMAT(‘1997-10-04 22:23:00‘, -> ‘%H %k %I %r %T %S %w‘); -> ‘22 22 10 10:23:00 PM 22:23:00 00 6‘ mysql> SELECT DATE_FORMAT(‘1999-01-01‘, ‘%X %V‘); -> ‘1998 52‘ mysql> SELECT DATE_FORMAT(‘2006-06-00‘, ‘%d‘); -> ‘00‘ #2 準備表和記錄 CREATE TABLE blog ( id INT PRIMARY KEY auto_increment, NAME CHAR (32), sub_time datetime ); INSERT INTO blog (NAME, sub_time) VALUES (‘第1篇‘,‘2015-03-01 11:31:21‘), (‘第2篇‘,‘2015-03-11 16:31:21‘), (‘第3篇‘,‘2016-07-01 10:21:31‘), (‘第4篇‘,‘2016-07-22 09:23:21‘), (‘第5篇‘,‘2016-07-23 10:11:11‘), (‘第6篇‘,‘2016-07-25 11:21:31‘), (‘第7篇‘,‘2017-03-01 15:33:21‘), (‘第8篇‘,‘2017-03-01 17:32:21‘), (‘第9篇‘,‘2017-03-01 18:31:21‘); #3. 提取sub_time字段的值，按照格式後的結果即"年月"來分組 SELECT DATE_FORMAT(sub_time,‘%Y-%m‘),COUNT(1) FROM blog GROUP BY DATE_FORMAT(sub_time,‘%Y-%m‘); #結果 +-------------------------------+----------+ | DATE_FORMAT(sub_time,‘%Y-%m‘) | COUNT(1) | +-------------------------------+----------+ | 2015-03 | 2 | | 2016-07 | 4 | | 2017-03 | 3 | +-------------------------------+----------+ rows in set (0.00 sec)需要掌握函數：date_format
更多：
一 自定義函數
delimiter //
create function f1(
i1 int,
i2 int)
returns int
BEGIN
declare num int;
set num = i1 + i2;
return(num);
END //
delimiter ;
View Code
二 刪除函數
drop function func_name;
View Code
三 執行函數
# 獲取返回值
select UPPER(‘egon‘) into @res;
SELECT @res;
# 在查詢中使用
select f1(11,nid) ,name from tb2;
View Code
六、流程控制
一 條件語句
delimiter //
CREATE PROCEDURE proc_if ()
BEGIN
declare i int default 0;
if i = 1 THEN
SELECT 1;
ELSEIF i = 2 THEN
SELECT 2;
ELSE
SELECT 7;
END IF;
END //
delimiter ;
if條件語句
二 循環語句
delimiter // CREATE PROCEDURE proc_while () BEGIN DECLARE num INT ; SET num = 0 ; WHILE num < 10 DO SELECT num ; SET num = num + 1 ; END WHILE ; END // delimiter ;while循環
python-day48--mysql之視圖、觸發器、事務、存儲過程、函數