[转]mysql创建定时任务
一、前言 自 MySQL5.1.6起,增加了一个非常有特色的功能–事件调度器(Event Scheduler),可以用做定时执行某些特定任务(例如:删除记录、对数据进行汇总等等),来取代原先只能由操作系统的计划任务来执行的工作。更值得 一提的是MySQL的事件调度器可以精确
一、前言
自 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;
二、创建事件(CREATE EVENT)
先来看一下它的语法:
1
|
CREATE ? EVENT [IF NOT ? EXISTS] event_name
|
2
|
? ON SCHEDULE schedule
|
3
|
[ ON COMPLETION [ NOT ] PRESERVE]
|
4
|
[ENABLE | DISABLE]
|
5
|
[COMMENT? 'comment' ]
|
6
|
DO sql_statement;
|
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) 首先来看一个简单的例子来演示每秒插入一条记录到数据表
1
|
USE test;
|
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表:
1
|
CREATE ? EVENT e_test
|
2
|
? ON SCHEDULE? AT ? CURRENT_TIMESTAMP ? + INTERVAL 5? DAY
|
3
|
DO? TRUNCATE TABLE ? test.aaa;
|
3) 2007年7月20日12点整清空test表:
1
|
CREATE ? EVENT e_test
|
2
|
? ON SCHEDULE? AT ? TIMESTAMP ? '2007-07-20 12:00:00'
|
3
|
DO? TRUNCATE TABLE ? test.aaa;
|
4) 每天定时清空test表:
1
|
CREATE ? EVENT e_test
|
2
|
? ON SCHEDULE EVERY 1? DAY
|
3
|
DO? TRUNCATE TABLE ? test.aaa;
|
5) 5天后开启每天定时清空test表:
1
|
CREATE ? EVENT e_test
|
2
|
? ON SCHEDULE EVERY 1? DAY
|
3
|
STARTS? CURRENT_TIMESTAMP + INTERVAL 5? DAY
|
4
|
DO? TRUNCATE TABLE ? test.aaa;
|
6) 每天定时清空test表,5天后停止执行:
1
|
CREATE ? EVENT e_test
|
2
|
? ON SCHEDULE EVERY 1? DAY
|
3
|
ENDS? CURRENT_TIMESTAMP + INTERVAL 5? DAY
|
4
|
DO? TRUNCATE TABLE ? test.aaa;
|
7) 5天后开启每天定时清空test表,一个月后停止执行:
1
|
CREATE ? EVENT e_test
|
2
|
? ON SCHEDULE EVERY 1? DAY
|
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表(只执行一次,任务完成后就终止该事件):
1
|
CREATE ? EVENT e_test
|
2
|
? ON SCHEDULE EVERY 1? DAY
|
3
|
? ON COMPLETION? NOT ? PRESERVE
|
4
|
DO? TRUNCATE TABLE ? test.aaa;
|
[ENABLE | DISABLE]可是设置该事件创建后状态是否开启或关闭,默认为ENABLE。
[COMMENT ‘comment’]可以给该事件加上注释。
三、修改事件(ALTER EVENT)
1
|
ALTER ? EVENT event_name
|
2
|
[ ON SCHEDULE schedule]
|
3
|
[RENAME? TO new_event_name]
|
4
|
[ ON COMPLETION [ NOT ] PRESERVE]
|
5
|
[COMMENT? 'comment' ]
|
6
|
[ENABLE | DISABLE]
|
7
|
[DO sql_statement]
|
1) 临时关闭事件
ALTER EVENT e_test DISABLE;
2) 开启事件
ALTER EVENT e_test ENABLE;
3) 将每天清空test表改为5天清空一次:
ALTER EVENT e_test
ON SCHEDULE EVERY 5 DAY;
四、删除事件(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。
* 首先创建存储过程
01
|
delimiter //
|
02
|
? create procedure ? `Slave_Monitor`()
|
03
|
? begin
|
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;
|
09
|
SLAVE START;
|
10
|
? END IF;
|
11
|
? end ; //
|
12
|
delimiter ;
|
由于存储过程中无法调用类似 SHOW SLAVE STATUS 这样的语句,因此无法得到确切的复制错误信息和错误代码,不能进一步的处理 SLAVE 停止的各种情况。
* 接着,创建任务
1
|
CREATE ? EVENT IF NOT ? EXISTS `Slave_Monitor`
|
2
|
? ON SCHEDULE EVERY 5? SECOND
|
3
|
? ON COMPLETION PRESERVE
|
4
|
DO
|
5
|
CALL Slave_Monitor();
|
创建了一个任务,每 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;
作者:zeo112140 发表于2013-8-13 13:55:52 原文链接
阅读:4 评论:0 查看评论
原文地址:[转]mysql创建定时任务, 感谢原作者分享。

Alat AI Hot

Undresser.AI Undress
Apl berkuasa AI untuk mencipta foto bogel yang realistik

AI Clothes Remover
Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

Undress AI Tool
Gambar buka pakaian secara percuma

Clothoff.io
Penyingkiran pakaian AI

AI Hentai Generator
Menjana ai hentai secara percuma.

Artikel Panas

Alat panas

Notepad++7.3.1
Editor kod yang mudah digunakan dan percuma

SublimeText3 versi Cina
Versi Cina, sangat mudah digunakan

Hantar Studio 13.0.1
Persekitaran pembangunan bersepadu PHP yang berkuasa

Dreamweaver CS6
Alat pembangunan web visual

SublimeText3 versi Mac
Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

Topik panas

Kemahiran pemprosesan struktur data besar: Pecahan: Pecahkan set data dan proseskannya dalam bahagian untuk mengurangkan penggunaan memori. Penjana: Hasilkan item data satu demi satu tanpa memuatkan keseluruhan set data, sesuai untuk set data tanpa had. Penstriman: Baca fail atau hasil pertanyaan baris demi baris, sesuai untuk fail besar atau data jauh. Storan luaran: Untuk set data yang sangat besar, simpan data dalam pangkalan data atau NoSQL.

Prestasi pertanyaan MySQL boleh dioptimumkan dengan membina indeks yang mengurangkan masa carian daripada kerumitan linear kepada kerumitan logaritma. Gunakan PreparedStatements untuk menghalang suntikan SQL dan meningkatkan prestasi pertanyaan. Hadkan hasil pertanyaan dan kurangkan jumlah data yang diproses oleh pelayan. Optimumkan pertanyaan penyertaan, termasuk menggunakan jenis gabungan yang sesuai, membuat indeks dan mempertimbangkan untuk menggunakan subkueri. Menganalisis pertanyaan untuk mengenal pasti kesesakan; gunakan caching untuk mengurangkan beban pangkalan data;

Membuat sandaran dan memulihkan pangkalan data MySQL dalam PHP boleh dicapai dengan mengikuti langkah berikut: Sandarkan pangkalan data: Gunakan arahan mysqldump untuk membuang pangkalan data ke dalam fail SQL. Pulihkan pangkalan data: Gunakan arahan mysql untuk memulihkan pangkalan data daripada fail SQL.

Bagaimana untuk memasukkan data ke dalam jadual MySQL? Sambung ke pangkalan data: Gunakan mysqli untuk mewujudkan sambungan ke pangkalan data. Sediakan pertanyaan SQL: Tulis pernyataan INSERT untuk menentukan lajur dan nilai yang akan dimasukkan. Laksanakan pertanyaan: Gunakan kaedah query() untuk melaksanakan pertanyaan sisipan Jika berjaya, mesej pengesahan akan dikeluarkan.

Salah satu perubahan utama yang diperkenalkan dalam MySQL 8.4 (keluaran LTS terkini pada 2024) ialah pemalam "Kata Laluan Asli MySQL" tidak lagi didayakan secara lalai. Selanjutnya, MySQL 9.0 mengalih keluar pemalam ini sepenuhnya. Perubahan ini mempengaruhi PHP dan apl lain

Untuk menggunakan prosedur tersimpan MySQL dalam PHP: Gunakan PDO atau sambungan MySQLi untuk menyambung ke pangkalan data MySQL. Sediakan penyata untuk memanggil prosedur tersimpan. Laksanakan prosedur tersimpan. Proses set keputusan (jika prosedur tersimpan mengembalikan hasil). Tutup sambungan pangkalan data.

Mencipta jadual MySQL menggunakan PHP memerlukan langkah berikut: Sambung ke pangkalan data. Buat pangkalan data jika ia tidak wujud. Pilih pangkalan data. Buat jadual. Laksanakan pertanyaan. Tutup sambungan.

Pangkalan data Oracle dan MySQL adalah kedua-dua pangkalan data berdasarkan model hubungan, tetapi Oracle lebih unggul dari segi keserasian, skalabiliti, jenis data dan keselamatan manakala MySQL memfokuskan pada kelajuan dan fleksibiliti dan lebih sesuai untuk set data bersaiz kecil. ① Oracle menyediakan pelbagai jenis data, ② menyediakan ciri keselamatan lanjutan, ③ sesuai untuk aplikasi peringkat perusahaan ① MySQL menyokong jenis data NoSQL, ② mempunyai langkah keselamatan yang lebih sedikit, dan ③ sesuai untuk aplikasi bersaiz kecil hingga sederhana.
