事件触发器

触发器会在指定的ddl事件发生时自动执行函数。目前事件触发器仅在PG兼容模式下可用。

语法格式

  • 创建事件触发器。

    1. CREATE EVENT TRIGGER name
    2.     ON event
    3.     [ WHEN filter_variable IN (filter_value [, ... ]) [ AND ... ] ]
    4.     EXECUTE PROCEDURE function_name()

  • 修改事件触发器。

    1. ALTER EVENT TRIGGER name DISABLE
    2. ALTER EVENT TRIGGER name ENABLE [ REPLICA | ALWAYS ]
    3. ALTER EVENT TRIGGER name OWNER TO { new_owner | CURRENT_USER | SESSION_USER }
    4. ALTER EVENT TRIGGER name RENAME TO new_name

  • 删除事件触发器。

    1. DROP EVENT TRIGGER [ IF EXISTS ] name [ CASCADE | RESTRICT ];

参数说明

  • name

    事件触发器名称。

  • filter_variable

    事件触发器用来做过滤的变量（目前仅支持TAG）。

  • event

    事件触发器支持的事件，目前支持ddl_command_start、ddl_command_end、sql_drop、table_rewrite。

  • function_name

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

  • new_name

    修改后的新事件触发器名称。

  • disable

    禁用该事件触发器。

  • ENABLE [ REPLICA | ALWAYS ]

    该事件触发器在session_replication_role为REPLICA\任何取值时可用。

示例

  1. --创建事件触发器函数(用于ddl_command_start、ddl_command_end事件)
  2. openGauss=# create function test_event_trigger() returns event_trigger as $$
  3. BEGIN
  4.     RAISE NOTICE 'test_event_trigger: % %', tg_event, tg_tag;
  5. END
  6. $$ language plpgsql;
  8. --创建事件触发器函数(用于sql_drop事件)
  9. openGauss=# CREATE OR REPLACE FUNCTION drop_sql_command()
  10. RETURNS event_trigger AS $$
  11. BEGIN
  12. RAISE NOTICE '% - sql_drop', tg_tag;
  13. END;
  14. $$ LANGUAGE plpgsql;
  16. --创建事件触发器函数(用于table_rewrite事件)
  17. openGauss=# CREATE OR REPLACE FUNCTION test_evtrig_no_rewrite() RETURNS event_trigger
  18. LANGUAGE plpgsql AS $$
  19. BEGIN
  20.   RAISE EXCEPTION 'rewrites not allowed';
  21. END;
  22. $$;
  24. --创建事件类型为ddl_command_start的事件触发器
  25. openGauss=# create event trigger regress_event_trigger on ddl_command_start
  26.    execute procedure test_event_trigger();
  28. --创建事件类型为ddl_command_end的事件触发器
  29. openGauss=# create event trigger regress_event_trigger_end on ddl_command_end
  30.    execute procedure test_event_trigger();
  32. --创建事件类型为sql_drop的事件触发器
  33. openGauss=# CREATE EVENT TRIGGER sql_drop_command ON sql_drop
  34.     EXECUTE PROCEDURE drop_sql_command();
  36. --创建事件类型为table_rewrite的事件触发器
  37. openGauss=# create event trigger no_rewrite_allowed on table_rewrite
  38.   when tag in ('alter table') execute procedure test_evtrig_no_rewrite();
  40. --执行ddl语句查看事件触发器效果(触发ddl_command_start与ddl_command_end)
  41. openGauss=# create table event_trigger_table (a int);
  43. --执行alter table语句查看事件触发器效果(触发ddl_command_start与table_rewrite,ddl_command_end由于禁止rewrite报错不触发)
  44. openGauss=# alter table event_trigger_table alter column a type numeric;
  46. --执行drop语句查看事件触发器效果(触发ddl_command_start、sql_drop与ddl_command_end)
  47. openGauss=# drop table event_trigger_table;
  49. --修改事件触发器
  50. openGauss=# create role regress_evt_user WITH ENCRYPTED PASSWORD 'EvtUser123';
  51. openGauss=# ALTER EVENT TRIGGER regress_event_trigger RENAME TO regress_event_trigger_start;
  52. --应该失败，事件触发器的owner只能为超级用户
  53. openGauss=# ALTER EVENT TRIGGER regress_event_trigger_start owner to regress_evt_user;
  54. openGauss=# ALTER EVENT TRIGGER regress_event_trigger_start disable;
  55. openGauss=# ALTER EVENT TRIGGER regress_event_trigger_start enable always;
  57. --删除触发器
  58. openGauss=# DROP EVENT TRIGGER regress_event_trigger_start;
  59. openGauss=# DROP EVENT TRIGGER regress_event_trigger_end;
  60. openGauss=# DROP EVENT TRIGGER sql_drop_command;
  61. openGauss=# DROP EVENT TRIGGER no_rewrite_allowed;