DBA Data[Home] [Help]

APPS.CN_PURGE_TABLES_PVT dependencies on AD_PARALLEL_UPDATES_PKG

Line 140: ad_parallel_updates_pkg.initialize_rowid_range( ad_parallel_updates_pkg.ROWID_RANGE, p_table_owner, p_table_name, p_script_name, p_worker_id, p_no_of_workers, p_batch_size, 0);

136: SELECT TO_CHAR(sysdate,'dd-mm-rr:hh:mi:ss') INTO l_time FROM dual;
137:
138: debugmsg('CN_PURGE_TABLES_PVT.delete_table: delete start l_time ' || l_time );
139:
140: ad_parallel_updates_pkg.initialize_rowid_range( ad_parallel_updates_pkg.ROWID_RANGE, p_table_owner, p_table_name, p_script_name, p_worker_id, p_no_of_workers, p_batch_size, 0);
141:
142: debugmsg('CN_PURGE_TABLES_PVT.delete_table:after ad_parallel_updates_pkg.initialize_rowid_range ' );
143:
144: ad_parallel_updates_pkg.get_rowid_range( l_start_rowid, l_END_rowid, l_any_rows_to_process, p_batch_size, TRUE);

Line 142: debugmsg('CN_PURGE_TABLES_PVT.delete_table:after ad_parallel_updates_pkg.initialize_rowid_range ' );

138: debugmsg('CN_PURGE_TABLES_PVT.delete_table: delete start l_time ' || l_time );
139:
140: ad_parallel_updates_pkg.initialize_rowid_range( ad_parallel_updates_pkg.ROWID_RANGE, p_table_owner, p_table_name, p_script_name, p_worker_id, p_no_of_workers, p_batch_size, 0);
141:
142: debugmsg('CN_PURGE_TABLES_PVT.delete_table:after ad_parallel_updates_pkg.initialize_rowid_range ' );
143:
144: ad_parallel_updates_pkg.get_rowid_range( l_start_rowid, l_END_rowid, l_any_rows_to_process, p_batch_size, TRUE);
145:
146: debugmsg('CN_PURGE_TABLES_PVT.delete_table:after ad_parallel_updates_pkg.get_rowid_range l_any_rows_to_process ' );

Line 144: ad_parallel_updates_pkg.get_rowid_range( l_start_rowid, l_END_rowid, l_any_rows_to_process, p_batch_size, TRUE);

140: ad_parallel_updates_pkg.initialize_rowid_range( ad_parallel_updates_pkg.ROWID_RANGE, p_table_owner, p_table_name, p_script_name, p_worker_id, p_no_of_workers, p_batch_size, 0);
141:
142: debugmsg('CN_PURGE_TABLES_PVT.delete_table:after ad_parallel_updates_pkg.initialize_rowid_range ' );
143:
144: ad_parallel_updates_pkg.get_rowid_range( l_start_rowid, l_END_rowid, l_any_rows_to_process, p_batch_size, TRUE);
145:
146: debugmsg('CN_PURGE_TABLES_PVT.delete_table:after ad_parallel_updates_pkg.get_rowid_range l_any_rows_to_process ' );
147:
148: IF (l_any_rows_to_process) THEN

Line 146: debugmsg('CN_PURGE_TABLES_PVT.delete_table:after ad_parallel_updates_pkg.get_rowid_range l_any_rows_to_process ' );

142: debugmsg('CN_PURGE_TABLES_PVT.delete_table:after ad_parallel_updates_pkg.initialize_rowid_range ' );
143:
144: ad_parallel_updates_pkg.get_rowid_range( l_start_rowid, l_END_rowid, l_any_rows_to_process, p_batch_size, TRUE);
145:
146: debugmsg('CN_PURGE_TABLES_PVT.delete_table:after ad_parallel_updates_pkg.get_rowid_range l_any_rows_to_process ' );
147:
148: IF (l_any_rows_to_process) THEN
149: --dbms_output.put_line('ROWS Still LEFT For Processing');
150: x_row_to_process_flag := 'Y';

Line 162: -- debugmsg('CN_PURGE_TABLES_PVT.delete_table:after ad_parallel_updates_pkg.get_rowid_range l_any_rows_to_process True' );

158:
159: WHILE (l_any_rows_to_process = TRUE)
160: LOOP
161: --dbms_output.put_line('start rowid '||l_start_rowid||' end_rowid '||l_end_rowid||' batch_size '||l_batch_size);
162: -- debugmsg('CN_PURGE_TABLES_PVT.delete_table:after ad_parallel_updates_pkg.get_rowid_range l_any_rows_to_process True' );
163: BEGIN
164: IF (p_table_name = 'CN_PAYMENT_API_ALL') THEN
165: DELETE
166: /*+ ROWID (cnh) */

Line 440: debugmsg('Before ad_parallel_updates_pkg.processed_rowid_range value_error - ' || sqlerrm);

436: l_rows_processed := SQL%ROWCOUNT;
437: EXCEPTION
438: WHEN value_error THEN
439: x_return_status := 'F';
440: debugmsg('Before ad_parallel_updates_pkg.processed_rowid_range value_error - ' || sqlerrm);
441: WHEN OTHERS THEN
442: x_return_status := 'F';
443: debugmsg('Before ad_parallel_updates_pkg.processed_rowid_range error - ' || sqlerrm);
444: END;

Line 443: debugmsg('Before ad_parallel_updates_pkg.processed_rowid_range error - ' || sqlerrm);

439: x_return_status := 'F';
440: debugmsg('Before ad_parallel_updates_pkg.processed_rowid_range value_error - ' || sqlerrm);
441: WHEN OTHERS THEN
442: x_return_status := 'F';
443: debugmsg('Before ad_parallel_updates_pkg.processed_rowid_range error - ' || sqlerrm);
444: END;
445: --debugmsg('Before ad_parallel_updates_pkg : rollback before processed_rowid_range - ');
446: --rollback;
447: ad_parallel_updates_pkg.processed_rowid_range( l_rows_processed, l_END_rowid);

Line 445: --debugmsg('Before ad_parallel_updates_pkg : rollback before processed_rowid_range - ');

441: WHEN OTHERS THEN
442: x_return_status := 'F';
443: debugmsg('Before ad_parallel_updates_pkg.processed_rowid_range error - ' || sqlerrm);
444: END;
445: --debugmsg('Before ad_parallel_updates_pkg : rollback before processed_rowid_range - ');
446: --rollback;
447: ad_parallel_updates_pkg.processed_rowid_range( l_rows_processed, l_END_rowid);
448:
449: --

Line 447: ad_parallel_updates_pkg.processed_rowid_range( l_rows_processed, l_END_rowid);

443: debugmsg('Before ad_parallel_updates_pkg.processed_rowid_range error - ' || sqlerrm);
444: END;
445: --debugmsg('Before ad_parallel_updates_pkg : rollback before processed_rowid_range - ');
446: --rollback;
447: ad_parallel_updates_pkg.processed_rowid_range( l_rows_processed, l_END_rowid);
448:
449: --
450: -- get new range of rowids
451: --

Line 452: ad_parallel_updates_pkg.get_rowid_range( l_start_rowid, l_end_rowid, l_any_rows_to_process, p_batch_size, FALSE);

448:
449: --
450: -- get new range of rowids
451: --
452: ad_parallel_updates_pkg.get_rowid_range( l_start_rowid, l_end_rowid, l_any_rows_to_process, p_batch_size, FALSE);
453:
454: END LOOP;
455:
456: SELECT TO_CHAR(sysdate,'dd-mm-rr:hh:mi:ss') INTO l_time FROM dual;