mysql创建定时执行存储过程任务

本文涉及的产品
云数据库 RDS MySQL Serverless,0.5-2RCU 50GB
简介:

sql语法很多,是一门完整语言。这里仅仅实现一个功能,不做深入研究。

目标:定时更新表或者清空表。

案例:曾经做过定时清空位置信息表的任务。(然而,当时并未考虑服务器挂掉后的情况)

本次测试:每5s更新表字段+1

1.prepare

创建一个表:

1
2
3
4
5
6
7
8
9
10
11
DROP  TABLE  IF EXISTS `test_sche`;
CREATE  TABLE  `test_sche` (
   `id`  int (11)  NOT  NULL ,
   `counts`  int (11)  DEFAULT  NULL ,
   PRIMARY  KEY  (`id`)
) ENGINE=InnoDB  DEFAULT  CHARSET=utf8;
 
-- ----------------------------
-- Records of test_sche
-- ----------------------------
INSERT  INTO  `test_sche`  VALUES  ( '1' '188' );

  

2.创建一个存储过程

1
2
3
4
5
6
CREATE  DEFINER=`root`@`localhost`  PROCEDURE  ` add `()
BEGIN
     #Routine body goes here...
 
UPDATE  test_sche  SET  counts=counts+1  WHERE  id=1;
END

注意,创建存储过程的时候,如果采用命令行的方式,需要先修改命令结束符,将分号改成其他的符号

1
2
3
4
5
6
7
8
9
10
-- 设置分隔符为 '$$' ,mysql默认的语句分隔符为 ';' ,这样在后续的 create 到 end 这段代码都会看成是一条语句来执行 
DELIMITER $$ 
 
//创建存储过程或者事件语句
 
 
//结束
$$
- 将语句分割符设置回  ';' 
DELIMITER ;

  

3.创建一个事件,并调用存储过程

1
2
3
4
CREATE  DEFINER=`root`@`localhost` EVENT `test_sche_event`
ON  SCHEDULE EVERY 5  SECOND  STARTS  '2016-07-12 22:11:50'
ON  COMPLETION  NOT  PRESERVE ENABLE
DO CALL ` add `

  

3.1开启定时器

1
set  GLOBAL  event_scheduler = 1; 

  

到这里,定时任务已经可以执行了,查询可以发现count字段一直在累加。如果想要查看事件运行情况:

 

3.2查看事件运行状态

1
select  from  mysql.event 

  

3.3开启或者关闭事件

1
2
3
4
ALTER  EVENT test_sche_event DISABLE;
 
 
ALTER  EVENT test_sche_event ENABLE;

  

4.懒人的做法

好久没去写sql,语法都快忘光了,然而借助工具还是很容易做出定时器的。这里采用Navicat for mysql:

 

4.1创建存储过程

 

4.2创建事件

 

本文转自Ryan.Miao博客园博客,原文链接:http://www.cnblogs.com/woshimrf/p/5665236.html,如需转载请自行联系原作者
相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境,其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
15天前
|
存储 SQL 关系型数据库
轻松入门MySQL:加速进销存!利用MySQL存储过程轻松优化每日销售统计(15)
轻松入门MySQL:加速进销存!利用MySQL存储过程轻松优化每日销售统计(15)
|
1月前
|
关系型数据库 MySQL API
Flink CDC产品常见问题之mysql整库同步到starrock时任务挂掉如何解决
Flink CDC(Change Data Capture)是一个基于Apache Flink的实时数据变更捕获库,用于实现数据库的实时同步和变更流的处理;在本汇总中,我们组织了关于Flink CDC产品在实践中用户经常提出的问题及其解答,目的是辅助用户更好地理解和应用这一技术,优化实时数据处理流程。
|
1月前
|
SQL DataWorks 关系型数据库
DataWorks常见问题之dataworks同步Rds任务失败如何解决
DataWorks是阿里云提供的一站式大数据开发与管理平台,支持数据集成、数据开发、数据治理等功能;在本汇总中,我们梳理了DataWorks产品在使用过程中经常遇到的问题及解答,以助用户在数据处理和分析工作中提高效率,降低难度。
|
1月前
|
监控 关系型数据库 MySQL
Flink CDC产品常见问题之flink-cdc任务抓取全量的mysql数据不生效如何解决
Flink CDC(Change Data Capture)是一个基于Apache Flink的实时数据变更捕获库,用于实现数据库的实时同步和变更流的处理;在本汇总中,我们组织了关于Flink CDC产品在实践中用户经常提出的问题及其解答,目的是辅助用户更好地理解和应用这一技术,优化实时数据处理流程。
|
1月前
|
存储 关系型数据库 MySQL
Mysql基础第二十六天,使用存储过程
Mysql基础第二十六天,使用存储过程
28 0
Mysql基础第二十六天,使用存储过程
|
1月前
|
存储 SQL 关系型数据库
【MySQL 数据库】9、存储过程
【MySQL 数据库】9、存储过程
202 0
|
26天前
|
Java 关系型数据库 MySQL
Flink1.18.1和CDC2.4.1 本地没问题 提交任务到服务器 报错java.lang.NoClassDefFoundError: Could not initialize class io.debezium.connector.mysql.MySqlConnectorConfig
【2月更文挑战第33天】Flink1.18.1和CDC2.4.1 本地没问题 提交任务到服务器 报错java.lang.NoClassDefFoundError: Could not initialize class io.debezium.connector.mysql.MySqlConnectorConfig
46 2
|
1月前
|
关系型数据库 MySQL API
Flink CDC产品常见问题之mysql整库同步到starrock时任务挂掉如何解决
Flink CDC产品常见问题之mysql整库同步到starrock时任务挂掉如何解决
|
2月前
|
关系型数据库 MySQL Linux
Linux环境下定时备份mysql数据库
Linux环境下定时备份mysql数据库
|
2月前
|
存储 SQL 关系型数据库
[MySQL]存储过程
[MySQL]存储过程
74 0
[MySQL]存储过程