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

时间:2022-12-07 23:30:35

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创建存储过程

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

 

4.2创建事件

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

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

小例子:

//创建存储过程
DELIMITER $$
CREATE PROCEDURE bofangliang ()
BEGIN
UPDATE cou_sell_way_tbl SET SHOWBROWSE_NUM=SHOWBROWSE_NUM+50 WHERE SHOWBROWSE_NUM<=2000;
END
$$
DELIMITER ;


//创建事件并设置启动时间及循环时间
CREATE DEFINER=`root`@`localhost` EVENT `bofangliang_sche_event`
ON SCHEDULE EVERY 1 DAY STARTS '2017-02-23 10:17:00'
ON COMPLETION NOT PRESERVE ENABLE
DO CALL bofangliang();

//开启所有事件
set GLOBAL event_scheduler = 1;
//关闭事件
ALTER EVENT bofangliang_sche_event DISABLE;
//开启事件
ALTER EVENT bofangliang_sche_event ENABLE;

//查询当前所有事件状态
select * from mysql.event;

alter table cou_sell_way_tbl add SHOWBROWSE_NUM int(11);