Oracle应用迁移到AnalyticDB for PostgreSQL指导

AnalyticDB for PostgreSQL（简称：ADB for PG）对Oracle语法有着较好的兼容，本文介绍如何将Oracle应用迁移到AnalyticDB for PostgreSQL。

1 PL/SQL

PL/SQL（Procedural Language/SQL）是一种过程化的SQL语言，是Oracle对SQL语句的拓展，使得SQL的使用可以具有一般编程语言的特点，因此，可以用来实现复杂的业务逻辑。PL/SQL对应了ADB for PG中的PL/PGSQL

1.1Package

ADB for PG的plpgsql不支持package，需要把package 转换成 schema，并package里面的所有procedure和 function转换成ADB for PG的function。
例如：

create or replace package pkg is 
…
end;

可以转换成：

create schema pkg;

  1. Package定义的变量

     procedure/function的局部变量保持不变，全局变量在ADB for PG中可以使用临时表进行保存。详见1.4.5节。

  2. Package初始化块

    如果可以删掉，就删掉，删不掉的话，可以使用function封装，在需要的时候主动调用该function。

  3. Package 内定义的procedure/function

    Package 内定义的procedure和function 转成adb for pg的function，并把function 定义到package对应的schema内。
例如，有一个Package名为pkg中有如下函数：
    FUNCTION test_func (args int) RETURN int is 
var number := 10;
BEGIN
… … 
END;
    转换成如下ADB for PG的function：
    CREATE OR REPLACE FUNCTION pkg. test_func(args int) RETURNS int AS 
$$… …  $$LANGUAGE plpgsql;

1.2 Procedure/function

对于oracle的procedure和function，不论是package的还是全局的，都转换成adb for pg 的function。
例如：

CREATE OR REPLACE FUNCTION test_func (v_name varchar2, v_version varchar2)
RETURN varchar2 ISret varchar(32);
BEGINIF v_version IS NULL THENret := v_name;
ELSEret := v_name || '/' || v_version;END IF;RETURN ret;
END;

转化成：

CREATE OR REPLACE FUNCTION test_func (v_name varchar, v_version varchar)
RETURNS varchar AS 
$$DECLAREret varchar(32);
BEGINIF v_version IS NULL THENret := v_name;
ELSEret := v_name || '/' || v_version;END IF;RETURN ret;
END;$$LANGUAGE plpgsql;

Procedure/function转换的关键点：

  1. RETURN 关键字转成RETURNS
  2. 函数体使用$\$ ... $\$封装起来
  3. 函数语言声明
  4. Subprocedure需要转换成ADB for PG的function

1.3 PL statement

1.3.1 For语句

带有REVERSE的整数FOR循环的工作方式不同：PL/SQL中是从第二个数向第一个数倒数，而PL/pgSQL是从第一个数向第二个数倒数，因此在移植时需要交换循环边界。
示例：

FOR i IN REVERSE 1..3 LOOPDBMS_OUTPUT.PUT_LINE (TO_CHAR(i));
END LOOP;

转换成：

FOR i IN REVERSE 3..1 LOOPRAISE ‘%’ ,i;
END LOOP;

1.3.2 PRAGMA语句

ADB for PG 无PRAGMA语句，删除。

1.3.3 事务处理

ADB for PG 的function 内部无法使用事务控制语句，如begin，commit，rollback等。
修改方法：

  1. 删除函数体内的事务控制语句，把事务控制放在函数体外；
  2. 把函数按照commit/rollback 拆分成多个。

1.3.4 EXECUTE语句

ADB for PG支持类似oracle的动态sql语句，不同之处如下：

  1. 不支持using 语法，解决方法是把参数拼接到sql串中；
  2. 数据库标识符使用quote_ident包裹，数值使用quote_literal包裹。

示例：

EXECUTE 'UPDATE employees_temp SET commission_pct = :x' USING a_null;

转换成：

EXECUTE 'UPDATE employees_temp SET commission_pct = ' || quote_literal(a_null);

1.3.5 Pipe row

Pipe row函数，使用adb for pg的table function来替换。
示例：

