【MogDB】MogDB5.2.0重磅发布第七篇-支持PLSQL编译依赖

news2024/11/13 10:14:27

一、前言

在原生PG中，创建一个自定义函数或者存储过程，如果出入参的类型不存在，那么创建将会报错；但在ORACLE中仍然可以创建，只是状态为失效，后续补上缺少的类型即可。而原生PG则必须依照特定的顺序来创建数据库对象。openGauss2.1版本起新增了package这种可以内建类型、函数、过程的对象，整个依赖关系变得更加复杂，自动化迁移工具已经无法一次性自动将ORACLE的全部对象在openGauss中进行一次性创建。

在某客户项目中，MogDB联合openGauss社区，由社区提供初版代码，MogDB侧进行大范围（真实应用系统中数百万行存储过程代码的各种混合场景）的测试验证及BUG修复，完成了PLSQL编译依赖这一重要功能；另外，MogDB5.2.0版本中，相较于openGauss 6.0版本，还额外增加了PLSQL增量编译这个特性。
注意，本文以MogDB5.2.0版本进行演示，部分实现和openGauss6.0中的PLSQL编译依赖存在区别。

二、常见场景

1.创建一个package ，其中有一个function的入参是一个自定义类型，但该自定义类型还没创建

在不开启编译依赖功能时，这个场景会报错。“ERROR:”，意味着该语句执行不成功，因此这个包也没有创建到数据库中,所以也无法再接着创建package body

openGauss=# create package pkg_test1 is
openGauss$# function f1(i ty_xyz) return int;
openGauss$# end pkg_test1;
openGauss$# /
ERROR:  type ty_xyz does not exist
openGauss=#

如果开启了编译依赖功能，则可以创建成功，并同时发出警告“WARNNING:”

MogDB=> create package pkg_test1 is
MogDB$> function f1(i ty_xyz) return int;
MogDB$> end pkg_test1;
MogDB$> /
WARNING:  Type ty_xyz does not exist.
WARNING:  The header information of function f1 is not defined.
CONTEXT:  compilation of PL/pgSQL package or object near line 1
WARNING:  Package or object created with compilation errors.
CREATE PACKAGE
MogDB=>

继续创建package body和缺少的类型

MogDB=> create package body pkg_test1 is
MogDB$> function f1(i ty_xyz) return int is
MogDB$> begin
MogDB$> return 1;
MogDB$> end;
MogDB$> end pkg_test1;
MogDB$> /
WARNING:  Type ty_xyz does not exist.
WARNING:  The header information of function f1 is not defined.
CONTEXT:  compilation of PL/pgSQL package or object near line 1
WARNING:  The header information of function f1 is not defined.
CONTEXT:  compilation of PL/pgSQL package or object near line 2
WARNING:  Package or object Body created with compilation errors.
CREATE PACKAGE BODY
MogDB=> create type ty_xyz is object(a int);
MogDB$> /
CREATE OBJECT TYPE
MogDB=>

就可以正常调用函数了

MogDB=> call pkg_test1.f1(ty_xyz(1));
 f1
----
  1
(1 row)

到这里，可能会有人说，制定一个开发规范，必须先建自定义类型，再建依赖这个自定义类型的包不就好了嘛！
且不谈如果对象出现了互相依赖怎么办，如果这个时候开发人员要修改已经创建的自定义类型怎么办？
在openGauss5.0版本中，不支持create or replace type（OG6.0支持了，但有一些功能约束），因此想要修改一个自定义类型，必须先把它drop掉，然后再创建。但是由于这个类型被函数所依赖了，无法drop，提示要加cascade

openGauss=# drop type ty_xyz;
ERROR:  cannot drop type ty_xyz because other objects depend on it
DETAIL:  function public.f1(ty_xyz) depends on type ty_xyz
HINT:  Use DROP ... CASCADE to drop the dependent objects too.

如果加cascade去drop

openGauss=# drop type ty_xyz cascade;
NOTICE:  drop cascades to function public.f1(ty_xyz)
DROP TYPE
openGauss=# select pkgname from gs_package where pkgname='pkg_test1';
  pkgname
-----------
 pkg_test1
(1 row)
openGauss=# select count(1) from pg_proc where proname='f1';
 count
-------
     0
(1 row)

会发现包还在，但里面的函数不见了，引起元数据缺失。就算此时再把这个类型补上去，丢失的函数也不会自动补回来。如果启用了PLSQL编译依赖功能，则不会存在此问题，因为删除类型的时候就不会去删除依赖这个类型的对象了。

2.package A中的function入参类型是package B中定义的类型，修改package B并replace

在openGauss5.0版本中，先按顺序创建两个package

openGauss=# create package pkg_test_b is
openGauss$# type sty_123 is record(a int);
openGauss$# end pkg_test_b;
openGauss$# /
CREATE PACKAGE
openGauss=# create package pkg_test_a is
openGauss$# function f2( i pkg_test_b.sty_123) return int;
openGauss$# end pkg_test_a;
openGauss$# /
CREATE PACKAGE
openGauss=# create package body pkg_test_a is
openGauss$# function f2( i pkg_test_b.sty_123) return int is
openGauss$# begin
openGauss$# return 1;
openGauss$# end;
openGauss$# end pkg_test_a;
openGauss$# /
CREATE PACKAGE BODY
openGauss=#

