王朝网络
分享
 
 
 

如何使用pipeline function获得实时输出

王朝other·作者佚名  2008-06-01
宽屏版  字体: |||超大  

很多人都知道,在普通的函数中,使用dbms_output输出的信息,需要在服务器执行完整个函数后一次性的返回给客户端。但你如果需要在客户端实时的输出函数执行过程中的一些信息,在Oracle 9i以后则可以使用管道函数(pipeline function)。

PIPELINED(关键字)表明这是一个管道函数,管道函数的返回值类型必须为集合,在函数中,PIPE ROW语句被用来返回该集合的单个元素,函数则以一个空的RETURN语句结束,以表明它已经完成。

create or replace type MsgType as table of varchar2(4000);

/

create or replace function f_pipeline_test

return MsgType

PIPELINED

as

begin

for i in 1 .. 10

loop

pipe row( 'Iteration ' || i || ' at ' || systimestamp );

dbms_lock.sleep(1);

end loop;

pipe row( 'All done!' );

return;

end;

/

在sql*plus中执行该函数,大家需要首先设置arraysize为1,否则服务器会按照默认的15来向客户端返回信息,这会影响我们的测试效果。

SQL> set arraysize 1

SQL> select * from table( f_pipeline_test );

COLUMN_VALUE

-----------------------------------------------------

Iteration 1 at 14-FEB-08 02.13.18.273988000 PM +08:00

Iteration 2 at 14-FEB-08 02.13.19.275988000 PM +08:00

Iteration 3 at 14-FEB-08 02.13.20.277767000 PM +08:00

Iteration 4 at 14-FEB-08 02.13.21.279591000 PM +08:00

Iteration 5 at 14-FEB-08 02.13.22.281366000 PM +08:00

Iteration 6 at 14-FEB-08 02.13.23.283189000 PM +08:00

Iteration 7 at 14-FEB-08 02.13.24.283965000 PM +08:00

Iteration 8 at 14-FEB-08 02.13.25.285785000 PM +08:00

Iteration 9 at 14-FEB-08 02.13.26.286570000 PM +08:00

Iteration 10 at 14-FEB-08 02.13.27.288387000 PM +08:00

All done!

11 rows selected.

如果要在pipeline中执行DML操作,则必须使用自治事务,否则会报ORA-14551错误

create or replace function f_pipeline_testdml

return MsgType

PIPELINED

as

begin

for i in 1 .. 10

loop

insert into test values(1);

pipe row( 'insert into test values( ' || i || ') success at ' || systimestamp );

dbms_lock.sleep(1);

end loop;

pipe row( 'All done!' );

return;

end;

/

SQL> select * from table( f_pipeline_testdml );

select * from table( f_pipeline_testdml )

*

ERROR at line 1:

ORA-14551: cannot perform a DML operation inside a query

ORA-06512: at "NING.F_PIPELINE_TESTDML", line 8

create or replace function f_pipeline_testdml

return MsgType

PIPELINED

as

pragma autonomous_transaction;

begin

for i in 1 .. 10

loop

insert into test values(1);

commit;

pipe row( 'insert values ' || i || ' success at ' || systimestamp );

dbms_lock.sleep(1);

end loop;

pipe row( 'All done!' );

return;

end;

/

SQL> select * from table( f_pipeline_testdml );

COLUMN_VALUE

--------------------------------------------------------------------------------

insert values 1 success at 14-FEB-08 02.16.47.855158000 PM +08:00

insert values 2 success at 14-FEB-08 02.16.48.865559000 PM +08:00

insert values 3 success at 14-FEB-08 02.16.49.867377000 PM +08:00

insert values 4 success at 14-FEB-08 02.16.50.873154000 PM +08:00

insert values 5 success at 14-FEB-08 02.16.51.874942000 PM +08:00

insert values 6 success at 14-FEB-08 02.16.52.880781000 PM +08:00

insert values 7 success at 14-FEB-08 02.16.53.882543000 PM +08:00

insert values 8 success at 14-FEB-08 02.16.54.894348000 PM +08:00

insert values 9 success at 14-FEB-08 02.16.55.896153000 PM +08:00

insert values 10 success at 14-FEB-08 02.16.56.901904000 PM +08:00

All done!

11 rows selected.

在Oracle 9205及其之后的版本中,在pipeline function中使用自治事务,则必须在pipe row之前提交或者回滚事务,否则会报ORA-06519错误。

create or replace function f_pipeline_testdml

return MsgType

PIPELINED

as

pragma autonomous_transaction;

begin

for i in 1 .. 10

loop

insert into test values(1);

pipe row( 'insert values ' || i || ' success at ' || systimestamp );

dbms_lock.sleep(1);

end loop;

pipe row( 'All done!' );

commit;

return;

end;

/

SQL> select * from table( f_pipeline_testdml );

select * from table( f_pipeline_testdml )

*

ERROR at line 1:

ORA-06519: active autonomous transaction detected and rolled back

ORA-06512: at "NING.F_PIPELINE_TESTDML", line 10

此处是由于在9205中修复Bug 2711518导致了自治事务的行为有所改变。如果系统从9205之前的版本升级到之后的版本,需要保证pipeline function的行为和以前版本一致,Oracle提供了一个10946事件来设置和以前版本的兼容性,如果在管道函数中使用了select for update的cursor,则必须设置event回归以前的特性,否则即使在pipe row之前commit也会导致出现ORA-1002错误。

ALTER SYSTEM SET EVENT = "10946 trace name context forever, level 8" scope=spfile;

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
2023年上半年GDP全球前十五强
 百态   2023-10-24
美众议院议长启动对拜登的弹劾调查
 百态   2023-09-13
上海、济南、武汉等多地出现不明坠落物
 探索   2023-09-06
印度或要将国名改为“巴拉特”
 百态   2023-09-06
男子为女友送行,买票不登机被捕
 百态   2023-08-20
手机地震预警功能怎么开?
 干货   2023-08-06
女子4年卖2套房花700多万做美容:不但没变美脸,面部还出现变形
 百态   2023-08-04
住户一楼被水淹 还冲来8头猪
 百态   2023-07-31
女子体内爬出大量瓜子状活虫
 百态   2023-07-25
地球连续35年收到神秘规律性信号,网友:不要回答!
 探索   2023-07-21
全球镓价格本周大涨27%
 探索   2023-07-09
钱都流向了那些不缺钱的人,苦都留给了能吃苦的人
 探索   2023-07-02
倩女手游刀客魅者强控制(强混乱强眩晕强睡眠)和对应控制抗性的关系
 百态   2020-08-20
美国5月9日最新疫情:美国确诊人数突破131万
 百态   2020-05-09
荷兰政府宣布将集体辞职
 干货   2020-04-30
倩女幽魂手游师徒任务情义春秋猜成语答案逍遥观:鹏程万里
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案神机营:射石饮羽
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案昆仑山:拔刀相助
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案天工阁:鬼斧神工
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案丝路古道:单枪匹马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:与虎谋皮
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:李代桃僵
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:指鹿为马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:小鸟依人
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:千金买邻
 干货   2019-11-12
 
>>返回首页<<
推荐阅读
 
 
频道精选
 
静静地坐在废墟上,四周的荒凉一望无际,忽然觉得,凄凉也很美
© 2005- 王朝网络 版权所有