TYPE pair IS RECORD(a int, b int);
TYPE numset_t IS TABLE OF pair;FUNCTION f1(x int) RETURN numset_t PIPELINED IS
DECLAREv_p pair;
BEGINFOR i IN 1..x LOOPv_p.a := i;v_p.b := i+10;PIPE ROW(v_p);END LOOP;RETURN;
END;select * from f1(10);

转换成：

create type pair as (a int, b int);create or replace function f1(x int) returns setof pair as 
$$declare
rec pair;
beginfor i in 1..x looprec := row(i, i+10);return next rec;end loop;return ;
end$$language 'plpgsql';select * from f1(10);

说明：

  1. 自定义类型pair转换成adb for pg的复合类型pair
  2. Table of类型不需要定义，使用adb for pg的setof 替换

  3. Pipe row 语句转换成下面两个语句：

      rec := row(i);return next rec;

  4. 上面的oracle function还可以转换成如下：

    create or replace function f1(x int) returns setof record as 
$$declare
rec record;
beginfor i in 1..x looprec := row(i, i+10);return next rec;end loop;return ;
end$$
language 'plpgsql';

与第一种改法的不同支持是，不需要提前定义数据类型numset_t.正因为这一点所以在查询的时候需要指定返回的类型，如下：select * from f1(10) as (a int, b int);

1.3.6 异常处理

  1. 使用raise抛出异常
  2. Catch异常后，不能rollback事务，只能在udf外做rollback
  3. ADB for PG支持的error，可以参考: https://www.postgresql.org/docs/8.3/errcodes-appendix.html

1.3.7 function中同时有Return和OUT参数

在adb pg中，不允许fucntion同时有return和out参数，因此，可以把需要返回的参数改写成out类型参数。

示例：

CREATE OR REPLACE FUNCTION test_func(id int, name varchar(10), out_id out int) returns varchar(10)
AS $body$
BEGINout_id := id + 1;return name;
end
$body$
LANGUAGE PLPGSQL;

改写成：

CREATE OR REPLACE FUNCTION test_func(id int, name varchar(10), out_id out int, out_name out varchar(10))
AS $body$
BEGINout_id := id + 1;out_name := name;
end
$body$
LANGUAGE PLPGSQL;

然后select * from test_func(1,’1’) into rec;从rec中取对应字段的返回值即可。

1.4 PL数据类型

1.4.1 Record

使用ADB for PG的复合数据类型替换
示例：

TYPE rec IS RECORD (a int, b int)；

改写成：

CREATE TYPE rec AS (a int, b int);

1.4.2 Nest table

  1. Nest table 作为pl 变量，可以使用ADB for PG的array类型替换。
    示例：
DECLARETYPE Roster IS TABLE OF VARCHAR2(15);names Roster := Roster('D Caruso', 'J Hamil', 'D Piro', 'R Singh');
BEGINFOR i IN names.FIRST .. names.LASTLOOPIF names(i) = 'J Hamil' THENDBMS_OUTPUT.PUT_LINE(names(i));END IF;END LOOP;
END;

改写成：

create or replace function f1() returns void as 
$$declarenames varchar(15)[] := '{"D Caruso", "J Hamil", "D Piro", "R Singh"}';len int := array_length(names, 1);
beginfor i in 1..len loopif names[i] = 'J Hamil' thenraise notice '%', names[i];end if;end loop;return ;
end$$language 'plpgsql';select f();
  1. 作为function返回值，则可以使用table function替换，参考1.3.5节。

1.4.3 Associative Array

无替换类型。

1.4.4 Variable-Size Arrays

与nest table 一样，使用array类型替换。

1.4.5 Global variables

目前ADB for PG不支持global variables，一种方法是把一个package中的所有global variables存入一张临时表（temporary table）中, 然后定义修改、获取global variables的函数。

示例：

create temporary table global_variables (id int,g_count int,g_set_id varchar(50),g_err_code varchar(100)
);insert into global_variables values(0, 1, null，null);CREATE OR REPLACE FUNCTION get_variable() returns setof global_variables AS$$DECLARErec global_variables%rowtype;
BEGINexecute 'select * from global_variables' into rec;return next rec;
END;$$LANGUAGE plpgsql;CREATE OR REPLACE FUNCTION set_variable(in param varchar(50), in value anyelement) returns void AS$$BEGINexecute 'update global_variables set ' ||  quote_ident(param) || ' = ' || quote_literal(value);
END;$$LANGUAGE plpgsql;

