404: -- Fetching records from OE_ORDER_HEADERS_ALL table
405: -----------------------------------------------------------
406: l_table_name := 'OE_ORDER_HEADERS_ALL' ;
407:
408: ad_parallel_updates_pkg.delete_update_information(
409: 0,
410: l_table_owner,
411: l_table_name,
412: l_script_name ) ;
410: l_table_owner,
411: l_table_name,
412: l_script_name ) ;
413:
414: ad_parallel_updates_pkg.initialize_rowid_range(
415: ad_parallel_updates_pkg.ROWID_RANGE,
416: l_table_owner,
417: l_table_name,
418: l_script_name,
411: l_table_name,
412: l_script_name ) ;
413:
414: ad_parallel_updates_pkg.initialize_rowid_range(
415: ad_parallel_updates_pkg.ROWID_RANGE,
416: l_table_owner,
417: l_table_name,
418: l_script_name,
419: X_worker_id,
419: X_worker_id,
420: X_num_workers,
421: X_batch_size, 0) ;
422:
423: ad_parallel_updates_pkg.get_rowid_range(
424: l_start_rowid,
425: l_end_rowid,
426: l_any_rows_to_process,
427: X_batch_size,
585: END LOOP;
586: END ;
587: --6757060
588:
589: ad_parallel_updates_pkg.processed_rowid_range
590: (l_rows_processed,
591: l_end_rowid) ;
592:
593: COMMIT ;
591: l_end_rowid) ;
592:
593: COMMIT ;
594:
595: ad_parallel_updates_pkg.get_rowid_range
596: (l_start_rowid,
597: l_end_rowid,
598: l_any_rows_to_process,
599: X_batch_size,
640: -- Fetching records from OE_PAYMENTS table
641: -----------------------------------------------------------
642: l_table_name := 'OE_PAYMENTS' ;
643:
644: ad_parallel_updates_pkg.delete_update_information(
645: 0,
646: l_table_owner,
647: l_table_name,
648: l_script_name ) ;
646: l_table_owner,
647: l_table_name,
648: l_script_name ) ;
649:
650: ad_parallel_updates_pkg.initialize_rowid_range(
651: ad_parallel_updates_pkg.ROWID_RANGE,
652: l_table_owner,
653: l_table_name,
654: l_script_name,
647: l_table_name,
648: l_script_name ) ;
649:
650: ad_parallel_updates_pkg.initialize_rowid_range(
651: ad_parallel_updates_pkg.ROWID_RANGE,
652: l_table_owner,
653: l_table_name,
654: l_script_name,
655: X_worker_id,
655: X_worker_id,
656: X_num_workers,
657: X_batch_size, 0) ;
658:
659: ad_parallel_updates_pkg.get_rowid_range(
660: l_start_rowid,
661: l_end_rowid,
662: l_any_rows_to_process,
663: X_batch_size,
779:
780: l_process_total1 := l_process_total1 + l_rows_processed ;
781: END IF ;
782:
783: ad_parallel_updates_pkg.processed_rowid_range
784: (l_rows_processed,
785: l_end_rowid) ;
786:
787: COMMIT ;
785: l_end_rowid) ;
786:
787: COMMIT ;
788:
789: ad_parallel_updates_pkg.get_rowid_range
790: (l_start_rowid,
791: l_end_rowid,
792: l_any_rows_to_process,
793: X_batch_size,
833: -- Fetching records from OE_PAYMENTS table
834: -----------------------------------------------------------
835: l_table_name := 'OE_PAYMENTS' ;
836:
837: ad_parallel_updates_pkg.delete_update_information(
838: 0,
839: l_table_owner,
840: l_table_name,
841: l_script_name ) ;
839: l_table_owner,
840: l_table_name,
841: l_script_name ) ;
842:
843: ad_parallel_updates_pkg.initialize_rowid_range(
844: ad_parallel_updates_pkg.ROWID_RANGE,
845: l_table_owner,
846: l_table_name,
847: l_script_name,
840: l_table_name,
841: l_script_name ) ;
842:
843: ad_parallel_updates_pkg.initialize_rowid_range(
844: ad_parallel_updates_pkg.ROWID_RANGE,
845: l_table_owner,
846: l_table_name,
847: l_script_name,
848: X_worker_id,
848: X_worker_id,
849: X_num_workers,
850: X_batch_size, 0) ;
851:
852: ad_parallel_updates_pkg.get_rowid_range(
853: l_start_rowid,
854: l_end_rowid,
855: l_any_rows_to_process,
856: X_batch_size,
952:
953: l_process_total1 := l_process_total1 + l_rows_processed ;
954: END IF ;
955:
956: ad_parallel_updates_pkg.processed_rowid_range
957: (l_rows_processed,
958: l_end_rowid) ;
959:
960: COMMIT ;
958: l_end_rowid) ;
959:
960: COMMIT ;
961:
962: ad_parallel_updates_pkg.get_rowid_range
963: (l_start_rowid,
964: l_end_rowid,
965: l_any_rows_to_process,
966: X_batch_size,
1158: -- Fetching records from OE_PAYMENTS table
1159: -----------------------------------------------------------
1160: l_table_name := 'OE_PAYMENTS' ;
1161:
1162: ad_parallel_updates_pkg.delete_update_information(
1163: 0,
1164: l_table_owner,
1165: l_table_name,
1166: l_script_name ) ;
1164: l_table_owner,
1165: l_table_name,
1166: l_script_name ) ;
1167:
1168: ad_parallel_updates_pkg.initialize_rowid_range(
1169: ad_parallel_updates_pkg.ROWID_RANGE,
1170: l_table_owner,
1171: l_table_name,
1172: l_script_name,
1165: l_table_name,
1166: l_script_name ) ;
1167:
1168: ad_parallel_updates_pkg.initialize_rowid_range(
1169: ad_parallel_updates_pkg.ROWID_RANGE,
1170: l_table_owner,
1171: l_table_name,
1172: l_script_name,
1173: X_worker_id,
1173: X_worker_id,
1174: X_num_workers,
1175: X_batch_size, 0) ;
1176:
1177: ad_parallel_updates_pkg.get_rowid_range(
1178: l_start_rowid,
1179: l_end_rowid,
1180: l_any_rows_to_process,
1181: X_batch_size,
1322:
1323: l_process_total1 := l_process_total1 + l_rows_processed ;
1324: END IF ;
1325:
1326: ad_parallel_updates_pkg.processed_rowid_range
1327: (l_rows_processed,
1328: l_end_rowid) ;
1329:
1330: COMMIT ;
1328: l_end_rowid) ;
1329:
1330: COMMIT ;
1331:
1332: ad_parallel_updates_pkg.get_rowid_range
1333: (l_start_rowid,
1334: l_end_rowid,
1335: l_any_rows_to_process,
1336: X_batch_size,
1359: -- Fetching records from OE_ORDER_HEADERS_ALL table
1360: -----------------------------------------------------------
1361: l_table_name := 'OE_ORDER_HEADERS_ALL' ;
1362:
1363: ad_parallel_updates_pkg.delete_update_information(
1364: 0,
1365: l_table_owner,
1366: l_table_name,
1367: l_script_name ) ;
1365: l_table_owner,
1366: l_table_name,
1367: l_script_name ) ;
1368:
1369: ad_parallel_updates_pkg.initialize_rowid_range(
1370: ad_parallel_updates_pkg.ROWID_RANGE,
1371: l_table_owner,
1372: l_table_name,
1373: l_script_name,
1366: l_table_name,
1367: l_script_name ) ;
1368:
1369: ad_parallel_updates_pkg.initialize_rowid_range(
1370: ad_parallel_updates_pkg.ROWID_RANGE,
1371: l_table_owner,
1372: l_table_name,
1373: l_script_name,
1374: X_worker_id,
1374: X_worker_id,
1375: X_num_workers,
1376: X_batch_size, 0) ;
1377:
1378: ad_parallel_updates_pkg.get_rowid_range(
1379: l_start_rowid,
1380: l_end_rowid,
1381: l_any_rows_to_process,
1382: X_batch_size,
1449:
1450: l_process_total1 := l_process_total1 + l_rows_processed ;
1451: END IF ;
1452:
1453: ad_parallel_updates_pkg.processed_rowid_range
1454: (l_rows_processed,
1455: l_end_rowid) ;
1456:
1457: COMMIT ;
1455: l_end_rowid) ;
1456:
1457: COMMIT ;
1458:
1459: ad_parallel_updates_pkg.get_rowid_range
1460: (l_start_rowid,
1461: l_end_rowid,
1462: l_any_rows_to_process,
1463: X_batch_size,
1488: -- Fetching records from OE_ORDER_HEADERS_HISTORY table
1489: -----------------------------------------------------------
1490: l_table_name := 'OE_ORDER_HEADER_HISTORY' ;
1491:
1492: ad_parallel_updates_pkg.delete_update_information(
1493: 0,
1494: l_table_owner,
1495: l_table_name,
1496: l_script_name ) ;
1494: l_table_owner,
1495: l_table_name,
1496: l_script_name ) ;
1497:
1498: ad_parallel_updates_pkg.initialize_rowid_range(
1499: ad_parallel_updates_pkg.ROWID_RANGE,
1500: l_table_owner,
1501: l_table_name,
1502: l_script_name,
1495: l_table_name,
1496: l_script_name ) ;
1497:
1498: ad_parallel_updates_pkg.initialize_rowid_range(
1499: ad_parallel_updates_pkg.ROWID_RANGE,
1500: l_table_owner,
1501: l_table_name,
1502: l_script_name,
1503: X_worker_id,
1503: X_worker_id,
1504: X_num_workers,
1505: X_batch_size, 0) ;
1506:
1507: ad_parallel_updates_pkg.get_rowid_range(
1508: l_start_rowid,
1509: l_end_rowid,
1510: l_any_rows_to_process,
1511: X_batch_size,
1576:
1577: l_process_total1 := l_process_total1 + l_rows_processed ;
1578: END IF ;
1579:
1580: ad_parallel_updates_pkg.processed_rowid_range
1581: (l_rows_processed,
1582: l_end_rowid) ;
1583:
1584: COMMIT ;
1582: l_end_rowid) ;
1583:
1584: COMMIT ;
1585:
1586: ad_parallel_updates_pkg.get_rowid_range
1587: (l_start_rowid,
1588: l_end_rowid,
1589: l_any_rows_to_process,
1590: X_batch_size,