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 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_loglogin_type create_time values clean current_timestamp end event_type: recurring execute_at: null interval_value: 5 interval_field: second sql_mode: starts: 2025-02-04 22:50:00 ends: 2025-02-05 22:49:47 status: enabled 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: 52 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 rootlocalhost : 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