MySQL 事件调度器

简介

在本次实验中，你将学习如何使用 MySQL 事件调度器（Event Scheduler）来自动化任务。本实验将引导你完成以下步骤：启用事件调度器、创建一个定期更新表中数据的事件、检查事件的执行状态，最后删除该事件。

第一步是连接到 MySQL 服务器，并使用 SQL 命令启用事件调度器。在启用前后，你需要验证调度器的状态。随后，你将创建一个定期更新表的事件。接着，本实验将引导你检查事件的执行状态，最后，当不再需要该事件时，教你如何删除它。

Skills Graph

%%%%{init: {'theme':'neutral'}}%%%% flowchart RL mysql(("MySQL")) -.-> mysql/BasicKeywordsandStatementsGroup(["Basic Keywords and Statements"]) mysql(("MySQL")) -.-> mysql/SystemManagementToolsGroup(["System Management Tools"]) mysql/BasicKeywordsandStatementsGroup -.-> mysql/use_database("Database Selection") mysql/BasicKeywordsandStatementsGroup -.-> mysql/create_database("Database Creation") mysql/BasicKeywordsandStatementsGroup -.-> mysql/create_table("Table Creation") mysql/BasicKeywordsandStatementsGroup -.-> mysql/drop_table("Table Removal") mysql/BasicKeywordsandStatementsGroup -.-> mysql/select("Data Retrieval") mysql/BasicKeywordsandStatementsGroup -.-> mysql/insert("Data Insertion") mysql/BasicKeywordsandStatementsGroup -.-> mysql/update("Data Update") mysql/SystemManagementToolsGroup -.-> mysql/show_status("Status Overview") mysql/SystemManagementToolsGroup -.-> mysql/show_variables("Configuration Overview") subgraph Lab Skills mysql/use_database -.-> lab-550906{{"MySQL 事件调度器"}} mysql/create_database -.-> lab-550906{{"MySQL 事件调度器"}} mysql/create_table -.-> lab-550906{{"MySQL 事件调度器"}} mysql/drop_table -.-> lab-550906{{"MySQL 事件调度器"}} mysql/select -.-> lab-550906{{"MySQL 事件调度器"}} mysql/insert -.-> lab-550906{{"MySQL 事件调度器"}} mysql/update -.-> lab-550906{{"MySQL 事件调度器"}} mysql/show_status -.-> lab-550906{{"MySQL 事件调度器"}} mysql/show_variables -.-> lab-550906{{"MySQL 事件调度器"}} end

启用事件调度器

在这一步中，我们将在 MySQL 中启用事件调度器（Event Scheduler）。事件调度器是一个执行预定事件的后台线程。默认情况下，它是禁用的。我们需要启用它才能创建和运行事件。

首先，让我们使用 mysql 客户端连接到 MySQL 服务器。打开一个终端并执行以下命令：

mysql -u root -p

系统会提示你输入 root 用户的密码。输入你在安装 MySQL 时设置的密码。如果你没有设置密码，直接按回车键即可。

现在你已经连接到 MySQL 服务器，你可以检查事件调度器的当前状态。执行以下 SQL 查询：

SHOW GLOBAL VARIABLES LIKE 'event_scheduler';

你应该会看到类似以下的输出：

+------------------+-------+
| Variable_name    | Value |
+------------------+-------+
| event_scheduler  | OFF   |
+------------------+-------+
1 row in set (0.00 sec)

这证实了事件调度器目前处于禁用状态。

要启用事件调度器，请执行以下 SQL 查询：

SET GLOBAL event_scheduler = ON;

此命令会全局启用事件调度器。

现在，让我们验证事件调度器是否已启用。再次执行相同的 SHOW GLOBAL VARIABLES 查询：

SHOW GLOBAL VARIABLES LIKE 'event_scheduler';

你现在应该会看到类似以下的输出：

+------------------+-------+
| Variable_name    | Value |
+------------------+-------+
| event_scheduler  | ON    |
+------------------+-------+
1 row in set (0.00 sec)

这证实了事件调度器现在已启用。

最后，输入 exit 并按回车键退出 MySQL 客户端。

exit

你已成功在 MySQL 中启用了事件调度器。在下一步中，我们将创建一个定期更新数据的事件。

创建定期更新数据的事件

在这一步中，我们将创建一个 MySQL 事件，用于定期更新表中的数据。首先，我们需要创建一个数据库和一张表。然后，我们将创建一个事件，每分钟更新一次该表。

首先，让我们使用 mysql 客户端连接到 MySQL 服务器。打开一个终端并执行以下命令：

mysql -u root -p

当系统提示时，输入 root 用户的密码。

现在，让我们创建一个名为 test_db 的数据库：

CREATE DATABASE IF NOT EXISTS test_db;

接下来，切换到 test_db 数据库：

USE test_db;

现在，让我们创建一个名为 event_table 的表，该表包含两列：id（INT 类型，主键，自增）和 value（INT 类型）：

CREATE TABLE IF NOT EXISTS event_table (
    id INT AUTO_INCREMENT PRIMARY KEY,
    value INT
);

