oracle管道函数是一类特殊的函数,oracle管道函数返回值类型必须为集合。
在普通的函数中,使用dbms_output输出的信息,需要在服务器执行完整个函数后一次性的返回给客户端。如果需要在客户端实时的输出函数执行过程中的一些信息,在oracle9i以后可以使用管道函数(pipeline function)。
关键字PIPELINED表明这是一个oracle管道函数,oracle管道函数的返回值类型必须为集合,在函数中,PIPE ROW语句被用来返回该集合的单个元素,函数以一个空的RETURN 语句结束,以表明它已经完成。接下来演示一下管道函数的实际用法。
在创建管道函数之前必须创建一个用于存放管道函数返回值的类型,因为管道的返回值可以看做是一个虚表。
1、创建type对象
SQL> create or replace type MsgType as table of varchar2(4000);
2 /
类型已创建。
2、创建管道函数,注意PIPELINED关键字和pipe的用法
SQL> create or replace function f_pipeline_test return MsgType
2 pipelined as
3 begin
4 for i in 1 .. 10 loop
5 pipe row('Iteration'||i||'at'systimestamp);
6 sys.dbms_lock.sleep(1);
7 end loop;
8 pipe row('all done!');
9 return;
10 end;
11 /
警告: 创建的函数带有编译错误。
以上function编译错误详细信息为:“Error: PLS-00201: 必须说明标识符 'DBMS_LOCK'”,这是由于授权的原因,可通过如下方案解决:
SQL> conn sys/oracle as sysdba
已连接。
SQL> grant execute on dbms_lock to test;
授权成功。
SQL> conn test/test
已连接。
在sql*plus中执行该函数,首先设置arraysize为1,否则服务器会按照默认的15来向客户端返回信息,这会影响我们的测试效果。
SQL> set arraysize 1
SQL> select * from table(f_pipeline_test);
COLUMN_VALUE
--------------------------------------------------------------------------
Iteration1at10-10月-14 10.49.50.533000000 上午 +08:00
Iteration2at10-10月-14 10.49.51.563000000 上午 +08:00
Iteration3at10-10月-14 10.49.52.577000000 上午 +08:00
Iteration4at10-10月-14 10.49.53.591000000 上午 +08:00
Iteration5at10-10月-14 10.49.54.605000000 上午 +08:00
Iteration6at10-10月-14 10.49.55.619000000 上午 +08:00
Iteration7at10-10月-14 10.49.56.633000000 上午 +08:00
Iteration8at10-10月-14 10.49.57.647000000 上午 +08:00
Iteration9at10-10月-14 10.49.58.661000000 上午 +08:00
Iteration10at10-10月-14 10.49.59.675000000 上午 +08:00
all done!
已选择11行。