错误捕获语句

功能描述

缺省时，当PL/pgSQL函数执行过程中发生错误时退出函数执行，并且周围的事务也会回滚。

可以用一个带有EXCEPTION子句的BEGIN块捕获错误并且从中恢复。其语法是正常的BEGIN块语法中的一个拓展。

注意事项

• 如果没有发生错误，这种形式的块只是简单地执行所有语句，然后转到END之后的下一个语句。

• 如果在执行的语句内部发生了一个错误，则这个语句将会回滚，然后转到EXCEPTION列表。寻找匹配错误的第一个条件。

  • 如果找到匹配，则执行对应的handler_statements，然后转到END之后的下一个语句。

  • 如果没有找到匹配，则会向事务的外层报告错误，和没有EXCEPTION子句一样。错误码可以捕获同一类的其他错误码。也就是说该错误可以被一个包围块用EXCEPTION捕获，如果没有包围块，则进行退出函数处理。

• 如果在选中的handler_statements里发生了新错误，则不能被这个EXCEPTION子句捕获，而是向事务的外层报告错误。一个外层的EXCEPTION子句可以捕获它。

• 如果一个错误被EXCEPTION捕获，PL/pgSQL函数的局部变量保持错误发生时的原值，但是所有该块中想写入数据库中的状态都回滚。

语法格式

[<<label>>]
[DECLARE
    declarations]
BEGIN
    statements
EXCEPTION
    WHEN condition [OR condition ...] THEN
        handler_statements
    [WHEN condition [OR condition ...] THEN
        handler_statements
    ...]
END;

参数说明

• condition

  可以是SQL标准错误码编号说明的任意值。特殊的条件名OTHERS匹配除了QUERY_CANCELED之外的所有错误类型。

• handler_statements

  捕获到错误语句后执行的操作。

示例

示例1

当控制到达给y赋值的地方时，会有一个division_by_zero错误失败。这个错误将被EXCEPTION子句捕获。而在RETURN语句里返回的数值将是x的增量值。

1、创建测试表并插入数据。

CREATE TABLE mytab(id INT,firstname VARCHAR(20),lastname VARCHAR(20)) ;
INSERT INTO mytab(firstname, lastname) VALUES('Tom', 'Jones');

2、创建函数并调用。

CREATE FUNCTION fun_exp() RETURNS INT
AS $$
DECLARE
    x INT :=0;
    y INT;
BEGIN
    UPDATE mytab SET firstname = 'Joe' WHERE lastname = 'Jones';
    x := x + 1;
    y := x / 0;
EXCEPTION
    WHEN division_by_zero THEN
        RAISE NOTICE 'caught division_by_zero';
        RETURN x;
END;$$
LANGUAGE plpgsql;

call fun_exp();

当结果显示如下信息，则表示捕获到错误语句。

NOTICE:  caught division_by_zero
 fun_exp 
----------------
       1
(1 row)

3、查询表数据验证结果。

select * from mytab;

结果显示如下：

 id | firstname | lastname 
----+-----------+----------
    | Tom       | Jones
(1 row)

4、删除测试表和函数。

DROP FUNCTION fun_exp();
DROP TABLE mytab;

• 进入和退出一个包含EXCEPTION子句的块要比不包含的块开销大的多。因此，不必要的时候不要使用EXCEPTION。

• 在下列场景中，无法捕获处理异常，整个存储过程回滚：节点故障、网络故障引起的存储过程参与节点线程退出以及COPY FROM操作中源数据与目标表的表结构不一致造成的异常。

示例2

UPDATE/INSERT异常，这个例子根据使用异常处理器执行恰当的UPDATE或INSERT 。

1、创建测试表。

CREATE TABLE db (a INT, b TEXT);

2、创建测试函数。

CREATE FUNCTION merge_db(key INT, data TEXT) RETURNS VOID AS
$$
BEGIN
    LOOP									
        UPDATE db SET b = data WHERE a = key;		--第一次尝试更新key
        IF found THEN
            RETURN;
        END IF;		
        BEGIN		--不存在，所以尝试插入key，如果其他人同时插入相同的key，我们可能得到唯一key失败。
            INSERT INTO db(a,b) VALUES (key, data);
            RETURN;
        EXCEPTION WHEN unique_violation THEN
        END;		 --什么也不做，并且循环尝试再次更新。
     END LOOP;
END;
$$
LANGUAGE plpgsql;

3、调用函数并查询数据进行对比。

SELECT merge_db(1, 'david');
SELECT * FROM db;

结果显示如下：

 merge_db
----------

(1 row)

 a |   b   
---+-------
 1 | david
(1 row)

再次调用并查询。

SELECT merge_db(1, 'dennis');
SELECT * FROM db;

结果显示如下：

 merge_db
----------

(1 row)

 a |   b    
---+--------
 1 | dennis
(1 row)

4、删除FUNCTION和TABLE。

DROP FUNCTION merge_db;
DROP TABLE db;