Mysql存儲過程、觸發(fā)器、事件調度器使用入門指南
更新時間：2022年01月22日 11:36:44 作者：長不大的大灰狼
存儲過程（Stored Procedure）是一種在數據庫中存儲復雜程序的數據庫對象。為了完成特定功能的SQL語句集，經過編譯創(chuàng)建并保存在數據庫中，本文給大家介紹Mysql存儲過程、觸發(fā)器、事件調度器使用入門指南，感興趣的朋友一起看看吧
存儲過程（Stored Procedure）是一種在數據庫中存儲復雜程序的數據庫對象。為了完成特定功能的SQL語句集，經過編譯創(chuàng)建并保存在數據庫中。
一、存儲過程的簡單使用
創(chuàng)建存儲過程
create procedure test()
begin
select * from users;
end;調用存儲過程
call test();
二、存儲過程中的變量
create procedure test() begin -- 使用 declare語句聲明一個變量 declare username varchar(32) default ''; -- 使用set語句給變量賦值 set username='xiaoxiao'; -- 將users表中id=1的名稱賦值給變量username select name into username from users where id=1; -- 返回變量 select username; end;
注意：
- 變量可以通過set來賦值，也可以通過select into的方式賦值；
- 變量需要返回，可以使用select語句，如：select 變量名。
三、變量的作用域
存儲過程的作用域在begin和end塊之間，變量聲明在begin之外，可以作為全局變量使用：
create procedure test()
begin
declare userscount int default 0; -- 用戶表中的數量
begin
select count(*) into userscount from users;
select userscount; -- 返回用戶表中的數量
end;
begin
declare maxmoney int default 0; -- 最大金額
select max(money) into maxmoney from orders;
select userscount,maxmoney; -- 返回用戶表中的數量、最大金額
end;
end;四、存儲過程參數
create procedure 名稱([IN|OUT|INOUT] 參數名 參數數據類型 ) begin ...... end
IN: 傳入參數（不指定時，默認就是IN類型）
create procedure test(userId int)
begin
declare username varchar(32) default '';
select name into username from users where id=userId;
select username;
end;OUT：傳出參數
create procedure test(in userId int,out username varchar(32))
begin
select name into username from users where id=userId;
end;INOUT: 既是傳入又是傳出參數
create procedure test6(inout userId int,inout username varchar(32))
begin
set userId=2;
set username='';
select id,name into userId,username from users where id=userId;
end;五、邏輯控制語句
1、條件語句
if() then... elseif() then... else ... end if;
create procedure test(in userid int)
begin
declare my_status int default 0;
select status into my_status from users where id=userid;
if(my_status=1)
then
update users set score=score+10 where id=userid;
elseif(my_status=2)
then
update users set score=score+20 where id=userid;
else
update users set score=score+30 where id=userid;
end if;
end;2、循環(huán)語句
（1）while
while(表達式) do ...... end while;
create procedure test()
begin
declare i int default 0;
while(i<10) do
begin
select i;
set i=i+1;
insert into test1(id) values(i);
end;
end while;
end;（2）repeat
repeat...until...end repeat;
只有當until為真是才跳出循環(huán)：
create procedure test()
begin
declare i int default 0;
repeat
begin
select i;
set i=i+1;
insert into test1(id) values(i);
end;
until i>=10 -- 如果i>=10,則跳出循環(huán)
end repeat;
end;3、case分支
case ... when ... then.... when.... then.... else ... end case;
create procedure testcate(userid int)
begin
declare my_status int default 0;
select status into my_status from users where id=userid;
case my_status
when 1 then update users set score=10 where id=userid;
when 2 then update users set score=20 where id=userid;
when 3 then update users set score=30 where id=userid;
else update users set score=40 where id=userid;
end case;
end;六、游標
游標保存了查詢結果的臨時區(qū)域
declare 變量名 cursor ... -- 創(chuàng)建一個游標變量 close 變量名; -- 關閉游標
create procedure test()
begin
declare stopflag int default 0;
declare username VARCHAR(32);
declare username_cur cursor for select name from users where id%2=0;
-- 游標變量username_cur保存了查詢的臨時結果，即結果集
-- 在游標變量中數據的結尾，將變量stopflag設置為1，用于循環(huán)中判斷是否結束
declare continue handler for not found set stopflag=1;
open username_cur; -- 打卡游標
fetch username_cur into username; -- 游標向前走一步，取出一條記錄放到變量username中
while(stopflag=0) do -- 如果游標還沒有結尾，就繼續(xù)
begin
-- 在用戶名前門拼接 '_cur' 字符串
update users set name=CONCAT(username,'_cur') where name=username;
fetch username_cur into username;-- 游標向前走一步，取出一條記錄放到變量username中
end;
end while; -- 結束循環(huán)
close username_cur; -- 關閉游標
end;七、自定義函數
-- 創(chuàng)建函數 create function 函數名(參數) returns 返回類型； -- 函數體 begin ...... end； -- 指定函數的返回值 returns --函數調用 select 函數名()。
create function getusername(userid int) returns varchar(32)
reads sql data -- 從數據庫中讀取數據，但不修改數據
begin
declare username varchar(32) default '';
select name into username from users where id=userid;
return username;
end;八、觸發(fā)器
觸發(fā)器也是一種數據庫對象，在滿足定義條件時觸發(fā)，并執(zhí)行觸發(fā)器中定義的語句集合。
創(chuàng)建觸發(fā)器：create trigger 觸發(fā)器名
after、before：在對表操作之前（before）或者之后（after）觸發(fā)動作。
操作事件：insert,update,delete等修改操作
影響的范圍：for each row
1、需求：出于審計目的，當有人往表users插入一條記錄時，把插入的userid,username,插入動作和操作時間記錄下來。
create trigger tr_users_insert after insert on users
for each row
begin
insert into oplog(userid,username,action,optime)
values(NEW.userid,NEW.name,'insert',now());
end;2、需求：出于審計目的，當刪除users表時，記錄刪除前該記錄的主要字段值
create trigger tr_users_delete before delete on users
for each row
begin
insert into oplog(userid,username,action,optime)
values(OLD.id,OLD.name,'delete',now());
end;九、事件
觸發(fā)器只是針對某個表產生的事件執(zhí)行一些語句,而事件調度器則是在某一個(間隔)時間執(zhí)行一些語句。
在使用這個功能之前必須確保事件調度器event_scheduler已開啟：
SET GLOBAL event_scheduler = 1; -- 或者 SET GLOBAL event_scheduler = on; --查看開啟情況 show variables like '%event_scheduler%';
create event[IF NOT EXISTS]event_name -- 創(chuàng)建使用create event
ON SCHEDULE schedule -- on schedule 什么時候來執(zhí)行
[ON COMPLETION [NOT] PRESERVE] -- 調度計劃執(zhí)行完成后是否還保留
[ENABLE | DISABLE] -- 是否開啟事件，默認開啟
[COMMENT 'comment'] -- 事件的注釋
DO sql_statement; -- 這個調度計劃要做什么？需求：設計一個福彩的開獎過程，每3分鐘開獎一次
-- 存儲過程
create procedure test()
begin
insert into lottery(num1,num2,num3,ctime)
select FLOOR(rand()*9)+1,FLOOR(rand()*9)+1,FLOOR(rand()*9)+1,now();
end;-- 事件
create event if not exists test_event -- 創(chuàng)建一個事件
on schedule every 3 minute -- on schedule 每三分鐘執(zhí)行一次
on completion preserve
do call test; --調用存儲過程參考文章：mysql存儲過程學習筆記
到此這篇關于Mysql存儲過程、觸發(fā)器、事件調度器使用入門的文章就介紹到這了,更多相關Mysql存儲過程、觸發(fā)器、事件調度器內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
這篇文章主要介紹了MySQL中由load data語句引起死鎖的解決案例,文中講到了InnoDB引擎的數據表中一些鎖的機制,需要的朋友可以參考下2016-01-01
下面小編就為大家?guī)硪黄獪\談mysql 針對單張表的備份與還原。小編覺得挺不錯的，現在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-03-03
這篇文章主要給大家介紹了關于MySQL服務器 IO 100%的相關資料，文中通過示例代碼介紹的介紹非常詳細，對大家學習或者使用mysql具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2018-10-10
這篇文章主要介紹了mysql用戶權限管理,結合實例形式分析了mysql用戶權限管理概念、原理及用戶權限的查看、修改、刪除等操作技巧,需要的朋友可以參考下2020-04-04
Workbench是MySQL最近釋放的可視數據庫設計工具,這個工具是設計 MySQL數據庫的專用工具,下面這篇文章主要給大家介紹了關于MySQL?Workbench操作的相關資料,需要的朋友可以參考下2023-03-03
這篇文章主要介紹了關于mysql中的json解析函數JSON_EXTRACT講解，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-07-07
mysql 5.6 從陌生到熟練之_數據庫備份恢復的實現方法
下面小編就為大家?guī)硪黄猰ysql 5.6 從陌生到熟練之_數據庫備份恢復的實現方法。小編覺得挺不錯的，現在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2016-10-10
我們在使用mysql的時候要注意這方面的問題,一個因為數據庫字段命名不當造成的問題檢查起來還是相當麻煩的,今天遇到這種問題,花費了很長時間才找到問題所在，這是無語2015-04-04
這篇文章主要介紹了MySQL之MHA高可用配置及故障切換實現詳細部署步驟，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2021-03-03
大家好，本篇文章主要講的是全面盤點MySQL中的那些重要日志文件，感興趣的同學快來看一看吧，對你有用的話記得收藏，方便下次瀏覽2021-11-11