关于 pipe row的用法2009/12/30 14:53

=========================================================== 作者: flysky0814(http://flysky0814.itpub.net)
发表于:2007.11.28 11:14
分类: oracle10g
出处：http://flysky0814.itpub.net/post/35477/419443
--------------------------------------------------------------- 为了让 PL/SQL 函数返回数据的多个行，必须通过返回一个 REF CURSOR 或一个数据集合来完成。REF CURSOR 的这种情况局限于可以从查询中选择的数据，而整个集合在可以返回前，必须进行具体化。Oracle 9i 通过引入的管道化表函数纠正了后一种情况。表函数是返回整个行的集(通常作为一个集合)的函数，可以直接从 SQL 语句中进行查询，就好像它是一个真正的数据库表一样。管道化表函数与之相似，但是它像在构建时一样返回数据，而不是一次全部返回。管道化表函数更加有效， 因为数据可以尽可能快地返回。

管道化表函数必须返回一个集合。在函数中，PIPE ROW 语句被用来返回该集合的单个元素，该函数必须以一个空的 RETURN 语句结束，以表明它已经完成。一旦我们创建了上述函数，我们就可以使用 TABLE 操作符从 SQL 查询中调用它。

管道化表函数经常被用来把数据从一种类型转化成另一种类型。

下面是用 Pipelined Table 实现 split 函数的例子：

CREATE OR REPLACE TYPE ty_str_split IS TABLE OF VARCHAR2 (4000);

CREATE OR REPLACE FUNCTION fn_split (p_str IN VARCHAR2, p_delimiter IN VARCHAR2)RETURN ty_str_split PIPELINEDISj INT := 0;i INT := 1;len INT := 0;len1 INT := 0;str VARCHAR2 (4000);BEGINlen := LENGTH (p_str);len1 := LENGTH (p_delimiter);

WHILE j < lenLOOPj := INSTR (p_str, p_delimiter, i);

IF j = 0THENj := len;str := SUBSTR (p_str, i);PIPE ROW (str);

IF i >= lenTHENEXIT;END IF;ELSEstr := SUBSTR (p_str, i, j - i);i := j + len1;PIPE ROW (str);END IF;END LOOP;

RETURN;END fn_split;/

测试：SELECT * FROM TABLE (fn_split ('1;;12;;123;;1234;;12345', ';;'));

结果：112123123412345 又一个简单的例子：CREATE TYPE mytype AS OBJECT (field1 NUMBER,field2 VARCHAR2 (50));

CREATE TYPE mytypelist AS TABLE OF mytype;

CREATE OR REPLACE FUNCTION pipelinemeRETURN mytypelist PIPELINEDISv_mytype mytype;BEGINFOR v_count IN 1 .. 20LOOPv_mytype := mytype (v_count, 'Row ' || v_count);PIPE ROW (v_mytype); END LOOP;

RETURN;END pipelineme;SELECT * FROM TABLE (pipelineme);FIELD1 FIELD2 ------ ------------------------1 Row 12 Row 23 Row 34 Row 45 Row 56 Row 67 Row 78 Row 89 Row 910 Row 1011 Row 1112 Row 1213 Row 1314 Row 1415 Row 1516 Row 1617 Row 1718 Row 1819 Row 1920 Row 20

*********************************

create or replace type dlsys.split_tbl as table of varchar2(32767);

create or replace function dlsys.dlsplit(p_list varchar2,
                                         p_del varchar2 := ',')
return dlsys.split_tbl
pipelined is
l_idx pls_integer;
l_list varchar2(32767) := p_list;
begin
loop
    l_idx := instr(l_list, p_del);
    if l_idx > 0 then
      pipe row(substr(l_list, 1, l_idx - 1));
      l_list := substr(l_list, l_idx + length(p_del));
    else
      pipe row(l_list);
      exit;
    end if;
end loop;
return;
end dlsplit;

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

DECLARE
  a   ty_str_split  ;
BEGIN
   select   fn_split ('1;;12;;123;;1234;;12345;;w', ';;') into a from dual ;
   a(1) := 'ell';
   dbms_output.put_line(a(100));
   null;
END;