此时调用函数是正常的

openGauss=# call pkg_test_a.f2(null);
 f2
----
  1
(1 row)

然后修改pkg_test_b，原本的代码不动，在里面新增一个类型

openGauss=# create or replace package pkg_test_b is
openGauss$# type sty_123 is record(a int);
openGauss$# type sty_456 is record(b int);
openGauss$# end pkg_test_b;
openGauss$# /
CREATE PACKAGE
openGauss$#

再去调用这个函数

openGauss=# call pkg_test_a.f2(null);
ERROR:  function "f2" doesn't exist

结果函数不存在了，但这个操作明明没有对pkg_test_a进行直接操作。这是因为replace pkg_test_b的时候，对pkg_test_b里所有的对象做了自动的级联删除，依赖了这个包的其他对象，都被自动删了，和前一个场景中提到的问题一样。
如果开启了PLSQL编译依赖功能，则该问题也不再存在

三、原理说明

在openGauss6.0.0版本中，通过设置behavior_compat_options=plpgsql_dependency来开启此功能；
在MogDB 5.2.0版本中，通过设置enable_plsql_compiledepend=on来开启此功能。

对于每一个创建成功的function，必须明确头部的参数类型，在pg_proc中会记录对应这些类型的oid。当引用的类型不存在时，则无法获取其oid。因此该功能引入了一个undefined类型（oid=4408）,只要根据类型名称找不到类型，就先将该函数的该参数类型设置为undefined；在gs_dependencies_obj、gs_dependencies中记录引用的依赖关系；并且pg_object中记录该procedure为失效状态

MogDB=> create procedure f_test_1 (l_abc abc,l_def out def)
MogDB-> is
MogDB$> begin
MogDB$> null;
MogDB$> end;
MogDB$> /
WARNING:  The header information of function f_test_1 is not defined.
CONTEXT:  compilation of PL/pgSQL function "f_test_1" near line 2
WARNING:  Procedure created with compilation errors.
CREATE PROCEDURE
MogDB=>

MogDB=> \x
Expanded display is on.
MogDB=> select oid,* from pg_proc where proname='f_test_1';
-[ RECORD 1 ]-------+------------------------
oid                 | 26632
proname             | f_test_1
pronamespace        | 16783
proowner            | 16781
prolang             | 12563
procost             | 100
prorows             | 0
provariadic         | 0
protransform        | -
proisagg            | f
proiswindow         | f
prosecdef           | t
proleakproof        | f
proisstrict         | f
proretset           | f
provolatile         | v
pronargs            | 1
pronargdefaults     | 0
prorettype          | 4408
proargtypes         | 4408
proallargtypes      | {4408,4408}
proargmodes         | {i,o}
proargnames         | {l_abc,l_def}
proargdefaults      |
prosrc              |  DECLARE
                    | begin
                    | null;
                    | end
probin              |
proconfig           |
proacl              | {system=X/system}
prodefaultargpos    |
fencedmode          | f
proshippable        | f
propackage          | f
prokind             | p
proargsrc           | l_abc abc,l_def out def
propackageid        | 0
proisprivate        | f
proargtypesext      |
prodefaultargposext |
allargtypes         | 4408 4408
allargtypesext      |
objecttypeoid       |
methodtype          |
isfinal             |
instantiable        |
overriding          |
inherited           |

MogDB=>

MogDB=> select oid,* from pg_catalog.gs_dependencies_obj where name like 'f_test_1%' or name in ('abc','def');
-[ RECORD 1 ]------------------------------------------------------------------------------------------------------------------------------------------------------------------------
oid         | 26630
schemaname  | system
packagename | null
type        | 3
name        | abc
objnode     | {DependenciesUndefined}
-[ RECORD 2 ]------------------------------------------------------------------------------------------------------------------------------------------------------------------------
oid         | 26631
schemaname  | system
packagename | null
type        | 3
name        | def
objnode     | {DependenciesUndefined}
-[ RECORD 3 ]------------------------------------------------------------------------------------------------------------------------------------------------------------------------
oid         | 26633
schemaname  | system
packagename | null
type        | 5
name        | f_test_1(pg_catalog.undefined,pg_catalog.undefined)
objnode     | {DependenciesProchead :undefined true :proName f_test_1 :proArgSrc l_abc\ abc,l_def\ out\ def :funcHeadSrc create\ procedure\ f_test_1\ \(l_abc\ abc,l_def\ out\ def\)}


MogDB=> select * from pg_catalog.gs_dependencies where objectname  like 'f_test_1%' ;
-[ RECORD 1 ]----------------------------------------------------
schemaname  | system
packagename | null
refobjpos   | 4
refobjoid   | 26630
objectname  | f_test_1(pg_catalog.undefined,pg_catalog.undefined)
-[ RECORD 2 ]----------------------------------------------------
schemaname  | system
packagename | null
refobjpos   | 4
refobjoid   | 26631
objectname  | f_test_1(pg_catalog.undefined,pg_catalog.undefined)

MogDB=>

