MySQL 存储过程中的错误处理

大家好，今天本人给大家带来文章《MySQL 存储过程中的错误处理》，文中内容主要涉及到MySQL、存储过程、错误提示，如果你对数据库方面的知识点感兴趣，那就请各位朋友继续看下去吧~希望能真正帮到你们，谢谢！

本文主要基于一篇 MySQL Tutorial的文章，同时补充了自己的几个实践。

概述

我们在执行普通的 MySQL SQL 语句的时候，都会在某些情况下遇到错误。比如，我们向一张表中插入一条已经存在的记录，导致了主键重复，会出现如下的错误：

上图中标记为红色的部分，就是 MySQL 返回的错误信息在

DECLARE action HANDLER FOR condition_value statement;

如果一个错误条件的值符合

DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET has_error = 1;

下面是另一个错误处理器，指出如果发生任何错误就回滚之前的操作，给出一条错误信息，并退出当前代码块的执行。如果你是在声明存储过程的

DECLARE EXIT HANDLER FOR SQLEXCEPTION
BEGIN
ROLLBACK;
SELECT 'An error has occurred, operation rollbacked and the stored procedure was terminated';
END;

下面的错误处理器指出，如果有发生数据行不存在的错误，其实就是指在使用游标（Cursor）或者

DECLARE CONTINUE HANDLER FOR NOT FOUND SET no_row_found = 1;

译者注：如果只是为了检查

DECLARE CONTINUE HANDLER FOR 1062
SELECT 'Error, duplicate key occurred';

存储过程中出错处理的示例

首先为了演示我们创建一张新表，表名是

CREATE TABLE article_tags(
    article_id INT,
    tag_id     INT,
    PRIMARY KEY(article_id,tag_id)
);

DELIMITER $$

CREATE PROCEDURE insert_article_tags(IN article_id INT, IN tag_id INT)
BEGIN

    DECLARE CONTINUE HANDLER FOR 1062
    SELECT CONCAT('duplicate keys (',article_id,',',tag_id,') found') AS msg;

    -- insert a new record into article_tags
    INSERT INTO article_tags(article_id,tag_id)
    VALUES(article_id,tag_id);

    -- return tag count for the article
    SELECT COUNT(*) FROM article_tags;
END $$

然后，通过下面的命令，我们给 Id=1 的 Article 新增 Id 为1，2，3 的 Tag:

CALL insert_article_tags(1,1);
CALL insert_article_tags(1,2);
CALL insert_article_tags(1,3);

这之后，我们就要尝试插入一条重复的记录来看看错误处理器是否真的会被执行到。

CALL insert_article_tags(1,3);

我们得到了一条错误信息。不过因为我们声明的是

DELIMITER $$

CREATE PROCEDURE insert_article_tags_2(IN article_id INT, IN tag_id INT)
BEGIN

    DECLARE EXIT HANDLER FOR SQLEXCEPTION 
    SELECT 'SQLException invoked';

    DECLARE EXIT HANDLER FOR 1062 
        SELECT 'MySQL error code 1062 invoked';

    DECLARE EXIT HANDLER FOR SQLSTATE '23000'
    SELECT 'SQLSTATE 23000 invoked';

    -- insert a new record into article_tags
    INSERT INTO article_tags(article_id,tag_id)
       VALUES(article_id,tag_id);

    -- return tag count for the article
    SELECT COUNT(*) FROM article_tags;
END $$

最后，我们可以尝试新增一条重复主键的记录看看效果：

CALL insert_article_tags_2(1,3);

可以看到这次只输出了错误信息就没有继续向下执行了。

错误处理器的优先级

当有多个错误处理器都满足特定错误条件的时候，MySQL将按更明确者优先的原则决定优先级。

MySQL中的每个错误都会映射到一个特定的错误码，因此错误码是最明确的。一个

DELIMITER $$

CREATE PROCEDURE insert_article_tags_3(IN article_id INT, IN tag_id INT)
BEGIN

    DECLARE EXIT HANDLER FOR 1062 SELECT 'Duplicate keys error encountered';
    DECLARE EXIT HANDLER FOR SQLEXCEPTION SELECT 'SQLException encountered';
    DECLARE EXIT HANDLER FOR SQLSTATE '23000' SELECT 'SQLSTATE 23000';

    -- insert a new record into article_tags
    INSERT INTO article_tags(article_id,tag_id)
    VALUES(article_id,tag_id);

    -- return tag count for the article
    SELECT COUNT(*) FROM article_tags;
END $$

当我们通过下面的命令，试图调用上面的存储过程插入一条主键重复的记录到

CALL insert_article_tags_3(1,3);

使用命名错误条件

我们先看一个错误处理器的声明：

DECLARE EXIT HANDLER FOR 1051 SELECT 'Please create table abc first';
SELECT * FROM abc;

DECLARE condition_name CONDITION FOR condition_value;

DECLARE table_not_found CONDITION for 1051;
DECLARE EXIT HANDLER FOR  table_not_found SELECT 'Please create table abc first';
SELECT * FROM abc;

这样代码的可读性比之前明显好多了。需要注意的是，要在存储过程声明一个命名条件的语句，则该语句必须出现在错误处理器或者游标声明的前面。

一个在 handler 中实用的辅助函数

实际应用中，存储过程中的错误被我们的错误处理器捕获了之后，你如果还想用类似

DELIMITER $$
CREATE FUNCTION fn_get_error()
RETURNS VARCHAR(250)
BEGIN
    DECLARE code CHAR(5) DEFAULT '00000';
    DECLARE msg TEXT;
    DECLARE errno INT;
    
    GET DIAGNOSTICS CONDITION 1 code = RETURNED_SQLSTATE, 
        errno = MYSQL_ERRNO, msg = MESSAGE_TEXT;
    
    RETURN COALESCE(CONCAT("ERROR ", errno, " (", code, "): ", msg), '-');
END$$

那么在实际使用时，就可以在错误处理器中这样用：

     DECLARE EXIT HANDLER FOR SQLEXCEPTION 
     BEGIN 
         ROLLBACK; 
         SET ret = -9; 
         SELECT ret AS 'ret', fn_get_error() AS 'err';
     END;        
    
    DECLARE EXIT HANDLER FOR 1062
    BEGIN
        ROLLBACK; 
         SET ret = -1; 
         SELECT ret AS 'ret', fn_get_error() AS 'err';
    END;

那么在有错误发生的时候，就可以得到如下的错误提示了：

本篇关于《MySQL 存储过程中的错误处理》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于数据库的相关知识，请关注golang学习网公众号！