当前位置：首页 > article >正文

MySQL 事件调度器(Event Scheduler)的使用

article 2025/2/6 8:43:37

MySQL 事件调度器的使用

1、需求
2、前置条件
- 1、确认是否开启了Event Scheduler
- 2、开启 Event Scheduler
- 3、创建Event的语法
- 4、创建或修改Event需要的权限
3、实现文章开头的需求
- 1、创建事件调度
- 2、查看事件的状态
- 3、查看login_log表，看表中的create_time是否是每隔5s产生1条记录
4、参考文档

1、需求

假设我们有一个需求，每隔5s，清除表login_log中2年前的记录，并插入一条当前清理的记录，那么这个该如何实现呢？
实现这个需求的方式有很多种，此处我们通过数据库的 Event Scheduler 来实现下。

2、前置条件

1、确认是否开启了Event Scheduler

root@localhost : temp_work 09:42:01>show variables like '%event_scheduler%';
+-----------------+-------+
| Variable_name   | Value |
+-----------------+-------+
| event_scheduler | ON    |
+-----------------+-------+
1 row in set (0.01 sec)

root@localhost : temp_work 09:42:32>

event_scheduler的返回值为ON开始开启了，为OFF表示未开启。

2、开启 Event Scheduler

手动开启，通过SET GLOBAL event_scheduler = ON;命令开启

root@localhost : temp_work 09:47:10>SET GLOBAL event_scheduler = ON;
Query OK, 0 rows affected (0.00 sec)

root@localhost : temp_work 09:51:56>

通过命令手动开启关闭

如果我们希望Event Scheduler在MySql服务一启动时就启用，那么就需要在my.cnf配置文件中进行配置

[mysqld]
event_scheduler = ON

启动就生效
Event Scheduler的配置https://dev.mysql.com/doc/refman/8.4/en/events-configuration.html

3、创建Event的语法

CREATE
    [DEFINER = user]
    EVENT
    [IF NOT EXISTS]
    event_name
    ON SCHEDULE schedule
    [ON COMPLETION [NOT] PRESERVE]
    [ENABLE | DISABLE | DISABLE ON {REPLICA | SLAVE}]
    [COMMENT 'string']
    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}

部分语法解释：

on schedule: 表示这个事件什么时候执行。
   >> at timestamp: 表示的是一次性的事件，即只会执行一次。
     ｜- at 2025-02-04 23:59:59 表示这个事件将会在2025-02-04 23:59:59这个时间点执行。
     ｜- at timestamp + INTERVAL 2 HOUR 表示这个事件将会在创建之后的2个小时之后执行。
   >> every: 表示的是周期性任务，即每隔多长时间执行一次，同时也可执行这个事件的开始执行时间和结束执行时间，通过STARTS和ENDS关键字来表示。
     ｜- every 5 second starts '2025-02-04 22:50:00' ends current_timestamp + interval 1 day 表示这个事件每5秒执行一次，从 2025-02-04 22:50:00开始执行，1周后停止执行。
on completion preserve 表示如果事件过期了，则会保留，如果加上[NOT] 则不保留。
DO event_body 此处的event_body可以是一条SQL语句，也可以是BEGIN ... END包括的语句块。

创建Event 语法 https://dev.mysql.com/doc/refman/8.4/en/create-event.html

4、创建或修改Event需要的权限

创建或修改Event事件时，需要EVENT权限。

创建或修改Event需要的权限
Event Scheduler涉及到的权限 https://dev.mysql.com/doc/refman/8.4/en/events-privileges.html

3、实现文章开头的需求

1、创建事件调度

