如何实现流水线函数_PIPELINED关键字与PIPE ROW应用-Oracle-PHP中文网

PIPE ROW 在 Oracle PL/SQL 中怎么写才不报错

直接说结论：pipe row 只能在定义为 pipelined 的函数里用，且函数返回类型必须是已声明的集合类型（比如 table of number），不能是 ref cursor 或标量。

常见错误现象：调用时抛 ORA-06553: PLS-382: expression is of wrong type，或者 ORA-06553: PLS-306: wrong number or types of arguments —— 大多因为返回类型没对上、忘了加 PIPELINED，或在普通函数里硬塞了 PIPE ROW。

函数头必须显式写 RETURN ... PIPELINED，不能只在 body 里用 PIPE ROW
返回集合类型需提前用 CREATE OR REPLACE TYPE 建好，不能用匿名嵌套表（如 RETURN SYS.ODCIVARCHAR2LIST 是特例，但不推荐依赖）
PIPE ROW 每次只能传一个元素，类型必须和集合元素类型完全一致（包括精度、字符集、NULL 性）
函数体内不能有 RETURN（除了最后的 END RETURN），否则会提前退出，后续 PIPE ROW 不执行

示例（安全写法）：

CREATE OR REPLACE TYPE num_list AS TABLE OF NUMBER;

CREATE OR REPLACE FUNCTION gen_nums(n IN NUMBER) RETURN num_list PIPELINED IS
BEGIN
  FOR i IN 1..n LOOP
    PIPE ROW(i); -- 类型匹配：num_list 元素是 NUMBER，i 是 NUMBER
  END LOOP;
  RETURN; -- 必须有，但不带值
END;

为什么用 PIPELINED 而不是普通函数返回集合

核心区别在执行模型：PIPELINED 函数是“边算边吐”，调用方（比如 SQL 查询）可以逐行消费结果；普通函数得等全部计算完、构造好整个集合再一次性返回，内存和延迟都高。

典型使用场景：处理大结果集但下游只取前几行（SELECT * FROM TABLE(gen_nums(1000000)) WHERE ROWNUM ），或需要流式 join / filter 的 ETL 场景。

非 pipelined 函数：Oracle 会把整个集合加载进 PGA，100 万行 NUMBER 可能占几十 MB 内存
Pipelined 函数：每调一次 PIPE ROW，就向调用方送一行，PGA 压力恒定（常驻约 1–2 行缓冲）
兼容性注意：10g+ 支持，但 9i 不支持；如果函数被物化视图引用，部分版本要求必须 DETERMINISTIC（而 pipelined 函数通常不满足）