跳至主要內容

MySQL事件

大约 4 分钟约 1263 字

事件概述

事件调度器,简称事件,可以做为定时任务调度器,取代部分只能使用操作系统才能执行的工作。MySQL支持每秒执行一次事件,在一些对实时性能比较高的环境下还是非常实用的。

事件调度器是定时触发执行的,从这个角度上看也可以称其为“临时触发器”,但是它与触发器有所区别,触发器只针对某一个表产生的事件执行一些语句,而事件调度器则是在某一段(间隔)时间执行一些语句。

查看事件是否开启

事件由一个特殊的线程来管理。启用事件调度器后,拥有SUPER权限的用户就可以通过SHOW PROCESSLIST命令就可以看到这个线程。

我们可以通过下面的代码查看事件是否开启。

show variables like 'event_scheduler';
select @@event_scheduler;
show processlist;
运行结果
运行结果

从运行结果中可以看到,事件已经开启。

开启事件

设定全局变量event_scheduler的值就可以动态地控制时间是否开启。开启MySQL事件调度器,可以通过下面两种方式实现。

  1. 设置全局参数

    在MySQL的命令行中,使用SET GLOBAL命令可以开启或关闭事件。如开启事件,就可以使用下面的代码。

    set global event_scheduler = OFF;
    show variables like 'event_scheduler';
    
    运行结果
    运行结果
  2. 更改配置文件

    在MySQL的配置文件my.ini中,找到[mysqld],然后在下面添加如下的字符串即可始终开启事件。

    event_scheduler = ON

创建事件

在MySQL中,可以通过CREATE EVENT语句来创建事件,语法如下。

CREATE 
[DEFINER = {user|CURRENT_USER}]
EVENT [IF NOT EXISTS] event_name
ON SCHEDULE schedule
[ON COMPLETION [NOT] PRESERVE]
[ENABLE|DISABLE|DISABLE ON SLAVE]
[COMMENT 'comment']
DO event_body;

各子句的详细说明如下表。

子句说明
DEFINER可选,用于定义事件执行时检查权限的用户
ON SCHEDULE schedule必选,用于定义执行的时间和时间间隔
ON COMPLETION [NOT] PRESERVE可选,用于定义事件是否循环执行,即是一次执行还是永久执行,默认是依次执行,即NOT PRESERVE
ENABLE|DISABLE|
DISABLE ON SLAVE
可选,用于指定事件的一种属性。关键字ENABLE表示该事件是活动的,也就是调度器检查事件是否必须调用;关键字DISABLE表示该事件是关闭的,也就是事件的声明存储到目录中,但是调度器不会检查它是否应该调用;关键字DISABLE ON SLAVE表示事件在从机中是被关闭的。如不指定这三个选项中的任何一个,则在一个事件被创建后,它立即变为活动的。
COMMENT 'comment'可选,用于定义事件的注释
DO event_body必选,用于指定事件启动后要执行的代码。可以是任何有效的SQL语句、存储过程或者一个计划执行的程序。若要包含多个语句,可以用begin ... end复合结构

在ON SCHEDULE子句中,参数schedule的值为一个AS语句,用于指定事件在某个时刻发生,其语法格式如下。

AT timestamp [+ INTERVAL interval] ...
| EVERY interval
[START timestamp [+ INTERVAL interval] ...]
[ENDS timestamp [+ INTERVAL interval] ...]

参数说明如下。

  1. timestamp:表示一个具体的时间点,后面再加上一个时间间隔,表示在这个时间间隔后事件发生。

  2. EVERY子句:用于表示事件在指定区间内每个多长时间发生一次,其中STARTS子句用于指定开始时间,ENDS用于指定结束时间。

  3. interval:表示一个从现在开始的时间,其值由一个数值和一个单位组成。例如,使用4 WEEK表示4周,使用'1:10' HOUR_MINUTE表示1小时10分钟。间隔的距离用DATE_ADD()支配。

    interval参数值的参数如下:

    quantity {YEAR|QUARTER|MONTH|DAY|HOUR|MINUTE|WEEK|SECOND|YEAR_MONTH
    |DAY_HOUR|DAY_MINUTE|DAY_SECOND|HOUR_MINUTE|HOUR_SECOND|MINUTE_SECOND}
    

如下面我们创建一个每五秒向表中插入一个数据的事件。

create event auto_add on schedule every 5 second on completion preserve 
do insert into tb_time (createtime, name) values (now(), 'root');
运行结果
运行结果

下面我们再来创建一个自动在月初保存已注册人数的事件调度器。

use db;
-- 创建表
create table tb_info (
    id int primary key not null auto_increment,
    num_user int not null,
    savetime datetime not null default now()
);  
-- 创建存储过程
delimiter //
create procedure auto_save_num()
begin 
declare num int default 0;
select count(*) into num from tb_user;
insert into tb_info (num_user) values (num);
end
//
delimiter ;
-- 调用存储过程
call auto_save_num();
select * from tb_info;
call auto_save_num();
select * from tb_info;
-- 创建事件
create event auto_save_number on schedule every 1 month starts date_add(date_add(date_sub(curdate(),interval day(curdate())-1 day ),interval 1 month ),interval 1 hour) on completion preserve do call auto_save_num();
运行结果
运行结果

修改事件

修改事件的语法如下。

ALTER
[DEFINER = {user | CURRENT_USER}]
    EVENT event_name
    [ON SCHEDULE schedule]
    [ON COMPLETION [NOT] PRESERVE]
    [RENAME TO new_event_name]
    [ENABLE|DISABLE|DISABLE ON SLAVE]
    [COMMENT 'comment']
[DO event_body];

删除事件

删除事件的语法如下。

DROP EVENT [IF EXISTS] event_name;
上次编辑于:
贡献者: QI