MogDB=> select * from pg_object where object_oid=26632;
-[ RECORD 1 ]------------------------------
object_oid  | 26632
object_type | P
creator     | 16781
ctime       | 2024-11-06 14:12:06.944254+08
mtime       | 2024-11-06 14:12:06.944254+08
createcsn   |
changecsn   |
valid       | f

MogDB=>

此时如果将不存在的类型补上,则procedure会自动根据类型名称更新相关表。
比如我们先把abc这个类型建上，可以发现procedure的Undefined类型只有一个了，但此时pg_object 里仍然是失效状态

MogDB=> create type abc is (a int);
CREATE TYPE
MogDB=> select oid from pg_type where typname='abc';
-[ RECORD 1 ]
oid | 26636
MogDB=> select oid,* from pg_catalog.gs_dependencies_obj where name like 'f_test_1%' or name in ('abc','def');
-[ RECORD 1 ]------------------------------------------------------------------------------------------------------------------------------------------------------------------------
oid         | 26631
schemaname  | system
packagename | null
type        | 3
name        | def
objnode     | {DependenciesUndefined}
-[ RECORD 2 ]------------------------------------------------------------------------------------------------------------------------------------------------------------------------
oid         | 26630
schemaname  | system
packagename | null
type        | 3
name        | abc
objnode     | {DependenciesType :typType c :typCategory C :attrInfo a:pg_catalog.int4, :isRel false :elemTypName <> :idxByTypName <> :baseTypeOid 0}
-[ RECORD 3 ]------------------------------------------------------------------------------------------------------------------------------------------------------------------------
oid         | 26633
schemaname  | system
packagename | null
type        | 5
name        | f_test_1(system.abc,pg_catalog.undefined)
objnode     | {DependenciesProchead :undefined true :proName f_test_1 :proArgSrc l_abc\ abc,l_def\ out\ def :funcHeadSrc create\ procedure\ f_test_1\ \(l_abc\ abc,l_def\ out\ def\)}

MogDB=> select * from pg_catalog.gs_dependencies where objectname  like 'f_test_1%' ;
-[ RECORD 1 ]------------------------------------------
schemaname  | system
packagename | null
refobjpos   | 4
refobjoid   | 26630
objectname  | f_test_1(system.abc,pg_catalog.undefined)
-[ RECORD 2 ]------------------------------------------
schemaname  | system
packagename | null
refobjpos   | 4
refobjoid   | 26631
objectname  | f_test_1(system.abc,pg_catalog.undefined)

MogDB=> select oid,* from pg_proc where proname='f_test_1';
-[ RECORD 1 ]-------+------------------------
oid                 | 26632
proname             | f_test_1
pronamespace        | 16783
proowner            | 16781
prolang             | 12563
procost             | 100
prorows             | 0
provariadic         | 0
protransform        | -
proisagg            | f
proiswindow         | f
prosecdef           | t
proleakproof        | f
proisstrict         | f
proretset           | f
provolatile         | v
pronargs            | 1
pronargdefaults     | 0
prorettype          | 4408
proargtypes         | 26636
proallargtypes      | {26636,4408}
proargmodes         | {i,o}
proargnames         | {l_abc,l_def}
proargdefaults      |
prosrc              |  DECLARE
                    | begin
                    | null;
                    | end
probin              |
proconfig           |
proacl              | {system=X/system}
prodefaultargpos    |
fencedmode          | f
proshippable        | f
propackage          | f
prokind             | p
proargsrc           | l_abc abc,l_def out def
propackageid        | 0
proisprivate        | f
proargtypesext      |
prodefaultargposext |
allargtypes         | 26636 4408
allargtypesext      |
objecttypeoid       |
methodtype          |
isfinal             |
instantiable        |
overriding          |
inherited           |

MogDB=>

MogDB=> select * from pg_object where object_oid=26632;
-[ RECORD 1 ]------------------------------
object_oid  | 26632
object_type | P
creator     | 16781
ctime       | 2024-11-06 14:12:06.944254+08
mtime       | 2024-11-06 14:12:06.944254+08
createcsn   |
changecsn   |
valid       | f

MogDB=>

我们接着把另一个类型补上

MogDB=> create type def is (a int);
CREATE TYPE
MogDB=> select oid from pg_type where typname='def';
-[ RECORD 1 ]
oid | 26643

MogDB=> select oid,* from pg_catalog.gs_dependencies_obj where name like 'f_test_1%' or name in ('abc','def');
-[ RECORD 1 ]-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
oid         | 26630
schemaname  | system
packagename | null
type        | 3
name        | abc
objnode     | {DependenciesType :typType c :typCategory C :attrInfo a:pg_catalog.int4, :isRel false :elemTypName <> :idxByTypName <> :baseTypeOid 0}
-[ RECORD 2 ]-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
oid         | 26631
schemaname  | system
packagename | null
type        | 3
name        | def
objnode     | {DependenciesType :typType c :typCategory C :attrInfo a:pg_catalog.int4, :isRel false :elemTypName <> :idxByTypName <> :baseTypeOid 0}
-[ RECORD 3 ]-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
oid         | 26633
schemaname  | system
packagename | null
type        | 5
name        | f_test_1(system.abc,system.def)
objnode     | {DependenciesProchead :undefined false :proName f_test_1 :proArgSrc l_abc\ abc,l_def\ out\ def :funcHeadSrc create\ procedure\ f_test_1\ \(l_abc\ abc,l_def\ out\ def\)}

