oracle管道函数的用法

oracle管道函数是一类特殊的函数，oracle管道函数返回值类型必须为集合，下面就为您将介绍oracle管道函数的语法，供您参考学习。

创新互联建站是一家专业提供坡头企业网站建设,专注与成都网站设计、成都网站制作、外贸网站建设、HTML5建站、小程序制作等业务。10年已为坡头众多企业、政府机构等服务。创新互联专业的建站公司优惠进行中。

在普通的函数中，使用dbms_output输出的信息，需要在服务器执行完整个函数后一次性的返回给客户端。如果需要在客户端实时的输出函数执行过程中的一些信息，在oracle9i以后可以使用管道函数(pipeline function)。

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

 
 
 
    
  
  
  
  1. create or replace type MsgType as table of varchar2(4000);  
    2.   
  
  
  2. /  
    3.   
  
  
  3.  
    4.   
  
  
  4. create or replace function f_pipeline_test  
    5.   
  
  
  5. return MsgType  
    6.   
  
  
  6. PIPELINED  
    7.   
  
  
  7. as  
    8.   
  
  
  8. begin  
    9.   
  
  
  9.    for i in 1 .. 10  
    10.   
  
  
  10.    loop  
    11.   
  
  
  11.    pipe row( 'Iteration ' || i || ' at ' || systimestamp );  
    12.   
  
  
  12.    dbms_lock.sleep(1);  
    13.   
  
  
  13.    end loop;  
    14.   
  
  
  14.    pipe row( 'All done!' );  
    15.   
  
  
  15.    return;  
    16.   
  
  
  16. end;  
    17.   
  
  
  17. /  
    18.   
  
  
  18.  
    19.

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

 
 
 
    
  
  
  
  1. SQL> set arraysize 1  
    2.   
  
  
  2. SQL> select * from table( f_pipeline_test );  
    3.   
  
  
  3.  
    4.   
  
  
  4. COLUMN_VALUE  
    5.   
  
  
  5. --------------------------------------------------------------------------------  
    6.   
  
  
  6. Iteration 1 at 14-FEB-08 02.13.18.273988000 PM +08:00  
    7.   
  
  
  7. Iteration 2 at 14-FEB-08 02.13.19.275988000 PM +08:00  
    8.   
  
  
  8. Iteration 3 at 14-FEB-08 02.13.20.277767000 PM +08:00  
    9.   
  
  
  9. Iteration 4 at 14-FEB-08 02.13.21.279591000 PM +08:00  
    10.   
  
  
  10. Iteration 5 at 14-FEB-08 02.13.22.281366000 PM +08:00  
    11.   
  
  
  11. Iteration 6 at 14-FEB-08 02.13.23.283189000 PM +08:00  
    12.   
  
  
  12. Iteration 7 at 14-FEB-08 02.13.24.283965000 PM +08:00  
    13.   
  
  
  13. Iteration 8 at 14-FEB-08 02.13.25.285785000 PM +08:00  
    14.   
  
  
  14. Iteration 9 at 14-FEB-08 02.13.26.286570000 PM +08:00  
    15.   
  
  
  15. Iteration 10 at 14-FEB-08 02.13.27.288387000 PM +08:00  
    16.   
  
  
  16. All done!  
    17.   
  
  
  17.  
    18.   
  
  
  18. 11 rows selected.  
    19.   
  
  
  19.  
    20.

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

 
 
 
    
  
  
  
  1. create or replace function f_pipeline_testdml  
    2.   
  
  
  2. return MsgType  
    3.   
  
  
  3. PIPELINED  
    4.   
  
  
  4. as  
    5.   
  
  
  5. begin  
    6.   
  
  
  6.    for i in 1 .. 10  
    7.   
  
  
  7.    loop  
    8.   
  
  
  8.    insert into test values(1);  
    9.   
  
  
  9.    pipe row( 'insert into test values( ' || i || ') success at ' || systimestamp );  
    10.   
  
  
  10.    dbms_lock.sleep(1);  
    11.   
  
  
  11.    end loop;  
    12.   
  
  
  12.    pipe row( 'All done!' );  
    13.   
  
  
  13.    return;  
    14.   
  
  
  14. end;  
    15.   
  
  
  15. /  
    16.   
  
  
  16.  
    17.  
 
 
 
 
 
    
  
  
  
  1. SQL> select * from table( f_pipeline_testdml );  
    2.   
  
  
  2. select * from table( f_pipeline_testdml ) 
    3.  
 
 
 
 
 
    
  
  
  
  1.  *  
    2.   
  
  
  2. ERROR at line 1:  
    3.   
  
  
  3. ORA-14551: cannot perform a DML operation inside a query  
    4.   
  
  
  4. ORA-06512: at "NING.F_PIPELINE_TESTDML", line 8create or replace function f_pipeline_testdml  
    5.   
  
  
  5. return MsgType  
    6.   
  
  
  6. PIPELINED  
    7.   
  
  
  7. as  
    8.   
  
  
  8. pragma autonomous_transaction;  
    9.   
  
  
  9. begin  
    10.   
  
  
  10.    for i in 1 .. 10  
    11.   
  
  
  11.    loop  
    12.   
  
  
  12.    insert into test values(1);  
    13.   
  
  
  13.    commit;  
    14.   
  
  
  14.    pipe row( 'insert values ' || i || ' success at ' || systimestamp );  
    15.   
  
  
  15.    dbms_lock.sleep(1);  
    16.   
  
  
  16.    end loop;  
    17.   
  
  
  17.    pipe row( 'All done!' );  
    18.   
  
  
  18.    return;  
    19.   
  
  
  19. end;  
    20.   
  
  
  20. /  
    21.   
  
  
  21.  
    22.   
  
  
  22. SQL> select * from table( f_pipeline_testdml );  
    23.   
  
  
  23.  
    24.   
  
  
  24. COLUMN_VALUE  
    25.   
  
  
  25. --------------------------------------------------------------------------------  
    26.   
  
  
  26. insert values 1 success at 14-FEB-08 02.16.47.855158000 PM +08:00  
    27.   
  
  
  27. insert values 2 success at 14-FEB-08 02.16.48.865559000 PM +08:00  
    28.   
  
  
  28. insert values 3 success at 14-FEB-08 02.16.49.867377000 PM +08:00  
    29.   
  
  
  29. insert values 4 success at 14-FEB-08 02.16.50.873154000 PM +08:00  
    30.   
  
  
  30. insert values 5 success at 14-FEB-08 02.16.51.874942000 PM +08:00  
    31.   
  
  
  31. insert values 6 success at 14-FEB-08 02.16.52.880781000 PM +08:00  
    32.   
  
  
  32. insert values 7 success at 14-FEB-08 02.16.53.882543000 PM +08:00  
    33.   
  
  
  33. insert values 8 success at 14-FEB-08 02.16.54.894348000 PM +08:00  
    34.   
  
  
  34. insert values 9 success at 14-FEB-08 02.16.55.896153000 PM +08:00  
    35.   
  
  
  35. insert values 10 success at 14-FEB-08 02.16.56.901904000 PM +08:00  
    36.   
  
  
  36. All done!  
    37.   
  
  
  37.  
    38.   
  
  
  38. 11 rows selected.  
    39.

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

 
 
 
    
  
  
  
  1. create or replace function f_pipeline_testdml  
    2.   
  
  
  2. return MsgType  
    3.   
  
  
  3. PIPELINED  
    4.   
  
  
  4. as  
    5.   
  
  
  5. pragma autonomous_transaction;  
    6.   
  
  
  6. begin  
    7.   
  
  
  7.    for i in 1 .. 10  
    8.   
  
  
  8.    loop  
    9.   
  
  
  9.    insert into test values(1);  
    10.   
  
  
  10.    pipe row( 'insert values ' || i || ' success at ' || systimestamp );  
    11.   
  
  
  11.    dbms_lock.sleep(1);  
    12.   
  
  
  12.    end loop;  
    13.   
  
  
  13.    pipe row( 'All done!' );  
    14.   
  
  
  14.    commit;  
    15.   
  
  
  15.    return;  
    16.   
  
  
  16. end;  
    17.   
  
  
  17. /  
    18.   
  
  
  18.  
    19.   
  
  
  19. SQL> select * from table( f_pipeline_testdml );  
    20.   
  
  
  20. select * from table( f_pipeline_testdml )  
    21.

  *
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;

【编辑推荐】

oracle自定义函数的使用

计算时间差的Oracle函数

Oracle日期函数简介

创建Oracle包的语法

Oracle TRIM函数语法介绍

新闻标题：oracle管道函数的用法
分享路径：http://www.shufengxianlan.com/qtweb/news44/75994.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

响应式网站知识

行业网站建设

成都移动机房　　 　成都企业网站建设公司　　 　新津网站运维　　 　电商网站　　 　成都企业网站定制　　 　php空间　　 　雕琢时光　　 　云主机　　 　服务器租用　　 　郫县门窗定制　　 　成都服务器租用　　 　成都广告公司　　 　香港云服务器租用　　 　钢筋机械设备　　 　八点广告　　 　网站优化公司　　 　彭州网站建设　　 　手机网站开发　　 　装饰公司网站建设方案　　 　德阳服务器托管