批量SQL之 BULK COLLECT 子句

    BULK COLLECT 子句会批量检索结果,即一次性将结果集绑定到一个集合变量中,并从SQL引擎发送到PL/SQL引擎。通常可以在SELECT INTO、
FETCH INTO以及RETURNING INTO子句中使用BULK COLLECT。本文将逐一描述BULK COLLECT在这几种情形下的用法。
    有关FORALL语句的用法请参考:批量SQL之 FORALL 语句

 

一、BULK COLLECT批量绑定的示例

--下面的示例中使用了BULK COLLECT将得到的结果集绑定到记录变量中
DECLARE
   TYPE emp_rec_type IS RECORD          --声明记录类型
   (
      empno      emp.empno%TYPE
     ,ename      emp.ename%TYPE
     ,hiredate   emp.hiredate%TYPE
   );

   TYPE nested_emp_type IS TABLE OF emp_rec_type;  --声明记录类型变量 

   emp_tab   nested_emp_type;
BEGIN
   SELECT empno, ename, hiredate
   BULK   COLLECT INTO emp_tab       --使用BULK COLLECT 将所得的结果集一次性绑定到记录变量emp_tab中
   FROM   emp;

   FOR i IN emp_tab.FIRST .. emp_tab.LAST
   LOOP
      DBMS_OUTPUT.put_line('Current record is '||emp_tab(i).empno||chr(9)||emp_tab(i).ename||chr(9)||emp_tab(i).hiredate);
   END LOOP;
END;
--上面的例子可以通过FOR 循环和普通的SELECT INTO来实现,那两者之间的差异呢?
--差异是FOR循环的SELECT INTO逐行提取并绑定到记录变量,而BULK COLLECT则一次即可提取所有行并绑定到记录变量。即谓批量绑定。

二、使用LIMIT限制FETCH数据量
    在使用BULK COLLECT 子句时,对于集合类型,如嵌套表,联合数组等会自动对其进行初始化以及扩展(如下示例)。因此如果使用BULK
COLLECT子句操作集合,则无需对集合进行初始化以及扩展。由于BULK COLLECT的批量特性,如果数据量较大,而集合在此时又自动扩展,为避
免过大的数据集造成性能下降,因此使用limit子句来限制一次提取的数据量。limit子句只允许出现在fetch操作语句的批量中。

    用法:
        FETCH ... BULK COLLECT INTO ... [LIMIT rows]

DECLARE
   CURSOR emp_cur IS
      SELECT empno, ename, hiredate FROM emp;

   TYPE emp_rec_type IS RECORD
   (
      empno      emp.empno%TYPE
     ,ename      emp.ename%TYPE
     ,hiredate   emp.hiredate%TYPE
   );

   TYPE nested_emp_type IS TABLE OF emp_rec_type;   -->定义了基于记录的嵌套表

   emp_tab     nested_emp_type;           -->定义集合变量,此时未初始化
   v_limit     PLS_INTEGER := 5;          -->定义了一个变量来作为limit的值
   v_counter   PLS_INTEGER := 0;
BEGIN
   OPEN emp_cur;

   LOOP
      FETCH emp_cur
      BULK   COLLECT INTO emp_tab         -->fetch时使用了BULK COLLECT子句
      LIMIT v_limit;                      -->使用limit子句限制提取数据量

      EXIT WHEN emp_tab.COUNT = 0;        -->注意此时游标退出使用了emp_tab.COUNT,而不是emp_cur%notfound
      v_counter   := v_counter + 1;       -->记录使用LIMIT之后fetch的次数

      FOR i IN emp_tab.FIRST .. emp_tab.LAST
      LOOP
         DBMS_OUTPUT.put_line( 'Current record is '||emp_tab(i).empno||CHR(9)||emp_tab(i).ename||CHR(9)||emp_tab(i).hiredate);
      END LOOP;
   END LOOP;

   CLOSE emp_cur;

   DBMS_OUTPUT.put_line( 'The v_counter is ' || v_counter );
END;

三、RETURNING 子句的批量绑定
    BULK COLLECT除了与SELECT,FETCH进行批量绑定之外,还可以与INSERT,DELETE,UPDATE语句结合使用。当与这几个DML语句结合时,我们
需要使用RETURNING子句来实现批量绑定。

