百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 编程网 > 正文

Oracle数据库bulk collect批量绑定详解--附实例说明

yuyutoo 2024-10-28 20:21 1 浏览 0 评论

概述

BULK COLLECT 子句会批量检索结果,即一次性将结果集绑定到一个集合变量中,并从SQL引擎发送到PL/SQL引擎。通常可以在SELECT INTO、 FETCH INTO以及RETURNING INTO子句中使用BULK COLLECT。


语法

FETCH BULK COLLECT <cursor_name> BULK COLLECT INTO <collection_name>
LIMIT <numeric_expression>;
or
FETCH BULK COLLECT <cursor_name> BULK COLLECT INTO <array_name>
LIMIT <numeric_expression>;

Oracle8i中首次引入了Bulk Collect特性,该特性可以让我们在PL/SQL中能使用批查询,批查询在某些情况下能显著提高查询效率。

采用bulk collect可以将查询结果一次性地加载到collections中。

而不是通过cursor一条一条地处理。

可以在select into,fetch into,returning into语句使用bulk collect。

注意在使用bulk collect时,所有的into变量都必须是collections


实例: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; 
/

实验:使用LIMIT限制FETCH数据量

在使用BULK COLLECT 子句时,对于集合类型,如嵌套表,联合数组等会自动对其进行初始化以及扩展(如下示例)。因此如果使用BULK

COLLECT子句操作集合,则无需对集合进行初始化以及扩展。由于BULK COLLECT的批量特性,如果数据量较大,而集合在此时又自动扩展,为避免过大的数据集造成性能下降,因此使用limit子句来限制一次提取的数据量。limit子句只允许出现在fetch操作语句的批量中。

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子句来实现批量绑定。

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; 
/

篇幅有限,关于bulk collect批量绑定方面的内容就介绍到这了,大家可以试着对存储过程中loop循环中的DML语句做适当改写,看是不是效率上有一定提升。实际上最好的应该是FORALL与BULK COLLECT结合使用,可以极大的提高执行效率。

后面会分享更多DBA方面内容,感兴趣的朋友可以关注下!

相关推荐

MySQL5.5+配置主从同步并结合ThinkPHP5设置分布式数据库

前言:本文章是在同处局域网内的两台windows电脑,且MySQL是5.5以上版本下进行的一主多从同步配置,并且使用的是集成环境工具PHPStudy为例。最后就是ThinkPHP5的分布式的连接,读写...

thinkphp5多语言怎么切换(thinkphp5.1视频教程)

thinkphp5多语言进行切换的步骤:第一步,在配置文件中开启多语言配置。第二步,创建多语言目录。相关推荐:《ThinkPHP教程》第三步,编写语言包。视图代码:控制器代码:效果如下:以上就是thi...

基于 ThinkPHP5 + Bootstrap 的后台开发框架 FastAdmin

FastAdmin是一款基于ThinkPHP5+Bootstrap的极速后台开发框架。主要特性基于Auth验证的权限管理系统支持无限级父子级权限继承,父级的管理员可任意增删改子级管理员及权限设置支持单...

Thinkphp5.0 框架实现控制器向视图view赋值及视图view取值操作示

本文实例讲述了Thinkphp5.0框架实现控制器向视图view赋值及视图view取值操作。分享给大家供大家参考,具体如下:Thinkphp5.0控制器向视图view的赋值方式一(使用fetch()方...

thinkphp5实现简单评论回复功能(php评论回复功能源码下载)

由于之前写评论回复都是使用第三方插件:畅言所以也就没什么动手,现在证号在开发一个小的项目,所以就自己动手写评论回复,没写过还真不知道评论回复功能听着简单,但仔细研究起来却无法自拔,由于用户量少,所以...

ThinkPHP框架——实现定时任务,定时更新、清理数据

大家好,我是小蜗牛,今天给大家分享一下,如何用ThinkPHP5.1.*版本实现定时任务,例如凌晨12点更新数据、每隔10秒检测过期会员、每隔几分钟发送请求保证ip的活性等本次分享,主要用到一个名为E...

BeyongCms系统基于ThinkPHP5.1框架的轻量级内容管理系统

BeyongCms内容管理系统(简称BeyongCms)BeyongCms系统基于ThinkPHP5.1框架的轻量级内容管理系统,适用于企业Cms,个人站长等,针对移动App、小程序优化;提供完善简...

YimaoAdminv3企业建站系统,使用 thinkphp5.1.27 + mysql 开发

介绍YimaoAdminv3.0.0企业建站系统,使用thinkphp5.1.27+mysql开发。php要求5.6以上版本,推荐使用5.6,7.0,7.1,扩展(curl,...

ThinkAdmin-V5开发笔记(thinkpad做开发)

前言为了快速开发一款小程序管理后台,在众多的php开源后台中,最终选择了基于thinkphp5的,轻量级的thinkadmin系统,进行二次开发。该系统支持php7。文档地址ThinkAdmin-V5...

thinkphp5.0.9预处理导致的sql注入复现与详细分析

复现先搭建thinkphp5.0.9环境...

thinkphp5出现500错误怎么办(thinkphp页面错误)

thinkphp5出现500错误,如下图所示:相关推荐:《ThinkPHP教程》require():open_basedirrestrictionineffect.File(/home/ww...

Thinkphp5.0极速搭建restful风格接口层

下面是基于ThinkPHPV5.0RC4框架,以restful风格完成的新闻查询(get)、新闻增加(post)、新闻修改(put)、新闻删除(delete)等server接口层。1、下载Thin...

基于ThinkPHP5.1.34 LTS开发的快速开发框架DolphinPHP

DophinPHP(海豚PHP)是一个基于ThinkPHP5.1.34LTS开发的一套开源PHP快速开发框架,DophinPHP秉承极简、极速、极致的开发理念,为开发集成了基于数据-角色的权限管理机...

ThinkPHP5.*远程代码执行高危漏洞手工与升级修复解决方法

漏洞描述由于ThinkPHP5框架对控制器名没有进行足够的安全检测,导致在没有开启强制路由的情况下,黑客构造特定的请求,可直接GetWebShell。漏洞评级严重影响版本ThinkPHP5.0系列...

Thinkphp5代码执行学习(thinkphp 教程)

Thinkphp5代码执行学习缓存类RCE版本5.0.0<=ThinkPHP5<=5.0.10Tp框架搭建环境搭建测试payload...

取消回复欢迎 发表评论: