时间：2021-07-01 10:21:17 帮助过：15人阅读
#存储过程合法
DROP PROCEDURE IF EXISTS test;
CREATE PROCEDURE test()
BEGIN
DECLARE i INT;
SET i=1;
END;
#函数非法
DROP FUNCTION IF EXISTS test;
CREATE FUNCTION test()
BEGIN
DECLARE i INT;
SET i=1;
END;
（2）使用存储过程/函数，比使用单独的SQL语句要快。
2、创建函数
语法：
create procedure 存储过程名字([in|out|inout] 参数 datatype)
comment ‘here is zhushi‘
begin
MySQL 语句;
end;
参数：如果不指定in/out/inout，则默认为in；()不能省；参数前不加@；参数不能指定默认值。参数中可以使用各种类型，包括varchar，但是一定要指定长度，否则报错。
out参数：
drop procedure if exists bb;
create procedure bb(out total int)
begin
set total = 3;#方法1:不能有@，已验证
#方法2已验证可以：select count(*) into total from user;
end;
call bb(@total);
select @total;#调用语句和select语句中，都必须使用@，因为自定义变量不能与@分离，没有@相当于局部变量
返回值：
create function 存储过程名字([in|out|inout] 参数 datatype) returns int
begin
MySQL 语句;
return 1;
end;
注释：comment后面跟注释，在show procedure status中可以看到；可以省略
函数体：如果MySQL语句不止一句，则需要begin/end；每条语句都需要分号；注释可以使用/**/、--、#；函数中可以使用return，存储过程中不能使用。
创建函数实例：
drop procedure if exists pr_add;
create procedure pr_add(a int,b int)
begin
declare c int;
if a is null then
set a = 0;
end if;
if b is null then
set b = 0;
end if;
set c = a + b;
select c as sum;
/* return c; 不能在 MySQL 存储过程中使用。return 只能出现在函数中。*/
end;
3、delimiter：分界符；主要用在MySQL客户端。
delimiter的作用是规定分界符；当客户端遇到分界符时，便会执行MySQL命令。默认情况下，分界符是分号；但是在有些情景下，如定义函数，不希望遇到分号执行命令，而是等函数定义结束后执行命令，此时便使用形如delimiter $$的语句改变分界符，待函数定义结束后，再使用delimiter ;将分界符变回分号。
因此在非MySQL客户端，如sql文件、Navicat for MySQL中执行语句时，不需要使用delimiter。
4、错误说明
Error Code: 1418. This function has none of DETERMINISTIC, NO SQL, or READS SQL DATA in its declaration and binary logging is enabled (you *might* want to use the less safe log_bin_trust_function_creators variable)
原因：在主从复制的两台MySQL服务器中开启了二进制日志选项log-bin，slave会从master复制数据，而一些操作，比如function所得的结果在master和slave上可能不同，所以存在潜在的安全隐患。因此，在默认情况下回阻止function的创建。
解决方案1：将log_bin_trust_function_creators参数设置为ON，这样一来开启了log-bin的MySQL Server便可以随意创建function。这里存在潜在的数据安全问题，除非明确的知道创建的function在master和slave上的行为完全一致。
查看状态：SHOW VARIABLES LIKE ‘%log_bin_trust_function_creators%‘
设置：set global log_bin_trust_function_creators=1【动态设置在重启数据库后失效；修改配置文件后重启数据库可以永久改变】
5、变量声明：
declare用于在函数中声明局部变量，只在函数中有效
DECLARE variable_name1,variable_name2,…… datatype(size) DEFAULT default_value;
set variable_name1 = 1;//赋值
SELECT COUNT(*) INTO total_products FROM products#另外一种赋值方式，值得注意
set @用于定义会话变量(严格说是用户变量)，在整个会话中都有效；不需要指定datatype，MySQL自动指定。
set @var = 1;
set用于对局部变量赋值时，必须等所有的declare语句执行结束(个人怀疑是不是在函数中，所有的declare必须都放在最前面)
#以下语句会报错
drop procedure if exists test;
CREATE PROCEDURE test()
BEGIN
DECLARE i INT;
SET i = 1;
DECLARE o INT;
END;
#以下语句则正确
drop procedure if exists test;
CREATE PROCEDURE test()
BEGIN
DECLARE i INT;
DECLARE o INT;
SET i = 1;
END;
6、调用函数：不能省略参数，可以使用null代替
call pr_add(10,20);
或者
set @a = 10;
set @b = 20;
call pr_add(@a, @b);
7、删除函数
drop procedure if exists aa;
drop precedure aa;#如果aa不存在则会错误
8、查看函数
show procedure/function status：查看该服务器上所有数据库的所有procedure/function的状态
show create procedure/function 名称：查看指定函数的状态
show procedure status like ‘%……%‘
二、定时器
1、确认版本：5.1以上开始支持
select version()
2、开启event功能：默认是关闭的
show variables like ‘event_scheduler‘
set global event_scheduler=‘on‘;
3、创建event需要的存储过程
drop procedure if exists test_proce;
create procedure test_proce()
begin
insert into `user`(name,age) values(‘zhoudan‘,‘18‘);
end;
4、创建定时器
drop event if exists test_event;
create event test_event
on schedule every 1 second #执行的间隔时间
starts ‘2015-01-10 00:10:00‘ #开始执行的时间
on completion preserve disable #创建定时器后是否立即启动，如果是disable需要手动启动
do call test_proce();
5、启动、关闭、查看定时器
alter event test_event on completion preserve enable; #启动定时器
alter event test_event on completion preserve disable; #关闭定时器
show events; #显示本数据库下所有定时器
6、注意：如果存储过程执行过程中有错误，则整个过程中可能并不报错，但是定时器指定的存储过程无法正确执行。
三、触发器
1、创建触发器示例
create trigger newuser
after insert
on `user`
for each row
call test_proce1()
触发器名：之前是表中唯一，现在不确定；稳妥的做法是数据库唯一
执行时机：after/before
响应的活动：只支持insert/update/delete
关联的表：on ‘user‘；目前MySQL只有表支持触发器，视图和临时表都不支持
for each row：行级触发器，即影响多少行就触发多少次；与之对应的是语句触发器，即语句执行一次出发一次；由于MySQL只支持行级触发器，因此该语句不可省略。
执行的动作：
（1）可以是单条语句，可以是begin和end包围的多条语句，也可以支持call()
（2）现在版本的动作不能返回值，如含有return语句的function，select语句等；如果包含select语句，会报错Not allowed to return a result set from a trigger
（3）动作不能对本表进行 insert ,update ,delete 操作，以免递归循环触发；不仅是insert不能触发本表的insert语句，也不能触发本表的update和delete语句，其他同理
2、一些限制
（1）每个表对每个活动只能有两个触发器(一前一后)，因此一个表最多可以有6个触发器
（2）一个触发器不能与多个事件或多个表关联
（3）如果before触发器执行失败，则MySQL不会执行相应操作和after触发器；如果操作执行失败，则MySQL触发器不会执行after触发器
3、删除与查看：触发器不能修改或覆盖，如果要重新定义触发器，必须先删除在添加
drop trigger newuser;
show triggers;
show create trigger ‘newuser‘;
4、insert触发器
说明：引用名字为new的虚拟表，访问被插入的行；一般用before进行数据验证、净化，用after进行日志处理等；对于auto_increment列，new在insert之前值为0，insert之后是新的自动生成的值
before：被插入的值可以被更改；注意语法(使用普通的update语句，创建触发器的时候没有问题，执行插入的时候就会报错)
create trigger newuser2
before insert
on `user`
for each row
set new.name=‘zhoubapi‘
after
create trigger newuser
after insert
on `user`
for each row
insert into tmp values(new.id,new.name,new.age)
5、delete触发器：引用名字为old的虚拟表访问被删除的行；old中的值全部只可读
6、update触发器：既可以引用old，也可以引用new；可读性同上
四、函数语句学习
1、if
if a is null then
set a = 0;
end if;
if not exists(select 1 from ta_test where id = ‘1111‘) then
#mysql语句
end if;
2、while
declare i int;
set i=1;
while i<1000 do
#mysql语句
set i = i +1;
end while ;
3、错误处理【参考：http://blog.csdn.net/seteor/article/details/17791855】
（1）针对存储过程 、触发器或函数内部语句可能发生的错误或警告信息，需要进行相关异常的捕捉，然后作出相应的处理，异常处理的方式如下：
DECLARE {CONTINUE | EXIT} HANDLER FOR {SQLSTATE sqlstate_code| MySQL error code| condition_name} handler_actions
（2）Handler Type：CONTINUE | EXIT，处理类型，继续或退出；exit只退出当前Block。
（3）Handler Condition：SQLSTATE sqlstate_code| MySQL error code| condition_name，触发条件；其中condition_name(命名条件)既可以自己定义，也可是使用系统内置的SQLEXCEPTION、SQLWARNING和NOT FOUND。如果对于一个错误，同时有MySQL码、SQLSTATE和命名条件可以捕获，那么只能捕获一次错误，且捕获顺序是MySQL码->SQLSTATE->命名条件。
（4）handler_actions：错误发生时执行的操作，在continue或exit之前执行。
（5）作用域：如果定义在begin/end之内，则begin/end之外的错误不会捕获。
（6）示例：游标与错误处理结合
DROP PROCEDURE IF EXISTS test;
CREATE PROCEDURE test()
BEGIN
DECLARE no_more_record INT DEFAULT 0;
DECLARE pname VARCHAR(100);
DECLARE cur_record CURSOR FOR SELECT name FROM ta_tmp WHERE id < 8;
DECLARE CONTINUE HANDLER FOR NOT FOUND SET no_more_record = 1;
OPEN cur_record;
FETCH cur_record INTO pname;
WHILE no_more_record != 1 DO
SELECT pname;
FETCH cur_record INTO pname;
END WHILE;
CLOSE cur_record;
END;
4、临时表【参考：http://blog.csdn.net/crazylaa/article/details/5368698】
（1）MySQL不支持数组，但是在存储过程中，有时候需要使用复杂的运算结果，尤其是组合使用几个表的数据时，此时可以考虑使用临时表。
（2）临时表：只有在当前连接情况下， TEMPORARY 表才是可见的。当连接关闭时， TEMPORARY 表被自动取消。这意味着两个不同的连接可以使用相同的临时表名称，同时两个临时表不会互相冲突，也不与原有的同名的非临时表冲突。
（3）基本的使用方法如下
#创建临时表
CREATE TEMPORARY TABLE IF not exists tmpTable(
user_id VARCHAR(30) primary KEY,
drawingNumber int
);
truncate TABLE tmpTable;#在使用前清理数据
......#在后面的语句中可以对tmpTable进行增删改查
MySQL5-函数/存储过程与定时器、触发器
标签：定时 slave 二进制日志 where crazy 复制 不同的 str alter