AnalyticDB PostgreSQL 7.0 支持存储过程(CREATE PROCEDURE)特性

简介: AnalyticDB PostgreSQL 7.0 新增了存储过程功能的支持,让用户在使用ADB PG时能够更方便高效地开发业务,并能够更好地兼容Oracle等传统数仓的业务。

背景

在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中实现业务需求。

相关实践学习
使用CLup和iSCSI共享盘快速体验PolarDB for PostgtreSQL
在Clup云管控平台中快速体验创建与管理在iSCSI共享盘上的PolarDB for PostgtreSQL。
AnalyticDB PostgreSQL 企业智能数据中台:一站式管理数据服务资产
企业在数据仓库之上可构建丰富的数据服务用以支持数据应用及业务场景;ADB PG推出全新企业智能数据平台,用以帮助用户一站式的管理企业数据服务资产,包括创建, 管理,探索, 监控等; 助力企业在现有平台之上快速构建起数据服务资产体系
目录
相关文章
|
9月前
|
存储 SQL Oracle
【Oracle系列】- 存储过程(Stored Procedure)
【Oracle系列】- 存储过程(Stored Procedure)
180 0
|
14天前
|
SQL 存储 分布式计算
DataWorks产品使用合集之在DataWorks中调用存储过程(PROCEDURE)如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
19 0
|
2月前
|
关系型数据库 MySQL 测试技术
数据库专家带你体验PolarDB MySQL版 Serverless的极致弹性特性!
本次基于阿里云瑶池数据库解决方案体验馆,带你体验PolarDB MySQL Serverless形态下的性能压测环境,基于可选择的标准压测工具进行压测,构造弹性场景进行压测,实时动态展示弹性能力、价格和性价比结果,压测环境可开放定制修改、可重复验证。参与活动即有机会获得鼠标、小米打印机、卫衣等精美礼品。
数据库专家带你体验PolarDB MySQL版 Serverless的极致弹性特性!
|
3月前
|
关系型数据库 MySQL 测试技术
数据库专家带你体验PolarDB MySQL版 Serverless的极致弹性特性
本次基于阿里云瑶池数据库解决方案体验馆,带你体验PolarDB MySQL Serverless形态下的性能压测环境,基于可选择的标准压测工具进行压测,构造弹性场景进行压测,实时动态展示弹性能力、价格和性价比结果,压测环境可开放定制修改、可重复验证。参与活动即有机会获得鼠标、小米打印机、卫衣等精美礼品。
|
4月前
|
存储 SQL 安全
函数(Function)和存储过程(Stored Procedure)的区别(小白情感版)
函数(Function)和存储过程(Stored Procedure)的区别(小白情感版)
46 0
|
10月前
|
存储 SQL 数据库
存储过程(Stored Procedure)
存储过程(Stored Procedure)
54 1
|
5月前
|
存储 关系型数据库 分布式数据库
PolarDB-X HTAP新特性 ~ 列存索引
随着数据爆炸式的增长,传统的OLTP和OLAP解决方案基于简单的读写分离或ETL模型,将在线库的数据以T+1的方式抽取到数据仓库中进行计算,这种方案存在存储成本高、实时性差、链路和维护成本高等缺陷。 为应对数据爆炸式增长的挑战,PolarDB分布式版本基于对象存储设计了一套列存索引(Clustered Columnar Index,CCI)功能,支持将行存数据实时同步到列存存储上
76011 148
|
8月前
|
关系型数据库 调度 数据库
直播预告 | PolarDB-PG 企业级特性 —— Shared Server特性详解
PolarDB-PG 提供了 Shared Server 内置连接池功能,实现了用户连接与后端进程的解绑。后端进程在运行时可以根据实时负载和进程污染情况进行动态转换。负载调度算法使用 Stall 机制弹性控制 Worker 数量,同时避免用户连接饿死。从根本上解决了高并发或者大量短连接带来的性能、稳定性问题。
|
8月前
|
关系型数据库 分布式数据库 数据库
直播预告 | PolarDB-PG 企业级特性 —— 闪回特性详解
闪回表 (Flashback Table) 功能是PolarDB-PG数据库高可用的一个重要特性,支持在数据人为误操作时,快速闪回到某个时间点,恢复以及查看丢失的数据。本期分享将会介绍闪回表、闪回日志的基本原理以及特性,并演示闪回功能的使用方法。
直播预告 | PolarDB-PG 企业级特性 —— 闪回特性详解
|
存储 关系型数据库 MySQL
【MySQL】存储过程1305 - PROCEDURE xkgl.studnet_grade does not exist
存储过程不存在,重新执行创建存储过程的命令,查看是否有该存储过程。
107 0

相关产品

  • 云数据库 RDS PostgreSQL 版