MogDB=> select * from pg_catalog.gs_dependencies where objectname  like 'f_test_1%' ;
-[ RECORD 1 ]--------------------------------
schemaname  | system
packagename | null
refobjpos   | 4
refobjoid   | 26630
objectname  | f_test_1(system.abc,system.def)
-[ RECORD 2 ]--------------------------------
schemaname  | system
packagename | null
refobjpos   | 4
refobjoid   | 26631
objectname  | f_test_1(system.abc,system.def)

MogDB=> select oid,* from pg_proc where proname='f_test_1';
-[ RECORD 1 ]-------+------------------------
oid                 | 26632
proname             | f_test_1
pronamespace        | 16783
proowner            | 16781
prolang             | 12563
procost             | 100
prorows             | 0
provariadic         | 0
protransform        | -
proisagg            | f
proiswindow         | f
prosecdef           | t
proleakproof        | f
proisstrict         | f
proretset           | f
provolatile         | v
pronargs            | 1
pronargdefaults     | 0
prorettype          | 26643
proargtypes         | 26636
proallargtypes      | {26636,26643}
proargmodes         | {i,o}
proargnames         | {l_abc,l_def}
proargdefaults      |
prosrc              |  DECLARE
                    | begin
                    | null;
                    | end
probin              |
proconfig           |
proacl              | {system=X/system}
prodefaultargpos    |
fencedmode          | f
proshippable        | f
propackage          | f
prokind             | p
proargsrc           | l_abc abc,l_def out def
propackageid        | 0
proisprivate        | f
proargtypesext      |
prodefaultargposext |
allargtypes         | 26636 26643
allargtypesext      |
objecttypeoid       |
methodtype          |
isfinal             |
instantiable        |
overriding          |
inherited           |

MogDB=> select * from pg_object where object_oid=26632;
-[ RECORD 1 ]------------------------------
object_oid  | 26632
object_type | P
creator     | 16781
ctime       | 2024-11-06 14:12:06.944254+08
mtime       | 2024-11-06 14:12:06.944254+08
createcsn   |
changecsn   |
valid       | f

MogDB=>

可以看到这个procedure的参数没有undefined类型了，但是pg_object中仍然为失效状态，此时可以通过执行alter procedure {procedure_name} compile命令来让它重新编译，编译通过即更新为有效状态；或者直接执行这个procedure，也会触发自动编译。

MogDB=> alter procedure f_test_1 compile;
ALTER PROCEDURE
MogDB=> select * from pg_object where object_oid=26632;
-[ RECORD 1 ]------------------------------
object_oid  | 26632
object_type | P
creator     | 16781
ctime       | 2024-11-06 14:12:06.944254+08
mtime       | 2024-11-06 15:31:58.694414+08
createcsn   |
changecsn   | 24098
valid       | t

MogDB=>

如果此时再drop掉其中一个type,可以发现procedure里那个类型又变成了undefined，并且procedure也变成了失效状态

MogDB=> drop type abc;
DROP TYPE
MogDB=> select oid,* from pg_proc where proname='f_test_1';
-[ RECORD 1 ]-------+------------------------
oid                 | 26632
proname             | f_test_1
pronamespace        | 16783
proowner            | 16781
prolang             | 12563
procost             | 100
prorows             | 0
provariadic         | 0
protransform        | -
proisagg            | f
proiswindow         | f
prosecdef           | t
proleakproof        | f
proisstrict         | f
proretset           | f
provolatile         | v
pronargs            | 1
pronargdefaults     | 0
prorettype          | 26643
proargtypes         | 4408
proallargtypes      | {4408,26643}
proargmodes         | {i,o}
proargnames         | {l_abc,l_def}
proargdefaults      |
prosrc              |  DECLARE
                    | begin
                    | null;
                    | end
probin              |
proconfig           |
proacl              | {system=X/system}
prodefaultargpos    |
fencedmode          | f
proshippable        | f
propackage          | f
prokind             | p
proargsrc           | l_abc abc,l_def out def
propackageid        | 0
proisprivate        | f
proargtypesext      |
prodefaultargposext |
allargtypes         | 4408 26643
allargtypesext      |
objecttypeoid       |
methodtype          |
isfinal             |
instantiable        |
overriding          |
inherited           |

MogDB=>select oid,* from pg_catalog.gs_dependencies_obj where name like 'f_test_1%' or name in ('abc','def');
-[ RECORD 1 ]-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
oid         | 26631
schemaname  | system
packagename | null
type        | 3
name        | def
objnode     | {DependenciesType :typType c :typCategory C :attrInfo a:pg_catalog.int4, :isRel false :elemTypName <> :idxByTypName <> :baseTypeOid 0}
-[ RECORD 2 ]-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
oid         | 26630
schemaname  | system
packagename | null
type        | 3
name        | abc
objnode     | {DependenciesUndefined}
-[ RECORD 3 ]-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
oid         | 26644
schemaname  | system
packagename | null
type        | 5
name        | f_test_1(pg_catalog.undefined,system.def)
objnode     | {DependenciesProchead :undefined true :proName f_test_1 :proArgSrc l_abc\ abc,l_def\ out\ def :funcHeadSrc create\ or\ replace\ procedure\ f_test_1\ \(l_abc\ abc,l_def\ out\ def\)}

