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

更新时间：2013年04月10日 17:29:17 作者：

本篇文章小编为大家介绍一下，浅谈PL/SQL批处理语句:BULK COLLECT与FORALL对优化做出的贡献。有需要的朋友可以参考一下

我们知道PL/SQL程序中运行SQL语句是存在开销的，因为SQL语句是要提交给SQL引擎处理
这种在PL/SQL引擎和SQL引擎之间的控制转移叫做上下文却换，每次却换时，都有额外的开销

请看下图：

但是，FORALL和BULK COLLECT可以让PL/SQL引擎把多个上下文却换压缩成一个，这使得在PL/SQL中的要处理多行记录的SQL语句执行的花费时间骤降
请再看下图：

下面详解这爷俩

㈠通过BULK COLLECT 加速查询

⑴ BULK COLLECT 的用法

采用BULK COLLECT可以将查询结果一次性地加载到collections中，而不是通过cursor一条一条地处理
可以在select into ，fetch into ， returning into语句使用BULK COLLECT
注意在使用BULK COLLECT时，所有的INTO变量都必须是collections

举几个简单例子：

① 在select into语句中使用bulk collect

复制代码代码如下:

DECLARE 
TYPE sallist IS TABLE OF employees.salary%TYPE;
sals sallist;
BEGIN
SELECT salary BULK COLLECT INTO sals FROM employees where rownum<=50;
--接下来使用集合中的数据
END;
/

② 在fetch into中使用bulk collect

复制代码代码如下:

DECLARE
TYPE deptrectab IS TABLE OF departments%ROWTYPE;
dept_recs deptrectab;
CURSOR cur IS SELECT department_id,department_name FROM departments where department_id>10;
BEGIN
OPEN cur;
FETCH cur BULK COLLECT INTO dept_recs;
--接下来使用集合中的数据
END;
/

③ 在returning into中使用bulk collect

复制代码代码如下:

CREATE TABLE emp AS SELECT * FROM employees;

DECLARE
TYPE numlist IS TABLE OF employees.employee_id%TYPE;
enums numlist;
TYPE namelist IS TABLE OF employees.last_name%TYPE;
names namelist;
BEGIN
DELETE emp WHERE department_id=30
RETURNING employee_id,last_name BULK COLLECT INTO enums,names;
DBMS_OUTPUT.PUT_LINE('deleted'||SQL%ROWCOUNT||'rows:');
FOR i IN enums.FIRST .. enums.LAST
LOOP
DBMS_OUTPUT.PUT_LINE('employee#'||enums(i)||':'||names(i));
END LOOP;
END;
/

deleted6rows:
employee#114:Raphaely
employee#115:Khoo
employee#116:Baida
employee#117:Tobias
employee#118:Himuro
employee#119:Colmenares

EATE TABLE emp AS SELECT * FROM employees;DECLARE TYPE numlist IS TABLE OF employees.employee_id%TYPE; enums numlist; TYPE namelist IS TABLE OF employees.last_name%TYPE; names namelist;BEGIN DELETE emp WHERE department_id=30 RETURNING employee_id,last_name BULK COLLECT INTO enums,names; DBMS_OUTPUT.PUT_LINE('deleted'||SQL%ROWCOUNT||'rows:'); FOR i IN enums.FIRST .. enums.LAST LOOP DBMS_OUTPUT.PUT_LINE('employee#'||enums(i)||':'||names(i)); END LOOP;END;/deleted6rows:employee#114:Raphaelyemployee#115:Khooemployee#116:Baidaemployee#117:Tobiasemployee#118:Himuroemployee#119:Colmenares

⑵ BULK COLLECT 对大数据DELETE UPDATE的优化

这里举DELETE就可以了，UPDATE同理

举个案例：
需要在一个1亿行的大表中，删除1千万行数据
需求是在对数据库其他应用影响最小的情况下，以最快的速度完成

如果业务无法停止的话，可以参考下列思路：
根据ROWID分片、再利用Rowid排序、批量处理、回表删除
在业务无法停止的时候，选择这种方式，的确是最好的
一般可以控制在每一万行以内提交一次，不会对回滚段造成太大压力
我在做大DML时，通常选择一两千行一提交
选择业务低峰时做，对应用也不至于有太大影响
代码如下：

复制代码代码如下:

DECLARE
--按rowid排序的cursor
--删除条件是oo=xx，这个需根据实际情况来定
CURSOR mycursor IS SELECT rowid FROM t WHERE OO=XX ORDER BY rowid;
TYPE rowid_table_type IS TABLE OF rowid index by pls_integer;
v_rowid rowid_table_type;
BEGIN
OPEN mycursor;
LOOP
FETCH mycursor BULK COLLECT INTO v_rowid LIMIT 5000;--5000行提交一次
EXIT WHEN v_rowid.count=0;
FORALL i IN v_rowid.FIRST..v_rowid.LAST
DELETE t WHERE rowid=v_rowid(i);
COMMIT;
END LOOP;
CLOSE mycursor;
END;
/

