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
[IFNOTEXISTS]
event_name
ON SCHEDULE schedule
[ON COMPLETION [NOT] PRESERVE]
[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}
部分语法解释:
-
on schedule
: 表示这个事件什么时候执行。>> at timestamp
: 表示的是一次性的事件,即只会执行一次。
|- at 2025-02-04 23:59:59
表示这个事件将会在2025-02-04 23:59:59这个时间点执行。
|- at timestamp + INTERVAL 2 HOUR
表示这个事件将会在创建之后的2个小时之后执行。 |- 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 co
mplet
ion preserve
表示如果事件过期了,则会保留,如果加上[NOT] 则不保留。event_body
可以是一条SQL语句,也可以是BEGIN ... END
包括的语句块。创建Event 语法 https://dev.mysql.com/doc/refman/8.4/en/create-event.html
4、创建或修改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>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