其中，临时表global_variables中，字段id为这个表的分布列，因为ADB for PG中不允许对于分布列的修改，需要多加一个这样的字段。
tmp_rec record;
修改一个全局变量时，使用：select * from set_variable(‘g_error_code’, ‘error’::varchar) into tmp_rec;
获取一个全局变量时，使用：select * from get_variable() into tmp_rec; error_code := tmp_rec.g_error_code;

1.5 SQL

1.5.1 Connect by

Oracle 层次查询，adb for pg没有等价替换的sql语句。转换思路是使用循环按层次遍历。
示例：

create table employee(emp_id numeric(18),lead_id numeric(18),emp_name varchar(200),salary numeric(10,2),dept_no varchar(8)
);
insert into employee values('1',0,'king','1000000.00','001');
insert into employee values('2',1,'jack','50500.00','002');
insert into employee values('3',1,'arise','60000.00','003');
insert into employee values('4',2,'scott','30000.00','002');
insert into employee values('5',2,'tiger','25000.00','002');
insert into employee values('6',3,'wudde','23000.00','003');
insert into employee values('7',3,'joker','21000.00','003');
insert into employee values('3',7,'joker','21000.00','003');
select emp_id,lead_id,emp_name,prior emp_name as lead_name,salaryfrom employeestart with  lead_id=0connect by prior emp_id =  lead_id

转换成：

create or replace function f1(tablename text, lead_id int, nocycle boolean) returns setof employee as 
$$declareidx int := 0;res_tbl varchar(265) := 'result_table';prev_tbl varchar(265) := 'tmp_prev';curr_tbl varchar(256) := 'tmp_curr';current_result_sql varchar(4000);tbl_count int;rec record;
beginexecute 'truncate ' || prev_tbl;execute 'truncate ' || curr_tbl;execute 'truncate ' || res_tbl;loop-- 查询当前层次结果，并插入到tmp_curr表current_result_sql := 'insert into ' || curr_tbl || ' select t1.* from ' || tablename || ' t1';if idx > 0 thencurrent_result_sql := current_result_sql || ', ' || prev_tbl || ' t2 where t1.lead_id = t2.emp_id';elsecurrent_result_sql := current_result_sql || ' where t1.lead_id = ' || lead_id;end if;execute current_result_sql;-- 如果有环，删除已经遍历过的数据if nocycle is false thenexecute 'delete from ' || curr_tbl || ' where (lead_id, emp_id) in (select lead_id, emp_id from ' || res_tbl || ') ';end if;-- 如果没有数据，则退出execute 'select count(*) from ' || curr_tbl into tbl_count;exit when tbl_count = 0;-- 把tmp_curr数据保存到result表execute 'insert into ' || res_tbl || ' select * from ' || curr_tbl;execute 'truncate ' || prev_tbl;execute 'insert into ' || prev_tbl || ' select * from ' || curr_tbl;execute 'truncate ' || curr_tbl;idx := idx + 1;end loop;-- 返回结果current_result_sql := 'select * from ' || res_tbl;for rec in execute current_result_sql loopreturn next rec;end loop;return;
end$$language plpgsql;

1.5.2 Rownum

  1. 限定查询结果集大小，可以使用limit替换
    示例：
select * from t where rownum < 10;

转换成：

select * from t limit 10;
  1. 使用row_number() over()生成rownum
    示例：

select rownum, * from t;
转换成：

select row_number() over() as rownum, * from t;

1.5.3 Dual表

  1. 去掉dual
    示例：
select sysdate from dual;

转换成：

select current_timestamp;
  1. 创建一个叫dual的表。

1.5.4 Select中的udf

