SQL奇技淫巧之pipeline管道-Toy模板网

这篇具有很好参考价值的文章主要介绍了SQL奇技淫巧之pipeline管道。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

① 先创建一个对象(Object)类型，表示要通过管道传递的数据结构：

CREATE OR REPLACE TYPE test_type AS OBJECT (
  colum1 NUMBER,
  colum2 VARCHAR2(100)
);

这里创建了一个名为 test_type 的类型，AS OBJECT表示这个类型是一个对象类型，
包含了两个字段(也可以说是列)，数字类型的colum1和字符串类型的colum2 ；

② 再创建一个集合(Table)类型，这样可以传递多行数据：

CREATE OR REPLACE TYPE test_type_table AS TABLE OF test_type;

这里创建了一个名为test_type_table的类型，AS TABLE表示这个类型是一个表(集合)类型，
OF test_type表示这个类型是基于test_type对象创建的，就是说这个集合类型是用于存放test_type对象的；

③ 创建一个管道函数，返回自定义的类型集合

CREATE OR REPLACE FUNCTION pipeline_function RETURN test_type_table PIPELINED IS
  -- 函数逻辑
BEGIN
  -- 生产返回数据
  FOR i IN 1..10 
  LOOP
    PIPE ROW(test_type(i, 'Value ' || i));
  END LOOP;
  RETURN;
END;

创建了一个名为pipeline_function的函数，RETURN test_type_table表示返回值为test_type_table类型集合
PIPELINED表示函数将以流方式返回结果集，允许调用者在数据可用时逐行处理数据，而不是一次性返回整个结果集
用一个1-10的循环创建test_type对象，并用PIPE ROW(test_type(colum1, colum2))的方式把对象一个一个放入test_type_table类型集合中
其中PIPE ROW(object)是一个与PIPELINED关键字搭配使用的固定语句，用来返回一行数据