一. 觸發器
使用觸發器可以定制用戶對某一張表的數據進行 [增, 刪 ,改] 操作時前后的行為, (注意 沒有查詢),在進行增刪改的時候出發的某個動作叫做 觸發器. 其實就是在增刪改的時候另外執行了一段SQL語句. 觸發器器是被動調用的 不能由用戶直接調用
一. 創建觸發器
# 插入前 CREATE TRIGGER tri_before_insert_tb1 BEFORE INSERT ON tb1 FOR EACH ROW BEGIN #begin和end里面寫觸發器要做的sql事情，注意里面的代碼縮進，並且給觸發器起名字的時候，名字的格式最好這樣寫，有表示意義，一看名字就知道要做什么，是給哪個表設置的觸發器 ... 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 ... END
下面模擬一下觸發器的工作過程
#准備表 CREATE TABLE cmd ( #這是一張指令信息表，你在系統里面執行的任何的系統命令都在表里面寫一條記錄 id INT PRIMARY KEY auto_increment, #id USER CHAR (32), #用戶 priv CHAR (10), #權限 cmd CHAR (64), #指令 sub_time datetime, #提交時間 success enum ('yes', 'no') #是否執行成功，0代表執行失敗 ); CREATE TABLE errlog ( #指令執行錯誤的信息統計表，專門提取上面cmd表的錯誤記錄 id INT PRIMARY KEY auto_increment, #id err_cmd CHAR (64), #錯誤指令 err_time datetime #錯誤命令的提交時間 ); #現在的需求是：不管正確或者錯誤的cmd，都需要往cmd表里面插入，然后，如果是錯誤的記錄，還需要往errlog表里面插入一條記錄 #若果沒有觸發器，我們會怎么實現，我們完全可以通過咱們的應用程序來做，根據cmd表里面的success這個字段是哪個值（yes成功，no表示失敗），在給cmd插入記錄的時候，判斷一下這個值是yes或者no，來判斷一下成功或者失敗，如果失敗了，直接給errlog來插入一條記錄 #但是mysql說，你的應用程序可以省事兒了，你只需要往cmd表里面插入數據就行了，沒必要你自己來判斷了，可以使用觸發器來實現，可以判斷你插入的這條記錄的success這個字段對應的值，然后自動來觸發觸發器，進行errlog表的數據插入 #創建觸發器 delimiter // （或者寫$$，其他符號也行，但是不要寫mysql不能認識的，知道一下就行了），delimiter 是告訴mysql，遇到這句話的時候，就將sql語句的結束符分號改成delimiter后面的// CREATE TRIGGER tri_after_insert_cmd AFTER INSERT ON cmd FOR EACH ROW #在你cmd表插入一條記錄之后觸發的。 BEGIN #每次給cmd插入一條記錄的時候，都會被mysql封裝成一個對象，叫做NEW，里面的字段都是這個NEW的屬性 IF NEW.success = 'no' THEN #mysql里面是可以寫這種判斷的，等值判斷只有一個等號，然后寫then INSERT INTO errlog(err_cmd, err_time) VALUES(NEW.cmd, NEW.sub_time) ; #必須加分號，並且注意，我們必須用delimiter來包裹，不然，mysql一看到分號，就認為你的sql結束了，所以會報錯 END IF ; #然后寫end if，必須加分號 END// #只有遇到//這個完成的sql才算結束 delimiter ; #然后將mysql的結束符改回為分號 #往表cmd中插入記錄，觸發觸發器，根據IF的條件決定是否插入錯誤日志 INSERT INTO cmd ( USER, priv, cmd, sub_time, success ) VALUES ('chao','0755','ls -l /etc',NOW(),'yes'), ('chao','0755','cat /etc/passwd',NOW(),'no'), ('chao','0755','useradd xxx',NOW(),'no'), ('chao','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)
二. 刪除觸發器
drop trigger tri_after_insert_cmd;
二. 存儲過程
一. 先說一下存儲過程的優缺點
存儲過程的優點:
#1. 用於替代程序寫的SQL語句，實現程序與sql解耦 #2. 基於網絡傳輸，傳別名的數據量小，而直接傳sql數據量大
存儲過程的缺點:
#1. 程序員擴展功能不方便
二. 創建存儲過程(無參)
delimiter // create procedure p1() BEGIN select * from blog; INSERT into blog(name,sub_time) values("xxx",now()); END // delimiter ; #在mysql中調用 call p1(); #類似於MySQL的函數，但不是函數昂，別搞混了，MySQL的函數(count()\max()\min()等等)都是放在sql語句里面用的，不能單獨的使用，存儲過程是可以直接調用的 call 名字+括號; #MySQL的視圖啊觸發器啊if判斷啊等等都能在存儲過程里面寫，這是一大堆的sql的集合體，都可以綜合到這里面 #在python中基於pymysql調用 cursor.callproc('p1') print(cursor.fetchall())
三. 創建存儲過程(有參)
對於存儲過程，可以接收參數，其參數有三類： #in 僅用於傳入參數用 #out 僅用於返回值用 #inout 既可以傳入又可以當作返回值
in: 傳入參數:
delimiter // create procedure p2( in n1 int, #n1參數是需要傳入的，也就是接收外部數據的，並且這個數據必須是int類型 in n2 int ) BEGIN select * from blog where id > n1; #直接應用變量 END // delimiter ; #調用存儲過程的兩種方式：或者說是兩個地方吧 #在mysql中調用 call p2(3,2) #在python中基於pymysql調用 cursor.callproc('p2',(3,2)) print(cursor.fetchall())
out : 返回值 :
#查看存儲過程的一些信息：show create procedure p3; #查看視圖啊、觸發器啊都這么看，還可以用\G，show create procedure p3\G;\G的意思是你直接查看表結構可能橫向上顯示不完，\G是讓表給你豎向顯示，一row是一行的字段 delimiter // create procedure p3( in n1 int, out res int ) BEGIN select * from blog where id > n1; set res = 1; #我在這里設置一個res=1，如果上面的所有sql語句全部正常執行了，那么這一句肯定也就執行了，那么此時res=1，如果我最開始傳入的時候，給res的值設置的是0， #那么你想，最后我接收到的返回值如果是0，那么說明你中間肯定有一些sql語句執行失敗了 #注意寫法：out的那個參數，可以用set來設置，set設置之后表示這個res可以作為返回值，並且不需要像python一樣寫一個return，你直接set之后的值，就是這個存儲過程的返回值 END // delimiter ; #在mysql中調用 set @res=0; #這是MySQL中定義變量名的固定寫法(set @變量名=值)，可以自己規定好，0代表假（執行失敗），1代表真（執行成功），如果這個被改為1了，說明存儲過程中的sql語句執行成功了 call p3(3,@res);#注意：不要這樣寫：call p3（3，1），這樣out的參數值你寫死了，沒法確定后面這個1是不是成功了，也就是說隨后這個out的值可能改成0了，也就是失敗了，但是這樣你就判斷不了了，你后面查看的這個res就成1了，所以這個參數應該是一個變量名昂，定義變量名就是上一句,如果你直接傳一個常量數字，會報錯的，寫法不對。 select @res; #看一下這個結果，就知道這些sql語句是不是執行成功了，大家明白了嗎~~~ #在python中基於pymysql調用，在python中只需要知道存儲過程的名字就行了 cursor.callproc('p3',(3,0)) #0相當於set @res=0，為什么這里這個out參數可以寫常數0啊，因為你用的pymysql,人家會幫你搞定，pymysql其實會幫你寫成這樣：第一個參數變量名：@_p3_0=3，第二個：@_p3_1=0，也就是pymysql會自動幫你對應上一個變量名，pymysql只是想讓你寫的時候更方便 #沿着網絡將存儲過程名和參數發給了mysql服務端，比咱們發一堆的sql語句肯定要快對了，mysql幫你調用存儲過程 print(cursor.fetchall()) #查詢select的查詢結果 cursor.execute('select @_p3_0,@_p3_1;') #@_p3_0代表第一個參數，@_p3_1代表第二個參數，即返回值 print(cursor.fetchall()) #別忘了關掉： cursor.close() conn.close() #注意昂：存儲過程在哪個庫里面建的，就只能在哪個庫里面用
inout : 既可以傳入又可以返回值:
delimiter // create procedure p4( inout n1 int ) BEGIN select * from blog where id > n1; set n1 = 1; END // delimiter ; #在mysql中調用 set @x=3; call p4(@x); select @x; #在python中基於pymysql調用 cursor.callproc('p4',(3,)) print(cursor.fetchall()) #查詢select的查詢結果 cursor.execute('select @_p4_0;') print(cursor.fetchall())
三. 事務
事務的四大特性
原子性(sql不可分離,要么都成功,要么都失敗.) (最主要)
一致性(不能丟東西,要一直, 轉賬,這面扣錢,那邊就得收錢)
隔離性(不完全成功后,外人看不到,外人看到的信息還是你硬盤上的,只有commit之后刷到硬盤上,外人才能看到)
持久性(執行完了也就是commit之后,不能更改,只有去硬盤上操作)
create table user( id int primary key auto_increment, name char(32), balance int ); insert into user(name,balance) values ('wsb',1000), ('chao',1000), ('ysb',1000); #原子操作 start transaction; update user set balance=900 where name='wsb'; #買支付100元 update user set balance=1010 where name='chao'; #中介拿走10元 update user set balance=1090 where name='ysb'; #賣家拿到90元 commit; #只要不進行commit操作，就沒有保存下來，沒有刷到硬盤上 #出現異常，回滾到初始狀態 start transaction; update user set balance=900 where name='wsb'; #買支付100元 update user set balance=1010 where name='chao'; #中介拿走10元 uppdate user set balance=1090 where name='ysb'; #賣家拿到90元,出現異常沒有拿到 rollback; #如果上面三個sql語句出現了異常，就直接rollback，數據就直接回到原來的狀態了。但是執行了commit之后，rollback這個操作就沒法回滾了 #我們要做的是檢測這幾個sql語句是否異常，沒有異常直接commit，有異常就rollback，但是現在單純的只是開啟了事務，但是還沒有說如何檢測異常，我們先來一個存儲過程來捕獲異常，等我們學了存儲過程，再細說存儲過程。 commit; #通過存儲過程來捕獲異常：(shit！，寫存儲過程的是，注意每一行都不要縮進！！！按照下面的縮進來寫，居然讓我翻車了！！！我記住你了~~~)，我的代碼直接黏貼就能用。 delimiter // create PROCEDURE p5() BEGIN DECLARE exit handler for sqlexception BEGIN rollback; END; START TRANSACTION; update user set balance=900 where name='wsb'; #買支付100元 update user set balance=1010 where name='chao'; #中介拿走10元 #update user2 set balance=1090 where name='ysb'; #賣家拿到90元 update user set balance=1090 where name='ysb'; #賣家拿到90元 COMMIT; END // delimiter ; # 然后調用這個過程
call p5(); mysql> select * from user; +----+------+---------+ | id | name | balance | +----+------+---------+ | 1 | wsb | 1000 | | 2 | chao | 1000 | | 3 | ysb | 1000 | +----+------+---------+ rows in set (0.00 sec)