ADB for PG支持在select中调用udf，但是udf中不能有sql语句，否则会收到如下的错误信息：
ERROR: function cannot execute on segment because it accesses relation "public.t2" (functions.c:155) (seg1 slice1 127.0.0.1:25433 pid=52153) (cdbdisp.c:1326)
DETAIL:
SQL statement "select b from t2 where a = $1 "

转换方法是把select中的udf转换成sql表达式或者子查询等
示例：

create or replace FUNCTION f1(arg int) RETURN int ISv int;
BEGINselect b into v from t2 where a = arg;return v;
END;select a, f1(b) from t1;

转换成：

select t1.a, t2.b from t1, t2 where t1.b = t2.a;

1.5.5 （+）多表外链接

ADB for PG 不支持(+)这样的语法形式，需要转换成标准的outer join语法。
示例：

oracle
select * from a,b where a.id=b.id(+)

转换成：

select * from a left join b on a.id=b.id

如果在(+)中有三表的join，需要先用wte做两表的join，再用+号那个表跟wte表做outer join。
示例：

Select * from test1 t1, test2 t2, test3 t3 where t1.col1(+) between NVL(t2.col1, t3.col1) and NVL(t3.col1, t2.col1);

转换成：

with cte as (select t2.col1 as low, t2.col2, t3.col1 as high, t3.col2 as c2 from t2, t3)
select * from t1 right outer join cte on t1.col1 between coalesce(cte.low, cte.high) and coalesce(cte.high,cte.low);

1.5.6 Merge into

对于merge into语法的转换，在ADB for PG中先使用update进行更新，然后使用GET DIAGNOSTICS rowcount := ROW_COUNT;语句获取update更新的行数，如果update更新的行数为0，那么再使用insert语句进行插入。

MERGE INTO test1 t1USING (SELECT t2.col1 col1, t3.col2 col2,FROM test2 t2, test3 t3) SON S.col1 = 1 and S.col2 = 2            
WHEN MATCHED THENUPDATESET test1.col1 = S.col1+1,test1.col2 = S.col2+2
WHEN NOT MATCHED THENINSERT (col1, col2)VALUES(S.col1+1, S.col2+2);

转换成：

Update test1 t1 SET t1.col1 = test2.col1+1, test3.col2 = S.col2+2 where test2.col1 = 1 and test2.col2 = 2;
GET DIAGNOSTICS rowcount := ROW_COUNT;
if rowcount = 0 theninsert into test1 values(test2.col1+1, test3.col2+2);

2 系统函数转换对照表

oracleADB for PG
sysdatecurrent timestamp
trunctrunc/ date trunc
dbms_output.put_lineraise 语句
decode转成case when/直接使用decode
NVLcoalesce

3 数据类型转换对照表

oracleADB for PG
sysdatecurrent timestamp
trunctrunc/ date trunc
dbms_output.put_lineraise 语句
decode转成case when/直接使用decode
NVLcoalesce
oracleADB for PG
VARCHAR2varchar or text
DATEtimestamp
LONGtext
LONG RAWbytea
CLOBtext
NCLOBtext
BLOBbytea
RAWbytea
ROWIDoid
FLOATdouble precision
DECdecimal
DECIMALdecimal
DOUBLE PRECISIONdouble precision
INTint
INTERGEinteger
REALreal
SMALLINTsmallint
NUMBERnumeric
BINARY_FLOATdouble precision
BINARY_DOUBLEdouble precision
TIMESTAMPtimestamp
XMLTYPExml
BINARY_INTEGERinteger
PLS_INTEGERinteger
TIMESTAMP WITH TIME ZONEtimestamp with time zone
TIMESTAMP WITH LOCAL TIME ZONEtimestamp with time zone


原文链接
本文为云栖社区原创内容，未经允许不得转载。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/518673.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

生产环境使用HBase，你必须知道的最佳实践

生产环境使用HBase，你必须知道的最佳实践

来源 | 阿丸笔记封图| CSDN 下载于视觉中国前面&#xff0c;我们已经打下了很多关于HBase的理论基础&#xff0c;今天&#xff0c;我们主要聊聊在实际开发使用HBase中&#xff0c;需要关注的一些最佳实践经验。Schema设计七大原则1&#xff09;每个region的大小应该控制在10G到…
阅读更多...
PL/SQL提示“ORA-01722：无效数字”

