27: l_nb_row NUMBER;
28: BEGIN
29:
30: /* ------ Initialize the rowid ranges ------ */
31: ad_parallel_updates_pkg.initialize_rowid_range(
32: ad_parallel_updates_pkg.ROWID_RANGE,
33: l_table_owner,
34: l_table_name,
35: l_script_name,
28: BEGIN
29:
30: /* ------ Initialize the rowid ranges ------ */
31: ad_parallel_updates_pkg.initialize_rowid_range(
32: ad_parallel_updates_pkg.ROWID_RANGE,
33: l_table_owner,
34: l_table_name,
35: l_script_name,
36: l_worker_id,
37: l_num_workers,
38: l_batch_size, 0);
39:
40: /* ------ Get rowid ranges ------ */
41: ad_parallel_updates_pkg.get_rowid_range(
42: l_start_rowid,
43: l_end_rowid,
44: l_any_rows_to_process,
45: l_batch_size,
290: AND psatd.cust_trx_line_gl_dist_id = ctlgd.cust_trx_line_gl_dist_id
291: AND doub.customer_trx_id = trx.customer_trx_id;
292:
293:
294: ad_parallel_updates_pkg.processed_rowid_range(
295: l_rows_processed,
296: l_end_rowid);
297:
298: commit;
296: l_end_rowid);
297:
298: commit;
299:
300: ad_parallel_updates_pkg.get_rowid_range(
301: l_start_rowid,
302: l_end_rowid,
303: l_any_rows_to_process,
304: l_batch_size,
338: l_rows_processed number := 0;
339: BEGIN
340:
341: /* ------ Initialize the rowid ranges ------ */
342: ad_parallel_updates_pkg.initialize_rowid_range(
343: ad_parallel_updates_pkg.ROWID_RANGE,
344: l_table_owner,
345: l_table_name,
346: l_script_name,
339: BEGIN
340:
341: /* ------ Initialize the rowid ranges ------ */
342: ad_parallel_updates_pkg.initialize_rowid_range(
343: ad_parallel_updates_pkg.ROWID_RANGE,
344: l_table_owner,
345: l_table_name,
346: l_script_name,
347: l_worker_id,
348: l_num_workers,
349: l_batch_size, 0);
350:
351: /* ------ Get rowid ranges ------ */
352: ad_parallel_updates_pkg.get_rowid_range(
353: l_start_rowid,
354: l_end_rowid,
355: l_any_rows_to_process,
356: l_batch_size,
970: AND EXISTS (SELECT NULL FROM psa_mf_rct_dist_all psa
971: WHERE psa.receivable_application_id = app.receivable_application_id);
972:
973:
974: ad_parallel_updates_pkg.processed_rowid_range(
975: l_rows_processed,
976: l_end_rowid);
977:
978: commit;
976: l_end_rowid);
977:
978: commit;
979:
980: ad_parallel_updates_pkg.get_rowid_range(
981: l_start_rowid,
982: l_end_rowid,
983: l_any_rows_to_process,
984: l_batch_size,
1015: l_rows_processed number := 0;
1016: BEGIN
1017:
1018: /* ------ Initialize the rowid ranges ------ */
1019: ad_parallel_updates_pkg.initialize_rowid_range(
1020: ad_parallel_updates_pkg.ROWID_RANGE,
1021: l_table_owner,
1022: l_table_name,
1023: l_script_name,
1016: BEGIN
1017:
1018: /* ------ Initialize the rowid ranges ------ */
1019: ad_parallel_updates_pkg.initialize_rowid_range(
1020: ad_parallel_updates_pkg.ROWID_RANGE,
1021: l_table_owner,
1022: l_table_name,
1023: l_script_name,
1024: l_worker_id,
1025: l_num_workers,
1026: l_batch_size, 0);
1027:
1028: /* ------ Get rowid ranges ------ */
1029: ad_parallel_updates_pkg.get_rowid_range(
1030: l_start_rowid,
1031: l_end_rowid,
1032: l_any_rows_to_process,
1033: l_batch_size,
1201:
1202:
1203: l_rows_processed := l_rows_processed + SQL%ROWCOUNT;
1204:
1205: ad_parallel_updates_pkg.processed_rowid_range(
1206: l_rows_processed,
1207: l_end_rowid);
1208:
1209: commit;
1207: l_end_rowid);
1208:
1209: commit;
1210:
1211: ad_parallel_updates_pkg.get_rowid_range(
1212: l_start_rowid,
1213: l_end_rowid,
1214: l_any_rows_to_process,
1215: l_batch_size,
1665: l_last_fetch BOOLEAN := FALSE;
1666: BEGIN
1667:
1668: /* ------ Initialize the rowid ranges ------ */
1669: ad_parallel_updates_pkg.initialize_rowid_range(
1670: ad_parallel_updates_pkg.ROWID_RANGE,
1671: l_table_owner,
1672: l_table_name,
1673: l_script_name,
1666: BEGIN
1667:
1668: /* ------ Initialize the rowid ranges ------ */
1669: ad_parallel_updates_pkg.initialize_rowid_range(
1670: ad_parallel_updates_pkg.ROWID_RANGE,
1671: l_table_owner,
1672: l_table_name,
1673: l_script_name,
1674: l_worker_id,
1675: l_num_workers,
1676: l_batch_size, 0);
1677:
1678: /* ------ Get rowid ranges ------ */
1679: ad_parallel_updates_pkg.get_rowid_range(
1680: l_start_rowid,
1681: l_end_rowid,
1682: l_any_rows_to_process,
1683: l_batch_size,
2149: CLOSE c;
2150:
2151: l_rows_processed := l_rows_processed + SQL%ROWCOUNT;
2152:
2153: ad_parallel_updates_pkg.processed_rowid_range(
2154: l_rows_processed,
2155: l_end_rowid);
2156:
2157: commit;
2155: l_end_rowid);
2156:
2157: commit;
2158:
2159: ad_parallel_updates_pkg.get_rowid_range(
2160: l_start_rowid,
2161: l_end_rowid,
2162: l_any_rows_to_process,
2163: l_batch_size,