MySQL定时任务Event详解

文章目录

  • 基本概念
  • 一、Event事件使用权限
  • 二、开启\关闭Event事件
  • 三、Event事件定义格式
  • 四、事件调度使用案例
    • 4.1 准备工作
    • 4.2 创建单次定时执行事件
      • 4.2.1 创建指定时间单次执行事件任务
      • 4.2.2 创建延迟时间单次执行事件任务
      • 4.2.3 创建单次执行事件任务[多SQ执行]
    • 4.3 创建循环定时执行事件
      • 4.3.1 从当前开始每10秒执行一次事件
      • 4.3.2 指定某个时间开始,每隔1分钟执行一次
      • 4.3.3 从当前时间延迟指定时间,每隔5分钟执行一次
      • 4.3.3 每天执行一次,开始时间为明天凌晨1点整


基本概念

MySQL5.1开始,增加了一个十分有用的功能:事件调度器(event scheduler),该功能可以定时单次执行或者多次执行某些任务,比如日志数据的删除、数据统计报告、数据备份等。原来只能通过程序或者Crontab结合脚本做的事情,现在可以使用Event来做。并且MySQL提供的事件调度器可以精确到秒,而操作系统的计划任务比如Cron只能精确到分钟。


一、Event事件使用权限

用户需要要调用某个Event,需要查看用户是否拥有执行Event的权限。Event权限的设置保存在mysql.user表和mysql.db表中的event_priv字段。N表示没有执行权限,Y表示拥有执行Event的权限。如果您对MySQL的权限管理还不是很清楚,您可以参考文章:Mysql用户权限分配详解


二、开启\关闭Event事件

查询Event事件功能是否开启,ON则表示开启,OFF表示未开启。

SELECT @@event_scheduler; -- 方法一
SHOW VARIABLES LIKE '%event_scheduler%'; -- 方法二

在这里插入图片描述
关闭Event事件功能可以使用以下指令:

SET GLOBAL event_scheduler = 1; -- 方法一
SET GLOBAL event_scheduler = on; -- 方法二

开启Event事件功能可以使用以下指令:

SET GLOBAL event_scheduler = 0;
SET GLOBAL event_scheduler = off;

除了可以通过指令关闭和开启Event事件功能之外,还可以通过配置文件my.cnf配置是否开启Event功能,只需要在my.cnf中配置event_scheduler=1或者event_scheduler=0开控制是否开启。不配置则默认为关闭。

常用指定某个事件开启\关闭\查询\删除指令

开启指定事件:ALTER EVENT 具体事件名称 ON COMPLETION PRESERVE ENABLE;
关闭指定事件:ALTER EVENT 具体的事件名称 ON COMPLETION PRESERVE DISABLE;
查看事件:SHOW EVENTS; 或者 SELECT * FROM INFORMATION_SCHEMA.'EVENTS';
删除指定事件:DROP EVENT IF EXISTS 具体事件名称;

三、Event事件定义格式

以下是创建一个事件调度的大体结构格式,其中使用[]括号括起来的内容是可选项,可以填或者不填。

CREATE EVENT [IF NOT EXISTS] 事件名称
ON SCHEDULE 调度策略
[ON COMPLETION [NOT] PRESERVE]
[ENABLE | DISABLE | DISABLE ON SLAVE]
[COMMENT '备注内容']
DO sql_statement;

参数详细说明:

参数解释
IF NOT EXISTS这个是判断是否存在相同的Event名称,如果不存在才创建
调度策略调度策略是整个调度中最重要的,用于定义这个事件何时触发,是单次调度还是多次调度,具体使用方法将在后续案列中演示
ON COMPLETION PRESERVE是指当本次事件调度执行完成后,会保留该事件。如果您不配置,则默认是ON COMPLETION NOT PRESERVE ,表示执行完成后自动删除该事件。如果是周期性调度的话,需要配置成该类型
ON COMPLETION NOT PRESERVE本次调度执行完成后自动删除该事件
ENABLE \ DISABLE \ DISABLE ON SLAVE用于指定事件状态,ENABLE表示该事件是启动状态,DISABLE 表示未启动,DISABLE ON SLAVE表示对于从数据库则不启动该事件。如果不指定这三个选择中的任意一个,则在一个事件创建之后,它默认是ENABLE状态
SQL_STATEMENT用于指定事件启动时所要执行的代码。可以是任何有效的sql语句、存储过程或者一个计划执行的事件。如果包含多条语句,可以使用BEGIN…END复合结构

