ORACLE 自定义函数,必须通过返回一个 REF CURSOR 或一个数据集合来完成。REF CURSOR 的这种情况局限于可以从查询中选择的数据,而整个集合在可以返回前,必须进行具体化。但是这种集合类型,并不能直接作为 FROM 的宾语。不过,自从 Oracle9i 之后,提供了一个叫做"管道化表函数"的概念。来解决此类问题,这种类型的函数,必须返回一个集合类型,且标明 PIPELINED。这个函数不能返回具体变量,必须以一个空的RETURN 返回。这个函数中,通过 PIPE ROW() 语句来送出要返回的表中的每一行。调用这个函数的时候,通过 TABLE() 关键字把管道流仿真为一个数据集。
管道化表函数,可以接受查询语句或游标作为输入参数,该函数可以平行执行,并可持续输出数据流,被称作管道式输出,应用表函数可将数据转换分阶段处理,并省去中间结果的存储和缓冲表。
下面是用Pipelined Table 实现的示例:
1)创建表
create table table1 ( id_ varchar2(45), name_ varchar2(45), update_time date, sys_id varchar2(45) ); insert into table1 (ID_, NAME_, UPDATE_TIME, SYS_ID) values ('1', 'zhangshan', to_date('01-01-2015', 'dd-mm-yyyy'), '001'); insert into table1 (ID_, NAME_, UPDATE_TIME, SYS_ID) values ('2', 'lisi', to_date('30-01-2014', 'dd-mm-yyyy'), '002'); insert into table1 (ID_, NAME_, UPDATE_TIME, SYS_ID) values ('3', 'wangwu', to_date('12-06-2014', 'dd-mm-yyyy'), '003'); insert into table1 (ID_, NAME_, UPDATE_TIME, SYS_ID) values ('4', 'xiaoxiao', to_date('06-01-2015', 'dd-mm-yyyy'), '004'); insert into table1 (ID_, NAME_, UPDATE_TIME, SYS_ID) values ('5', 'zhouchang', to_date('13-08-2014', 'dd-mm-yyyy'), '005');
2)创建包(Packages)
create or replace package my_package as type my_table is record( id_ varchar2(45), name_ varchar2(45), update_time date, sys_id varchar2(45) ); type my_type is table of my_table; function get_table(time_ date) return my_type pipelined; end my_package;
3)创建包体(Packages bodies)
create or replace package body my_package as function get_table(time_ date) return my_type pipelined is row_t my_table; begin for row_t in (select b.* from (select id_, max(sys_id) maxsysid from table1 where update_time < trunc(time_, 'month') group by id_) a, table1 b where b.sys_id = a.maxsysid) loop pipe row(row_t); end loop; return; end; end my_package;
4)PL/SQL调用此函数
select * from table(my_package.get_table(to_date('2014-12-31 10:34:12','yyyy-MM-dd hh24:mi:ss')));
运行结果:
相关推荐
14.6.1 并行管道函数 644 14.6.2 DIY并行化 648 14.7 小结 652 第15章 数据加载和卸载 655 15.1 SQL*Loader 655 15.1.1 用SQLLDR加载数据的FAQ 660 15.1.2 SQLLDR警告 686 15.1.3 SQLLDR小结 686 15.2 外部...
管道函数的使用总结如下两点: 每当在查询里使用PL/SQL函数时,该查询将被序列化,即一个处理器只能运行一个查询实例,那么在这种情况下不可能使用并行查询(比如在数据仓库中要经常使用这项技术)。因此,为了使用...
2.1 定义数据库和实例....................................................................125 2.2 SGA和后台进程......................................................................133 2.3 连接Oracle .....
管道函数的使用总结如下两点: 每当在查询里使用PL/SQL函数时,该查询将被序列化,即一个处理器只能运行一个查询实例,那么在这种情况下不可能使用并行查询(比如在数据仓库中要经常使用这项技术)。因此,为了使用...
第11章 模块化、打包并发送到库 11.1 包和模块 11.1.1 类比 11.1.2 定义 11.1.3 符号表 11.2 标准Perl库 11.2.1 @INC数组 11.2.2 包和.p1文件 11.2.3 模块和.pm文件 11.2.4 来自CPAN的...
10.3 一个简单的TCP/IP服务器端和客户端实例讲解 10.4 本章小结 第11章 用户登录注册模块 11.1 数据库设计 11.2 最基本的注册模块 11.2.1 页面效果 11.2.2 代码实现 11.3 带验证码的注册模块 11.3.1 页面效果 11.3.2...
其他一些对数组或哈希表有用的函数包括sort(),next(),prev()和each()。 对象 使用new语句产生一个对象: class foo { function do_foo () { echo "Doing foo."; } } $bar = new foo; $bar->do_foo(); 改变变量...
学生提问:为什么静态内部类实例方法也不能访问外部类的实例属性呢? 207 学生提问:接口里是否能定义内部接口? 208 6.7.3 使用内部类 208 学生提问:既然内部类是外部类的成员,是否可以为外部类定义子类,在...
3.1.2 可变参数函数 3.1.3 增强版for循环 3.1.4 基本数据的拆、装箱操作(autoboxing和unboxing) 3.2 枚举 3.2.1 枚举的实现原理 3.2.2 枚举的简单应用 3.2.3 枚举的高级特性 3.3 反射 3.3.1 反射的基石——Class类...