使用流水线函数访问PL/SQL对象集合中的方法问题

使用流水线函数返回对象集合时，完全可以访问对象的方法，你的问题源于代码实现中的语法错误和调用方式问题，而非流水线函数本身的限制。

关键问题分析 #

1. 对象类型方法定义语法错误
   原代码中方法定义缺少MEMBER关键字（实例方法必须声明），且末尾用了句号而非分号，导致方法未被正确识别：

   -- 错误写法
   method function some_number_doubled Return Number.
   -- 正确写法
   MEMBER FUNCTION some_number_doubled RETURN NUMBER;
   

   同时，对象方法必须在TYPE BODY中实现，仅定义类型头是不够的。

2. 流水线函数定义不完整
   原函数未标注PIPELINED关键字，且缺少将游标数据实例化为cool_object的逻辑，导致返回的集合可能未正确创建对象实例。

3. 方法调用方式错误
   使用SELECT *只能展开对象的属性，无法自动调用方法，必须显式指定方法调用语法。

修正后的完整代码示例 #

1. 修正对象类型及方法实现 #

-- 创建对象类型头
CREATE OR REPLACE TYPE schema1.cool_object FORCE AS OBJECT (
    att_pid NUMBER,
    att_some_number NUMBER,
    -- 正确声明实例方法
    MEMBER FUNCTION some_number_doubled RETURN NUMBER
);
/

-- 实现对象方法体
CREATE OR REPLACE TYPE BODY schema1.cool_object AS
    MEMBER FUNCTION some_number_doubled RETURN NUMBER IS
    BEGIN
        RETURN self.att_some_number * 2;
    END;
END;
/

-- 创建嵌套表类型
CREATE OR REPLACE TYPE schema1.cool_object_ns IS TABLE OF schema1.cool_object;
/

2. 修正流水线函数 #

-- 包定义
CREATE OR REPLACE PACKAGE schema1.package1 AS
    FUNCTION f_pipeline(p_rows SYS_REFCURSOR) RETURN schema1.cool_object_ns PIPELINED;
END package1;
/

-- 包体实现
CREATE OR REPLACE PACKAGE BODY schema1.package1 AS
    FUNCTION f_pipeline(p_rows SYS_REFCURSOR) RETURN schema1.cool_object_ns PIPELINED IS
        v_pid NUMBER;
        v_some_number NUMBER;
    BEGIN
        -- 遍历游标，实例化对象并输出到流水线
        FETCH p_rows INTO v_pid, v_some_number;
        WHILE p_rows%FOUND LOOP
            PIPE ROW(schema1.cool_object(v_pid, v_some_number));
            FETCH p_rows INTO v_pid, v_some_number;
        END LOOP;
        CLOSE p_rows;
        RETURN;
    END f_pipeline;
END package1;
/

3. 正确调用对象方法的查询 #

SELECT 
    obj.att_pid,
    obj.att_some_number,
    -- 显式调用对象方法
    obj.some_number_doubled() AS doubled_some_number
FROM TABLE (schema1.package1.f_pipeline(CURSOR(SELECT pid, some_number FROM person_table))) obj;

额外性能优化提示 #

如果要通过并行提升性能，可以在查询中添加并行提示（确保对象方法为纯函数，无副作用）：

SELECT /*+ PARALLEL */
    obj.att_pid,
    obj.att_some_number,
    obj.some_number_doubled() AS doubled_some_number
FROM TABLE (schema1.package1.f_pipeline(CURSOR(SELECT pid, some_number FROM person_table))) obj;

内容的提问来源于stack exchange，提问作者Eric Boyd