如何在Oracle 19c中通过管道化表函数提高数据转换的吞吐量？

PIPELINED函数在Oracle 19c中需严格满足四重约束才能发挥流式与并行优势：①返回类型必须为显式创建的集合类型；②函数体仅允许PIPE ROW()且末尾需无参RETURN；③调用必须用TABLE()包裹；④并行需同时声明PARALLEL_ENABLE并加SQL提示。

pipelined 函数在 oracle 19c 中不是“开箱即用就快”，它只在你严格满足类型定义、声明语法、调用方式和执行环境四重约束时，才能真正释放流式输出与并行能力。

必须先建好集合类型，不能直接用系统内置类型

Oracle 要求 PIPELINED 函数返回值必须是显式创建的集合类型（TABLE OF），不能直接用 SYS.ODCIVARCHAR2LIST 或 SYS.ODCINUMBERLIST 这类系统类型——虽然能编译通过，但调用时大概率触发 ORA-22905，或让优化器基数估算严重失真（默认估成 8168 行）。

• 先建对象类型：CREATE OR REPLACE TYPE t_row AS OBJECT (id NUMBER, name VARCHAR2(100))
• 再建表类型：CREATE OR REPLACE TYPE t_rows AS TABLE OF t_row
• 函数签名必须是：FUNCTION f_transform(p_limit IN NUMBER) RETURN t_rows PIPELINED

函数体里只能 PIPE ROW()，不能 RETURN 值

函数体内禁止任何带值的 RETURN 语句，也不能构造集合后返回（如 RETURN t_rows(...)）。一旦出现，编译会报 PLS-00713（未声明为 PIPELINED 却用了 PIPE ROW），或运行时报 ORA-14551（无法在查询中执行 DML）。

• 正确写法：循环中每处理一行，就 PIPE ROW(t_row(...))
• 错误写法：RETURN t_rows(...)、RETURN 后跟空括号、RETURN NULL
• 末尾必须留一个无参数的 RETURN（不带值），否则 PL/SQL 编译不过

调用必须套 TABLE()，且参数位置不能错

直接写 f_transform(1000) 是非法的：优化器不认识这个返回值结构，立刻报 ORA-22905。必须用 TABLE(f_transform(1000)) 包裹，且参数必须在括号内紧贴函数名。

• ✅ 正确：SELECT * FROM TABLE(f_transform(1000))
• ❌ 错误：SELECT * FROM TABLE(f_transform)(1000)（语法不合法）
• ❌ 错误：SELECT * FROM f_transform(1000)（触发 ORA-22905）
• 如果函数参数是 REF CURSOR，确保上游游标稳定打开，别被优化器提前物化

要并行就得双启用：PARALLEL_ENABLE + SQL 提示

PARALLEL_ENABLE 不是装饰词，它和 SQL 层的并行提示是硬联动。只写一个，另一个没配，函数照样单线程跑。

• 函数声明必须含：FUNCTION f_split(...) RETURN t_rows PIPELINED PARALLEL_ENABLE
• SQL 调用必须加提示：SELECT /*+ PARALLEL(4) */ * FROM TABLE(f_split(...))
• 函数体内严禁包变量、会话级临时表、DBMS_SESSION.SET_IDENTIFIER 等状态绑定操作，否则并行时数据交叉污染
• 若需日志或控制表写入，必须用 PRAGMA AUTONOMOUS_TRANSACTION 封装 DML

真正卡住吞吐量的，往往不是数据量本身，而是类型没导出、TABLE() 漏套、并行开关只开一半，或者函数里偷偷用了会话变量——这些地方一错，流式就退化成全量构造集合，性能反而更差。