背景
在ADB PG6中,函数(Function)可以实现大部分的存储过程功能(SQL stored procedures),我们通常建议用户使用函数来实现存储过程业务,但是通过此方法改造存储过程给用户带来了额外的工作量;且函数内部不支持事务控制,无法完全替代存储过程功能。因此存储过程是许多ADB PG用户、及PostgresSQL从业者们期待已久的功能。
ADB PG7新增了存储过程功能的支持,让用户在使用ADB PG时能够更方便高效地开发业务,并能够更好地兼容Oracle等传统数仓的业务。本文将演示ADB PG7中存储过程的使用方法。
存储过程的使用
语法
存储过程的语法和函数类似:
CREATE[OR REPLACE ] PROCEDURE name ([[ argmode ][ argname ] argtype [{ DEFAULT |=} default_expr ][, ...]]){ LANGUAGE lang_name | TRANSFORM { FOR TYPE type_name }[, ... ]|[ EXTERNAL ] SECURITY INVOKER |[ EXTERNAL ] SECURITY DEFINER |SET configuration_parameter { TO value |= value |FROM CURRENT }|AS'definition'|AS'obj_file','link_symbol'} ...
例子1
创建存储过程,并在存储过程中控制不同事务:
CREATE PROCEDURE proc() LANGUAGE plpgsql AS $$ BEGINCREATETABLE table_a (id int);INSERTINTO table_a VALUES(1); COMMIT;CREATETABLE table_b (cid int);INSERTINTO table_b VALUES(1); ROLLBACK; END;$$;
调用存储过程:
CALL proc();
查看存储过程的执行结果,可以看到table_a表相关事务提交,成功创建和插入数据;而table_b表相关的事务在存储过程中被回滚:
adbpg=# \d List of relations Schema | Name | Type | Owner | Storage --------+---------+-------+------------+--------- public | table_a |table| adbpgadmin | heap (1 row)adbpg=# select*from table_a; id ----1(1 row)
例子2
在ADB PG7中,通过使用存储过程事务提交能力,在任务期间及时回收表空间:
CREATE PROCEDURE run_procedure() LANGUAGE plpgsql AS $$ BEGIN FOR i in1..10 LOOP INSERTINTO t VALUES(i);-- 在表t上进行一系列任务,例如INSERT TRUNCATE t; COMMIT;-- 在循环内提交TRUNCATE,回收表t的物理存储空间 END LOOP; END;$$;
而在ADB PG6中,使用Function实现类似功能,则无法在循环中及时提交TRUNCATE回收表空间。仅在Function执行完成后作为一个事务一次提交:
CREATE FUNCTION run_function() RETURNS void LANGUAGE plpgsql AS $$ BEGIN FOR i in1..10 LOOP INSERTINTO t VALUES(i);-- 在表t上进行一系列任务,例如INSERT TRUNCATE t;-- COMMIT; 不支持事务提交 END LOOP; END;$$;
总结
ADB PG7版本PG内核升级带来了存储过程特性的支持。相比较ADB PG6,您无需使用函数功能改写存储过程,并可以在存储过程中控制事务。通过使用存储过程功能,业务可以更方便、平滑地迁移至ADB PG中,并可以帮助您更好地在ADB PG中实现业务需求。