Vous faire comprendre les procédures stockées MySQL en dix minutes

Cet article partagera avec vous mes notes lors de l'apprentissage des procédures stockées MySQL. Il présente en détail les connaissances pertinentes sur les procédures stockées MySQL. J'espère qu'il sera utile à tout le monde.

1. Définition

La procédure stockée (procédure stockée) est un ensemble d'instructions SQL utilisées pour exécuter des fonctions spécifiques dans les grands systèmes de base de données. Elles sont stockées dans la base de données après avoir été compilées pour la première fois. ils n'ont pas besoin d'être rappelés. Pour compiler, l'utilisateur exécute la procédure stockée en spécifiant son nom et en donnant les paramètres (si la procédure stockée a des paramètres). La procédure stockée est un objet important dans la base de données.

2. Caractéristiques des procédures stockées

1. Peut effectuer des jugements et des opérations plus complexes
2. Programmable et flexible
3. Le code de programmation SQL peut être réutilisé
4. La vitesse d'exécution est relativement plus rapide
5 , Réduisez la transmission de données entre réseaux et économisez des frais généraux

3. Créez une procédure stockée simple

1. Syntaxe simple pour créer une procédure stockée

create procedure 名称()
begin
.........
end

2. Créez une procédure stockée simple

create procedure testa()
begin
    select * from users;
    select * from orders;
end;

3. Appelez la procédure stockée

call testa();

Les résultats de l'opération sont comme le montrent les figures (1) et (2) :                                                                                                                                                                                                                                                                                                                                                                Figure (2)

4. Variables de la procédure stockée

1. Passer en premier Un exemple simple pour apprendre la déclaration et l'affectation des variables

create procedure test2()
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;

2. Résumé

(1) Utilisez declare pour déclarer une variable. Declare ne déclare qu'une seule variable, et la variable doit d'abord être déclarée puis utilisée

(2) Les variables ont Le type de données et la longueur sont cohérents avec le type de données SQL de MySQL, donc ; il peut même formuler des valeurs par défaut, des jeux de caractères et des règles de tri, etc. ;

                  (4) Si la variable doit être renvoyée, vous pouvez utiliser l'instruction select, telle que : sélectionnez le nom de la variable.的 量 量 5. Le rôle des variables

1. Explication de la portée des variables :

(1) Les variables dans la procédure de stockage sont une portée fonctionnelle. ?                             . Vérifiez la portée de la variable à l'aide d'un exemple

Condition : créez une procédure stockée pour compter le nombre de lignes dans les tables des utilisateurs et des commandes et les montants maximum et minimum dans la table des commandes

create procedure test3()
begin
  begin
    declare userscount int default 0; -- 用户表中的数量
    declare ordercount int default 0; -- 订单表中的数量
    select count(*) into userscount from users;
    select count(*) into ordercount from orders;
    select userscount,ordercount; -- 返回用户表中的数量、订单表中的数量
  end;
  begin 
    declare maxmoney int default 0; -- 最大金额
    declare minmoney int default 0; -- 最小金额
    select max(money) into maxmoney from orders;
    select min(money) into minmoney from orders;
    select maxmoney,minmoney; -- 返回最金额、最小金额
   end;
end;

Appelez la procédure stockée ci-dessus, les résultats sont présentés dans la figure (3) et la figure (4) :                                                                                                        3. J'ai modifié la procédure test(3) comme suit :

créer une procédure test3()

commencer

commencer

déclarer le nombre d'utilisateurs int par défaut 0 ; -- la quantité dans le tableau des utilisateurs

déclarer le nombre de commandes par défaut 0 ; -- la quantité dans le tableau des commandes

sélectionnez le nombre d'utilisateurs parmi les utilisateurs ;

sélectionnez le nombre (* ) dans le nombre de commandes à partir des commandes ; int par défaut 0 ; -- montant minimum

sélectionnez max(money) dans maxmoney à partir des commandes ;

        select min(money) into minmoney from orders;

        select userscount,ordercount，maxmoney,minmoney; -- 返回最金额、最小金额

       end;

    end;