--下面示例中从表emp中删除所有deptno=20的记录
DECLARE
   TYPE emp_rec_type IS RECORD
   (
      empno      emp.empno%TYPE
     ,ename      emp.ename%TYPE
     ,hiredate   emp.hiredate%TYPE
   );

   TYPE nested_emp_type IS TABLE OF emp_rec_type;

   emp_tab   nested_emp_type;
--   v_limit   PLS_INTEGER := 3;
--   v_counter   PLS_INTEGER := 0;
BEGIN
   DELETE FROM emp
   WHERE  deptno = 20
   RETURNING empno, ename, hiredate     -->使用returning 返回这几个列
   BULK   COLLECT INTO emp_tab;         -->将前面返回的列的数据批量插入到集合变量  

   DBMS_OUTPUT.put_line( 'Deleted ' || SQL%ROWCOUNT || ' rows.' );
   COMMIT;

   IF emp_tab.COUNT > 0 THEN                 -->当集合变量不为空时,输出所有被删除的元素
      FOR i IN emp_tab.FIRST .. emp_tab.LAST
      LOOP
         DBMS_OUTPUT.
          put_line(
                       'Current record  '
                    || emp_tab( i ).empno
                    || CHR( 9 )
                    || emp_tab( i ).ename
                    || CHR( 9 )
                    || emp_tab( i ).hiredate
                    || ' has been deleted' );
      END LOOP;
   END IF;
END;

四、FORALL与BULK COLLECT 综合运用
    FORALL与BULK COLLECT是实现批量SQL的两个重要方式,我们可以将其结合使用以提高性能。下面的示例即是两者的总和运用。

DROP TABLE tb_emp;

CREATE TABLE tb_emp AS                        -->创建表tb_emp
   SELECT empno, ename, hiredate
   FROM   emp
   WHERE  1 = 2;

DECLARE
   CURSOR emp_cur IS                          -->声明游标
      SELECT empno, ename, hiredate FROM emp;

   TYPE nested_emp_type IS TABLE OF emp_cur%ROWTYPE;  -->基于游标的嵌套表类型

   emp_tab   nested_emp_type;                         -->声明嵌套变量
BEGIN
   SELECT empno, ename, hiredate
   BULK   COLLECT INTO emp_tab                        -->BULK  COLLECT批量提取数据
   FROM   emp
   WHERE  sal > 1000;

   FORALL i IN 1 .. emp_tab.COUNT                     -->使用FORALL语句将变量中的数据插入到表tb_emp
      INSERT INTO (SELECT empno, ename, hiredate FROM tb_emp)
      VALUES emp_tab( i );

   COMMIT;
   DBMS_OUTPUT.put_line( 'The total ' || emp_tab.COUNT || ' rows has been inserted to tb_emp' );
END;

五、BULK COLLECT的限制
1、不能对使用字符串类型作键的关联数组使用BULK COLLECT 子句。
2、只能在服务器端的程序中使用BULK COLLECT,如果在客户端使用,就会产生一个不支持这个特性的错误。
3、BULK COLLECT INTO 的目标对象必须是集合类型。
4、复合目标(如对象类型)不能在RETURNING INTO 子句中使用。
5、如果有多个隐式的数据类型转换的情况存在,多重复合目标就不能在BULK COLLECT INTO 子句中使用。
6、如果有一个隐式的数据类型转换,复合目标的集合(如对象类型集合)就不能用于BULK COLLECTINTO 子句中。

 

六、更多参考

批量SQL之 FORALL 语句

PL/SQL 集合的初始化与赋值

PL/SQL 联合数组与嵌套表
PL/SQL 变长数组
PL/SQL --> PL/SQL记录

SQL tuning 步骤

高效SQL语句必杀技

父游标、子游标及共享游标

绑定变量及其优缺点

dbms_xplan之display_cursor函数的使用

dbms_xplan之display函数的使用

执行计划中各字段各模块描述

使用 EXPLAIN PLAN 获取SQL语句执行计划

时间: 2024-09-17 04:51:33

批量SQL之 BULK COLLECT 子句的相关文章

PostgreSQL Oracle 兼容性之 - PL/SQL FORALL, BULK COLLECT

