批处理过程的优化--改写一段存储过程为一个SQL

对于批处理业务，程序员的一般性思维方法是：

打开一个游标，然后逐条处理。如果想加快点速度，那就多开一些并发进程。

下面的存储过程代码就是这样一个比较典型的例子：

根据一张表的记录（先去重），更新另一张表，v_part参数是表的分区号，为了并发而设计。

CREATE OR REPLACE procedure HSS.proc_mbi_day(v_part number) is

cursor cur_ofr_id is

select a.ofr_id from tb_mbi_temp2 a;

begin

sql_2:=

'insert into hss.tb_mbi_temp2(ofr_id) select distinct a.ofr_id

from tb_bil_mbi_day a where a.part='||v_part;

execute immediate sql_2;

v_commit:=0;

open cur_ofr_id;

loop

fetch cur_ofr_id into v_ofr_id;

exit when cur_ofr_id%notfound;

sql_6:=

'select nvl(min(ofr_code),0) from hss.tb_prd_ofr a

where a.ofr_id = :v_ofr_id and rownum = 1';

execute immediate sql_6 into v_ofr_code using v_ofr_id;

sql_4:=

'update tb_bil_mbi_day a set a.ofr_code=:v_ofr_code where a.ofr_id=:v_ofr_id and a.part=:v_part';

execute immediate sql_4 using v_ofr_code,v_ofr_id,v_part;

v_commit:=v_commit+1;

if v_commit >= 100 then

commit;

v_commit:=0;

end if;

end loop;

对于这个一个逻辑不是太复杂的业务，我们完全可以通过下面这样一个SQL来实现：

merge into tb_bil_mbi_day_0 b using

(select ofr_id,nvl(ofr_code,0) as ofr_code

from (select ofr_id,ofr_code,

row_number() over (partition by ofr_id order by ofr_ode) as rn

from hss.tb_prd_ofr) a where rn=1

) a on (b.ofr_id=a.ofr_id )

when matched then

update set b.ofr_code = a.ofr_code;

这样的改写不是为了简洁，而是为了更加高效。上面存储过程执行需要几个小时，而经过改写后的SQL只需要执行几分钟。

是不是应该考虑优化一下你们的批处理业务了呢？