触发器

触发器会在指定的数据库事件发生时自动执行函数。

语法格式

  • 创建触发器

    1. CREATE TRIGGER trigger_name { BEFORE | AFTER | INSTEAD OF } { event [ OR ... ] }
    2.     ON table_name
    3.     [ FOR [ EACH ] { ROW | STATEMENT } ]
    4.     [ WHEN ( condition ) ]
    5.     EXECUTE PROCEDURE function_name ( arguments );

  • 修改触发器

    1. ALTER TRIGGER trigger_name ON table_name RENAME TO new_trigger_name;

  • 删除触发器

    1. DROP TRIGGER trigger_name ON table_name [ CASCADE | RESTRICT ];

参数说明

  • trigger_name

    触发器名称。

  • BEFORE

    触发器函数是在触发事件发生前执行。

  • AFTER

    触发器函数是在触发事件发生后执行。

  • INSTEAD OF

    触发器函数直接替代触发事件。

  • event

    启动触发器的事件，取值范围包括：INSERT、UPDATE、DELETE或TRUNCATE，也可以通过OR同时指定多个触发事件。

  • table_name

    触发器对应的表名称。

  • FOR EACH ROW | FOR EACH STATEMENT

    触发器的触发频率。

    • FOR EACH ROW是指该触发器是受触发事件影响的每一行触发一次。
    • FOR EACH STATEMENT是指该触发器是每个SQL语句只触发一次。

    未指定时默认值为FOR EACH STATEMENT。约束触发器只能指定为FOR EACH ROW。

  • function_name

    用户定义的函数，必须声明为不带参数并返回类型为触发器，在触发器触发时执行。

  • arguments

    执行触发器时要提供给函数的可选的以逗号分隔的参数列表。

  • new_trigger_name

    修改后的新触发器名称。

示例

  1. --创建源表及触发表
  2. openGauss=# CREATE TABLE test_trigger_src_tbl(id1 INT, id2 INT, id3 INT);
  3. openGauss=# CREATE TABLE test_trigger_des_tbl(id1 INT, id2 INT, id3 INT);
  5. --创建触发器函数
  6. openGauss=# CREATE OR REPLACE FUNCTION tri_insert_func() RETURNS TRIGGER AS
  7.            $$
  8.            DECLARE
  9.            BEGIN
  10.                    INSERT INTO test_trigger_des_tbl VALUES(NEW.id1, NEW.id2, NEW.id3);
  11.                    RETURN NEW;
  12.            END
  13.            $$ LANGUAGE PLPGSQL;
  15. openGauss=# CREATE OR REPLACE FUNCTION tri_update_func() RETURNS TRIGGER AS
  16.            $$
  17.            DECLARE
  18.            BEGIN
  19.                    UPDATE test_trigger_des_tbl SET id3 = NEW.id3 WHERE id1=OLD.id1;
  20.                    RETURN OLD;
  21.            END
  22.            $$ LANGUAGE PLPGSQL;
  24. openGauss=# CREATE OR REPLACE FUNCTION TRI_DELETE_FUNC() RETURNS TRIGGER AS
  25.            $$
  26.            DECLARE
  27.            BEGIN
  28.                    DELETE FROM test_trigger_des_tbl WHERE id1=OLD.id1;
  29.                    RETURN OLD;
  30.            END
  31.            $$ LANGUAGE PLPGSQL;
  33. --创建INSERT触发器
  34. openGauss=# CREATE TRIGGER insert_trigger
  35.            BEFORE INSERT ON test_trigger_src_tbl
  36.            FOR EACH ROW
  37.            EXECUTE PROCEDURE tri_insert_func();
  39. --创建UPDATE触发器
  40. openGauss=# CREATE TRIGGER update_trigger
  41.            AFTER UPDATE ON test_trigger_src_tbl  
  42.            FOR EACH ROW
  43.            EXECUTE PROCEDURE tri_update_func();
  45. --创建DELETE触发器
  46. openGauss=# CREATE TRIGGER delete_trigger
  47.            BEFORE DELETE ON test_trigger_src_tbl
  48.            FOR EACH ROW
  49.            EXECUTE PROCEDURE tri_delete_func();
  51. --执行INSERT触发事件并检查触发结果
  52. openGauss=# INSERT INTO test_trigger_src_tbl VALUES(100,200,300);
  53. openGauss=# SELECT * FROM test_trigger_src_tbl;
  54. openGauss=# SELECT * FROM test_trigger_des_tbl;  //查看触发操作是否生效。
  56. --执行UPDATE触发事件并检查触发结果
  57. openGauss=# UPDATE test_trigger_src_tbl SET id3=400 WHERE id1=100;
  58. openGauss=# SELECT * FROM test_trigger_src_tbl;
  59. openGauss=# SELECT * FROM test_trigger_des_tbl;  //查看触发操作是否生效
  61. --执行DELETE触发事件并检查触发结果
  62. openGauss=# DELETE FROM test_trigger_src_tbl WHERE id1=100;
  63. openGauss=# SELECT * FROM test_trigger_src_tbl;
  64. openGauss=# SELECT * FROM test_trigger_des_tbl;  //查看触发操作是否生效
  66. --修改触发器
  67. openGauss=# ALTER TRIGGER delete_trigger ON test_trigger_src_tbl RENAME TO delete_trigger_renamed;
  69. --删除触发器
  70. openGauss=# DROP TRIGGER insert_trigger ON test_trigger_src_tbl;
  71. openGauss=# DROP TRIGGER update_trigger ON test_trigger_src_tbl;
  72. openGauss=# DROP TRIGGER delete_trigger_renamed ON test_trigger_src_tbl;