MySQL之视图、触发器、事务、存储过程
生活随笔
收集整理的這篇文章主要介紹了
MySQL之视图、触发器、事务、存储过程
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
http://www.cnblogs.com/linhaifeng/articles/7495918.html
視圖
? 試圖就是一個虛擬表(非真實存在),本質就是【根據sql語句獲取動態的數據集,并為其命名】,用戶使用時只需要使用名稱即可獲取數據集,可將該數據集當作表來使用。
''' what: 視圖是由一張表或多張表的查詢結果構成的一張虛擬表 why: 將復雜常用的查詢結果保留下來重復使用 | 將一張大表拆分成多張小表語法: create [or replace] view 視圖名[(查詢字段別名們)] as 查詢語句 create view new_emp as (select * from emp);注: 1.查詢字段別名們 要與 查詢語句的查詢字段對應 2.create or replace: 操作視圖沒有則創建、有則替換 create or replace view new_emp(id,姓名,工資) as (select id,name,salary from emp where dep_id = 2);視圖的修改:alter 等價于 create or replace, 且語法一致 alter view new_emp(id,姓名,工資) as (select id,name,salary from emp where dep_id = 1);視圖中字段的操作:不允許alter操作字段 alter table new_emp rename new_emp1; alter view new_emp modify id tinyint;視圖中記錄的操作:等價于普通表,完成增刪改查 update new_emp set 姓名='san' where id = 3; delete from new_emp where id = 3; insert into new_emp(id, 姓名, 工資) values (10, "Bob", 10000); # 操作的是實體表, 虛擬表要重新創建才能拿到最新數據視圖的刪除: drop view 視圖名;總結: 虛擬表作用 -- 查詢 '''觸發器
使用觸發器可以定制用戶對表進行【增刪改】操作時前后的行為(不報包括查詢)
''' what:在表發生數據更新時,會自動觸發的功能稱之為觸發器 why:當一個表在發生數據更新時,需要去完成一些操作,可以為具體數據更新的方式添加觸發器語法: delimiter // create trigger 觸發器名 before|after insert|update|delete on 表名 for each row begin 需要觸發執行的sql代碼們 end // delimiter ;# 觸發器名: t1_before_insert_tri注:delimiter是用來修改sql的語句結束標識符刪除觸發器:drop trigger 觸發器名; ''' # 插入前 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... END# 刪除觸發器drop trigger tri_after_insert_cmd; # cmd表 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 trigger1 after insert on cmd for each row begin # new就是cmd當前插入的那條記錄(對象) if new.success = "no" then # 等待值判斷只有一個等號insert into errlog values(null, new.cmd, new.sub_time); end if; end // delimiter ;# 往表cmd中插入記錄,觸發觸發器,根據IF的條件決定是否插入錯誤日志 insert into cmd(user, priv, cmd, sub_time, success) values('egon', '0765', 'ls -l /etc', now(), 'yes'),('jerry', '0852', 'cat /etc/passwd', now(), 'no'),('kevin', '0867', 'useradd xxx', now(), 'no'),('owen', '0912', 'ps aux', now(), 'yes'); # 查看cmd數據信息 select * from cmd; # 查看錯誤日志表中的記錄是否有自動插入 select * from errlog;? 觸發器用戶無法直接調用,而是由對表的【增刪改】操作被動引發的
事務
事務用于將某些操作的多個SQL作為原子性操作,一旦有某一個出現錯誤,即可回滾到原來的狀態,從而保證數據庫數據完整性
''' what:事務是邏輯上的一組操作,要么都成功,要么都失敗 why:很多時候一個數據操作,不是一個sql語句就完成的,可能有很多個sql語句,如果部分sql執行成功而部分sql執行失敗將導致數據錯亂 eg:轉賬 => 轉入轉出均成功,才能認為操作成功事務的使用: start transaction; --開啟事物,在這條語句之后的sql將處在同一事務,并不會立即修改數據庫 commit;--提交事務,讓這個事物中的sql立即執行數據的操作, rollback;--回滾事務,取消這個事物,這個事物不會對數據庫中的數據產生任何影響事務的四大特性: 1.原子性:事務是一組不可分割的單位,要么同時成功,要么同時不成功 2.一致性:事物前后的數據完整性應該保持一致(數據庫的完整性:如果數據庫在某一時間點下,所有的數據都符合所有的約束,則稱數據庫為完整性的狀態) 3.隔離性:事物的隔離性是指多個用戶并發訪問數據時,一個用戶的事物不能被其它用戶的事務所干擾,多個并發事務之間數據要相互隔離 4.持久性:持久性是指一個事物一旦被提交,它對數據的改變就是永久性的,接下來即使數據庫發生故障也不應該對其有任何影響事務的用戶隔離級別: 數據庫使用者可以控制數據庫工作在哪個級別下,就可與防止不同的隔離性問題 read uncommitted --不做任何隔離,可能臟讀,幻讀 read committed --可以防止臟讀,不能防止不可重復讀,和幻讀, Repeatable read --可以防止臟讀,不可重復讀,不能防止幻讀 Serializable --數據庫運行在串行化實現,所有問題都沒有,就是性能低修改隔離級別: select @@tx_isolation;--查詢當前級別 set[session|global] transaction isolation level ....;修改級別 實例: set global transaction isolation level Repeatable read; 注:修改后重新連接服務器生效 ''' #準備數據 create table account(id int primary key auto_increment,name varchar(20),money double ); insert into account values(1,'owen',10000),(2,'egon',1000),(3,'jerry',1000),(4,'kevin',1000);# egon向owen借1000塊錢 # 未使用事務 update account set money = money - 1000 where id = 1; update account set moneys = money + 1000 where id = 2; # money打錯了導致執行失敗# 在python中使用事務處理 from pymysql.err import InternalError sql = 'update account set money = money - 1000 where id = 1;' sql2 = 'update account set moneys = money + 1000 where id = 2;' # money打錯了導致執行失敗 try:cursor.execute(sql)cursor.execute(sql2)conn.commit() # 提交事務 except InternalError:print("轉賬失敗")conn.rollback()# 回滾操作存儲過程
一、簡介
? 存儲過程包含了一系列可執行的sql語句,存儲過程存放于mysql中,通過調用它的名字可執行其內部的一堆sql語句
? 優點:
#1. 用于替代程序寫的SQL語句,實現程序與sql解耦#2. 基于網絡傳輸,傳別名的數據量小,而直接傳sql數據量大? 缺點:程序員擴展功能不方便
程序與數據庫結合使用的三種方式
#方式一:MySQL:存儲過程程序:調用存儲過程#方式二:MySQL:程序:純SQL語句#方式三:MySQL:程序:類和對象,即ORM(本質還是純SQL語句)二、創建簡單的存儲過程(無參)
delimiter // create procedure p1() BEGINselect * from blog;INSERT into blog(name,sub_time) values("xxx",now()); END // delimiter ;#在mysql中調用 call p1() #在python中基于pymysql調用 cursor.callproc('p1') print(cursor.fetchall())三、創建存儲過程(有參)
對于存儲過程,可以接收參數,其參數有三類:#in 僅用于傳入參數用 #out 僅用于返回值用 #inout 既可以傳入又可以當作返回值① in:傳入參數
delimiter // create procedure p2(in n1 int,in n2 int ) BEGINselect * from blog where id > n1; END // delimiter ;#在mysql中調用 call p2(3,2)#在python中基于pymysql調用 cursor.callproc('p2',(3,2)) print(cursor.fetchall())② out:返回值
delimiter // create procedure p3(in n1 int,out res int ) BEGINselect * from blog where id > n1;set res = 1; END // delimiter ;#在mysql中調用 set @res=0; #0代表假(執行失敗),1代表真(執行成功) call p3(3,@res); select @res;#在python中基于pymysql調用 cursor.callproc('p3',(3,0)) #0相當于set @res=0 print(cursor.fetchall()) #查詢select的查詢結果cursor.execute('select @_p3_0,@_p3_1;') #@p3_0代表第一個參數,@p3_1代表第二個參數,即返回值 print(cursor.fetchall())③ inout 可傳值可返回
delimiter // create procedure p4(inout n1 int ) BEGINselect * 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())四、執行存儲過程
① 在MySQL中執行存儲過程
-- 無參數 call proc_name()-- 有參數,全in call proc_name(1,2)-- 有參數,有in,out,inout set @t1=0; set @t2=3; call proc_name(1,2,@t1,@t2)② 在python中基于MySQL執行存儲過程
#!/usr/bin/env python # -*- coding:utf-8 -*- import pymysqlconn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123', db='t1') cursor = conn.cursor(cursor=pymysql.cursors.DictCursor) # 執行存儲過程 cursor.callproc('p1', args=(1, 22, 3, 4)) # 獲取執行完存儲的參數 cursor.execute("select @_p1_0,@_p1_1,@_p1_2,@_p1_3") result = cursor.fetchall()conn.commit() cursor.close() conn.close()print(result)五、刪除存儲過程
drop procedure proc_name;六、小結
''' what:用于完成指定功能的sql語句塊,類似于Python中的函數 why:將能指定功能的sql語句塊建立成存儲過程,不僅將sql語句邏輯化了,更是功能化了,那我們要完成相同的事,只需要重復使用建立的存儲過程,不就需要再重復書寫sql語句了 # 總結: 存儲過程可以讓sql語句具有 復用性, 從而提高開發效率語法: delimiter // create procedure 存儲過程名(輸入輸出類型1 參數名1 參數類型1(寬度), ... ,輸入輸出類型n 參數名n 參數類型n(寬度) ) begin sql語句塊 end // delimiter ; 注: 1.輸入輸出類型:in | out | inout 2.call 存儲過程名(實參們)來調用存儲過程案例: set @res = null; # 定義空值變量, 用來接收存儲過程的執行結果 delimiter // create procedure user_info(in b int, in l int, out res char(20)) begin select * from emp limit b, l; set res = 'success'; end // delimiter ; call user_info(2, 3, @res); # 調用存儲過程, 傳入相應的實參 select @res; # 查看存儲過程的執行結果變量的使用: 1.賦值變量:set @變量名 = 變量值 2.使用變量:@變量名 | select @變量名 3.刪除變量:set @變量名 = null三種開發方式: 1. 業務邏輯 + 存儲過程:高執行與開發效率,低耦合 | 不易移植,人員成本高 2. 業務邏輯 + 原生sql:人員成本低 | 開發難度大 3. 業務邏輯 + ORM:高開發效率,對象化操作數據庫,可移植 | 性能消耗加大,多表聯查、復雜條件會復制化ORM存儲過程的操作: 1.查看 select routine_name, routine_type from information_schema.routines where routine_schema='數據庫名';eg: select routine_name, routine_type from information_schema.routines where routine_schema='db2';2.刪除 drop procedure [if exists] 數據庫名.存儲過程名 ''' delimiter // create procedure send_money( out p_return_code char(20) ) begin # 異常處理declare exit handler for sqlexception begin # error set p_return_code = '錯誤異常'; rollback; end; # exit 也可以換成continue 表示發送異常時繼續執行declare exit handler for sqlwarning begin # warning set p_return_code = '警告異常'; rollback; end; start transaction;update account set money = money - 1000 where id = 1;update account set money = moneys + 1000 where id = 2; # moneys字段導致異常commit; # success set p_return_code = '轉賬成功'; # 代表執行成功 end // delimiter ;# 在mysql中調用存儲過程 set @res=null; call send_money(@res); select @res;轉載于:https://www.cnblogs.com/prodigal/p/10263421.html
總結
以上是生活随笔為你收集整理的MySQL之视图、触发器、事务、存储过程的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Nginx Mac笔记
- 下一篇: ubuntu导出数据库