MogDB=> select * from pg_catalog.gs_dependencies where objectname  like 'f_test_1%' ;
-[ RECORD 1 ]------------------------------------------
schemaname  | system
packagename | null
refobjpos   | 4
refobjoid   | 26631
objectname  | f_test_1(pg_catalog.undefined,system.def)
-[ RECORD 2 ]------------------------------------------
schemaname  | system
packagename | null
refobjpos   | 4
refobjoid   | 26630
objectname  | f_test_1(pg_catalog.undefined,system.def)

MogDB=> select * from pg_object where object_oid=26632;
-[ RECORD 1 ]------------------------------
object_oid  | 26632
object_type | P
creator     | 16781
ctime       | 2024-11-06 14:12:06.944254+08
mtime       | 2024-11-06 15:31:58.694414+08
createcsn   |
changecsn   | 24098
valid       | f

以上即为这个功能的基本原理。
但MogDB将这个功能运用于真实的应用场景中，还遇到了不少问题。

四、初版方案的问题

1.并发编译

当有procedure失效时，此时如果同时有多个会话去执行这个procedure，则每个会话都会自动触发编译，并且去更新系统表，而并发更新系统表时，会出现tuple concurrently updated的报错。
https://gitee.com/opengauss/openGauss-server/issues/I9AZ7T
另外，这个自动编译功会尝试进行级联编译，则可能会出现在一个事务中，更新系统表中的多行记录，此时如果存储过程复杂，各种嵌套，那么很有可能出现有两个会话对系统表相同行的更新顺序不一样，从而触发deadlock。
https://gitee.com/opengauss/openGauss-server/issues/I991AN

有开发经验的自然会想到，要不要在每次编译单个对象时，先加行锁，然后抛个自治事务去编译，再回来释放这个行锁？我们对比了Oracle执行存储过程时的自动编译，发现存储过程有效状态变化与主事务之间没有关系，就算存储过程没执行完，事务没提交，存储过程依然从无效变成了有效。
最后openGauss/MogDB的确也采取了自动使用自治事务去编译这种方式去解决这个问题。

2.依赖关系过多的情况下，replace package非常慢

某客户自研了一些应用系统，将所有存储过程里会用到的类型，均在一个package里建了subtype，此时所有存储过程都不再使用基本类型，而是统一使用这个package里的subtype。某天需要对这个package新增一个subtype，就会执行create or replace package 。
但openGauss对replace package的操作为，先逐个drop掉这个package里的所有type/function/procedure，然后再重新执行create package，逐个建立package里的type/function/procedure。试想，如果有上万个存储过程使用了这个package里的subtype作为参数类型，那么把type给drop后，则需要把这上万个存储过程的系统元数据全部更新一次，中间还会触发到级联编译，整个处理就变得非常慢。当时第一版代码进行这个场景的验证时，执行了1小时没执行完。

3.replace package会导致使用了这个package内函数的自定义视图，查询报错

openGauss=# show behavior_compat_options;
 behavior_compat_options
-------------------------
 plpgsql_dependency
(1 row)

openGauss=# create package pkg_test_view is
openGauss$# function f1 return int;
openGauss$# end pkg_test_view;
openGauss$# /
CREATE PACKAGE
openGauss=#
openGauss=# create package body pkg_test_view is
openGauss$# function f1 return int is
openGauss$# begin
openGauss$# return 1;
openGauss$# end;
openGauss$# end pkg_test_view;
openGauss$# /
CREATE PACKAGE BODY
openGauss=# create view view_test as
openGauss-# select pkg_test_view.f1() as a;
CREATE VIEW
openGauss=# select * from view_test;
 a
---
 1
(1 row)

openGauss=# create or replace package pkg_test_view is
openGauss$# v1 int;
openGauss$# function f1 return int;
openGauss$# end pkg_test_view;
openGauss$# /
CREATE PACKAGE
openGauss=#
openGauss=# create or replace package body pkg_test_view is
openGauss$# function f1 return int is
openGauss$# begin
openGauss$# return 1;
openGauss$# end;
openGauss$# end pkg_test_view;
openGauss$# /
CREATE PACKAGE BODY
openGauss=# select * from view_test;
ERROR:  cache lookup failed for function 23296
openGauss=# select * from pg_views where viewname='view_test';
ERROR:  cache lookup failed for function 23296
CONTEXT:  referenced column: definition
openGauss=# select pg_get_viewdef('view_test');
ERROR:  cache lookup failed for function 23296
CONTEXT:  referenced column: pg_get_viewdef
openGauss=#