调度策略配置语法:
调度策略有两种方式,单次和周期性循环执行,单次执行的关键字AT,后面可以接指定的执行时间字符串,比如 AT TIMESTAMP '2024-3-20 10:14:00' 表示在2024年3月20号早上10点14分整执行一次任务。周期性执行的关键字EVERY,比如EVERY 10 SECOND则表示每隔10秒执行一次任务。时间单位除了SECOND,还有 YEAR、QUARTER、MONTH、DAY、HOUR、MINUTE、WEEK、SECOND、YEAR_MONTH、DAY_HOUR、DAY_MINUTE 、DAY_SECOND、HOUR_MINUTE、HOUR_SECOND等等。


四、事件调度使用案例

4.1 准备工作

在演示案例之前,我们先创建一个message表,用于查看演示效果。

CREATE TABLE message (
id bigint(255) NOT NULL AUTO_INCREMENT,
message varchar(255) COLLATE utf8mb4_bin DEFAULT NULL,
message_date datetime DEFAULT NULL,
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;

在创建好之后,开始编写带一个Event调度任务。


4.2 创建单次定时执行事件

首先先确保您已经开启事件功能!否则事件即使创建也不会执行!!!然后通过指令SHOW EVENTS; 查看当前是否存在任何定时任务。
在这里插入图片描述


4.2.1 创建指定时间单次执行事件任务

以下SQL语句表示创建一个单次执行事件,事件名称叫singleEvent,指定在时间2024-3-21 14:20:00往message表里插入一条数据。我的message表是放在template_backend库下,这里请修改为您message表具体的库名

CREATE EVENT singleEvent
ON SCHEDULE
AT TIMESTAMP '2024-3-21 14:20:00'
DO
INSERT INTO `template_backend`.`message` (`message`, `message_date`) values ('指定时间单次执行任务', now())

执行完以上SQL语句后,可以通过指令SHOW EVENTS;查看当前有效事件。可以查看我们刚刚定义的事件。
DB:表示用作与哪个库,Name是事件名称。
Definer:表示哪个用户权限执行。
TypeONE TIME表示只执行一次。
statusENABLE表示当前事件为可用状态。
在这里插入图片描述
等到时间到2024-3-21 14:20:00之后,再次通过指令
SHOW EVENTS;查看当前有效事件发现事件singleEvent
已经被删除,而message表中也插入了我们预期的数据。
在这里插入图片描述


4.2.2 创建延迟时间单次执行事件任务

以下SQL语句表示创建一个单次延迟执行事件,事件名称叫delaySingleEvent,延迟事件为从当前事件开始往后延迟一分钟执行,往message中插入一条数据。

CREATE EVENT delaySingleEvent
ON SCHEDULE 
AT CURRENT_TIMESTAMP + INTERVAL 1 MINUTE
DO 
INSERT INTO  `template_backend`.`message` (`message`, `message_date`) values ('单次延迟一分钟执行事件', now())

执行以上SQL,并通过SHOW EVENTS; 查看事件是否创建成功:
在这里插入图片描述
等待一分钟后,再通过SHOW EVENTS; 指令查看可以发现事件被删除,表message也插入预期的数据:
在这里插入图片描述


4.2.3 创建单次执行事件任务[多SQ执行]

以下SQL语句表示创建一个单次执行事件,只是一次性执行多个SQL语句。事件名称叫specifiedBatchTimeEvent,指定在时间2024-3-22 09:42:00往message表里插入三条数据

CREATE EVENT specifiedBatchTimeEvent
ON SCHEDULE
AT TIMESTAMP '2024-3-22 09:42:00'
ENABLE
DO BEGIN
-- 具体执行的SQL
INSERT INTO `template_backend`.`message` (`message`, `message_date`) values ('批量插入第一条数据', now());
INSERT INTO `template_backend`.`message` (`message`, `message_date`) values ('批量插入第二条数据', now());
INSERT INTO `template_backend`.`message` (`message`, `message_date`) values ('批量插入第三条数据', now());
END;

执行完以上SQL后通过SHOW EVENTS;可以查看事件是否创建成功,可以看到事件已经被创建并且状态为ENABLED,并计划在2024-03-22 09:42:00执行。
在这里插入图片描述
等到2024-03-22 09:42:00后,查看表message可以看到我们预期的插入数据:
在这里插入图片描述


4.3 创建循环定时执行事件

4.3.1 从当前开始每10秒执行一次事件

以下SQL用于创建一个循环事件,每个EVERY 10 SECOND表示该事件每个十秒钟就执行一次,执行的操作是往message表写数据。

CREATE EVENT loopEvent
ON SCHEDULE
EVERY 10 SECOND
ON COMPLETION PRESERVE -- 保存事件
DO
INSERT INTO `template_backend`.`message` (`message`, `message_date`) values ('每十秒执行任务', now())

执行以上SQL后,可以通过SHOW EVENTS;查看事件是否被创建成功。

Type: RECURRING表示该事件是一个循环事件
Interval value:表示调度周期
Interval field: 表示调度周期的单位
Starts:表示事件从哪个时间点开始执行

在这里插入图片描述
通过查看Message表可以看到我们预想的数据,每个十秒插入一次。
在这里插入图片描述
如果您想停止该事件运行,您可以使用指令ALTER EVENT 事件名称 DISABLE。比如停止以上事件可以使用指令:ALTER EVENT loopEvent DISABLE,如果你想删除某个事件,可以使用指令:DROP EVENT IF EXISTS 事件名称;


4.3.2 指定某个时间开始,每隔1分钟执行一次

CREATE EVENT DelayedSchedulingEvent
ON SCHEDULE
EVERY 1 MINUTE STARTS '2024-03-22 10:10:00'
ON COMPLETION PRESERVE
DO INSERT INTO `template_backend`.`message` (`message`, `message_date`) values ('指定时间2024-03-22 10:10:00后,每隔1分钟执行', now());

在这里插入图片描述


4.3.3 从当前时间延迟指定时间,每隔5分钟执行一次

以下SQL用于创建一个循环事件,每个EVERY 1 MINUTE表示该事件每一分钟就执行一次,CURRENT_TIMESTAMP + INTERVAL 5 MINUTE表示从当前时间开始延迟五分钟再执行。

CREATE EVENT DelayedSchedulingEvent
ON SCHEDULE
EVERY 1 MINUTE STARTS CURRENT_TIMESTAMP + INTERVAL 5 MINUTE
ON COMPLETION PRESERVE
DO INSERT INTO `template_backend`.`message` (`message`, `message_date`) values ('延迟5分钟后,每隔1分钟执行', now());

查看message表预期数据:
在这里插入图片描述


4.3.3 每天执行一次,开始时间为明天凌晨1点整

以下SQL用于创建一个循环事件,从第二天的凌晨一天开始,以后每天执行一次,删除message表中日志大于15天的日志。

DROP EVENT IF EXISTS DelayedSchedulingEvent;
CREATE EVENT logClearEvent
ON SCHEDULE
EVERY 1 DAY STARTS DATE_ADD(DATE_ADD(CURDATE(), INTERVAL 1 DAY), INTERVAL 1 HOUR)
ON COMPLETION PRESERVE -- 执行完成一次后保存该事件
ENABLE -- DISABLE ON SLAVE --只有在主从中才使用,否则使用该指令,会默认数据是SAVLE数据 禁止SLAVE使用
DO BEGIN
-- 执行的具体SQL
DELETE FROM DELETE FROM `template_backend`.`message`  WHERE message.message_date <NOW() - INTERVAL 15 DAY;
END;

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/282856.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

数据仓库的数据处理架构Lambda和Kappa

1.数据仓库 数据仓库(Data Warehouse),简写DW。顾名思义,数据仓库是一个很大的数据存储集合,为企业分析性报告和决策支持而创建,是对多元业务数据的筛选与整合,具备一定的BI能力,主要用于企业的数据分析、数据挖掘、数据报表等方向,指导业务流程改进、监视时间、成本、…

从0到1实现RPC | 03 重载方法和参数类型转换

一、存在的问题 1.重载方法在当前的实现中还不支持&#xff0c;调用了会报错。 2.类型转换也还存在问题。 假设定义的接口如下&#xff0c;参数是float类型。 在Provider端接受到的是一个Double类型&#xff0c;这是因为web应用接收的请求后处理的类型。 在反射调用的时候就会…

前言:为什么C语言最适合编程入门?

前言&#xff1a;为什么C语言最适合编程入门&#xff1f; C语言被认为最适合编程入门的原因主要有以下几点&#xff1a; 基础且强大&#xff1a;C语言是一种基础且强大的编程语言。它提供了对底层硬件的直接访问&#xff0c;让初学者能够更好地理解计算机的工作原理&#xff0…

从零开始学Spring Boot系列-集成Kafka

Kafka简介 Apache Kafka是一个开源的分布式流处理平台&#xff0c;由LinkedIn公司开发和维护&#xff0c;后来捐赠给了Apache软件基金会。Kafka主要用于构建实时数据管道和流应用。它类似于一个分布式、高吞吐量的发布-订阅消息系统&#xff0c;可以处理消费者网站的所有动作流…

基于python+vue的O2O生鲜食品订购flask-django-nodejs-php

近年来互联网络的迅猛发展和电子终端设备的普及&#xff0c;赋予了各行业充足的发展空间。微信小程序的O2O生鲜食品订购相比于传统信息技术&#xff0c;时效性是它最大的特色&#xff0c;已经在电子娱乐、经济等中发挥着举足轻重的作用。短时间内迅速扩大了线上管理系统的规模。…

了解云原生

1、云原生学习路线 学习云原生(Cloud Native)技术涉及了解和掌握一系列的概念、技术和工具。云原生是一种构建和运行应用程序的方法&#xff0c;旨在充分利用云计算的灵活性、可伸缩性和弹性。以下是一个可以参考的学习路线&#xff1a; 了解云原生基础 学习云计算的基本概念&…

此站点正在尝试打开 ,chrome/edge 允许http网站打开url schema

正常https链接会有首次允许选项 但http没有&#xff0c;每次都会弹出&#xff0c;非常烦人。 Chrome / Edge 配置 地址栏输入 chrome://flags/搜索Insecure origins treated as secure, 配置允许网站&#xff0c;需要协议和端口再次跳转会显示始终允许选项

puppeteer使用示例云顶之弈官网

自己从0到1开发的&#xff0c;微信小程序【云顶宝藏】求求点个5星好评吧&#xff01; 需求&#xff1a;拿到所有英雄的信息 思路&#xff1a;点击每个英雄&#xff0c;进入英雄详情页&#xff0c;拿信息&#xff0c;并返回&#xff0c;继续下一个英雄** 最终效果 本地环境 win…

docker进阶篇,docker集群介绍

docker swarm 官网&#xff1a;https://docs.docker.com/engine/swarm/how-swarm-mode-works/nodes/ 什么是 docker swarm docker swarm 是 docker 官方提供的容器编排和集群管理工具。它允许用户将多个 docker 主机组成一个虚拟的 docker 集群&#xff0c;以便更高效地管理…

云计算系统等保测评对象和指标选取

1、云计算服务模式与控制范围关系 参考GBT22239-2019《基本要求》附录D 云计算应用场景说明。简要理解下图&#xff0c;主要是云计算系统安全保护责任分担原则和云服务模式适用性原则&#xff0c;指导后续的测评对象和指标选取。 2、测评对象选择 测评对象 IaaS模式 PaaS模式…

文本处理(有关go web方面)

文本处理 3.21 本文基本摘录至https://learnku.com/docs/build-web-application-with-golang/073-regular-processing/3197&#xff0c;仅供学习&#xff0c;如果有需要学习web的同学可以看这个&#xff0c;不懂的再来看我的&#xff0c;我的仅作补充 文本处理是什么&#xf…

基于CSS3制作专属可自由旋转的立方体

一、代码区域 1.1 css3代码区域 <style>* {padding: 0;margin: 0;list-style: none;}/* 1) 定义动画 */keyframes loop {0% {transform: rotateX(348deg) rotateY(67deg) rotateZ(95deg);}50% {transform: rotateX(0deg) rotateY(0deg) rotateZ(0deg);}100% {transform:…

论文阅读-MIPD:一种用于分布式深度神经网络训练的自适应梯度稀疏化框架

摘要—基于参数服务器架构的异步训练广泛应用于大规模数据集和深度神经网络模型的扩展训练。在大规模分布式深度学习系统中&#xff0c;通信一直被认为是主要瓶颈。最近的研究尝试通过梯度稀疏化和量化方法来减少通信流量。我们发现前期研究存在三个限制。首先&#xff0c;他们…

基于python+vue网络相册设计与实现flask-django-nodejs-php

网络相册设计与实现的目的是让使用者可以更方便的将人、设备和场景更立体的连接在一起。能让用户以更科幻的方式使用产品&#xff0c;体验高科技时代带给人们的方便&#xff0c;同时也能让用户体会到与以往常规产品不同的体验风格。 与安卓&#xff0c;iOS相比较起来&#xff0…

蓝桥杯2021年第十三届省赛真题-卡片

一、题目 卡片 小蓝有很多数字卡片&#xff0c;每张卡片上都是数字 0 到 9。 小蓝准备用这些卡片来拼一些数&#xff0c;他想从 1 开始拼出正整数&#xff0c;每拼一个&#xff0c; 就保存起来&#xff0c;卡片就不能用来拼其它数了。 小蓝想知道自己能从 1 拼到多少。 例如&am…

Cookie和Session登录注册案例

文章目录 一、需求说明![在这里插入图片描述](https://img-blog.csdnimg.cn/direct/f29467ed6b7f4de7a568004ad50de591.png)二、用户登录1、Dao层代码2、Service层代码3、Web层代码 三、记住用户四、用户注册五、展示验证码 一、需求说明 二、用户登录 1、Dao层代码 UserMapp…

双指针(滑动窗口)-算法刷题

一.移动零 算法思想 &#xff1a; 设置两个指针left,right&#xff0c;将数组分为三块[0,left]为不为0的元素&#xff0c;[left1,right-1]为0元素&#xff0c;[right,num.size()-1]为未扫描的区域&#xff0c;判断right位置&#xff0c;不为0元素则与left1位置元素交换,left和r…

使用jupyter-Python进行模拟股票分析

tushare财经数据接口包 pip install tushare作用&#xff1a;提供相关指定的财经数据 需求&#xff1a;股票分析 使用tushare包获取某股票的历史行情数据 输出该股票所有收盘比开盘上涨3%以上的日期 输出该股票所有开盘比前日收盘跌幅超过2%的日期 假如我从2015年1月1日开…

人像抠图HumanSeg——基于大规模电话会议视频数据集的连接感知人像分割

前言 人像抠图将图像中的人物与背景进行像素级别的区分的技术。通过人像分割&#xff0c;可以实现诸如背景虚化、弹幕穿人等各种有趣的功能&#xff0c;为视频通话和影音观看提供更加优质和丰富的体验。由于广泛部署到Web、手机和边缘设备&#xff0c;肖像分割在兼顾分割精度的…

TinyEMU源码分析之虚拟机初始化

TinyEMU源码分析之虚拟机初始化 1 初始化结构参数2 配置RAM地址空间3 初始化设备4 拷贝BIOS和Kernel5 手动写入5条指令6 体验第一条指令的执行 本文属于《 TinyEMU模拟器基础系列教程》之一&#xff0c;欢迎查看其它文章。 本文中使用的代码&#xff0c;均为伪代码&#xff0c…