Oracle PL/SQL 开发的童鞋,一定对O家的bulk批量处理的性能很是赞赏吧.但是PostgreSQL用户请不要垂涎,作为学院派和工业界的一颗璀璨明珠.开源数据库PostgreSQL,也有对应的批量处理策略哦,而且看起来性能完全不输Oracle.下面是一组LOOP和BULK的性能测试数据 一起来耍耍吧,先看看Oracle怎么耍的. Oracle PL/SQL FORALL, BULK COLLECT 为什么Oracle的PL/SQL过程语言需要bulk处理SQL,看一张图你就明白了,因为

pl/sql中bulk collect的用法

bulk collect可以将查询结果一次性地加载到collections中,而不用一条一条地处理.在select into,fetch into,returning into语句使用使用bulk collect时,所有的into变量都必须是collections. create table jy ( object_id number(12), object_name varchar2(20), object_type varchar2(20) ) 在select into语句中使用bulk c

批量 SQL 之 FORALL 语句

    对PL/SQL而言,任何的PL/SQL块或者子程序都是PL/SQL引擎来处理,而其中包含的SQL语句则由PL/SQL引擎发送SQL语句转交到SQL引擎来处理,SQL引擎处理完毕后向PL/SQL引擎返回数据.Pl/SQL与SQL引擎之间的通信则称之为上下文切换.过多的上下文切换将带来过量的性能负载.因此为减少性能的FORALL与BULK COLLECT的子句应运而生.即仅仅使用一次切换多次执行来降低上下文切换次数.本文主要描述FORALL子句. 一.FORALL语法描述     FORAL

批量SQL(原创)

批量sql概述 对 PL/SQL而言,任何的PL/SQL块或者子程序都是PL/SQL引擎来处理,而其中包含的SQL语句则由PL/SQL引擎发送SQL语句转交到SQL 引擎来处理,SQL引擎处理完毕后向PL/SQL引擎返回数据.Pl/SQL与SQL引擎之间的通信则称之为上下文切换.过多的上下文切换将带来过量的性 能负载.因此为减少性能的FORALL与BULK COLLECT的子句应运而生,即仅仅使用一次切换多次执行来降低上下文切换次数. 注意:并不是所有的SQL,FORALL语句都会一次性将SQL

Oracle数据库之FORALL与BULK COLLECT语句

 Oracle数据库之FORALL与BULK COLLECT语句    我们再来看一下PL/SQL块的执行过程:当PL/SQL运行时引擎处理一块代码时,它使用PL/SQL引擎来执行过程化的代码,而将SQL语句发送给SQL引擎来执行:SQL引擎执行完毕后,将结果再返回给PL/SQL引擎.这种在PL/SQL引擎和SQL引擎之间的交互,称为上下文交换(context switch).每发生一次交换,就会带来一定的额外开销.   FORALL,用于增强PL/SQL引擎到SQL引擎的交换. BULK CO

oracle下巧用bulk collect实现cursor批量fetch的sql语句_oracle

在一般的情况下,使用批量fetch的几率并不是很多,但是Oracle提供了这个功能我们最好能熟悉一下,说不定什么时候会用上它.  复制代码 代码如下: declare  cursor c1 is select * from t_depart;  v_depart t_depart%rowtype ;  type v_code_type is table of t_depart.depart_code%type ;  v_code v_code_type ;  type v_name_type i

浅谈PL/SQL批处理语句:BULK COLLECT与FORALL对优化做出的贡献_oracle

我们知道PL/SQL程序中运行SQL语句是存在开销的,因为SQL语句是要提交给SQL引擎处理这种在PL/SQL引擎和SQL引擎之间的控制转移叫做上下文却换,每次却换时,都有额外的开销 请看下图: 但是,FORALL和BULK COLLECT可以让PL/SQL引擎把多个上下文却换压缩成一个,这使得在PL/SQL中的要处理多行记录的SQL语句执行的花费时间骤降请再看下图: 下面详解这爷俩 ㈠ 通过BULK COLLECT 加速查询 ⑴ BULK COLLECT 的用法 采用BULK COLLECT可

【PL/SQL】初试 bulk collect

SQL> create table yang(last_name varchar2(20),first_name varchar2(10),salary number(10));   Table created Executed in 1.388 seconds SQL> begin   2  for i in 1000..100999 loop   3  insert into yang (last_name,first_name,salary) values('qilong'||(i-10

PL/SQL Practices On BULK COLLECT limit

Best practices for knowing your LIMIT and kicking %NOTFOUND I have started using BULK COLLECT whenever I need to fetch large volumes of data. This has caused me some trouble with my DBA, however. He is complaining that although my programs might be r