[og600@kylinv10sp3-node1 ~]$ gs_dump postgres -t view_test
gs_dump[port='21200'][postgres][2024-11-07 09:55:33]: Begin scanning database.
Progress: [==================================================] 100% (38/37, cur_step/total_step). finish scanning database
gs_dump[port='21200'][postgres][2024-11-07 09:55:33]: Finish scanning database.
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33] WARNING: could not resolve dependency loop among these items:
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33]   FUNCTION test_f3  (ID 442 OID 16420)
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33]   object type 21  (ID 4065 OID 16419)
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33]   PRE-DATA BOUNDARY  (ID 4069)
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33] WARNING: could not resolve dependency loop among these items:
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33]   FUNCTION test_f3  (ID 444 OID 16424)
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33]   object type 21  (ID 4066 OID 16423)
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33]   PRE-DATA BOUNDARY  (ID 4069)
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33] WARNING: could not resolve dependency loop among these items:
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33]   FUNCTION x  (ID 445 OID 23291)
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33]   object type 21  (ID 4067 OID 23290)
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33]   PRE-DATA BOUNDARY  (ID 4069)
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33] WARNING: could not resolve dependency loop among these items:
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33]   FUNCTION f1  (ID 447 OID 23301)
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33]   object type 21  (ID 4068 OID 23295)
gs_dump: [port='21200'] [postgres] [sorter] [2024-11-07 09:55:33]   PRE-DATA BOUNDARY  (ID 4069)
gs_dump[port='21200'][postgres][2024-11-07 09:55:33]: Start dumping objects
gs_dump: [port='21200'] [postgres] [archiver (db)] [2024-11-07 09:55:33] query failed: ERROR:  cache lookup failed for function 23296
CONTEXT:  referenced column: viewdef
gs_dump: [port='21200'] [postgres] [archiver (db)] [2024-11-07 09:55:33] query was: SELECT pg_catalog.pg_get_viewdef('23297'::pg_catalog.oid) AS viewdef
[og600@kylinv10sp3-node1 ~]$

问题2中说明了openGauss对replace package的处理方式，这个处理方式同时也会导致自定义视图无法查询ERROR: cache lookup failed for function 23296，因为函数被自动drop重建了，哪怕这个函数本身没有任何变化，这个函数的oid也不是之前的值了。而且出现这个问题的视图还无法查询视图的定义SQL，逻辑备份也会被中断。如果没有备份视图的原始SQL，那么这个问题将无法修复。MogDB在之前的版本中，相较openGauss，额外有多一个获取视图原始定义的函数pg_get_ori_viewdef，在遇到这个问题时，还有办法补救。

另外，openGauss这种处理方式，意味着修改package时，哪怕package body没有任何变化，也必须把package和package body的创建代码都执行一次。

五、MogDB对PLSQL编译依赖功能的额外增强

MogDB 5.2.0版本 ,在PLSQL编译依赖这个功能的基础上，额外增加了对replace package的增量处理逻辑–PLSQL增量编译。也就是说，在MogDB 5.2.0版本中，replace package，只会对系统表进行最低限度的变更，不再全部drop包内的全部对象，而是对type/function/procedure进行replace操作(replace 操作一般不变oid)；如果function head没变，则不会触发plsql编译依赖冗长的处理逻辑，如果function body也没变，则replace的操作也会直接忽略。简单来说，就是处理速度变快，而且不会丢东西了。

MogDB=> create view view_test as
MogDB$> select pkg_test_view.f1() as a;
CREATE VIEW
MogDB=> select * from view_test;
 a
---
 1
(1 row)

MogDB=> create or replace package pkg_test_view is
MogDB$> function f1 return int;
MogDB$> end pkg_test_view;
MogDB$> /
CREATE PACKAGE
MogDB=>
MogDB=> create or replace package body pkg_test_view is
MogDB$> function f1 return int is
MogDB$> begin
MogDB$> return 1;
MogDB$> end;
MogDB$> end pkg_test_view;
MogDB$> /
CREATE PACKAGE BODY
MogDB=> create or replace package pkg_test_view is
MogDB$> i int;
MogDB$> function f1 return int;
MogDB$> end pkg_test_view;
MogDB$> /
CREATE PACKAGE
MogDB=> select * from view_test;--package头里加东西也不需要重建body了
 a
---
 1
(1 row)

MogDB=>create or replace package body pkg_test_view is
MogDB$> function f1 return int is
MogDB$> begin
MogDB$> return 1;
MogDB$> end;
MogDB$> end pkg_test_view;
MogDB$> /
CREATE PACKAGE BODY
MogDB=> select * from view_test;
 a
---
 1
(1 row)

MogDB=>

MogDB在openGauss的基础上进行创新，加入了PLSQL增量编译逻辑，一次性解决了历史遗留的多个问题。

六、总结

对于拥有非常多存储过程的应用系统，尤其是那些有非常多package及自定义类型的应用来说，PLSQL编译依赖是必须要有的一个功能，否则根本无法实现从ORACLE到国产库的顺利迁移。对于PG/OG系数据库来说，这也是一个非常复杂的功能，因为存在既定框架的限制，需要相当大的研发测试投入，以及大量的真实测试场景输入，才可能把这个功能做完善做稳定。
MogDB 5.2.0支持这个功能后，对ORACLE应用迁移将变得更加顺畅。

  • 本文作者： DarkAthena
  • 本文链接： https://www.darkathena.top/archives/mogdb-5.2.0-support-plsql-dependencies
  • 版权声明： 本博客所有文章除特别声明外，均采用CC BY-NC-SA 3.0 许可协议。转载请注明出处

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

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