⑶ 限制BULK COLLECT 提取的记录数

语法：
FETCH cursor BULK COLLECT INTO ...[LIMIT rows]；
其中，rows可以是常量，变量或者求值的结果是整数的表达式

假设你需要查询并处理1W行数据，你可以用BULK COLLECT一次取出所有行，然后填充到一个非常大的集合中
可是，这种方法会消耗该会话的大量PGA，APP可能会因为PGA换页而导致性能下降

这时，LIMIT子句就非常有用，它可以帮助我们控制程序用多大内存来处理数据

例子：

复制代码代码如下:

DECLARE
CURSOR allrows_cur IS SELECT * FROM employees;
TYPE employee_aat IS TABLE OF allrows_cur%ROWTYPE INDEX BY BINARY_INTEGER;
v_emp employee_aat;
BEGIN
OPEN allrows_cur;
LOOP
FETCH allrows_cur BULK FETCH INTO v_emp LIMIT 100;

/*通过扫描集合对数据进行处理*/
FOR i IN 1 .. v_emp.count
LOOP
upgrade_employee_status(v_emp(i).employee_id);
END LOOP;

EXIT WHEN allrows_cur%NOTFOUND;
END LOOP;

CLOSE allrows_cur;
END;
/

⑷ 批量提取多列

需求：
提取transportation表中的油耗小于 20公里/RMB的交通具体的全部信息
代码如下：

复制代码代码如下:

DECLARE
--声明集合类型
TYPE vehtab IS TABLE OF transportation%ROWTYPE;
--初始化一个这个类型的集合
gas_quzzlers vehtab;
BEGIN
SELECT * BULK COLLECT INTO gas_quzzlers FROM transportation WHERE mileage < 20;
...

⑸ 对批量操作使用RETURNING子句

有了returning子句后，我们可以轻松地确定刚刚完成的DML操作的结果，无须再做额外的查询工作
例子请见BULK COLLECT 的用法的第三小点

㈡通过FORALL 加速DML

FORALL告诉PL/SQL引擎要先把一个或多个集合的所有成员都绑定到SQL语句中，然后再把语句发送给SQL引擎

⑴ 语法

未完待续。。。

您可能感兴趣的文章:

oracle 12c创建可插拔数据库（PDB）与用户详解
Oracle12c 中，增加了可插接数据库的概念，即PDB，允许一个数据库容器（CDB）承载多个可插拔数据库（PDB）。下面这篇文章主要给大家介绍了利用oracle 12c创建可插拔数据库（PDB）与用户的相关资料，文中介绍的很详细，需要的朋友可以参考借鉴，下面来一起看看吧。
2017-02-02
ORACLE8的分区管理
ORACLE8的分区管理...
2007-03-03
oracle 中 sqlplus命令大全
Oracle的sql*plus是与oracle数据库进行交互的客户端工具，借助sql*plus可以查看、修改数据库记录。接下来通过本文给大家介绍oracle中sqlplus命令知识，非常不错，感兴趣的朋友一起看看吧
2016-09-09
Oracle导出文本文件的三种方法(spool,UTL_FILE,sqluldr2)
这篇文章主要介绍了Oracle导出文本文件的三种方法(spool,UTL_FILE,sqluldr2),需要的朋友可以参考下
2023-05-05
常见数据库系统比较 Oracle数据库
常见数据库系统比较 Oracle数据库...
2007-03-03
oracle 使用rownum的三种分页方式
rownum是Oracle数据库中的一个特有关键字，返回的是一个数字代表记录的行号。这篇文章主要介绍了oracle 使用rownum的三种分页方式,需要的朋友可以参考下
2019-10-10
Oracle数据库中如何给表赋予权限
赋权是指将特定的权限授予用户或用户组,以便他们可以执行特定的操作,如查询、插入、更新和删除数据,创建和修改表结构,以及执行其他管理任务,这篇文章主要给大家介绍了关于Oracle数据库中如何给表赋予权限的相关资料,需要的朋友可以参考下
2024-01-01
在Oracle数据库中同时更新两张表的简单方法
这篇文章主要介绍了在Oracle数据库中同时更新两张表的简单方法,同时介绍了一种差异性合并更新的方法,需要的朋友可以参考下
2015-11-11
Excel VBA连接并操作Oracle
Excel通过ADO方式连接到Oracle并操作Oracle给我们这些编程能力不强的人带来很大的福音，结合着Excel的数据处理与图表制作，就能很轻松地处理一些常规工作。
2009-08-08
win7下oracle 10g安装图文教程
这篇文章主要为大家详细介绍了win7下oracle 10g安装图文教程，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-03-03