再次调用call test3(); 会报错如图（5）：

                               图（5）

    4、将userscount,ordercount改为全局变量，再次验证

    create procedure test3()

    begin

        declare userscount int default 0; -- 用户表中的数量

        declare ordercount int default 0; -- 订单表中的数量

        begin

            select count(*) into userscount from users;

            select count(*) into ordercount from orders;

            select userscount,ordercount; -- 返回用户表中的数量、订单表中的数量

      end;

      begin 

        declare maxmoney int default 0; -- 最大金额

        declare minmoney int default 0; -- 最小金额

        select max(money) into maxmoney from orders;

        select min(money) into minmoney from orders;

        select userscount,ordercount，maxmoney,minmoney; -- 返回最金额、最小金额

       end;

    end;

再次调用call test3(); 会报错如图（6）和图（7）：

       

                    图（6）       

                                                             

                    图（7）

因此，存储过程中变量的作用域，作用范围在begin和end块之间，end结束变量的作用范围即结束
    

六、存储过程参数

  1、基本语法

create procedure 名称([IN|OUT|INOUT] 参数名 参数数据类型 )
begin
.........
end

 存储过程的参数类型有：IN,OUT,INOUT，下面分别介绍这个三种类型：
    
  2、存储过程的传出参数IN

     说明：        

        （1）、传入参数：类型为in,表示该参数的值必须在调用存储过程事指定，如果不显示指定为in,那么默认就是in类型。

        （2）、IN类型参数一般只用于传入，在调用过程中一般不作为修改和返回

        （3）、如果调用存储过程中需要修改和返回值，可以使用OUT类型参数

通过一个实例来演示：

需求：编写存储过程，传入id,根据id返回name

 create procedure test4(userId int)
    begin
            declare username varchar(32) default '';
            declare ordercount int default 0;
            select name into username from users where id=userId;
            select username;
    end;

运行如图(8)

    

                                                       图(8)
  
    
   3、存储过程的传出参数out

        需求：调用存储过程时，传入userId返回该用户的name

        create procedure test5(in userId int,out username varchar(32))

        begin

            select name into username from users where id=userId;

        end;

        调用及运行结果如图(9)：

                                   图(9)
        
  概括：

        1、传出参数：在调用存储过程中，可以改变其值，并可返回；

        2、out是传出参数，不能用于传入参数值；

        3、调用存储过程时，out参数也需要指定，但必须是变量，不能是常量；

        4、如果既需要传入，同时又需要传出，则可以使用INOUT类型参数

    (3).存储过程的可变参数INOUT
    
        需求：调用存储过程时，传入userId和userName,即使传入，也是传出参数。

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;

 调用及运行结果如图(10)

        

                                       图(10)
    概括：
        1、可变变量INOUT:调用时可传入值，在调用过程中，可修改其值，同时也可返回值；
        2、INOUT参数集合了IN和OUT类型的参数功能；
        3、INOUT调用时传入的是变量，而不是常量；

七、存储过程条件语句

   1、基本结构

   （1）、条件语句基本结构：

if() then...else...end if;

   （2）、多条件判断语句：

if() then...
elseif() then...
else ...
end if;

   2、实例
    实例1：编写存储过程，如果用户userId是偶数则返回username,否则返回userId

create procedure test7(in userId int)
begin
   declare username varchar(32) default '';
   if(userId%2=0)
   then 
      select name into username from users where id=userId;
      select username;
   else
      select userId;
      end if;
end;

    调用及运行结果如图(11)和图(12)：

       

                        图(11)           

                                     

                               图(12)

    2、存储过程的多条件语句应用示例

        需求：根据用户传入的uid参数判断

        （1）、如果用户状态status为1，则给用户score加10分；

        （2）、 如果用户状态status为2，则给用户score加20分；

        （3）、 其他情况加30分

