批量数据处理存储过程模板

declare
  maxrows      number default 50000;
  row_id_table dbms_sql.Urowid_Table;
  cursor acnt_first_cur is
    select /*+ parallel(t1,8) */
     t1.rowid
      from EHISDATA.PERSON t1 
     order by t1.rowid;
begin
  open acnt_first_cur;
  loop
    exit when acnt_first_cur%notfound;
    fetch acnt_first_cur bulk collect
      into  row_id_table limit maxrows;
    forall i in 1 .. row_id_table.count
update EHISDATA.PERSON t1
   set t1.CERTIFICATE_NO               = transName(t1.CERTIFICATE_NO,'hash'),t1.EMAIL                        = transName(t1.EMAIL,t1.ENGLISH_NAME                 = transName(t1.ENGLISH_NAME,t1.ORGANIZATION_DEPARTMENT_NAME = transName(t1.ORGANIZATION_DEPARTMENT_NAME,t1.PERSON_NAME                  = transName(t1.PERSON_NAME,t1.PHONETICIZE_LASTNAME         = transName(t1.PHONETICIZE_LASTNAME,t1.REGIST_PLACE                 = transName(t1.REGIST_PLACE,t1.WORK_UNIT                    = transName(t1.WORK_UNIT,'hash')
       where t1.rowid = row_id_table(i);
    commit;
  end loop;
end;