使用BULK COLLECT+FORALL加速批量提交

1、        批量提交

批量提交特色:

占用较少undo,资源(独占锁,undo)快速释放,执行时间长web

批量提交适合场景:

在线大批量插入,更新,删除数据sql

2、        BULK COLLECT+FORALL性能提高

1.经过BULK COLLECT加速查询

无论是显示游标仍是隐式游标,均可以经过BULK COLLECT在数据库的单次交互中获取多行数据。BULKCOLLECT相对Cursor Loop方式减小了PL/SQL引擎和SQL引擎之间的切换次数,所以也减小了提取数据时的额外开销。
数据库

经过LIMIT rows限制提取的记录数

这种方法会减小对PGA的消耗,避免换页产生app

3经过FORALL 加速DML

FORALL告诉PL/SQL引擎要先把一个或多个集合的全部成员都绑定到SQL语句中,而后再把语句发送给SQL引擎若是for ..loop 循环,那么会发送n(循环的次数)次,而用Forall,一次行所有发送过去。
oop

3、        BULK COLLECT + FORALL 批量提交例句

insert

declare
  TYPE ARRAY IS TABLE OF big_table%ROWTYPE;
  l_data ARRAY;
  CURSOR c IS
    SELECT * FROM big_table;
BEGIN
  OPEN c;
  LOOP
    FETCH c BULK COLLECT
      INTO l_data LIMIT 5000;
  
    FORALL i IN 1 .. l_data.COUNT
      INSERT /*+append*/
      INTO big_table
      VALUES l_data
        (i);
    commit;
    EXIT WHEN c%NOTFOUND;
  END LOOP;
  CLOSE c;

delete

DECLARE
  CURSOR mycursor IS
    SELECT rowid FROM t WHERE OO = XX;
  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;
    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;

update

DECLARE
  CURSOR mycursor IS
    SELECT t_pk FROM t WHERE OO = XX;
  TYPE num_tab_t IS TABLE OF NUMBER(38);
  pk_tab NUM_TAB_T;
BEGIN
  OPEN mycursor;
  LOOP
    FETCH mycursor BULK COLLECT
      INTO pk_tab LIMIT 5000;
    EXIT WHEN pk_tab.count = 0;
    FORALL i IN pk_tab.FIRST .. v_rowid.LAST
      UPDATE t SET name = name || ’bulk’ WHERE t_pk = pk_tab(i);
    COMMIT;
  END LOOP;
  CLOSE mycursor;
END;
相关文章
相关标签/搜索