opengauss存储过程功能全面升级，支持package,pldebugger等诸多新特性 -m6米乐安卓版下载

create table tab1(col1 int);
create or replace package pck1 --包头，在包头内声明的变量存储过程等都为公有的，可以被外部访问
is
public_var1 int:=1; --在包头声明的公有变量public_var1，可以被外部访问
procedure public_proc1(col1 int,col2 int); --只在包头内声明的存储过程，因此为公有的，可以被外部访问。
end pck1;
/


create or replace package body pck1 --指定了package body关键字
is
private_var1 int:=1; --在包体内声明的私有变量private_var1,不能被外部访问
procedure private_proc1(col1 int,col2 int) --只在包体内定义的存储过程为私有存储过程
is
begin
raise notice 'col1   col2 = %',col1col2;
insert into tab1 values(col1col2);
end;
procedure public_proc1(col1 int,col2 int)--只在包体内定义的存储过程为私有存储过程
is
begin
private_proc1(1,2);
end;
--需与包头保持一致
end pck1;
/
> --package中的函数调用方式与存储过程调用方式一样
> call pck1.public_proc1(1,2);

create table t2(a int, b int);
insert into t2 values(1,2);
select * from t2;

--创建包含自治事务的存储过程
create or replace procedure autonomous_proc1(a int, b int)  as 
declare 
    num3 int := a;
    num4 int := b;
    pragma autonomous_transaction; --声明此存储过程为一个自治事务的存储过程
begin
    insert into t2 values(num3, num4); 
    dbe_output.print_line('just use call.');
end;
/
 --创建调用自治事务存储过程的普通存储过程
create or replace procedure proc1(a int, b int)  as 
declare 
c int:=0;
begin
    dbe_output.print_line('just no use call.');
    insert into t2 values(5, 6);--异常后回滚
    c:=c/0;
    exception when others then
    autonomous_proc1(a,b);
end;
/
--调用普通存储过程
select proc1(11,22);
select * from t2 order by a;
输出结果：
a  | b  
---- ----
1 |  2
11 | 22
(2 rows)

create or replace procedure test_debug ( in  x int) 
as  
begin
    insert into t1 (a) values (x);
    delete from t1 where a = x;
end;
/
输出结果:
create procedure
select oid from pg_proc where proname='test_debug';
输出结果：
  oid
-------
 16389
(1 row)

select * from dbe_pldebugger.turn_on(16389);
输出结果：
 nodename | port
---------- ------
 datanode |    0
(1 row)

server端执行存储过程，会在存储过程内第一条sql语句前hang住，等待debug端发送的调试消息。仅支持直接执行存储过程的调试，不支持通过trigger调用执行的存储过程调试。

call test_debug(1);

select * from dbe_pldebugger.attach('datanode',0);
输出结果：
 funcoid |  funcname  | lineno |              query
--------- ------------ -------- ----------------------------------
   16389 | test_debug |      3 |   insert into t1 (a) values (x);
(1 row)

select * from dbe_pldebugger.next();
输出结果：
 funcoid |  funcname  | lineno |        query
--------- ------------ -------- ----------------------
   16389 | test_debug |      0 | [execution finished]
(1 row)

select * from dbe_pldebugger.info_locals(); --打印全部变量
输出结果：
 varname | vartype | value | package_name | isconst
--------- --------- ------- -------------- ---------
 x       | int4    | 1     |              | f
(1 row)


select * from dbe_pldebugger.set_var('x', 2); --变量赋值
输出结果：
 set_var
---------
 t
(1 row)


select * from dbe_pldebugger.print_var('x'); --打印单个变量
输出结果：
 varname | vartype | value | package_name | isconst
--------- --------- ------- -------------- ---------
 x       | int4    | 2     |              | f
(1 row)

select * from dbe_pldebugger.continue();
输出结果：
 funcoid |  funcname  | lineno |        query
--------- ------------ -------- ----------------------
   16389 | test_debug |      0 | [execution finished]
(1 row)

select * from dbe_pldebugger.abort();
输出结果：
 abort
-------
 t
(1 row)

select * from dbe_pldebugger.info_code(16389);
输出结果：
 lineno |                           query                           | canbreak
-------- ----------------------------------------------------------- ----------
        | create or replace procedure public.test_debug( in  x int) | f
      1 | as  declare                                               | f
      2 | begin                                                     | f
      3 |     insert into t1 (a) values (x);                        | t
      4 |     delete from t1 where a = x;                           | t
      5 | end;                                                      | f
      6 | /                                                         | f
(7 rows)

select * from dbe_pldebugger.info_breakpoints();
输出结果：
 breakpointno | funcoid | lineno |              query              | enable
-------------- --------- -------- --------------------------------- --------
            0 |   16389 |      4 |     delete from t1 where a = x; | t

select * from dbe_pldebugger.info_breakpoints();
输出结果：
 breakpointno | funcoid | lineno |              query              | enable
-------------- --------- -------- --------------------------------- --------
            0 |   16389 |      4 |     delete from t1 where a = x; | t
(1 row)

select * from dbe_pldebugger.continue();
输出结果：
 funcoid |  funcname  | lineno |              query
--------- ------------ -------- ---------------------------------
   16389 | test_debug |      4 |     delete from t1 where a = x;