您的位置：首页 > 数据库 > Oracle

Oracle 中使用 fetch bulk collect into 批量效率的读取游标数据【转】

2009-10-21 11:53 561 查看
通常我们获取游标数据是用fetchsome_cursorintovar1,var2的形式，当游标中的记录数不多时不打紧。然而自Oracle8i起，Oracle为我们提供了fetchbulkcollect来批量取游标中的数据，存中即是合理的。它能在读取游标中大量数据的时候提升效率，就像SNMP协议中，V2版比V1版新加了GET-BULKPDU一样，也是用来更高效的批量取设备上的节点值（原来做过网管软件开发，故联想到此）。

fetchbulkcollectinto的使用格式是：fetchsome_cursorcollectintocol1,col2limitxxx。col1、col2是声明的集合类型变量，xxx为每次取数据块的大小（记录数），相当于缓冲区的大小，可以不指定limitxxx大小。下面以实际的例子来说明它的使用，并与逐条取记录的fetchinto执行效率上进行比较。测试环境是Oracle10g10.2.1.0，查询的联系人表sr_contacts中有记录数1802983条，游标中以rownum限定返回的记录数。

使用fetchbulkcollectinto获取游标数据


viewsource

print?

01.
declare

02.

03.
--声明需要集合类型及变量，参照字段的type来声明类型

04.
typeid_type
is
table
of
sr_contacts.sr_contact_id%type;

05.
v_idid_type;

06.

07.
typephone_type
is
table
of
sr_contacts.contact_phone%type;

08.
v_phonephone_type;

09.

10.
typeremark_type
is
table
of
sr_contacts.remark%type;

11.
v_remarkremark_type;

12.

13.
cursor
all_contacts_cur
is
--用rownum来限定取出的记录数来测试

14.
select
sr_contact_id,contact_phone,remark
from
sr_contacts
where
rownum<=100000;

15.

16.
begin

17.

18.
open
all_contacts_cur;

19.
loop

20.
fetch
all_contacts_curbulkcollect
into
v_id,v_phone,v_remarklimit256;

21.
for
i
in
1..v_id.
count
loop
--遍历集合

22.
--用v_id(i)/v_phone(i)/v_remark(i)取出字段值来执行你的业务逻辑

23.
null
;
--这里只放置一个空操作，只为测试循环取数的效率

24.
end
loop;

25.
exit
when
all_contacts_cur%notfound;
--exit不能紧接fetch了，不然会漏记录

26.
end
loop;

27.
close
all_contacts_cur;

28.
end
;


使用fetchinto逐行获取游标数据



viewsource

print?

01.
declare

02.

03.
--声明变量，参照字段的type来声明类型

04.
v_idsr_contacts.sr_contact_id%type;

05.
v_phonesr_contacts.contact_phone%type;

06.
v_remarksr_contacts.remark%type;

07.

08.
cursor
all_contacts_cur
is
--用rownum来限定取出的记录数来测试

09.
select
sr_contact_id,contact_phone,remark
from
sr_contacts
where
rownum<=100000;

10.

11.
begin

12.

13.
open
all_contacts_cur;

14.
loop

15.
fetch
all_contacts_cur
into
v_id,v_phone,v_remark;

16.
exit
when
all_contacts_cur%notfound;

17.
--用v_id/v_phone/v_remark取出字段值来执行你的业务逻辑

18.
null
;
--这里只放置一个空操作，只为测试循环取数的效率

19.
end
loop;

20.
close
all_contacts_cur;

21.
end
;


执行性能比较

看看测试的结果，分别执行五次所耗费的秒数：

当rownum<=100000时：
fetchbulkcollectinto耗时：0.125秒,0.125秒,0.125秒,0.125秒,0.141秒
fetchinto耗时：1.266秒,1.250秒,1.250秒,1.250秒,1.250秒

当rownum<=1000000时：
fetchbulkcollectinto耗时：1.157秒,1.157秒,1.156秒,1.156秒,1.171秒
fetchinto耗时：12.128秒,12.125秒,12.125秒,12.109秒,12.141秒

当rownum<=10000时：
fetchbulkcollectinto耗时：0.031秒,0.031秒,0.016秒,0.015秒,0.015秒
fetchinto耗时：0.141秒,0.140秒,0.125秒,0.141秒,0.125秒

当rownum<=1000时：
fetchbulkcollectinto耗时：0.016秒,0.015秒,0.016秒,0.016秒,0.015秒
fetchinto耗时：0.016秒,0.031秒,0.031秒,0.032秒,0.015秒

