欢迎回到我们的数据库事件系列!第 1 部分 概述了数据库事件和计划任务之间的区别,以及如何在 MySQL 中配置事件调度程序线程。在本文中,我们将探讨如何使用 CREATE EVENT 语法创建 MySQL 事件。
创建新的 MySQL 事件
创建事件类似于创建其他数据库对象,例如存储过程或函数。与这些对象一样,事件是包含 SQL 语句的命名数据库对象。这是基本语法:
CREATE EVENT [IF NOT EXIST] event_name ON SCHEDULE schedule DO event_body
有几点需要注意:
- 事件名在数据库模式中必须是唯一的。
- 如果事件主体中有多个 SQL 语句,则可以将它们包装在 BEGIN END 块中。
让我们创建一个实际的事件来使用上面的语法。我们将定义和安排一次性事件,将消息插入名为 messages 的表中。
首先,找到合适的测试数据库或创建一个新的测试数据库。然后使用 CREATE TABLE 语句创建一个名为“messages”的新表,如下所示:
CREATE TABLE IF NOT EXISTS messages ( id INT PRIMARY KEY AUTO_INCREMENT, message VARCHAR(255) NOT NULL, created_at DATETIME NOT NULL );
CREATE EVENT IF NOT EXISTS test_event ON SCHEDULE AT CURRENT_TIMESTAMP DO INSERT INTO messages(message,created_at) VALUES('Test MySQL Event 1',NOW());
在完成后保留事件
事件过期时会自动删除。像我们创建的一次性事件,它会在完成运行时过期。
我们可以在 MySQL 命令提示符发出以下语句来查看数据库模式的所有事件:
mysql> SHOW EVENTS FROM test; Empty set
若要使事件在过期后仍然保留,我们可以使用 ON COMPLETION PRESERVE 子句。这是创建另一个一次性事件的语句,该事件在创建后 30 秒运行,并且在运行后不会被删除:
CREATE EVENT test_event_2 ON SCHEDULE AT CURRENT_TIMESTAMP + INTERVAL 30 SECOND ON COMPLETION PRESERVE DO INSERT INTO messages(message,created_at) VALUES('Test MySQL Event 2',NOW());
等待至少 30 秒并检查 messages 表。这应添加了另一条记录:
让我们再次运行 SHOW EVENTS 语句。因为 ON COMPLETION PRESERVE 子句的效果,你可以看到事件在那里(虽然处于 DISABLED 状态):
mysql> SHOW EVENTS FROM test; +------+--------------+----------------+-----------+----------+---------------------+----------------+----------------+--------+------+----------+------------+----------------------+----------------------+--------------------+ | Db | Name | Definer | Time zone | Type | Execute at | Interval value | Interval field | Starts | Ends | Status | Originator | character_set_client | collation_connection | Database Collation | +------+--------------+----------------+-----------+----------+---------------------+----------------+----------------+--------+------+----------+------------+----------------------+----------------------+--------------------+ | test | test_event_2 | root@localhost | SYSTEM | ONE TIME | 2018-06-07 15:08:00 | NULL | NULL | NULL | NULL | DISABLED | 1 | utf8mb4 | utf8mb4_general_ci | utf8_general_ci | +------+--------------+----------------+-----------+----------+---------------------+----------------+----------------+--------+------+----------+------------+----------------------+----------------------+--------------------+ 1 row in set (0.02 sec)