PL/SQL提示“ORA-01722：无效数字”

解决方案:
阅读更多...
消息点击率翻倍的背后——闲鱼无侵入可扩展IFTTT系统

消息点击率翻倍的背后——闲鱼无侵入可扩展IFTTT系统

作者&#xff1a;闲鱼技术-剑辛 一、面临问题 在闲鱼生态里&#xff0c;用户之间会有很多种关系。其中大部分关系是由买家触发&#xff0c;联系到卖家&#xff0c;比如买家通过搜索、收藏、聊天等动作与卖家产生联系&#xff1b;另外一部分是平台与用户之间的关系。对这些关系…
阅读更多...
2019阿里云618大促主会场全攻略

2019阿里云618大促主会场全攻略

2019阿里云618大促活动已经于6月16日正式开启&#xff0c;从已开放的活动页面来看&#xff0c;整场大促活动由爆款拼团、满额最高返6000、上云接力赛分享集赞赢6.18万大奖三大活动组成。 在618这个年中的大幅度优惠促销日&#xff0c;怎样才能花最少的钱配置最特惠的云服务&am…
阅读更多...
Redis-6.2.5 安装 Linux环境(单机)

Redis-6.2.5 安装 Linux环境(单机)

文章目录1. 安装依赖环境2. 升级GCC3. 在线下载4. 解压5. 编译6. 安装7. 前台启动8. 后台启动9. 配置开机启动10. 常用命令11. 评析1. 安装依赖环境 yum install -y gcc-c autoconf automaker2. 升级GCC 这里说明一下&#xff0c;在编译之前&#xff1a;在编译之前需要升级gcc…
阅读更多...
Java-递归

Java-递归

