MySQL中的事件调度基础学习教程(2)-木庄网络博客

1）简单SQL示例：

CREATE EVENT e_hourly
  ON SCHEDULE
   EVERY 1 HOUR
  COMMENT ‘Clears out sessions table each hour.'
  DO
   DELETE FROM site_activity.sessions;

2）复杂SQL示例：

delimiter |
CREATE EVENT e
  ON SCHEDULE
   EVERY 5 SECOND
  DO
   BEGIN
    DECLARE v INTEGER;
    DECLARE CONTINUE HANDLER FOR SQLEXCEPTION BEGIN END;
    SET v = 0;
    WHILE v < 5 DO
     INSERT INTO t1 VALUES (0);
     UPDATE t2 SET s1 = s1 + 1;
     SET v = v + 1;
    END WHILE;
  END |
delimiter ;

3）Do子句中SQL的限制

基本上Do中可以使用任何在存储程序(Stored Routine)中允许的SQL语句，而存储程序中有些限制，event还有些额外的限制。

Stored Routine中如下语句不允许：

LOCK TABLES/UNLOCK TABLES
LOAD DATA与LOAD TABLE

支持动态SQL(PREPARE, EXECUTE, DEAALOCATE PREPARE)！但是PREPARE本身有些语句不允许执行。

INSERT DELAYED不会生效
EVENT的限制：

如果Do子句中包含ALTER EVENT子句，虽然能够创建，但是运行时会出错。
不要在Do子句中使用SELECT或SHOW这样仅仅是查询的语句，因为其输出无法从外部获取到。可以使用SELECT … INTO 这样的形式将查询结果保存起来。

5.查看EVENT
有如下方式可以查看event的信息：

mysql.event
information_schema.events
show events
show create event

三、event schedule其他注意点
MySQL保存了事件创建时的sql_mode作为其运行时的sql_mode;
如果在一个调度区间内任务没有处理完成，新的调度依然会生成，这样就会出现同时又多个任务在运行的情况。如果要避免多个任务同时存在，可以使用GET_LOCK()函数或者行锁、表锁。

四、 Mysql事件实战
测试环境
创建一个用于测试的test表：

CREATE TABLE `test` (
 `id` int(11) NOT NULL AUTO_INCREMENT,
 `t1` datetime DEFAULT NULL,
 `id2` int(11) NOT NULL DEFAULT '0',
 PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=106 DEFAULT CHARSET=utf8

实战1
Ø 创建一个每隔3秒往test表中插入一条数据的事件，代码如下：

CREATE EVENT IF NOT EXISTS test ON SCHEDULE EVERY 3 SECOND
ON COMPLETION PRESERVE
DO INSERT INTO test(id,t1) VALUES('',NOW());

Ø 创建一个10分钟后清空test表数据的事件

CREATE EVENT IF NOT EXISTS test
ON SCHEDULE
AT CURRENT_TIMESTAMP + INTERVAL 1 MINUTE
DO TRUNCATE TABLE test.aaa;

Ø 创建一个在2012-08-23 00:00:00时刻清空test表数据的事件，代码如下：

CREATE EVENT IF NOT EXISTS test
ON SCHEDULE
AT TIMESTAMP '2012-08-23 00:00:00'
DO TRUNCATE TABLE test;

Ø 创建一个从2012年8月22日21点45分开始到10分钟后结束，运行每隔3秒往test表中插入一条数据的事件，代码如下：

CREATE EVENT IF NOT EXISTS test ON SCHEDULE EVERY 3 SECOND
STARTS '2012-08-22 21:49:00' 
ENDS '2012-08-22 21:49:00'+ INTERVAL 10 MINUTE
ON COMPLETION PRESERVE
DO INSERT INTO test(id,t1) VALUES('',NOW());

实战2
通常的应用场景是通过事件来定期的调用存储过程，下面是一个简单的示例：
创建一个让test表的id2字段每行加基数2的存储过程，存储过程代码如下：

DROP PROCEDURE IF EXISTS test_add;
DELIMITER //
CREATE PROCEDURE test_add()
BEGIN
DECLARE 1_id INT DEFAULT 1;
DECLARE 1_id2 INT DEFAULT 0;
DECLARE error_status INT DEFAULT 0;
DECLARE datas CURSOR FOR SELECT id FROM test;
DECLARE CONTINUE HANDLER FOR NOT FOUND SET error_status=1;
OPEN datas;
FETCH datas INTO 1_id;
REPEAT
SET 1_id2=1_id2+2;
UPDATE test SET id2=1_id2 WHERE id=1_id;
FETCH datas INTO 1_id;
UNTIL error_status
END REPEAT;
CLOSE datas;
END
//

事件设置2012-08-22 00:00:00时刻开始运行，每隔1调用一次存储过程，40天后结束，代码如下：

CREATE EVENT test ON SCHEDULE EVERY 1 DAY
STARTS '2012-08-22 00:00:00'
ENDS '2012-08-22 00:00:00'+INTERVAL 40 DAY
ON COMPLETION PRESERVE DO
CALL test_add();

更多相关Mysql内容来自木庄网络博客

标签：Mysql

返回前面的内容