如何在 MYSQL 中编写可以从触发器和存储函数调用的信号函数？

Posted 2023-02-25

【中文标题】如何在 MYSQL 中编写可以从触发器和存储函数调用的信号函数？

【英文标题】：How to write signal function in MYSQL that can be call from Triggers and Stored functions?

【发布时间】：2012-11-12 16:09:19

【问题描述】：

在我的数据库中，我有一个 表：Employee 具有递归关联，员工可以是其他员工的老板。

表格说明：

mysql> DESC Employee;
+-------------+--------------+------+-----+---------+-------+
| Field       | Type         | Null | Key | Default | Extra |
+-------------+--------------+------+-----+---------+-------+
| SSN         | varchar(64)  | NO   | PRI | NULL    |       |
| name        | varchar(64)  | YES  |     | NULL    |       |
| designation | varchar(128) | NO   |     | NULL    |       |
| MSSN        | varchar(64)  | NO   | MUL | NULL    |       |
+-------------+--------------+------+-----+---------+-------+

员工表的当前状态是：

mysql> SELECT * FROM Employee;
    +-----+------+-------------+------+
    | SSN | name | designation | MSSN |
    +-----+------+-------------+------+
    | 1   | A    | OWNER       | 1    |
    | 2   | B    | BOSS        | 1    |  
    | 3   | C    | WORKER      | 2    |  
    | 4   | D    | BOSS        | 2    |  
    | 5   | E    | WORKER      | 4    |   
    | 6   | F    | WORKER      | 1    |  
    | 7   | G    | WORKER      | 4    |  
    +-----+------+-------------+------+
    7 rows in set (0.00 sec)

以下是表中各行的层次关系：

     A
    / \
   B   F
  / \
 c   D
    / \
   G   E

我想对 INSERT 施加以下约束：

员工不能成为自己的 BOSS。这仅适用于 OWNER。因此像这样查询。INSERT INTO Employee VALUES ("8", "H", "BOSS", "8"); 应该拒绝。 可以插入新的OWNER。

因为我正在使用 5.5 之前的 MYSQL 版本（不支持信号）。 所以我使用了一个 my_singal() 存储过程。

这样写：

CREATE PROCEDURE `my_signal`(in_errortext VARCHAR(255))
BEGIN
    SET @sql=CONCAT('UPDATE `', in_errortext, '` SET x=1');
    PREPARE my_signal_stmt FROM @sql;
    EXECUTE my_signal_stmt;
    DEALLOCATE PREPARE my_signal_stmt;
END// 

并且应用约束我知道written a Trigger check constraints are not yet implemented in MySQL！

DELIMITER $$
CREATE
  TRIGGER `employee_before_insert` BEFORE INSERT
    ON `Employee`
    FOR EACH ROW BEGIN
      CASE
       WHEN NEW.designation = 'OWNER'  THEN
          CALL my_signal('Error: can not insert new OWNER !');

       WHEN NEW.SSN = NEW.MSSN THEN
          CALL my_signal('Error: Row can not reference itself!');
      END CASE; 
  END$$   
DELIMITER ;  

它已成功编译并加载到数据库中。但是当我尝试插入时：

mysql> INSERT INTO Employee VALUES ("12", "K", "BOSS",   "12");
ERROR 1336 (0A000): Dynamic SQL is not allowed in stored function or trigger

我了解到 here 和 here

SQL 准备语句（PREPARE、EXECUTE、DEALLOCATE PREPARE）可用于存储过程，但不能用于存储函数或触发器。因此，存储函数和触发器不能使用

Dynamic SQL

（您将语句构造为字符串然后执行它们）。

经过一番努力，我可以编写另一个触发器，如下所示。 工作正常按照我的要求。

mysql> CREATE
    -> TRIGGER `employee_before_insert` BEFORE INSERT
    ->     ON `Employee`
    ->     FOR EACH ROW BEGIN
    ->      IF UCASE(NEW.designation) = 'OWNER'  THEN  /*UCASE*/
    ->        UPDATE `Error: can not insert new OWNER !` set x=1; 
    ->      END IF;
    ->      IF (NEW.SSN = NEW.MSSN) THEN
    ->        UPDATE `Error: Row can not reference itself!` set x=1;
    ->      END IF;
    -> END$$
Query OK, 0 rows affected (0.08 sec)

mysql> DELIMITER ;
mysql> INSERT INTO Employee VALUES ("12", "K", 'owner',   "11");
ERROR 1146 (42S02): Table 'dumy.Error: can not insert new OWNER !'
  doesn't exist
mysql> INSERT INTO Employee VALUES ("12", "K", 'Ajay',   "12");
ERROR 1146 (42S02): Table 'dumy.Error: Row can not reference itself!' 
  doesn't exist