从测试结果来看游标的记录数越大时，用fetchbulkcollectinto的效率很明显示，趋于很小时就差不多了。

注意了没有，前面使用fetchbulkcollectinto时前为每一个查询列都定义了一个集合，这样有些繁琐。我们之前也许用过表的%rowtype类型，同样的我们也可以定义表的%rowtype的集合类型。看下面的例子，同时在这个例子中，我们借助于集合的first、last属性来代替使用count属性来进行遍历。

viewsource

print?

01.
declare

02.

03.
--声明需要集合类型及变量，参照字段的type来声明类型

04.
typecontacts_type
is
table
of
sr_contacts%rowtype;

05.
v_contactscontacts_type;

06.

07.
cursor
all_contacts_cur
is
--用rownum来限定取出的记录数来测试

08.
select
*
from
sr_contacts
where
rownum<=10000;

09.

10.
begin

11.

12.
open
all_contacts_cur;

13.
loop

14.
fetch
all_contacts_curbulkcollect
into
v_contactslimit256;

15.
for
i
in
v_contacts.
first
..v_contacts.
last
loop
--遍历集合

16.
--用v_contacts(i).sr_contact_id/v_contacts(i).contact_phone/v_contacts(i).remark

17.
--的形式来取出各字段值来执行你的业务逻辑

18.
null
;
--这里只放置一个空操作，只为测试循环取数的效率

19.
end
loop;

20.
exit
when
all_contacts_cur%notfound;

21.
end
loop;

22.
close
all_contacts_cur;

23.
end
;


关于limit参数

你可以根据你的实际来调整limit参数的大小，来达到你最优的性能。limit参数会影响到pga的使用率。而且也可以在fetchbulk中省略limit参数，写成

fetchall_contacts_curbulkcollectintov_contacts;

有些资料中是说，如果不写limit参数，将会以数据库的arraysize参数值作为默认值。在sqlplus中用showarraysize可以看到该值默认为15，setarraysize256可以更改该值。而实际上我测试不带limit参数时，外层循环只执行了一轮，好像不是limit15，所以不写limit参数时，可以去除外层循环，begin-end部分可写成：

viewsource

print?

01.
begin

02.
open
all_contacts_cur;

03.
fetch
all_contacts_curbulkcollect
into
v_contacts;

04.
for
i
in
v_contacts.
first
..v_contacts.
last
loop
--遍历集合

05.
--用v_contacts(i).sr_contact_id/v_contacts(i).contact_phone/v_contacts(i).remark

06.
--的形式来取出各字段值来执行你的业务逻辑

07.
null
;
--这里只放置一个空操作，只为测试循环取数的效率

08.
dbms_output.put_line(2000);

09.
end
loop;

10.
close
all_contacts_cur;

11.
end
;


bulkcollect的其他用法(总是针对集合)

selectinto语句中，如：

SELECTsr_contact_id,contact_phoneBULKCOLLECTINTOv_id,v_phone
FROMsr_contactsWHEREROWNUM<=100;
dbms_output.put_line('Count:'||v_id.count||',First:'||v_id(1)||'|'||v_phone(1));

returninginto语句中，如：

DELETEFROMsr_contactsWHEREsr_contact_id<30
RETURNINGsr_contact_id,contact_phoneBULKCOLLECTINTOv_id,v_phone;
dbms_output.put_line('Count:'||v_id.count||',First:'||v_id(1)||'|'||v_phone(1));

forall的bulkdml操作，它大大优于for集合后的操作

fetchall_contacts_curbulkcollectintov_contacts;
foralliin1..v_contacts.count
--foralliinv_contacts.first..v_contacts.last
--foralliinindicesofv_contacts--10g以上,可以是非连续的集合
insertintosr_contacts(sr_contact_id,contact_phone,remark)
values(v_contacts(i).sr_contact_id,v_contacts(i).contact_phone,v_contacts(i).remark);
--或者是单条的delete/update操作

参考：1.Oracle中巧用bulkcollect实现cursor批量fetch
2.oracle批量绑定forallbulkcollect用法以及测试案例
3.bulkfetchlimit(zt)
4.OracleBulkBinding批量绑定
5.提高大表的更新效率的过程
6.使用forall语句的bulkdml操作
7.oracleforall
8.Oracle_学习开发子程序_复合数据类型三(批量绑定)
                                            

                                        

                        
                        内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 点击这里给我发消息 
                    

                    

                    

                        

                         标签： 
                                                

                        

                    


                

            


            

                
相关文章推荐

                

                
            

        

        

            

            
            

                

                    
新的分享

                    

                        
                    

                

            


            

                

                    
章节导航