root@localhost : temp_work 10:45:33>delimiter $$
root@localhost : temp_work 10:49:47>create event if not exists clean_login_event -- 事件的名称，不可重复
    ->     on schedule
    ->     every 5 second -- 事件的调度周期
    ->     starts '2025-02-04 22:50:00' -- 事件的开始事件
    ->     ends current_timestamp + interval 1 day -- 事件的结束事件
    ->     on completion preserve -- 表示事件过期了，进行保留
    ->     enable -- 启用这个事件
    ->     comment '每隔5秒清除2年前的日志，并产生一条新的记录' -- 注释
    ->     do
    ->         begin
    ->             -- 清除2年前的日志
    ->             delete from login_log where create_time <= current_timestamp - interval 2 year ;
    ->             -- 插入1条日志
    ->             insert into login_log(login_type, create_time) values ('clean', current_timestamp);
    ->         end $$
Query OK, 0 rows affected (0.00 sec)

root@localhost : temp_work 10:49:47>delimiter ;

这个事件做了2个事情，
1、每隔5s删除2年前的日志。
2、每隔5s产生1条新的日志。

2、查看事件的状态

root@localhost : temp_work 10:53:47>select * from information_schema.EVENTS a where a.EVENT_NAME = 'clean_login_event'\G;
*************************** 1. row ***************************
       EVENT_CATALOG: def
        EVENT_SCHEMA: temp_work
          EVENT_NAME: clean_login_event
             DEFINER: root@localhost
           TIME_ZONE: SYSTEM
          EVENT_BODY: SQL
    EVENT_DEFINITION: begin

            delete from login_log where create_time <= current_timestamp - interval 2 year ;

            insert into login_log(login_type, create_time) values ('clean', current_timestamp);
        end
          EVENT_TYPE: RECURRING
          EXECUTE_AT: NULL
      INTERVAL_VALUE: 5
      INTERVAL_FIELD: SECOND
            SQL_MODE: ONLY_FULL_GROUP_BY,STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION
              STARTS: 2025-02-04 22:50:00
                ENDS: 2025-02-05 22:49:47
              STATUS: ENABLED
       ON_COMPLETION: PRESERVE
             CREATED: 2025-02-04 22:49:47
        LAST_ALTERED: 2025-02-04 22:49:47
       LAST_EXECUTED: 2025-02-04 22:53:45
       EVENT_COMMENT: 每隔5秒清除2年前的日志，并产生一条新的记录
          ORIGINATOR: 1
CHARACTER_SET_CLIENT: utf8mb4
COLLATION_CONNECTION: utf8mb4_0900_ai_ci
  DATABASE_COLLATION: utf8mb4_0900_ai_ci
1 row in set (0.00 sec)

ERROR:
No query specified

root@localhost : temp_work 10:53:48>

LAST_EXECUTED: 表示事件最后一次的执行事件。
STATUS: 表示事件的状态

3、查看login_log表，看表中的create_time是否是每隔5s产生1条记录

root@localhost : temp_work 10:55:23>select * from login_log limit 10;
+----+------------+---------------------+
| id | login_type | create_time         |
+----+------------+---------------------+
|  1 | clean      | 2025-02-04 22:50:00 |
|  2 | clean      | 2025-02-04 22:50:05 |
|  3 | clean      | 2025-02-04 22:50:10 |
|  4 | clean      | 2025-02-04 22:50:15 |
|  5 | clean      | 2025-02-04 22:50:20 |
|  6 | clean      | 2025-02-04 22:50:25 |
|  7 | clean      | 2025-02-04 22:50:30 |
|  8 | clean      | 2025-02-04 22:50:35 |
|  9 | clean      | 2025-02-04 22:50:40 |
| 10 | clean      | 2025-02-04 22:50:45 |
+----+------------+---------------------+
10 rows in set (0.00 sec)

root@localhost : temp_work 10:55:33>

从以上的执行结果可以看到，是每隔5s产生了1条记录，说明我们的事件调度成功了。

4、参考文档

1、https://dev.mysql.com/doc/refman/8.4/en/events-configuration.html
2、https://dev.mysql.com/doc/refman/8.4/en/create-event.html.
3、https://dev.mysql.com/doc/refman/8.4/en/events-privileges.html

查看全文

http://www.kler.cn/a/533456.html