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

本文涉及的产品
阿里云百炼推荐规格 ADB PostgreSQL,4核16GB 100GB 1个月
RDS PostgreSQL Serverless,0.5-4RCU 50GB 3个月
推荐场景:
对影评进行热评分析
简介: 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中实现业务需求。

相关实践学习
阿里云百炼xAnalyticDB PostgreSQL构建AIGC应用
通过该实验体验在阿里云百炼中构建企业专属知识库构建及应用全流程。同时体验使用ADB-PG向量检索引擎提供专属安全存储,保障企业数据隐私安全。
AnalyticDB PostgreSQL 企业智能数据中台:一站式管理数据服务资产
企业在数据仓库之上可构建丰富的数据服务用以支持数据应用及业务场景;ADB PG推出全新企业智能数据平台,用以帮助用户一站式的管理企业数据服务资产,包括创建, 管理,探索, 监控等; 助力企业在现有平台之上快速构建起数据服务资产体系
目录
相关文章
|
6月前
|
存储 关系型数据库 MySQL
在阿里云的AnalyticDB MySQL版中使用CREATE TABLE语句来创建内表
在阿里云的AnalyticDB MySQL版中使用CREATE TABLE语句来创建内表【1月更文挑战第16天】【1月更文挑战第78篇】
362 3
|
6月前
|
Cloud Native 关系型数据库 OLAP
云原生数据仓库产品使用合集之阿里云云原生数据仓库AnalyticDB PostgreSQL版的重分布时间主要取决的是什么
阿里云AnalyticDB提供了全面的数据导入、查询分析、数据管理、运维监控等功能,并通过扩展功能支持与AI平台集成、跨地域复制与联邦查询等高级应用场景,为企业构建实时、高效、可扩展的数据仓库解决方案。以下是对AnalyticDB产品使用合集的概述,包括数据导入、查询分析、数据管理、运维监控、扩展功能等方面。
|
6月前
|
运维 Cloud Native 关系型数据库
云原生数据仓库产品使用合集之原生数据仓库AnalyticDB PostgreSQL版如果是列存表的话, adb支持通过根据某个字段做upsert吗
阿里云AnalyticDB提供了全面的数据导入、查询分析、数据管理、运维监控等功能,并通过扩展功能支持与AI平台集成、跨地域复制与联邦查询等高级应用场景,为企业构建实时、高效、可扩展的数据仓库解决方案。以下是对AnalyticDB产品使用合集的概述,包括数据导入、查询分析、数据管理、运维监控、扩展功能等方面。
|
3月前
|
关系型数据库 MySQL Java
【Azure 应用服务】应用服务连接 Azure MySQL 一直失败,报错 Create connection error
【Azure 应用服务】应用服务连接 Azure MySQL 一直失败,报错 Create connection error
|
4月前
|
SQL 安全 关系型数据库
MySQL创建视图(CREATE VIEW)13
【7月更文挑战第13天】创建视图是指在已经存在的 MySQL 数据库表上建立视图。视图可以建立在一张表中,也可以建立在多张表中。
68 1
|
4月前
|
关系型数据库 MySQL 数据库
Mysqlbug-Could not create or access the registry key needed for the MySQL applicationto, TIMESTAMP w
Mysqlbug-Could not create or access the registry key needed for the MySQL applicationto, TIMESTAMP w
|
5月前
|
运维 Cloud Native 关系型数据库
云原生数据仓库AnalyticDB产品使用合集之PostgreSQL版是否直接支持实时物化视图
阿里云AnalyticDB提供了全面的数据导入、查询分析、数据管理、运维监控等功能,并通过扩展功能支持与AI平台集成、跨地域复制与联邦查询等高级应用场景,为企业构建实时、高效、可扩展的数据仓库解决方案。以下是对AnalyticDB产品使用合集的概述,包括数据导入、查询分析、数据管理、运维监控、扩展功能等方面。
130 3
|
6月前
|
SQL 存储 分布式计算
DataWorks产品使用合集之在DataWorks中调用存储过程(PROCEDURE)如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
179 0
|
6月前
|
关系型数据库 MySQL Java
报错 create connection SQLException, url: jdbc:mysql://noreggie?serverTimezone=Asia/Shanghai&useUnicod
报错 create connection SQLException, url: jdbc:mysql://noreggie?serverTimezone=Asia/Shanghai&useUnicod
|
6月前
|
关系型数据库 MySQL 数据库
【MySQL】7. 基本查询(create / retrieve)
【MySQL】7. 基本查询(create / retrieve)
59 0

热门文章

最新文章

相关产品

  • 云原生数据仓库 AnalyticDB PostgreSQL版
  • 云数据库 RDS PostgreSQL 版