学习目标
学习openGauss触发器
触发器是对应用动作的响应机制,当应用对一个对象发起DML操作时,就会产生一个触发事件(Event),如果该对象上拥有该事件对应的触发器,那么就会检查触发器的触发条件(Condition)是否满足,如果满足触发条件,那么就会执行触发动作(Action)
课程学习
连接数据库
#第一次进入等待15秒 #数据库启动中... su - omm gsql -r
复制
1.创建源表及触发表
CREATE TABLE test_trigger_src_tbl(id1 INT, id2 INT, id3 INT) ;
CREATE TABLE test_trigger_des_tbl(id1 INT, id2 INT, id3 INT);
2.insert触发器
–创建触发器函数
CREATE OR REPLACE FUNCTION tri_insert_func() RETURNS TRIGGER AS $$ DECLARE BEGIN INSERT INTO test_trigger_des_tbl VALUES(NEW.id1, NEW.id2, NEW.id3); RETURN NEW; END $$ LANGUAGE PLPGSQL;
复制
–创建INSERT触发器
CREATE TRIGGER insert_trigger BEFORE INSERT ON test_trigger_src_tbl FOR EACH ROW EXECUTE PROCEDURE tri_insert_func();
复制
–执行INSERT触发事件并检查触发结果
INSERT INTO test_trigger_src_tbl VALUES(100,200,300);
–查看触发操作生效
SELECT * FROM test_trigger_src_tbl;
SELECT * FROM test_trigger_des_tbl;
3.update触发器
–创建触发器函数
CREATE OR REPLACE FUNCTION tri_update_func() RETURNS TRIGGER AS $$ DECLARE BEGIN UPDATE test_trigger_des_tbl SET id3 = NEW.id3 WHERE id1=OLD.id1; RETURN OLD; END $$ LANGUAGE PLPGSQL;
复制
–创建update触发器
CREATE TRIGGER update_trigger
AFTER UPDATE ON test_trigger_src_tbl
FOR EACH ROW
EXECUTE PROCEDURE tri_update_func();
–执行update触发事件并检查触发结果
UPDATE test_trigger_src_tbl SET id3=400 WHERE id1=100;
–查看触发操作生效
SELECT * FROM test_trigger_src_tbl;
SELECT * FROM test_trigger_des_tbl;
4.delete触发器
–创建触发器函数
CREATE OR REPLACE FUNCTION TRI_DELETE_FUNC() RETURNS TRIGGER AS $$ DECLARE BEGIN DELETE FROM test_trigger_des_tbl WHERE id1=OLD.id1; RETURN OLD; END $$ LANGUAGE PLPGSQL;
复制
–创建delete触发器
CREATE TRIGGER delete_trigger
BEFORE DELETE ON test_trigger_src_tbl
FOR EACH ROW
EXECUTE PROCEDURE tri_delete_func();
–执行delete触发事件并检查触发结果
DELETE FROM test_trigger_src_tbl WHERE id1=100;
–查看触发操作生效
SELECT * FROM test_trigger_src_tbl;
SELECT * FROM test_trigger_des_tbl;
5.修改触发器
–重命名
ALTER TRIGGER delete_trigger ON test_trigger_src_tbl RENAME TO delete_trigger_renamed;
–在系统表PG_TRIGGER中查看触发器
select * from PG_TRIGGER;
–查看表上的所有触发器
\dS+ test_trigger_src_tbl
6.禁用触发器
–禁用insert_trigger触发器
ALTER TABLE test_trigger_src_tbl DISABLE TRIGGER insert_trigger;
–执行INSERT
INSERT INTO test_trigger_src_tbl VALUES(100,200,300);
–查看触发操作没有生效
SELECT * FROM test_trigger_src_tbl;
SELECT * FROM test_trigger_des_tbl;
–禁用当前表上所有触发器
ALTER TABLE test_trigger_src_tbl DISABLE TRIGGER ALL;7.删除触发器
DROP TRIGGER update_trigger ON test_trigger_src_tbl;
DROP TRIGGER delete_trigger_renamed ON test_trigger_src_tbl;
课程作业
1.创建源表和触发表,在源表上创建insert触发器,创建操作触发表的触发器函数
-- 1.
-- 1.1.
create table tbl_src (id int, name char(10));
create table tbl_des (id int, name char(10));
-- 1.2.
create or replace function tri_ins_func() returns trigger as
$$
declare
begin
insert into tbl_des values (new.id, new.name);
return new;
end
$$ language plpgsql;
-- 1.3.
create trigger ins_tri
before insert on tbl_src
for each row
execute procedure tri_ins_func();
复制
2.在源表上执行insert操作,查看触发操作是否生效;禁用触发器后,再次查看触发操作是否生效
-- 2.
-- 2.1.
insert into tbl_src values (1, 'a');
select * from tbl_src;
select * from tbl_des;
-- 2.2.
alter table tbl_src disable trigger all;
insert into tbl_src values (2, 'aa');
select * from tbl_src;
select * from tbl_des;
复制
3.使用系统表PG_TRIGGER和\dS+查看触发器
4.重命名触发器
5.删除触发器
-- 3.
select * from pg_trigger;
\dS+ tbl_src
-- 4.
alter trigger ins_tri on tbl_src rename to ins_tri_1;
\dS+ tbl_src
-- 5.
drop trigger ins_tri_1 on tbl_src;
select * from pg_trigger;
-- drop table tbl_src;
-- drop table tbl_des;
复制
学习心得
本节课学习了INSERT/UPDATE/DELETE
三种触发器的基本使用方法,使用时需要注意语法细节,比如func后面要加括号,\dS+
的大小写等。
参考文档
openGauss产品文档 PG_TRIGGER
松鼠镇楼,按时打卡