相关文章

CSS教程（三）- CSS 三大特性

CSS教程（三）- CSS 三大特性

1. 层叠性 介绍 多组CSS样式共同作用于一个元素&#xff0c;就会出现 覆盖&#xff08;层叠&#xff09; 另一个冲突的样式。 层叠原则 样式冲突&#xff1a;遵循就近原则&#xff08;哪个样式离结构近&#xff0c;就执行哪个样式&#xff09; 样式不冲突&#xff0c;就不会重…
阅读更多...
CyclicBarrier使用详解及遇到的坑

CyclicBarrier使用详解及遇到的坑

上一篇文章讲的是关于是使用CountDownLatch实现生成年底报告遇到的问题&#xff0c;这个计数器和CyclicBarrier也有类似功能&#xff0c;但是应用场景不同。 一、应用场景 CountDownLatch&#xff1a; 有ABCD四个任务&#xff0c;ABC是并行执行,等ABC三个任务都执行完…
阅读更多...
Java-I/O框架14：Properties集合及使用

Java-I/O框架14：Properties集合及使用

视频链接&#xff1a;16.32 Properties使用&#xff08;2&#xff09;_哔哩哔哩_bilibilihttps://www.bilibili.com/video/BV1Tz4y1X7H7?spm_id_from333.788.player.switch&vd_sourceb5775c3a4ea16a5306db9c7c1c1486b5&p32 1.Properties集合 特性&#xff1a; 存储…
阅读更多...
Windows下mysql数据库备份策略

Windows下mysql数据库备份策略

Windows下mysql的增量备份和全量备份&#xff0c;并利用schtasks设置定时任务执行bat脚本。 一、备份要求 序号 备份类型 备份频次 备份时间 1 增量备份 每周一-每周六各一次 18:00:00 2 全量备份 每周日一次 18:00:00 二、备份方法 2.1增量备份 2.1.1准备工作…
阅读更多...
架构师备考-概念背诵（软件工程）

架构师备考-概念背诵（软件工程）

软件工程 软件开发生命周期： 软件定义时期：包括可行性研究和详细需求分析过程，任务是确定软件开发工程必须完成的总目标，具体可分成问题定义、可行性研究、需求分析等。软件开发时期：就是软件的设计与实现，可分成概要设计、详细设计、编码、测试等。软件运行和维护：就是…
阅读更多...
【Linux】Linux入门实操——vim、目录结构、远程登录、重启注销

【Linux】Linux入门实操——vim、目录结构、远程登录、重启注销

一、Linux 概述 1. 应用领域 服务器领域 linux在服务器领域是最强的&#xff0c;因为它免费、开源、稳定。 嵌入式领域 它的内核最小可以达到几百KB, 可根据需求对软件剪裁&#xff0c;近些年在嵌入式领域得到了很大的应用。 主要应用&#xff1a;机顶盒、数字电视、网络…
阅读更多...
【Java项目】基于SpringBoot的【生鲜交易系统】

【Java项目】基于SpringBoot的【生鲜交易系统】

技术简介&#xff1a; 系统软件架构选择B/S模式、java技术和MySQL数据库等&#xff0c;总体功能模块运用自顶向下的分层思想。 系统简介&#xff1a; 考虑到实际生活中在生鲜交易方面的需要以及对该系统认真的分析,将系统权限按管理员&#xff0c;用户这两类涉及用户划分。 (…
阅读更多...
AI Weekly『11月4-10日』: Anthropic发布Claude 3.5 Haiku，腾讯开源混元-Large模型！

AI Weekly『11月4-10日』: Anthropic发布Claude 3.5 Haiku，腾讯开源混元-Large模型！

大家好&#xff0c;我是木易&#xff0c;一个持续关注AI领域的互联网技术产品经理&#xff0c;国内Top2本科&#xff0c;美国Top10 CS研究生&#xff0c;MBA。我坚信AI是普通人变强的“外挂”&#xff0c;专注于分享AI全维度知识&#xff0c;包括但不限于AI科普&#xff0c;AI工…
阅读更多...
贪心算法day3（最长递增序列问题）

贪心算法day3（最长递增序列问题）

目录 1.最长递增三元子序列 2.最长连续递增序列 1.最长递增三元子序列 题目链接&#xff1a;. - 力扣&#xff08;LeetCode&#xff09; 思路&#xff1a;我们只需要设置两个数进行比较就好。设a为nums[0]&#xff0c;b 为一个无穷大的数&#xff0c;只要有比a小的数字就赋值…
阅读更多...
vue实现图片无限滚动播放

vue实现图片无限滚动播放

本人vue新手菜鸡&#xff0c;文章为自己在项目中遇到问题的记录&#xff0c;如有不足还请大佬指正 文章目录 实现效果代码展示总结 因为刚接触vue&#xff0c;本想着看看能不能用一些element的组件实现图片的轮播效果&#xff0c;尝试使用过element-UI里的走马灯Carouse&#x…
阅读更多...
[ 内网渗透实战篇-2 ] 父域子域架构的搭建与安装域环境判断域控定位组策略域森林架构配置信任关系

