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

1、需求

假设我们有一个需求,每隔5s,清除表login_log2年前的记录,并插入一条当前清理的记录,那么这个该如何实现呢?

实现这个需求的方式有很多种,此处我们通过数据库的 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>
MySQL 事件调度器(Event Scheduler)的使用
通过命令手动开启关闭

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

[mysqld]
event_scheduler = ON

MySQL 事件调度器(Event Scheduler)的使用Event Scheduler的配置https://dev.mysql.com/doc/refman/8.4/en/events-configuration.html

3、创建Event的语法

CREATE
    [DEFINER = user]
    EVENT
    [IFNOTEXISTS]
    event_name
    ON SCHEDULE schedule
    [ON COMPLETION [NOTPRESERVE]
    [ENABLE | DISABLE | DISABLEON {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}

部分语法解释:

  1. 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周后停止执行。
2. on completion preserve 表示如果事件过期了,则会保留,如果加上[NOT] 则不保留。
3. 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权限。

MySQL 事件调度器(Event Scheduler)的使用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>createeventifnotexists clean_login_event -- 事件的名称,不可重复
    ->     on schedule
    ->     every 5second-- 事件的调度周期
    ->     starts '2025-02-04 22:50:00'-- 事件的开始事件
    ->     ends current_timestamp + interval1day-- 事件的结束事件
    ->     on completion preserve-- 表示事件过期了,进行保留
    ->     enable-- 启用这个事件
    ->     comment'每隔5秒清除2年前的日志,并产生一条新的记录'-- 注释
    ->     do
    ->         begin
    ->             -- 清除2年前的日志
    ->             deletefrom login_log where create_time <= current_timestamp - interval2year ;
    ->             -- 插入1条日志
    ->             insertinto login_log(login_type, create_time) values ('clean'current_timestamp);
    ->         end $$
Query OK, 0rows 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

            deletefrom login_log where create_time <= current_timestamp - interval2year ;

            insertinto 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-0422:50:00
                ENDS: 2025-02-0522:49:47
              STATUS: ENABLED
       ON_COMPLETION: PRESERVE
             CREATED: 2025-02-0422:49:47
        LAST_ALTERED: 2025-02-0422:49:47
       LAST_EXECUTED: 2025-02-0422:53:45
       EVENT_COMMENT: 每隔5秒清除2年前的日志,并产生一条新的记录
          ORIGINATOR: 1
CHARACTER_SET_CLIENT: utf8mb4
COLLATION_CONNECTION: utf8mb4_0900_ai_ci
  DATABASE_COLLATION: utf8mb4_0900_ai_ci
1rowinset (0.00 sec)

ERROR:
Noquery 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 limit10;
+----+------------+---------------------+
| 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


原文始发于微信公众号(huan1993的编程coding):MySQL 事件调度器(Event Scheduler)的使用

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

文章由极客之音整理,本文链接:https://www.bmabk.com/index.php/post/309890.html

(0)
小半的头像小半

相关推荐

发表回复

登录后才能评论
极客之音——专业性很强的中文编程技术网站,欢迎收藏到浏览器,订阅我们!