因为我已经在许多过程中使用my_signal()，我需要编写许多新的存储函数和触发器，我需要再次使用my_signal() 函数。

It would also good for easy manipulation if sometime MYSQL version upgraded to 5.5(+)。

有人可以建议我以其他方式编写 my_signal() 以打印自定义错误消息吗？

我尝试如下：

DELIMITER $$ CREATE PROCEDURE my_signal(in_errortext VARCHAR(255)) DECLARE sql varchar(512); BEGIN SET sql=CONCAT('UPDATE ', in_errortext, ' SET x=1'); UPDATE sql SET x =1; END$$

但没用:(。

请帮助我。我将非常感激！

我特别不擅长MYSQL @Stored Procedures。

如果您想在您的系统上尝试here you can quickly find commands 来构建此数据库。

编辑 ~ MySQL 解释器充当编译器！

我们不能从触发器和存储函数中调用 Dynamic SQL 语句。

为了在所有存储的例程中保持相同的接口 my_signal() 我修改了 my_signal();添加了带有Dynamic SQL 的Static SQL 语句，并确保它不会从触发器中执行。我认为应该允许because MySQL is an interpreter not a compiler。

新建 my_signal()

DELIMITER $$
CREATE PROCEDURE `my_signal`(in_errortext VARCHAR(255))
BEGIN

    IF in_errortext = 'ERROR_INSERT_OWNER' THEN  /* Static SQL*/
        UPDATE `Error: can not insert new OWNER !` set x=1; 
    END IF;

    IF in_errortext = 'ERROR_INSERT_SELF_REFERENCE' THEN /* Static SQL*/
        UPDATE `Error: Row can not reference itself!` set x=1;

    ELSE /* Dynamic SQL*/    
        SET @sql=CONCAT('UPDATE `', in_errortext, '` SET x=1');
        PREPARE my_signal_stmt FROM @sql;
        EXECUTE my_signal_stmt;
        DEALLOCATE PREPARE my_signal_stmt;
    END IF;
END$$  

新触发器

DELIMITER $$
CREATE
    TRIGGER `employee_before_insert` BEFORE INSERT
    ON `Employee`
    FOR EACH ROW BEGIN
        CASE
         WHEN UPPER(NEW.name) = 'OWNER'  THEN
            CALL my_signal('ERROR_INSERT_OWNER');

         WHEN NEW.SSN = NEW.MSSN THEN
            CALL my_signal('ERROR_INSERT_SELF_REFERENCE');
        END CASE; 
    END$$   
DELIMITER ;

希望我尝试插入：

mysql> INSERT INTO Employee VALUES ("9", "X", "WOKER", "9" );
ERROR 1336 (0A000): Dynamic SQL is not allowed in stored function or trigger
mysql> INSERT INTO Employee VALUES ("9", "X", "OWNER", "9" );
ERROR 1336 (0A000): Dynamic SQL is not allowed in stored function or trigger  

哎呀！它的行为类似于编译器，而不是解释器。不是吗？

编辑：回答

幸运的是，我在编辑问题时得到了RolandoMySQLDBA 的回答。 答案是HERE 最后：我可以理解我们不能在触发器中执行动态 SQL。 我可能不得不求助于对 my_signal() 进行编码。 MySQL 现在还没有其他选择。

【问题讨论】：

你能限制直接插入你的表吗？我的意思是你能强制前端/后端团队使用你的存储过程/函数来插入这个表吗？

Edited Question and added Answer 以便其他人可以得到帮助。

【参考方案1】：

不幸的是，在 MySQL 5.5 之前，从触发器中强制 ROLLBACK 的唯一方法是像您故意那样生成错误。

这会导致两个问题。

错误消息让开发人员非常困惑，因为您无法返回自定义错误消息 如果操作语句会导致“真正的”错误，在某些情况下您甚至可能会覆盖它 并使调试更加困难。

这是从开发人员的角度来看的——我与我们的 DBA 就这个问题进行了很多讨论。但即使是一个做得很好的数据库——尤其是在 MySQL 上构建的数据库——有时也必须依赖于应用程序。 :)

【讨论】：

是的，我知道这一点：Error messages are customised but error codes are not! 另外**Dynamic-SQL** makes Stored-routines tough to debug'. But I don't have other option; my MySQL 版本是旧的 (5.1). In that case this is the only way for interrupting 触发器我的意思是在 MySQL 5.1 中` ...我将处理检查如果开发人员犯了一些错误，在后端也只是为了保持表中的数据一致性状态......顺便说一句，感谢您回答我的帖子，为您的关注和关注投票！