58: END IF;
59:
60:
61: /* ------ Initialize the rowid ranges ------ */
62: ad_parallel_updates_pkg.initialize_rowid_range(
63: ad_parallel_updates_pkg.ROWID_RANGE,
64: l_table_owner,
65: l_table_name,
66: l_script_name,
59:
60:
61: /* ------ Initialize the rowid ranges ------ */
62: ad_parallel_updates_pkg.initialize_rowid_range(
63: ad_parallel_updates_pkg.ROWID_RANGE,
64: l_table_owner,
65: l_table_name,
66: l_script_name,
67: l_worker_id,
68: l_num_workers,
69: l_batch_size, 0);
70:
71: /* ------ Get rowid ranges ------ */
72: ad_parallel_updates_pkg.get_rowid_range(
73: l_start_rowid,
74: l_end_rowid,
75: l_any_rows_to_process,
76: l_batch_size,
222: AND jg.rowid <= l_end_rowid;
223:
224: l_rows_processed := l_rows_processed + SQL%ROWCOUNT;
225:
226: ad_parallel_updates_pkg.processed_rowid_range(
227: l_rows_processed,
228: l_end_rowid);
229:
230: commit;
228: l_end_rowid);
229:
230: commit;
231:
232: ad_parallel_updates_pkg.get_rowid_range(
233: l_start_rowid,
234: l_end_rowid,
235: l_any_rows_to_process,
236: l_batch_size,
306:
307: BEGIN
308:
309: /* ------ Initialize the rowid ranges ------ */
310: ad_parallel_updates_pkg.initialize_rowid_range(
311: ad_parallel_updates_pkg.ROWID_RANGE,
312: l_table_owner,
313: l_table_name,
314: l_script_name,
307: BEGIN
308:
309: /* ------ Initialize the rowid ranges ------ */
310: ad_parallel_updates_pkg.initialize_rowid_range(
311: ad_parallel_updates_pkg.ROWID_RANGE,
312: l_table_owner,
313: l_table_name,
314: l_script_name,
315: l_worker_id,
316: l_num_workers,
317: l_batch_size, 0);
318:
319: /* ------ Get rowid ranges ------ */
320: ad_parallel_updates_pkg.get_rowid_range(
321: l_start_rowid,
322: l_end_rowid,
323: l_any_rows_to_process,
324: l_batch_size,
381:
382: CLOSE c;
383:
384:
385: ad_parallel_updates_pkg.processed_rowid_range(
386: l_rows_processed,
387: l_end_rowid);
388:
389: commit;
387: l_end_rowid);
388:
389: commit;
390:
391: ad_parallel_updates_pkg.get_rowid_range(
392: l_start_rowid,
393: l_end_rowid,
394: l_any_rows_to_process,
395: l_batch_size,
474:
475: BEGIN
476:
477: /* ------ Initialize the rowid ranges ------ */
478: ad_parallel_updates_pkg.initialize_rowid_range(
479: ad_parallel_updates_pkg.ROWID_RANGE,
480: l_table_owner,
481: l_table_name,
482: l_script_name,
475: BEGIN
476:
477: /* ------ Initialize the rowid ranges ------ */
478: ad_parallel_updates_pkg.initialize_rowid_range(
479: ad_parallel_updates_pkg.ROWID_RANGE,
480: l_table_owner,
481: l_table_name,
482: l_script_name,
483: l_worker_id,
484: l_num_workers,
485: l_batch_size, 0);
486:
487: /* ------ Get rowid ranges ------ */
488: ad_parallel_updates_pkg.get_rowid_range(
489: l_start_rowid,
490: l_end_rowid,
491: l_any_rows_to_process,
492: l_batch_size,
555:
556: CLOSE c;
557:
558:
559: ad_parallel_updates_pkg.processed_rowid_range(
560: l_rows_processed,
561: l_end_rowid);
562:
563: commit;
561: l_end_rowid);
562:
563: commit;
564:
565: ad_parallel_updates_pkg.get_rowid_range(
566: l_start_rowid,
567: l_end_rowid,
568: l_any_rows_to_process,
569: l_batch_size,
645:
646: BEGIN
647:
648: /* ------ Initialize the rowid ranges ------ */
649: ad_parallel_updates_pkg.initialize_rowid_range(
650: ad_parallel_updates_pkg.ROWID_RANGE,
651: l_table_owner,
652: l_table_name,
653: l_script_name,
646: BEGIN
647:
648: /* ------ Initialize the rowid ranges ------ */
649: ad_parallel_updates_pkg.initialize_rowid_range(
650: ad_parallel_updates_pkg.ROWID_RANGE,
651: l_table_owner,
652: l_table_name,
653: l_script_name,
654: l_worker_id,
655: l_num_workers,
656: l_batch_size, 0);
657:
658: /* ------ Get rowid ranges ------ */
659: ad_parallel_updates_pkg.get_rowid_range(
660: l_start_rowid,
661: l_end_rowid,
662: l_any_rows_to_process,
663: l_batch_size,
720:
721: CLOSE c;
722:
723:
724: ad_parallel_updates_pkg.processed_rowid_range(
725: l_rows_processed,
726: l_end_rowid);
727:
728: commit;
726: l_end_rowid);
727:
728: commit;
729:
730: ad_parallel_updates_pkg.get_rowid_range(
731: l_start_rowid,
732: l_end_rowid,
733: l_any_rows_to_process,
734: l_batch_size,
812:
813: BEGIN
814:
815: /* ------ Initialize the rowid ranges ------ */
816: ad_parallel_updates_pkg.initialize_rowid_range(
817: ad_parallel_updates_pkg.ROWID_RANGE,
818: l_table_owner,
819: l_table_name,
820: l_script_name,
813: BEGIN
814:
815: /* ------ Initialize the rowid ranges ------ */
816: ad_parallel_updates_pkg.initialize_rowid_range(
817: ad_parallel_updates_pkg.ROWID_RANGE,
818: l_table_owner,
819: l_table_name,
820: l_script_name,
821: l_worker_id,
822: l_num_workers,
823: l_batch_size, 0);
824:
825: /* ------ Get rowid ranges ------ */
826: ad_parallel_updates_pkg.get_rowid_range(
827: l_start_rowid,
828: l_end_rowid,
829: l_any_rows_to_process,
830: l_batch_size,
891:
892: CLOSE c;
893:
894:
895: ad_parallel_updates_pkg.processed_rowid_range(
896: l_rows_processed,
897: l_end_rowid);
898:
899: commit;
897: l_end_rowid);
898:
899: commit;
900:
901: ad_parallel_updates_pkg.get_rowid_range(
902: l_start_rowid,
903: l_end_rowid,
904: l_any_rows_to_process,
905: l_batch_size,
972:
973: BEGIN
974:
975: /* ------ Initialize the rowid ranges ------ */
976: ad_parallel_updates_pkg.initialize_rowid_range(
977: ad_parallel_updates_pkg.ROWID_RANGE,
978: l_table_owner,
979: l_table_name,
980: l_script_name,
973: BEGIN
974:
975: /* ------ Initialize the rowid ranges ------ */
976: ad_parallel_updates_pkg.initialize_rowid_range(
977: ad_parallel_updates_pkg.ROWID_RANGE,
978: l_table_owner,
979: l_table_name,
980: l_script_name,
981: l_worker_id,
982: l_num_workers,
983: l_batch_size, 0);
984:
985: /* ------ Get rowid ranges ------ */
986: ad_parallel_updates_pkg.get_rowid_range(
987: l_start_rowid,
988: l_end_rowid,
989: l_any_rows_to_process,
990: l_batch_size,
1029:
1030: CLOSE c;
1031:
1032:
1033: ad_parallel_updates_pkg.processed_rowid_range(
1034: l_rows_processed,
1035: l_end_rowid);
1036:
1037: commit;
1035: l_end_rowid);
1036:
1037: commit;
1038:
1039: ad_parallel_updates_pkg.get_rowid_range(
1040: l_start_rowid,
1041: l_end_rowid,
1042: l_any_rows_to_process,
1043: l_batch_size,
1103:
1104: BEGIN
1105:
1106: /* ------ Initialize the rowid ranges ------ */
1107: ad_parallel_updates_pkg.initialize_rowid_range(
1108: ad_parallel_updates_pkg.ROWID_RANGE,
1109: l_table_owner,
1110: l_table_name,
1111: l_script_name,
1104: BEGIN
1105:
1106: /* ------ Initialize the rowid ranges ------ */
1107: ad_parallel_updates_pkg.initialize_rowid_range(
1108: ad_parallel_updates_pkg.ROWID_RANGE,
1109: l_table_owner,
1110: l_table_name,
1111: l_script_name,
1112: l_worker_id,
1113: l_num_workers,
1114: l_batch_size, 0);
1115:
1116: /* ------ Get rowid ranges ------ */
1117: ad_parallel_updates_pkg.get_rowid_range(
1118: l_start_rowid,
1119: l_end_rowid,
1120: l_any_rows_to_process,
1121: l_batch_size,
1163:
1164: CLOSE c;
1165:
1166:
1167: ad_parallel_updates_pkg.processed_rowid_range(
1168: l_rows_processed,
1169: l_end_rowid);
1170:
1171: commit;
1169: l_end_rowid);
1170:
1171: commit;
1172:
1173: ad_parallel_updates_pkg.get_rowid_range(
1174: l_start_rowid,
1175: l_end_rowid,
1176: l_any_rows_to_process,
1177: l_batch_size,
1213: g_bulk_fetch_rows NUMBER := 10000;
1214: l_last_fetch BOOLEAN := FALSE;
1215: BEGIN
1216: /* ------ Initialize the rowid ranges ------ */
1217: ad_parallel_updates_pkg.initialize_rowid_range(
1218: ad_parallel_updates_pkg.ROWID_RANGE,
1219: l_table_owner,
1220: l_table_name,
1221: l_script_name,
1214: l_last_fetch BOOLEAN := FALSE;
1215: BEGIN
1216: /* ------ Initialize the rowid ranges ------ */
1217: ad_parallel_updates_pkg.initialize_rowid_range(
1218: ad_parallel_updates_pkg.ROWID_RANGE,
1219: l_table_owner,
1220: l_table_name,
1221: l_script_name,
1222: l_worker_id,
1223: l_num_workers,
1224: l_batch_size, 0);
1225:
1226: /* ------ Get rowid ranges ------ */
1227: ad_parallel_updates_pkg.get_rowid_range(
1228: l_start_rowid,
1229: l_end_rowid,
1230: l_any_rows_to_process,
1231: l_batch_size,
1287:
1288:
1289: l_rows_processed := l_rows_processed + SQL%ROWCOUNT;
1290:
1291: ad_parallel_updates_pkg.processed_rowid_range(
1292: l_rows_processed,
1293: l_end_rowid);
1294:
1295: commit;
1293: l_end_rowid);
1294:
1295: commit;
1296:
1297: ad_parallel_updates_pkg.get_rowid_range(
1298: l_start_rowid,
1299: l_end_rowid,
1300: l_any_rows_to_process,
1301: l_batch_size,