让我们向表中插入一个初始值：

INSERT INTO event_table (value) VALUES (0);

现在，让我们创建事件。该事件将每分钟更新 event_table 表中的 value 列。执行以下 SQL 语句：

CREATE EVENT IF NOT EXISTS update_event
ON SCHEDULE EVERY 1 MINUTE
DO
  UPDATE event_table SET value = value + 1;

此语句创建了一个名为 update_event 的事件。ON SCHEDULE EVERY 1 MINUTE 子句指定该事件应每分钟运行一次。DO 子句指定了事件运行时要执行的 SQL 语句，即把 value 列的值加 1。

要检查事件是否已创建，请执行以下 SQL 查询：

SHOW EVENTS FROM test_db;

你应该会看到类似以下的输出：

+----------+---------------+-------------+-----------+----------+---------------------+---------------------+-----------+------------+-------------------+----------------------+--------------------+--------------------+
| Db       | Name          | Definer     | Time zone | Type     | Execute at          | Interval_value      | Interval_field | Starts              | Ends               | Status             | Originator          | character_set_client | collation_connection | db_collation         |
+----------+---------------+-------------+-----------+----------+---------------------+---------------------+-----------+------------+-------------------+----------------------+--------------------+--------------------+
| test_db  | update_event  | root@%      | SYSTEM    | RECURRING | NULL                | 1                   | MINUTE       | 2024-10-27 14:30:00 | NULL              | ENABLED            | 1                    | utf8mb4              | utf8mb4_0900_ai_ci   | utf8mb4_0900_ai_ci   |
+----------+---------------+-------------+-----------+----------+---------------------+---------------------+-----------+------------+-------------------+----------------------+--------------------+--------------------+
1 row in set (0.00 sec)

这证实了事件已创建并已启用。

现在，退出 MySQL 客户端：

exit

现在，该事件将每分钟运行一次，更新 event_table 表中的 value 列。在下一步中，我们将检查该事件的执行状态。

检查事件执行状态

在这一步中，我们将检查上一步创建的事件的执行状态。我们会连接到 MySQL 服务器并查询 event_table 表，查看 value 列是否已更新。由于该事件每分钟运行一次，随着时间推移，你应该会看到该值不断增加。

首先，让我们使用 mysql 客户端连接到 MySQL 服务器：

mysql -u root -p

当系统提示时，输入 root 用户的密码。

接下来，切换到 test_db 数据库：

USE test_db;

现在，让我们查询 event_table 表，查看 value 列的当前值：

SELECT * FROM event_table;

你应该会看到类似以下的输出：

+----+-------+
| id | value |
+----+-------+
|  1 |     N |
+----+-------+
1 row in set (0.00 sec)

其中，N 是一个整数值。由于该事件每分钟运行一次，N 的值应该大于我们在上一步插入的初始值 0。如果你刚刚创建该事件，请等待一两分钟后再次运行查询。你应该会看到该值在不断增加。

为了进一步验证事件的执行情况，你可以查看 MySQL 错误日志，检查是否有与该事件相关的错误。不过，在这个实验中，如果 value 列正在更新，我们就假定该事件运行正常。

你可以多次运行 SELECT 查询，每次执行之间间隔一分钟，以观察 value 列的递增情况。这将证实该事件正在按预期运行。

最后，退出 MySQL 客户端：

exit

你已成功检查了事件的执行状态。在下一步中，我们将删除该事件。

删除事件

在这一步中，我们将删除之前步骤中创建的事件。删除事件会将其从 MySQL 服务器中移除，使其不再运行。

首先，让我们使用 mysql 客户端连接到 MySQL 服务器：

mysql -u root -p

当系统提示时，输入 root 用户的密码。

接下来，切换到 test_db 数据库：

USE test_db;

现在，让我们删除名为 update_event 的事件。执行以下 SQL 语句：

DROP EVENT IF EXISTS update_event;

此语句会在事件存在时将其删除。IF EXISTS 子句可避免在事件不存在时出现错误。

要验证事件是否已被删除，请执行以下 SQL 查询：

SHOW EVENTS FROM test_db;

你应该会看到一个空结果集，这表明 test_db 数据库中没有事件：

Empty set (0.00 sec)

或者，如果你在列表中看到 update_event，则意味着事件未成功删除。请检查你的 SQL 语法并再次尝试。

最后，退出 MySQL 客户端：

exit

你已成功删除事件。至此，本实验结束。你已经学会了如何启用事件调度器、创建定期更新数据的事件、检查事件执行状态以及删除事件。

总结

在本实验中，第一步重点是启用 MySQL 事件调度器（Event Scheduler），它是一个负责执行预定事件的后台线程。这包括使用 mysql 客户端连接到 MySQL 服务器，验证事件调度器的当前状态（初始状态为禁用），然后使用 SET GLOBAL event_scheduler = ON; 命令启用它。通过再次检查 event_scheduler 全局变量来确认是否成功启用。

接下来的步骤介绍了如何创建一个用于定期更新表的 MySQL 事件。这需要定义事件的调度计划以及它要执行的 SQL 语句。