create procedure test8(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;

调用程之前的users表的数据如图(13)，调用 call test8(1); 及运行结果图(14)：

           
                                   图(13)       

     

                                    图(14)
      

八、存储过程循环语句

    1、while语句

       （1）、while语句的基本结构

while(表达式) do 
   ......  
end while;

         （2）、示例
    需求：使用循环语句，向表test1(id)中插入10条连续的记录

create procedure test9()
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;

    调用及运行结果结果如图(15)和图(16)：

    

                                                                    图(15)

   

         图(16)

    2、repeat语句
    （1）、repeat语句基本的结构：

repeat...until...end repeat;

     （2）、示例

需求：给test1表中的id字段插入数据，从1到10

create procedure test10()
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;

   调用及运行结果结果如图(17)和图(18)

   

    图(17)             

   

              图(18)
        
    概括：
        until判断返回逻辑真或者假，表达式可以是任意返回真或者假的表达式，只有当until语句为真是，循环结束。
        

九、存储过程游标的使用

    1、什么是游标
        游标是保存查询结果的临时区域
    2、示例
    需求：编写存储过程，使用游标，把users表中 id为偶数的记录逐一更新用户名
    

create procedure test11()
    begin
        declare stopflag int default 0;
        declare username VARCHAR(32);
        -- 创建一个游标变量，declare 变量名 cursor ...
        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;
            end;
        end while; -- 结束循环
        close username_cur; -- 关闭游标
    end;

调用结果如图(19)：

                                     图(19)

十、自定义函数

    函数与存储过程最大的区别是函数必须有返回值，否则会报错
    
    1、一个简单的函数

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;

    调用及运行结果如图(20)：

                图(20)
    

    概括：

    1.创建函数使用create function 函数名(参数) returns 返回类型；

    2.函数体放在begin和end之间；

    3.returns指定函数的返回值；

    4.函数调用使用select getusername()。

2、示例

    需求：根据userid，获取accoutid,id,name组合成UUID作为用户的唯一标识

  create function getuuid(userid int) returns varchar(64)
    reads sql data  -- 从数据库中读取数据，但不修改数据
    begin
        declare uuid varchar(64) default '';
        select concat(accontid,'_',id,'_',name) into uuid from users where id=userid;
        return uuid;
    end;

调用及运行结果如图(21)

             图(21)

   
十一、触发器

    1、什么是触发器

    触发器与函数、存储过程一样，触发器是一种对象，它能根据对表的操作时间，触发一些动作，这些动作可以是insert,update,delete等修改操作。

    2、示例1

（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.id,NEW.name,'insert',now());
    end;

    创建成功后，给uses表中插入一条记录：

insert into users(id,name,age,status,score,accontid)
    values(6,'小周',23,1,'60','10001')；

  执行成功后，打开oplog表，可以看到oplog表中插入了一条记录如图(22)
    

                                                     图(22)
  

  （2）、总结

        1、创建触发器使用create trigger 触发器名
        2、什么时候触发？after insert on users,除了after还有before,是在对表操作之前（before）或者之后（after）触发动作的。
        3、对什么操作事件触发？ after insert on users,操作事件包括insert,update,delete等修改操作；
        4、对什么表触发? after insert on users
        5、影响的范围？for each row

3、示例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;

    删除users表中的一条记录

delete from users where id=6;

    执行成功后，打开oplog表，可以看到oplog表中插入了一条记录如图（23）

                                              图（23）

         
十二、流程控制

 1、case分支

   （1）、基本语法结构

case ...
when ... then....
when.... then....
else ... 
end case;

（2）、示例

users表中，根据userid获取status值，如果status为1，则修改score为10；如果status为2，则修改为20，如果status3，则修改为30；否则修改为40。

 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;

    调用过程 call testcate(1); ，执行结果如图（24）；

                             图（24）

十四、存储过程+event（事件）

     1、使用存储过程+事件事件一个简单的实现福彩3D开奖
        
        需求：设计一个福彩的开奖过程，没3分钟开奖一次
            第一步：先编写一个存储过程open_lottery,产生3个随机数，生成一条开奖记录
            第二步：编写一个时间调度器，每3分钟调用一次这个过程
          

create procedure open_lottery()
        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 lottery_event -- 创建一个事件
        on schedule every  3 minute  -- on schedule 什么时候来执行，没三分钟执行一次
        on completion preserve 
        do call open_lottery;

        运行结果如图(25)

        

                                                         图(25)

注意，如果event之一没有运行，请按照以下办法解决：

（1）、 show variables like '%event_scheduler%';
        set global event_scheduler=on;

（2）、 alert event lottery_event enable;

    2、解析event的创建格式
    （1）、基本语法

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; -- 这个调度计划要做什么？

（2）、执行时间说明

    1.单次计划任务示例
        在2019年2月1日4点执行一次

        on schedule at    '2019-02-01 04:00:00'
         
    2. 重复计划执行
        on schedule every 1 second 每秒执行一次
        on schedule every 1 minute 每分钟执行一次
        on schedule every 1 day 没天执行一次
        
    3.指定时间范围的重复计划任务
        每天在20:00:00执行一次
        on schedule every 1 day starts '2019-02-01 20:00:00'

十五、本文所用到的表

1、lottery表

2、oplog表

3、orders表

4、test1表

5、user表

推荐学习：mysql视频教程

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!