1、前言
自 MySQL5.1.6起,增長了一個很是有特點的功能–事件調度器(Event Scheduler),能夠用作定時執行某些特定任務(例如:刪除記錄、對數據進行彙總等等),來取代原先只能由操做系統的計劃任務來執行的工做。更值得 一提的是MySQL的事件調度器能夠精確到每秒鐘執行一個任務,而操做系統的計劃任務(如:Linux下的CRON或Windows下的任務計劃)只能精 確到每分鐘執行一次。對於一些對數據實時性要求比較高的應用(例如:股票、賠率、比分等)就很是適合。
事件調度器有時也可稱爲臨時觸發器(temporal triggers),由於事件調度器是基於特定時間週期觸發來執行某些任務,而觸發器(Triggers)是基於某個表所產生的事件觸發的,區別也就在這裏。
在使用這個功能以前必須確保event_scheduler已開啓,可執行
SET GLOBAL event_scheduler = 1;
---或咱們能夠在配置my.cnf文件 中加上 event_scheduler = 1
或
SET GLOBAL event_scheduler = ON;
來開啓,也能夠直接在啓動命令加上「--event_scheduler=1」,例如:
mysqld ... --event_scheduler=1
要查看當前是否已開啓事件調度器,可執行以下SQL:
SHOW VARIABLES LIKE 'event_scheduler';
或
SELECT @@event_scheduler;
或
SHOW PROCESSLIST;
2、建立事件(CREATE EVENT)
先來看一下它的語法:
mysql
1 |
CREATE EVENT [IF NOT EXISTS] event_name |
3 |
[ ON COMPLETION [ NOT ] PRESERVE] |
schedule:
AT TIMESTAMP [+ INTERVAL INTERVAL]
| EVERY INTERVAL [STARTS TIMESTAMP] [ENDS TIMESTAMP]
INTERVAL:
quantity {YEAR | QUARTER | MONTH | DAY | HOUR | MINUTE |
WEEK | SECOND | YEAR_MONTH | DAY_HOUR | DAY_MINUTE |
DAY_SECOND | HOUR_MINUTE | HOUR_SECOND | MINUTE_SECOND}
1) 首先來看一個簡單的例子來演示每秒插入一條記錄到數據表
sql
2 |
CREATE TABLE aaa (timeline TIMESTAMP ); |
3 |
CREATE EVENT e_test_insert |
4 |
ON SCHEDULE EVERY 1 SECOND |
5 |
DO INSERT INTO test.aaa VALUES ( CURRENT_TIMESTAMP ); |
等待3秒鐘後,再執行查詢看看:
mysql> SELECT * FROM aaa;
+---------------------+
| timeline |
+---------------------+
| 2007-07-18 20:44:26 |
| 2007-07-18 20:44:27 |
| 2007-07-18 20:44:28 |
+---------------------+
2) 5天后清空test表:
測試
2 |
ON SCHEDULE AT CURRENT_TIMESTAMP + INTERVAL 5 DAY |
3 |
DO TRUNCATE TABLE test.aaa; |
3) 2007年7月20日12點整清空test表:
spa
2 |
ON SCHEDULE AT TIMESTAMP '2007-07-20 12:00:00' |
3 |
DO TRUNCATE TABLE test.aaa; |
4) 天天定時清空test表:
操作系統
3 |
DO TRUNCATE TABLE test.aaa; |
5) 5天后開啓天天定時清空test表:
.net
3 |
STARTS CURRENT_TIMESTAMP + INTERVAL 5 DAY |
4 |
DO TRUNCATE TABLE test.aaa; |
6) 天天定時清空test表,5天后中止執行:
code
3 |
ENDS CURRENT_TIMESTAMP + INTERVAL 5 DAY |
4 |
DO TRUNCATE TABLE test.aaa; |
7) 5天后開啓天天定時清空test表,一個月後中止執行:
orm
3 |
STARTS CURRENT_TIMESTAMP + INTERVAL 5 DAY |
4 |
ENDS CURRENT_TIMESTAMP + INTERVAL 1 MONTH |
5 |
DO TRUNCATE TABLE test.aaa; |
[ON COMPLETION [NOT] PRESERVE]能夠設置這個事件是執行一次仍是持久執行,默認爲NOT PRESERVE。
8) 天天定時清空test表(只執行一次,任務完成後就終止該事件):
blog
3 |
ON COMPLETION NOT PRESERVE |
4 |
DO TRUNCATE TABLE test.aaa; |
[ENABLE | DISABLE]但是設置該事件建立後狀態是否開啓或關閉,默認爲ENABLE。
[COMMENT ‘comment’]能夠給該事件加上註釋。
3、修改事件(ALTER EVENT)
事件
3 |
[RENAME TO new_event_name] |
4 |
[ ON COMPLETION [ NOT ] PRESERVE] |
1) 臨時關閉事件
ALTER EVENT e_test DISABLE;
2) 開啓事件
ALTER EVENT e_test ENABLE;
3) 將天天清空test表改成5天清空一次:
ALTER EVENT e_test
ON SCHEDULE EVERY 5 DAY;
4、刪除事件(DROP EVENT)
語法很簡單,以下所示:
DROP EVENT [IF EXISTS] event_name
例如刪除前面建立的e_test事件
DROP EVENT e_test;
固然前提是這個事件存在,不然會產生ERROR 1513 (HY000): Unknown event錯誤,所以最好加上IF EXISTS
DROP EVENT IF EXISTS e_test;
注意:若是你將event執行了Alter event event_name disable.那麼當你從新啓動mysql服務
器後,該event將被刪除(測試版本:5.1.30)
應用案例
本案例是利用 event scheduler 的特性,每秒鐘調用一次存儲過程,用於判斷 SLAVE 是否正常運行,若是發現 SLAVE 關閉了,忽略 0 次錯誤,而後從新啓動 SLAVE。
* 首先建立存儲過程
02 |
create procedure `Slave_Monitor`() |
04 |
SELECT VARIABLE_VALUE INTO @SLAVE_STATUS |
05 |
FROM information_schema.GLOBAL_STATUS |
06 |
WHERE VARIABLE_NAME= 'SLAVE_RUNNING' ; |
07 |
IF ( 'ON' != @SLAVE_STATUS) THEN |
08 |
SET GLOBAL SQL_SLAVE_SKIP_COUNTER=0; |
因爲存儲過程當中沒法調用相似 SHOW SLAVE STATUS 這樣的語句,所以沒法獲得確切的複製錯誤信息和錯誤代碼,不能進一步的處理 SLAVE 中止的各類狀況。
* 接着,建立任務
1 |
CREATE EVENT IF NOT EXISTS `Slave_Monitor` |
2 |
ON SCHEDULE EVERY 5 SECOND |
建立了一個任務,每 5秒鐘執行一次,任務結束後依舊保留該任務,而不是刪除。固然了,在本例中的任務不會結束,除非將它手動禁止了。
*
若是在運行中想要臨時關閉一下某個任務,執行 ALTER EVENT 語句便可:
(root:localhost:)test> alter event `Slave_Monitor` ON
COMPLETION PRESERVE DISABLE;
(root:localhost:)test> alter event `Slave_Monitor` ON
COMPLETION PRESERVE ENABLE;
若是要每30秒執行如下語句:
- update userinfo set endtime = now() WHERE id = '110';
能夠給mysql建個定時任務,具體方法以下:
- delimiter // /* 設定語句終結符爲 //,因存儲過程語句用;結束 */
1、查看event是否開啓
- show variables like '%sche%';
開啓event_scheduler
- set global event_scheduler =1;
2、建立存儲過程test
- CREATE PROCEDURE test ()
- BEGIN
- update userinfo set endtime = now() where id = '110';
- END;
3、建立event e_test
- create event if not exists e_test
- on schedule every 30 second
- on completion preserve
- do call test();
每隔30秒將執行存儲過程test
關閉事件任務
- alter event e_test ON COMPLETION PRESERVE DISABLE;
開戶事件任務
- alter event e_test ON COMPLETION PRESERVE ENABLE;