mysql 事件调度器_MySQL事件调度器event的使用

梦里梦外; 2023-01-11 08:21 170阅读 0赞

Q：假设，有一个需求，希望在某一个时刻系统调用一个begin end执行一下；十分钟以后执行一下begin end。亦或有一个需求，每个多长时间周期性执行begin end。那么这个时候该怎么办呢？

A：

在Linux里面可以使用at、crontab来实现上面的需求；MySQL里面也有这样的方法，就是event对象。

也被称为MySQL事件调度器(Event Scheduler)，可以在某一个时间点执行一个SQL语句或一个语句块(BEGIN ... END)；或者每隔固定间隔重复执行。类似于Linux下的at、crontab或Windows下的Task Scheduler。

那么如何使用event，步骤如下：

1、开启数据库的event执行调度

> 查看是否开启定时器

mysql> show variables like '%event\_scheduler%';+-----------------+-------+

| Variable\_name | Value |

\+-----------------+-------+

| event\_scheduler | OFF |

\+-----------------+-------+

>开启

0：off

1：on

mysql> set global event\_scheduler=1;

mysql>exit

Bye

\[root@studying~\]\# mysql -uroot -p123

mysql> show variables like '%event\_scheduler%';+-----------------+-------+

| Variable\_name | Value |

\+-----------------+-------+

| event\_scheduler | ON |

\+-----------------+-------+

注意：

如果是设定事件计划为0 或OFF，即关闭事件计划进程的时候，不会有新的事件执行，但现有的正在运行的事件会执行到完毕。

对于线上环境来说，使用even时，注意在主库上开启定时器，从库上关闭定时器，event触发所有操作均会记录binlog进行主从同步，从库上开启定时器很可能造成卡库。切换主库后之后记得将新主库上的定时器打开。

2、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;

schedule:

AT timestamp \[+INTERVAL interval\] ...　　|EVERY interval

\[STARTS timestamp \[+INTERVAL interval\] ...\]

\[ENDS timestamp \[+INTERVAL interval\] ...\]

interval:

quantity \{YEAR| QUARTER | MONTH | DAY | HOUR | MINUTE |WEEK| SECOND | YEAR\_MONTH | DAY\_HOUR | DAY\_MINUTE |DAY\_SECOND| HOUR\_MINUTE | HOUR\_SECOND | MINUTE\_SECOND\}

详细解析：

①definer：指明该event的用户，服务器在执行该事件时，使用该用户来检查权限。

默认用户为当前用户，即definer = current\_user；

如果明确指明了definer，则必须遵循如下规则：

1.如果没有super权限，唯一允许的值就是自己当前用户，而不能设置为其他用户。

2.如果具有super权限，则可以指定任意存在的用户；如果指定的用户不存在，则事件在执行时会报错。

②if not exists：如果事件已经存在，则不会创建，也不会报错。

③on schedule子句：指定何时执行该事件，以及如何执行该事件

1)at timestamp用于创建单次执行的事件，timestamp执行事件执行的时间(如果指定的时间是过去的时间，则会产生一个warning)，时间可以是具体的时间字符串或者是一个datetime类型的表达式(如current\_timestamp)：

如果要指定将来某个时间，直接使用at timestamp，例：at '2017-08-08 08:08:08'；

如果要指定将来某个时间间隔，可利用interval关键字(interval关键字可以进行组合，at timestamp + INTERVAL 2 HOUR、 + INTERVAL 30 MINUTE)

2)every子句用于创建重复执行的事件，如果每分钟执行一次，则可以：EVERY 1 MINUTE。

当然，every子句可以指定一个开始事件和结束时间，通过STARTS和ENDS关键字来表示，具体语法与前面类似

例如：EVERY 12 HOUR STARTS CURRENT\_TIMESTAMP + INTERVAL 30 MINUTE ENDS CURRENT\_TIMESTAMP + INTERVAL 4 WEEK。

④通常情况下，如果一个事件过期已过期，则会被立即删除。但是，create event定义中通过on completion preserve子句可以保留已过期的时间。

默认：ON COMPLETION NOT PRESERVE，也就是不保存

⑤默认情况下，enable on slave，事件一旦创建后就立即开始执行；可以通过disable关键字来禁用该事件。

⑥comment子句用于给事件添加注释。

⑦do子句用于指示事件需要执行的操作，可以是一条SQL语句，也可以是被begin...end包括的语句块，也可以在语句块中调用存储过程。

基本格式：

CREATE EVENT event\_name

ON SCHEDULE

DO ;

mysql> create eventmy\_event

\-> on schedule every10second-> do update myschema.mytable set mycol = mycol + 1;

示例：建立一个计划任务，每分钟往表t2中添加数据(当前时间)

mysql>show events;

Emptyset (0.02sec)

mysql> create table t2(id intauto\_increment primary key,t\_time datetime);

mysql>delimiter $$

mysql>CREATE EVENT e\_daily->ON SCHEDULE-> 　　EVERY 1MINUTE-> 　　　　COMMENT 'Saves total number of sessions then clears the table each day'

\->DO->BEGIN-> 　　　　　　INSERT INTO t2 values (null,current\_timestamp);->END $$

mysql>delimiter ;

……过一段时间……

mysql> select \* fromt2;+----+---------------------+

| id | t\_time |

\+----+---------------------+

| 1 | 2017-04-04 18:02:38 |

| 2 | 2017-04-04 18:03:38 |

| 3 | 2017-04-04 18:04:38 |…………

3、查看新建的计划任务

mysql> select EVENT\_NAME,LAST\_EXECUTED frominformation\_schema.EVENTS;+------------+---------------------+

| EVENT\_NAME | LAST\_EXECUTED |

\+------------+---------------------+

| e\_daily | 2017-04-04 18:02:38 |

\+------------+---------------------+mysql>show events\\G;\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\* 1. row \*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*Db: db1

Name: e\_daily

Definer: root@localhost

Time zone: SYSTEM

Type: RECURRING

Execute at: NULL

Interval value:1Interval field: MINUTE

Starts:2017-04-04 18:02:38Ends: NULL

Status: ENABLED

Originator:0character\_set\_client: utf8

collation\_connection: utf8\_general\_ci

Database Collation: latin1\_swedish\_ci

\[root@studying~\]\# tail -1 /var/log/mysqld.log2017-04-04T08:01:16.311514Z 12 \[Note\] Event Scheduler: scheduler thread started with id 12