存储过程(Stored Procedure)是在大型数据库系统中,一组为了完成特定功能的SQL 语句集,存储在数据库中,经过第一次编译后调用不需要再次编译,用户通过指定存储过程的名字并给出参数(如果该存储过程带有参数)来执行它。存储过程是数据库中的一个重要对象。
1、能完成较复杂的判断和运算;
2、可编程行强,灵活;
3、SQL编程的代码可重复使用;
4、执行的速度相对快一些;
5、减少网络之间的数据传输,节省开销 ;
创建存储过程 DELIMITER $$ create procedure 名称() begin ......... end $$ 调用存储过程 call 名称(); 案例 DELIMITER $$ create procedure testa() begin select * from users; select * from orders; end $$ call testa();
定义:
(1)、变量的声明使用declare,一句declare只声明一个变量,变量必须先声明后使用; (2)、变量具有数据类型和长度,与mysql的SQL数据类型保持一致,因此甚至还能制定默认值、字符集和排序规则等; (3)、变量可以通过set来赋值,也可以通过select into的方式赋值; (4)、变量需要返回,可以使用select语句,如:select 变量名。
语法
案例 delimiter $$ create procedure test2() begin -- 使用 declare语句声明一个变量 declare username varchar(32) default 'lili'; -- 使用set语句给变量赋值 set username='xiaoxiao'; -- 将users表中id=1的名称赋值给username select name into username from users where id=1; -- 返回变量 select username; end $$
定义:
1、变量作用域说明: (1)、存储过程中变量是有作用域的,作用范围在begin和end块之间,end结束变量的作用范围即结束。 (2)、需要多个块之间传值,可以使用全局变量,即放在所有代码块之前 (3)、传参变量是全局的,可以在多个块之间起作用
案例:
delimiter $$ 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 $$ 调用存储函数 call test3();
1.基本语法
delimiter create procedure 名称([IN|OUT|INOUT] 参数名 参数数据类型 ) begin ......... end $$
1.存储过程的传出参数IN
(1)、传入参数:类型为in,表示该参数的值必须在调用存储过程事指定,如果不显示指定为in,那么默认就是in类型。 (2)、IN类型参数一般只用于传入,在调用过程中一般不作为修改和返回 (3)、如果调用存储过程中需要修改和返回值,可以使用OUT类型参数
案例:
-- 需求:编写存储过程,传入id,根据id返回name delimiter $$ 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 $$ 调用存储函数 call test4();
2.存储过程的传出参数out
1、传出参数:在调用存储过程中,可以改变其值,并可返回; 2、out是传出参数,不能用于传入参数值; 3、调用存储过程时,out参数也需要指定,但必须是变量,不能是常量; 4、如果既需要传入,同时又需要传出,则可以使用INOUT类型参数;
案例:
-- 需求:调用存储过程时,传入userId返回该用户的name delimiter $$ create procedure test5(in userId int,out username varchar(32)) begin select name into username from users where id=userId; end $$ 调用存储函数 call test5();
3.存储过程的可变参数INOUT
定义:
1、可变变量INOUT:调用时可传入值,在调用过程中,可修改其值,同时也可返回值; 2、INOUT参数集合了IN和OUT类型的参数功能; 3、INOUT调用时传入的是变量,而不是常量;
案例:
-- 需求:调用存储过程时,传入userId和userName,即使传入,也是传出参数。 delimiter $$ 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 $$ 调用存储函数 call test6();
1.基本语句
(1)、条件语句基本结构:
if() then...else...end if;
(2)、多条件判断语句:
if() then... elseif() then... else ... end if;
案例:
-- 编写存储过程,如果用户userId是偶数则返回username,否则返回userId delimiter $$ 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 $$ 调用存储函数 call test7();
1、while语句
(1)、while语句的基本结构
while(表达式) do ...... end while;
案例
-- 使用循环语句,向表test1(id)中插入10条连续的记录 delimiter $$ 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 $$ 调用存储函数 call test9();
2、repeat语句
(1)、repeat语句基本的结构:
repeat...until...end repeat;
案例:
-- 给test1表中的id字段插入数据,从1到10 delimiter $$ 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 $$ 调用存储函数 call test10();
1.什么是游标
游标是保存查询结果的临时区域
案例:
-- 编写存储过程,使用游标,把users表中 id为偶数的记录逐一更新用户名 delimiter $$ 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 $$ -- 调用存储函数 call test11();
1.定义:函数与存储过程最大的区别是函数必须有返回值,否则会报错。
案例:
delimiter $$ 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 $4 -- 调用存储函数 call getusername(参数);
概括:
1.创建函数使用create function 函数名(参数) returns 返回类型;
2.函数体放在begin和end之间;
3.returns指定函数的返回值;
4.函数调用使用select getusername()。
2.案例:根据userid,获取accoutid,id,name组合成UUID作为用户的唯一标识
delimiter $$ 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 $$ -- 调用存储函数 call getuuid(参数);
1、什么是触发器
触发器与函数、存储过程一样,触发器是一种对象,它能根据对表的操作时间,触发一些动作,这些动作可以是insert,update,delete等修改操作。
2.案例:
-- 出于审计目的,当有人往表users插入一条记录时,把插入的userid,username,插入动作和操作时间记录下来。 delimiter $$ 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 $$
3.总结
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
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。 delimiter $$ 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、使用存储过程+事件事件一个简单的实现福彩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;
注意,如果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'