public class Demo05 {public static void main(String[] args) {System.out.println(f(5));}// 5! 5*4*3*2*1 阶乘public static int f(int n){if (n1){return 1;} else {return n*f(n-1);}} }递归特别消耗资源&#xff0c;如果嵌套太多层就不建议使用了 https://www.bilibi…
阅读更多...
为什么说优秀架构师往往是一个悲观主义者？

为什么说优秀架构师往往是一个悲观主义者？

阿里妹导读&#xff1a;18年前&#xff0c;200家企业由于在事故中信息系统遭到严重破坏而永远地关闭了。这样的事故引发了后人深思&#xff0c;对于工程师而言&#xff0c;不仅要求设计的系统足够强壮&#xff0c;还需要具备考虑失败的能力&#xff0c;当失败场景悉数被考虑周全…
阅读更多...
石锤！今年Python要过苦日子了？ 程序员：我疯了！

石锤！今年Python要过苦日子了？ 程序员：我疯了！

Python的好日子到头了&#xff1f;Python终于要回归现实了&#xff1f;所有程序员&#xff0c;刚刚一份报告把Python的真相撕开了&#xff01;不信你看&#xff1a;Python今年要跑路&#xff1f;三份报告炸出真相....「人生苦短&#xff0c;钱多事少&#xff0c;快用Python」&a…
阅读更多...
Redis 基本数据类型试炼

Redis 基本数据类型试炼

文章目录1. String 类型2. 散列hashes3. 列表lists&#xff08;双向链表&#xff09;4. 集合set(自动去重)5. 有序集合sorted(自动去重)1. String 类型 # 设置单个值 set key value# 获取单个值 get key# 设置多个值 mset key1 value1 key2 value2 。。。# 获取多个值 mget …
阅读更多...
ECS事件通知之创建失败事件

ECS事件通知之创建失败事件

ECS提供了批量实例创建接口&#xff0c;可以一次调用创建最多100台实例。批量创建接口可以完成批量实例的创建、启动、IP分配等流程&#xff0c;可以快速完成实例资源的扩容。 在实例的创建过程中&#xff08;实际后台异步创建&#xff09;&#xff0c;库存和VSwitch中私网IP的…
阅读更多...
安装 kivy

安装 kivy

系统&#xff1a;Windows10 64位 python 3.7.6 最好管理员身份打开 命令行窗口pip安装 kivy 依赖 ——在 windows 命令行中&#xff0c;执行以下命令 pip3 install docutils pygments pypiwin32 kivy.deps.sdl2 kivy.deps.glew -i http://pypi.douban.com/simple --trusted-h…
阅读更多...
HSF/Dubbo序列化时的LocalDateTime, Instant的性能问题

HSF/Dubbo序列化时的LocalDateTime, Instant的性能问题

来源 在对Dubbo新版本做性能压测时&#xff0c;无意中发现对用例中某个TO&#xff08;Transfer Object&#xff09;类的一属性字段稍作修改&#xff0c;由Date变成LocalDateTime&#xff0c;结果是吞吐量由近5w变成了2w&#xff0c;RT由9ms升指90ms。 在线的系统&#xff0c;拼…
阅读更多...
Java-数组的声明与创建

Java-数组的声明与创建

public class ArrayDemo01 {// 变量的类型 变量的名字 变量的值&#xff1b;public static void main(String[] args) {// 数组定义方式有两种&#xff0c;但是推荐第一个int[] nums; // 1. 声明一个数组 // int nums1[];nums new int[10]; // 2. 创建一个数组// …
阅读更多...
云上快速搭建Serverless AI实验室

云上快速搭建Serverless AI实验室

Serverless Kubernetes和ACK虚拟节点都已基于ECI提供GPU容器实例功能&#xff0c;让用户在云上低成本快速搭建serverless AI实验室&#xff0c;用户无需维护服务器和GPU基础运行环境&#xff0c;极大降低AI平台运维的负担&#xff0c;显著提升整体计算效率。 如何使用GPU容器实…
阅读更多...
Vim快速移动光标至行首和行尾

Vim快速移动光标至行首和行尾

1、 需要按行快速移动光标时&#xff0c;可以使用键盘上的编辑键Home&#xff0c;快速将光标移动至当前行的行首。除此之外&#xff0c;也可以在命令模式中使用快捷键"^"&#xff08;即Shift6&#xff09;或0&#xff08;数字0&#xff09;。 2、 如果要快速移动光标…
阅读更多...
十分钟上手 ES 2020 新特性

十分钟上手 ES 2020 新特性

作者 | 浪里行舟责编 | 郭芮ES2020 是 ECMAScript 对应 2020 年的版本。这个版本不像 ES6 (ES2015)那样包含大量新特性。但也添加了许多有趣且有用的特性。本文的代码地址&#xff1a;https://github.com/ljianshu/Blog本文以简单的代码示例来介绍 ES2020新特性。这样&#xff…
阅读更多...
时延敏感业务低概率超时问题分析

时延敏感业务低概率超时问题分析

前言 作为阿里云底层提供的基础设施&#xff0c;内部的物理网络和许多网络产品在数据平面给客户的可操作性并不高&#xff0c;从一定程度上来说是个黑盒。当然&#xff0c;在传统的IDC环境&#xff0c;业务和物理网络之间也存在同样的隔阂。所以在遇到业务卡顿、延迟、不通等问…
阅读更多...
IDEA 自动删除无引用依赖

IDEA 自动删除无引用依赖

阅读更多...
Java-数组 三种初始化及内存分析

Java-数组 三种初始化及内存分析

声明的时候数组并不存在&#xff0c;创建的时候数组才真正的存在 数组初始化 除了八大基本类型&#xff0c;其他都是引用类型 public class ArrayDemo02 {public static void main(String[] args) {// 静态初始化&#xff1a; 创建 赋值int[] a {1,2,3,4};System.out.print…
阅读更多...
十分钟上线 - 函数计算构建支付宝小程序的后端

十分钟上线 - 函数计算构建支付宝小程序的后端

阿里云函数计算服务(FunctionCompute&#xff0c;FC)是一个事件驱动的全托管计算服务。通过函数计算与云端各个服务的广泛集成&#xff0c;开发者只需要编写函数代码&#xff0c;就能够快速地开发出弹性高可用的后端系统。接下来我们使用FC&#xff0c;来快速实现一个图片转换服…
阅读更多...
最新文章

Copyright @ 2022~2023