Mysql存儲過程、觸發器、事件調度器使用入門指南

Posted on by

存儲過程（Stored Procedure）是一種在數據庫中存儲復雜程序的數據庫對象。為瞭完成特定功能的SQL語句集，經過編譯創建並保存在數據庫中。

一、存儲過程的簡單使用

創建存儲過程

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、循環語句

（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為真是才跳出循環：

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,則跳出循環
    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;

六、遊標

遊標保存瞭查詢結果的臨時區域

declare 變量名 cursor ... -- 創建一個遊標變量
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，用於循環中判斷是否結束
        declare continue handler for not found set stopflag=1;
 
        open username_cur; -- 打卡遊標
        fetch username_cur into username; -- 遊標向前走一步，取出一條記錄放到變量username中
        while(stopflag=0) do -- 如果遊標還沒有結尾，就繼續
            begin 
                -- 在用戶名前門拼接 '_cur' 字符串
                update users set name=CONCAT(username,'_cur') where name=username;
                fetch username_cur into username;-- 遊標向前走一步，取出一條記錄放到變量username中
            end;
        end while; -- 結束循環
        close username_cur; -- 關閉遊標
    end;

七、自定義函數

-- 創建函數
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;

八、觸發器

觸發器也是一種數據庫對象，在滿足定義條件時觸發，並執行觸發器中定義的語句集合。

創建觸發器：create trigger 觸發器名
after、before：在對表操作之前（before）或者之後（after）觸發動作。
操作事件：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;

九、事件

觸發器隻是針對某個表產生的事件執行一些語句,而事件調度器則是在某一個(間隔)時間執行一些語句。

在使用這個功能之前必須確保事件調度器event_scheduler已開啟：

SET GLOBAL event_scheduler = 1;
-- 或者
SET GLOBAL event_scheduler = on;

--查看開啟情況
show variables like '%event_scheduler%';
create event[IF NOT EXISTS]event_name -- 創建使用create event
    ON SCHEDULE schedule -- on schedule 什麼時候來執行
    [ON COMPLETION [NOT] PRESERVE] -- 調度計劃執行完成後是否還保留
    [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 -- 創建一個事件
        on schedule every  3 minute -- on schedule 每三分鐘執行一次
        on completion preserve 
        do call test;  --調用存儲過程

參考文章：mysql存儲過程學習筆記

到此這篇關於Mysql存儲過程、觸發器、事件調度器使用入門的文章就介紹到這瞭,更多相關Mysql存儲過程、觸發器、事件調度器內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：