网站策划论坛,搜索引擎优化工具有哪些,信息管理网站开发的视频教程,网站开发公司业务员培训文章目录 概念常见操作事件调度器操作查看事件创建事件删除事件启动与关闭事件 精选示例构造实时数据定时统计数据 总结参考资料 概念
Mysql 事件是一种在特定时间点自动执行的数据库操作#xff0c;也可以称呼为定时任务#xff0c;它可以自动执行更新数据、插入数据、删除… 文章目录 概念常见操作事件调度器操作查看事件创建事件删除事件启动与关闭事件 精选示例构造实时数据定时统计数据 总结参考资料 概念
Mysql 事件是一种在特定时间点自动执行的数据库操作也可以称呼为定时任务它可以自动执行更新数据、插入数据、删除数据等操作无需人工干预。
优势
自动化可以定期执行重复性的任务无需手动干预。灵活性可以根据需求定制事件灵活控制任务的执行时间和频率。提高效率可以在非高峰时段执行耗时任务减少对数据库性能的影响。 常见的应用场景有定时备份数据库清理和统计数据。 常见操作
事件调度器操作
查看事件调度器是否开启ON 表示已开启。
show variables like %event_scheduler%;
------------------------
| Variable_name | Value |
------------------------
| event_scheduler | ON |
------------------------开启和关闭事件调度器
# 开启事件调度器
set global event_scheduler ON;
# 关闭事件调度器
set global event_scheduler OFF;更改配置文件进入 my.ini 文件修改重启 Mysql 服务器永久生效。
# 事件调度器启动状态
event_scheduler on查看事件
使用 show 或者 select 语句查看当前数据库中所有的事件。
show events;
select * from information_schema.events;创建事件
使用 create event 语句创建一个事件
基本语法
create[definer user]event[if not exists]event_nameon schedule schedule_body[on completion [not] preserve][enable | disable | disable on slave][comment comment]do event_body;definer可选用于定义事件执行时检查权限的用户。if not exists可选一般都加上用于判断要创建的事件是否存在。event_name定义指定的事件名是用来唯一标识事件的名称。在同一个数据库中事件名称必须是唯一的。on schedule schedule_bodyschedule_body 用于定义执行的时间和时间间隔。on completion [not] preserve可选指定事件是否循环执行默认为一次执行即 not preserve。enable | disable | disable on slave可选指定事件的一种属性enable 表示启动disable 表示关闭或者下线disable on slave 表示从属性上禁用默认启动comment ‘comment’可选添加事件的注释。do event_body必选event_body 用于指定事件启动时所要执行的代码可以是任何有效的sql 语句、存储过程或者一个计划执行的事件。如果包含多条语句可以使用 begin … end 复合结构。
schedule_body 语法
at timestamp [ interval interval] ...| every interval[starts timestamp [ interval interval] ...][ends timestamp [ interval interval] ...]at timestamp用于一次性活动指定事件仅在 timestamp 给出的日期和时间执行一次时间戳必须同时包含日期和时间或者必须是解析为日期时间值的表达式如果日期已过则会出现警告。
# 相当于“三周两天后”。此类子句的每个部分必须以 interval。
at current_timestamp interval 3 week interval 2 dayinterval 语法
interval:quantity {year | quarter | month | day | hour | minute |week | second | year_month | day_hour | day_minute |day_second | hour_minute | hour_second | minute_second}every interval每隔一段时间执行事件指定时间区间内每隔多长时间发生一次interval 其值由一个数值和单位(quantity)组成如 4 week 表示 4 周’1:10’ HOUR_MINUTE 表示1小时10分钟。starts timestamp指定事件的开始时间timestamp 为时间戳日期时间值表达式。ends timestamp指定事件的结束时间timestamp 为时间戳日期时间值表达式。
常见时间调度
# 每30分钟执行一次
on schedule every 30 minute
# 从 2024-01-03 18:00:00 开始每1小时执行一次
on schedule every 1 hourstarts 2024-01-03 18:00:00
# 从现在起30分钟后开始四周后结束这段期间内每12小时执行一次
on schedule every 12 hour starts current_timestamp interval 30 minute ends current_timestamp interval 4 week删除事件
使用 drop event 语句删除该事件。
drop event [if exists] event_name;启动与关闭事件
使用 alter event 语句对事件进行修改。
# 启动事件
alter event event_name enable;
# 关闭事件
alter event event_name disable;精选示例
构造实时数据
需求每分钟录入关于产品、省份的订单销售数据。
# 表新建
drop table if exists sql_test1.face_sales_data;
create table if not exists sql_test1.face_sales_data
(sales_date date comment 销售日期,order_code varchar(255) comment 订单编码,user_code varchar(255) comment 客户编号,product_name varchar(255) comment 产品名称,sales_province varchar(255) comment 销售省份,sales_number int comment 销量,create_time datetime default current_timestamp comment 创建时间,update_time datetime default current_timestamp on update current_timestamp comment 更新时间
);
# 创建事件任务多条语句用 begin ... end; 包住。
drop event if exists face_sales_data_task1;
create event if not exists face_sales_data_task1
on schedule every 1 minute
starts 2024-01-03 21:17:00
on completion preserve enable
do
beginset user_code floor(rand()*900000000 100000000);-- 随机生成用户编码set order_code md5(floor(rand()*900000000 100000000));-- 根据随机用户编码加密成编码set product_name ELT(CEILING(RAND() * 8) ,iPhone 15,iPhone 15 Pro,iPhone 15 Pro Max,Xiaomi 14,Xiaomi 14 Pro,Huawei Mate 60,Huawei Mate 60 Pro,Huawei Mate 60 Pro);-- 随机从中选择产品set sales_province ELT(CEILING(RAND() * 34) ,河北省,山西省,辽宁省,吉林省,黑龙江省,江苏省,浙江省,安徽省,福建省,江西省,山东省,河南省,湖北省,湖南省,广东省,海南省,四川省,贵州省,云南省,陕西省,甘肃省,青海省,台湾省,内蒙古自治区,广西壮族自治区,西藏自治区,宁夏回族自治区,新疆维吾尔自治区,北京市,上海市,天津市,重庆市,香港特别行政区,澳门特别行政区);set sales_number floor(rand()*1000);-- 随机生成销量select user_code,order_code,product_name,sales_province,sales_number;-- 查看生成的数据insert into sql_test1.face_sales_data(sales_date, order_code, user_code, product_name, sales_province, sales_number)values (curdate(),order_code,user_code,product_name,sales_province,sales_number);-- 数据录入
end;
select * from sql_test1.face_sales_data;通过创建事件后过一段时间再一次查看表可以发现每条记录 create_time 相差1说明任务调度设置成功这样就可以自动模拟实时销售数据啦。
如果要停止录入可以执行以下代码关闭事件。
alter event face_sales_data_task1 disable;定时统计数据
除了能模拟实时数据操作数据表外也可以执行存储过程统计数据。
drop event if exists get_table_info1_task1;
create event if not exists get_table_info1_task1on schedule every 10 minute starts current_timestamp ends current_timestamp interval 1 weekon completion preserve enabledo call get_table_info1();
# 下线
alter event get_table_info1_task1 disable;该存储过程来自上一文章Mysql 游标的定义和使用在这里我们直接引用他来创建定时任务。
总结
创建事件或定时任务可以解决很多重复性工作配合着动态 sql 和存储过程能起到实时更新数据功能不需要人工干预提高了工作效率让我们有更多的时间学习和处理其它问题。
参考资料
MySQL官方文档MySQL Tutorial 官方文档Mysql 动态SQLMysql 存储过程实现动态数据透视Mysql 游标的定义和使用
