利用rowid快速在线更新海量数据

shiri512003

good idea!

阿日

很不错的想法,学习了

ora110

很好，利用rowid和bulk collect.

wgz7747

原帖由 TO_TO_RO 于 2008-9-8 08:52 发表
这么大的表用游标遍历不太合适

这句说的经典

fromeast

原帖由 goodhawk 于 2008-9-8 23:29 发表
应该跟如下的写法差不多, 同时建议不要 1000 commit 一次, 可以考虑 10000 或者 30000 左右来一次,
太频繁也是浪费时间.

CURSOR c1 IS
    SELECT object_name,object_id,status
    FROM up
    ORDER BY object_name
    FOR UPDATE OF status;

BEGIN

FOR acct IN c1 LOOP   -- process each row one at a time   
  IF acct.status='INVALID' THEN
       UPDATE up SET status='TEST'
       WHERE current of c1;
  END IF;
END LOOP;

COMMIT;
END;

T1是在线表，用1000是为了减少对T1的锁定时间，按10000 rows/s的算，1秒会COMMIT 10次，我觉得不会造成太大的问题。但是用10000或30000，就会锁记录最长达到1秒或3秒，可能会影响在线业务。

[ 本帖最后由 fromeast 于 2008-9-9 13:02 编辑 ]

fromeast

原帖由 wgz7747 于 2008-9-9 10:12 发表

这句说的经典

确实发现了问题，在运行了8个小时后，报错退出了。错误码是ORA-600 [4454]。根据metalink上的资料，应该是9.2存在的BUG，原因是长时间的BATCH JOB造成savepoint号绕回，引发了ORA-600。现在的解决方法是找到报错之前更新的行数n，然后修改脚本，加个限制，更新到n-1000万行，就退出，再重启脚本。这样做的缺点是每次重启，都要耗费额外的时间在打开CURSOR上，约70分钟。

[ 本帖最后由 fromeast 于 2008-9-9 13:05 编辑 ]

Alienovo

不错  支持原创～

ZALBB

原帖由 rollingpig 于 2008-9-8 16:08 发表
加一个for all, 效果会更好
declare
maxrows number default 1000;
row_id_table dbms_sql.Urowid_Table;
currcount_table dbms_sql.number_Table;
  cursor cur_t2 is
    select /*+ use_hash(T1,T2) parallel(T1,16) parallel_index(IX_T1_id2,16) */
       T2.id2, T2.curr_count, T1.rowid row_id
    from T1, T2
    where T1.id2=T2.id2
    order by T1.rowid;
  v_counter number;
begin
  v_counter := 0;
open cur_t2;
LOOP
EXIT WHEN cur_t2%NOTFOUND;
FETCH cur_t2 bulk collect into row_id_table,currcount_table limit maxrows;
forall i in 1 .. row_id_table.count
    update T1 set curr_count=currcount_table(i)
       where rowid= row_id_table(i);
      commit;
  end loop;
end;
/
参考：
http://space.itpub.net/1249/viewspace-64339

请滚珠区确认一下，你这里定义的
row_id_table dbms_sql.Urowid_Table;
currcount_table dbms_sql.number_Table;
是否合适？我看不明白，

我觉得，先定义游标，再用游标定义内存表比较合适？

wang19840829

经典，突然觉得自己什么都不会。

liqy103

excellent!