标签:定时 slave 二进制日志 where crazy 复制 不同的 str alter
目录
一、函数/存储过程
二、定时器
三、触发器
四、函数语句学习
一、函数/存储过程
1、函数与存储过程
(1) function与procedure的区别:一个有返回值,一个没有,仅此而已。上述说法是错误的,function和procedure的用法有很多不同,总体来说procedure受到的限制较少,function的限制较多;而且procedure可以使用out参数返回值,因此尽量采用procedure。比如,以下存储过程的创建是合法的,但函数的常见则是非法的。
#存储过程合法
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用于对局部变量赋值时,必须等所有的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代替
或者
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以上开始支持
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
原文地址:http://www.cnblogs.com/kismetv/p/6947676.html