[ 内网渗透实战篇-2 ] 父域子域架构的搭建与安装域环境判断域控定位组策略域森林架构配置信任关系

&#x1f36c; 博主介绍 &#x1f468;‍&#x1f393; 博主介绍&#xff1a;大家好&#xff0c;我是 _PowerShell &#xff0c;很高兴认识大家~ ✨主攻领域&#xff1a;【渗透领域】【数据通信】 【通讯安全】 【web安全】【面试分析】 &#x1f389;点赞➕评论➕收藏 养成习…
阅读更多...
Follow软件的使用入门教程

Follow软件的使用入门教程

开篇 看到很多兄弟还不知道怎么用这个当下爆火的浏览器&#xff01;在这里简单给需要入门的小伙伴一些建议&#xff1a; 介绍 简单解释一下&#xff0c;RSS 意思是简易信息聚合&#xff0c;用户可以通过 RSS 阅读器或聚合工具自主订阅并浏览各个平台的内容源&#xff0c;不用…
阅读更多...
esp32学习：用虫洞ESP32开发板，快速实现无线图传

esp32学习：用虫洞ESP32开发板，快速实现无线图传

我们的虫洞ESP32-S3-EYE开发板&#xff0c;能够完美运行esp who AI代码&#xff0c;所以实现无线图传那是非常容易的&#xff0c;我们先看看esp who代码库中examples目录&#xff1a; 里面有比较多的web例程&#xff0c;在这些例程下&#xff0c;稍作修改&#xff0c;就可以快速…
阅读更多...
最新三维视觉下的扩散模型综述——Diffusion Models in 3D Vision: A Survey

最新三维视觉下的扩散模型综述——Diffusion Models in 3D Vision: A Survey

目录 摘要 一、引言 二、扩散模型简介 A.扩散模型的介绍 B.扩散模型的数学基础 C.扩散模型的变体 D.三维视觉中的生成过程 三、三维视觉基础 A.三维表示 B.三维视觉中的深度学习方法 C.3D视觉中的挑战 四、三维扩散生成任务 A.无条件生成 B.图像到三维 C.文本到…
阅读更多...
JavaSE：运算符 (学习笔记)

JavaSE：运算符 (学习笔记)

目录 一&#xff0c;算术运算符 【1】 共同点&#xff1a; 【2】 不同点&#xff1a; 二&#xff0c;关系运算符 三&#xff0c;逻辑运算符 2&#xff0c;&和&&的区别和联系 { |和||的区别和联系 }---两题类似 四&#xff0c;赋值运算符 五&#xff0c;拓展…
阅读更多...
strtok函数详解

strtok函数详解

strtok函数 strtok 函数是一个字符串分割函数&#xff0c;用于将字符串分割成一系列的标记。这个函数通过一组分隔符字符来确定标记的边界&#xff0c;每次调用都会返回字符串中的下一个标记&#xff0c;并且将原始字符串中的分隔符替换为空字符‘\0’&#xff0c;从而实际上是…
阅读更多...
题目练习之二叉树那些事儿（续集）

题目练习之二叉树那些事儿（续集）

♥♥♥~~~~~~欢迎光临知星小度博客空间~~~~~~♥♥♥ ♥♥♥零星地变得优秀~也能拼凑出星河~♥♥♥ ♥♥♥我们一起努力成为更好的自己~♥♥♥ ♥♥♥如果这一篇博客对你有帮助~别忘了点赞分享哦~♥♥♥ ♥♥♥如果有什么问题可以评论区留言或者私信我哦~♥♥♥ ✨✨✨✨✨✨个人…
阅读更多...
【入门篇】确定字符串是否包含唯一字符——多语言版本

【入门篇】确定字符串是否包含唯一字符——多语言版本

题目跳转&#xff1a;确定字符串是否包含唯一字符 题目解析 这个问题要求我们判断一个字符串中的字符是否唯一&#xff08;忽略字母的大小写&#xff09;&#xff0c;并输出相应的结果。如果字符串中所有的字符都是唯一的&#xff0c;输出 YES&#xff1b;否则&#xff0c;输…
阅读更多...
ConcurrentModificationException：检测到并发修改完美解决方法

ConcurrentModificationException：检测到并发修改完美解决方法

&#x1f6a6; ConcurrentModificationException&#xff1a;检测到并发修改完美解决方法 &#x1f4a1; &#x1f6a6; ConcurrentModificationException&#xff1a;检测到并发修改完美解决方法 &#x1f4a1;摘要1. 什么是ConcurrentModificationException&#xff1f;&…
阅读更多...
并查集 How many tables(hdu 1213) How many answers are wrong(hdu 3038)

并查集 How many tables(hdu 1213) How many answers are wrong(hdu 3038)

目录 前言 并查集 并查集的初始化 并查集的合并 并查集合并的优化&#xff0c;路径压缩 How many tables(hdu 1213) 问题描述 输入 输出 问题分析 代码 带权并查集 How many answers are wrong(hdu 3038) 问题描述 输入 输出 问题分析 代码 前言 感觉并查集总共有两个应…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023