背景
由于项目需要, 每个月的历史存量数据需要进行一个归档和备份操作, 以及一些日志表需要进行一个明细字段清除, 让 MySQL 数据库磁盘节省空间. 则需要一些定时任务来定时清理这些数据.
技术选型
Java 可以基于 Quartz/Timer 来使用定时任务机制来编写定时任务, 需要依赖于 Java 程序
基于 Linux 下 Crontab 来基于 cron 表达式构建定时任务文档必定需要编写对应的脚本, 但是在这个脚本中, 由于需要操作数据库, 必定会涉及到明文密码这样的一个数据, 这样不是很安全.
由于使用到的是 MySQL 数据库, 而 MySQL 又支持定时任务, 所以可以使用 MySQL 自带定时任务.
具体操作
MySQL 配置
由于定时任务这个选项在 MySQL 的默认配置是关闭的, 所以保险起见, 我们先查询一下该选项是否打开
show variables like '%event_scheduler%';
如果显示的为 Off 选项, 有提供如下两种方式对其进行修改
1. 语句方式 (当前启动的实例有效, 重启后无效)
set global event_scheduler=1;
2. 配置 my.cnf(Windows 下是 my.INI) 下添加如下选项
- [mysqld]
- event_scheduler=ON
然后将其保存后重启 MySQL 即可
sql 编写
创建存储过程 (procedure)[可选: 如果只是简单 sql 可以直接在定时任务中指定]
存储过程: 存储过程, 又称存储程序 (英语: Stored Procedure), 是在数据库存储复杂程序, 以便外部程序调用的数据库对象, 可以视为数据库的一种函数或子程序.
具体学习地址: 点我
create PROCEDURE sched_clean() -- 命名
BEGIN
-- 定义参数
- DECLARE begin_time BIGINT DEFAULT UNIX_TIMESTAMP(DATE_SUB(CURRENT_DATE(),interval 31 DAY))*1000;
- DECLARE end_time BIGINT DEFAULT UNIX_TIMESTAMP(DATE_SUB(CURRENT_DATE(),interval 30 DAY))*1000;
-- 更新数据
- UPDATE test_table SET rule_cost=null WHERE start_time>begin_time and start_time<end_time;
- END
创建定时任务
当创建好了存储过程后, 我们就可以定时调用该存储过程了
- CREATE EVENT `demo`.`day_of_clean_event`
- ON SCHEDULE EVERY '1' DAY STARTS DATE_ADD(DATE_ADD(CURDATE(), INTERVAL 1 DAY), INTERVAL 1 HOUR)
- ON completion preserve disable
- DO call sched_clean();
代码说明:
CREATE EVENT demo.day_of_clean_event
在 demo 数据库中创建一个名为 day_of_clean_event 事件
表示创建时间定时周期, 以及开始时间, 该处表示从明天 1 点从开始, 每天执行一次该任务
第三行表示创建后并不开始生效
第四行表示需要执行的任务 (这里你也可以直接编写 sql 语句)
相关查询
查询本机的所有事件
SELECT event_name,event_definition,interval_value,interval_field,status FROM information_schema.EVENTS;
开启 / 关闭已经创建好的事件
- alter event event_name on completion preserve enable;// 开启定时任务
- alter event event_name on completion preserve disable;// 关闭定时任务
值得注意的地方
如果你的全局参数没有配置开启定时任务, 则会导致你虽然执行了开启已经创建好的事件, 但是你在
information_schema.EVENTS
表中还是查询不到记录
常见的周期定时规则
1 周期执行 - 关键字 EVERY
单位有: second, minute, hour, day, week(周), quarter(季度), month, year, 如:
- on schedule every 1 second // 每秒执行 1 次
- on schedule every 2 minute // 每两分钟执行 1 次
- on schedule every 3 day // 每 3 天执行 1 次
2 在具体某个时间执行 - 关键字 AT, 如:
- on schedule at current_timestamp()+interval 5 day // 5 天后执行
- on schedule at current_timestamp()+interval 10 minute // 10 分钟后执行
- on schedule at '2016-10-01 21:50:00' // 在 2016 年 10 月 1 日, 晚上 9 点 50 执行
3 在某个时间段执行 - 关键字 STARTS ENDS, 如:
- on schedule every 1 day starts current_timestamp()+interval 5 day ends current_timestamp()+interval 1 month // 5 天后开始每天都执行执行到下个月底
- on schedule every 1 day ends current_timestamp()+interval 5 day // 从现在起每天执行, 执行 5 天
来源: https://www.cnblogs.com/lonecloud/p/11044182.html