注册 登录  
 加关注
   显示下一条  |  关闭
温馨提示!由于新浪微博认证机制调整,您的新浪微博帐号绑定已过期,请重新绑定!立即重新绑定新浪微博》  |  关闭

沧海,桑田,一念之间!

The future is in your hands!还有什么比坚持更重要!

 
 
 

日志

 
 
关于我

一个有着狂野的梦想的人! 理想的现实派,现实的理想主义者! 喜欢计算机,新技术。

网易考拉推荐

pipeline 异步输出  

2014-02-24 11:26:50|  分类: oracle |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |
之前在dbms_application_info的应用 提到,可以通过异步方式来展示处理进度。这里就将使用pipeline异步输出显示处理进度做一个简单的示例。

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


CREATE OR REPLACE function ZX_LXJ_TEST_pipeline
return msgtype
pipelined
IS
pragma autonomous_transaction;
v_id mytype.goodsid;
v_goodsname mytype.goodsname;
v_num number(10);
v_start_time pls_integer;
BEGIN
v_id := 1;
v_num := 1;
v_start_time := dbms_utility.get_time ;


for c in(select goodsid,rowid from zx_lxj_test_1) loop
update zx_lxj_test_1
set goodsid = goodsid +1
where rowid = c.rowid;

v_num := v_num + 1;

if mod(v_num,1000)=0 then
commit;
pipe row(v_num||'rows proccessed.');
end if;
end loop;
commit;
pipe row('All done.');

END;
/

创建该函数后,通过执行,select * from table( zx_lxj_test_pipeline ); 就会执行函数中对应的处理逻辑。并且每处理1000条记录就会打印到终端。

不过需要注意的是:在pipeline中,如果要使用DML,必须使用自治事务处理。在pipeline function中使用自治事务,则必须在pipe row之前提交或者回滚事务,否则会报ORA-06519错误。


  评论这张
 
阅读(458)| 评论(0)
推荐

历史上的今天

在LOFTER的更多文章

评论

<#--最新日志,群博日志--> <#--推荐日志--> <#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇,下一篇--> <#-- 热度 --> <#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->
 
 
 
 
 
 
 
 
 
 
 
 
 
 

页脚

网易公司版权所有 ©1997-2017