怎样在Oracle中开发PIPELINED管道表函数以实现流式数据返回-Oracle-PHP中文网

pipelined函数必须返回table of自定义对象类型，禁用内置集合类型；函数体内只能用pipe row推送数据，禁止return语句；不可执行dml操作；应避免长生命周期游标，优先使用隐式游标。

怎样在oracle中开发pipelined管道表函数以实现流式数据返回

PIPELINED函数必须搭配RETURN类型为TABLE OF自定义对象类型

Oracle不支持直接返回嵌套表或VARRAY的PIPELINED函数——必须先用CREATE OR REPLACE TYPE定义一个OBJECT类型，再基于它创建TABLE类型。常见错误是试图返回sys.odcivarchar2list等内置集合类型，这会导致编译失败：PLS-00653: aggregate/table functions not allowed in this context。

正确做法：

定义对象类型：CREATE OR REPLACE TYPE emp_row AS OBJECT (empno NUMBER, ename VARCHAR2(10))
定义表类型：CREATE OR REPLACE TYPE emp_table AS TABLE OF emp_row
函数声明中明确写：RETURN emp_table PIPELINED

PIPELINED函数体里只能用`PIPE ROW`不能用`RETURN`

这是最常踩的坑：在函数体内写RETURN emp_table()或RETURN NULL会直接报错PLS-00713: RETURN statement must be the last executable statement。PIPELINED函数的控制流由PIPE ROW驱动，每调用一次就向结果集“推送”一行，函数本身最终以END自然退出，不返回值。

典型结构：

FUNCTION get_emps RETURN emp_table PIPELINED IS
BEGIN
  FOR r IN (SELECT empno, ename FROM emp WHERE deptno = 10) LOOP
    PIPE ROW(emp_row(r.empno, r.ename)); -- 必须用PIPE ROW
  END LOOP;
  -- 这里不能写 RETURN
END;

不能在PIPELINED函数里做DML操作（INSERT/UPDATE/DELETE）

Oracle限制PIPELINED函数必须是READ ONLY的——如果函数内部执行了DML，调用时会报错：ORA-14551: cannot perform a DML operation inside a query。这不是权限问题，而是执行模型决定的：SQL引擎在执行SELECT * FROM TABLE(my_pipelined_func())时，会并发拉取多行，DML会破坏一致性。