eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.HR_DATA_PUMP dependencies on HR_DATA_PUMP

Line 1: package body hr_data_pump as

1: package body hr_data_pump as
2: /* $Header: hrdpump.pkb 120.8 2006/01/25 06:03:08 arashid noship $ */
3: /*
4: NOTES
5: o This package body contains the Data Pump engine code.

Line 774: hr_data_pump.message('exception : ' || l_exception_text);

770: where pbl.batch_line_id = p_id;
771: end if;
772:
773: begin
774: hr_data_pump.message('exception : ' || l_exception_text);
775: exception
776: -- Catch exceptions from logging code to allow status information
777: -- to be updated.
778: when others then

Line 922: hr_data_pump.g_disable_lookup_checks :=

918: --
919: -- User must explicitly set the action parameter to 'N' to
920: -- disable the lookup checks.
921: --
922: hr_data_pump.g_disable_lookup_checks :=
923: l_found and upper(l_pap_value) = 'Y';
924: end;
925:
926: /*

Line 952: hr_data_pump.message('Foreign key locking enforced');

948:
949: hr_pump_utils.set_dt_enforce_foreign_locks(p_enforce => l_lock);
950:
951: if l_lock then
952: hr_data_pump.message('Foreign key locking enforced');
953: else
954: hr_data_pump.message('***** Foreign key locking NOT enforced *****');
955: end if;
956: end set_dt_foreign_locking;

Line 954: hr_data_pump.message('* Foreign key locking NOT enforced *');

950:
951: if l_lock then
952: hr_data_pump.message('Foreign key locking enforced');
953: else
954: hr_data_pump.message('***** Foreign key locking NOT enforced *****');
955: end if;
956: end set_dt_foreign_locking;
957:
958: /*

Line 1035: hr_data_pump.message('range : ' || p_env.range_size);

1031: if(not l_found or p_env.error_limit < 0) then
1032: p_env.error_limit := ERRORS_DEFAULT;
1033: end if;
1034:
1035: hr_data_pump.message('range : ' || p_env.range_size);
1036: hr_data_pump.message('threads : ' || p_env.threads);
1037: hr_data_pump.message('max errors : ' || p_env.error_limit);
1038:
1039: exception

Line 1036: hr_data_pump.message('threads : ' || p_env.threads);

1032: p_env.error_limit := ERRORS_DEFAULT;
1033: end if;
1034:
1035: hr_data_pump.message('range : ' || p_env.range_size);
1036: hr_data_pump.message('threads : ' || p_env.threads);
1037: hr_data_pump.message('max errors : ' || p_env.error_limit);
1038:
1039: exception
1040: when others then

Line 1037: hr_data_pump.message('max errors : ' || p_env.error_limit);

1033: end if;
1034:
1035: hr_data_pump.message('range : ' || p_env.range_size);
1036: hr_data_pump.message('threads : ' || p_env.threads);
1037: hr_data_pump.message('max errors : ' || p_env.error_limit);
1038:
1039: exception
1040: when others then
1041: raise;

Line 1056: hr_data_pump.entry('insert_range');

1052: p_batch_id in number,
1053: p_range_info in range_info_r
1054: ) is
1055: begin
1056: hr_data_pump.entry('insert_range');
1057:
1058: -- Check that there are actually some rows
1059: -- in the range we are about to insert.
1060: if(p_range_info.rows_in_range > 0) then

Line 1074: hr_data_pump.exit('insert_range');

1070: p_range_info.range_start,
1071: p_range_info.range_end);
1072: end if;
1073:
1074: hr_data_pump.exit('insert_range');
1075: end insert_range;
1076:
1077: /*
1078: * Procedure to insert range rows for parallelisation.

Line 1103: hr_data_pump.entry('process_ranges');

1099: l_range_info range_info_r;
1100: l_proc_seq number;
1101: l_prv_link_val hr_pump_batch_lines.link_value%type;
1102: begin
1103: hr_data_pump.entry('process_ranges');
1104:
1105: -- Initialise the variables for range insertion.
1106: l_range_info.rows_in_range := 0;
1107: l_range_info.range_number := 0;

Line 1183: hr_data_pump.exit('process_ranges');

1179: close c1;
1180:
1181: return(l_range_info.range_number);
1182:
1183: hr_data_pump.exit('process_ranges');
1184:
1185: end process_ranges;
1186:
1187: /*

Line 1202: hr_data_pump.entry('start_slaves');

1198: l_count number;
1199: l_request_id number;
1200: l_slaves number;
1201: begin
1202: hr_data_pump.entry('start_slaves');
1203:
1204: -- Start one less than threads.
1205: l_slaves := p_env.threads - 1;
1206:

Line 1215: hr_data_pump.message('fnd_request.submit_request : ' || l_count);

1211:
1212: -- Start the slave processes.
1213: for l_count in 1..l_slaves loop
1214:
1215: hr_data_pump.message('fnd_request.submit_request : ' || l_count);
1216:
1217: l_request_id := fnd_request.submit_request
1218: (
1219: application => 'PER',

Line 1231: hr_data_pump.message('l_request_id : ' || l_request_id);

1227: argument5 => p_validate
1228: ,argument6 => to_char(p_env.pap_group_id)
1229: );
1230:
1231: hr_data_pump.message('l_request_id : ' || l_request_id);
1232:
1233: end loop;
1234:
1235: hr_data_pump.exit('start_slaves');

Line 1235: hr_data_pump.exit('start_slaves');

1231: hr_data_pump.message('l_request_id : ' || l_request_id);
1232:
1233: end loop;
1234:
1235: hr_data_pump.exit('start_slaves');
1236: end start_slaves;
1237:
1238: /*
1239: * This procedure calls the API wrapper module.

Line 1257: hr_data_pump.entry('call_wrapper');

1253: l_call_string varchar2(2000);
1254: l_cache_entry number;
1255: begin
1256:
1257: hr_data_pump.entry('call_wrapper');
1258:
1259: -- Start by parsing the call if necessary.
1260: -- It may not be if the information is
1261: -- already in the wrapper cache.

Line 1325: hr_data_pump.exit('call_wrapper');

1321: if hr_pump_utils.multi_msg_errors_exist then
1322: raise hr_multi_message.error_message_exist;
1323: end if;
1324:
1325: hr_data_pump.exit('call_wrapper');
1326:
1327: end call_wrapper;
1328:
1329: /*

Line 1347: hr_data_pump.entry('update_range_results');

1343: lbound binary_integer;
1344: ubound binary_integer;
1345: nrows binary_integer;
1346: begin
1347: hr_data_pump.entry('update_range_results');
1348:
1349: -- Delete the existing HR_PUMP_BATCH_EXCEPTIONS rows.
1350: lbound := 1;
1351: nrows := 250;

Line 1414: hr_data_pump.exit('update_range_results');

1410:
1411: lbound := lbound + nrows;
1412: end loop;
1413:
1414: hr_data_pump.exit('update_range_results');
1415: end update_range_results;
1416:
1417: /*
1418: * Handle API exceptions.

Line 1569: hr_data_pump.entry('proc_lines_in_range');

1565: -- Process errors after API exceptions.
1566: l_process_errors boolean;
1567: begin
1568:
1569: hr_data_pump.entry('proc_lines_in_range');
1570:
1571: -- Initialise variables.
1572: l_prv_link_val := null;
1573: l_err_mode := FALSE;

Line 1864: hr_data_pump.exit('proc_lines_in_range');

1860:
1861: -- Output debugging. Note error count is for this range.
1862: range_proc_debug(p_range_start, p_range_end, l_err_count);
1863:
1864: hr_data_pump.exit('proc_lines_in_range');
1865:
1866: --
1867: -- If MAXIMUM_ERRORS_ALLOWED exceeded, need to raise an error.
1868: --

Line 1917: hr_data_pump.entry('internal_slave');

1913: l_csr_range_rows range_fetch_cursor_t;
1914: l_atomic_calls boolean;
1915: begin
1916:
1917: hr_data_pump.entry('internal_slave');
1918:
1919: if p_single_threaded then
1920: hr_data_pump.message('SINGLE-THREADED');
1921: else

Line 1920: hr_data_pump.message('SINGLE-THREADED');

1916:
1917: hr_data_pump.entry('internal_slave');
1918:
1919: if p_single_threaded then
1920: hr_data_pump.message('SINGLE-THREADED');
1921: else
1922: hr_data_pump.message('MULTI-THREADED');
1923: end if;
1924:

Line 1922: hr_data_pump.message('MULTI-THREADED');

1918:
1919: if p_single_threaded then
1920: hr_data_pump.message('SINGLE-THREADED');
1921: else
1922: hr_data_pump.message('MULTI-THREADED');
1923: end if;
1924:
1925: -- Initialise the slave environment record.
1926: -- Do this here rather than in initialisation

Line 1954: hr_data_pump.entry('g_data_migrator_mode'||hr_general.g_data_migrator_mode);

1950: --
1951: -- Set global for data_migrator_mode. Only do this if the global
1952: -- has a value of 'N'.
1953: --
1954: hr_data_pump.entry('g_data_migrator_mode'||hr_general.g_data_migrator_mode);
1955: --
1956: l_data_migrator_mode := hr_general.g_data_migrator_mode;
1957: --
1958: if hr_general.g_data_migrator_mode = 'N' then

Line 1978: hr_data_pump.entry('g_data_migrator_mode'||hr_general.g_data_migrator_mode);

1974: hr_general.g_data_migrator_mode := l_pap_value;
1975: end if;
1976: end if;
1977: --
1978: hr_data_pump.entry('g_data_migrator_mode'||hr_general.g_data_migrator_mode);
1979: --
1980: -- Disable the FND audit.
1981: --
1982: disable_audit;

Line 2010: hr_data_pump.message('RR:SINGLE-THREADED');

2006: --
2007: -- Open the cursor. Use an ORDER BY for the single-threaded case.
2008: --
2009: if g_senv.single_threaded then
2010: hr_data_pump.message('RR:SINGLE-THREADED');
2011: open l_csr_range_rows for
2012: select hpr.rowid,
2013: hpr.starting_process_sequence,
2014: hpr.ending_process_sequence

Line 2027: hr_data_pump.message('RR:MULTI-THREADED');

2023: for update of
2024: hpr.starting_process_sequence, pbh.batch_status
2025: ;
2026: else
2027: hr_data_pump.message('RR:MULTI-THREADED');
2028: open l_csr_range_rows for
2029: select hpr.rowid,
2030: hpr.starting_process_sequence,
2031: hpr.ending_process_sequence

Line 2129: hr_data_pump.exit('internal_slave');

2125: -- This is no longer a running Data Pump session.
2126: --
2127: hr_pump_utils.set_current_session_running(p_running => false);
2128:
2129: hr_data_pump.exit('internal_slave');
2130:
2131: /*
2132: * Deal with any exceptions that came through. This would
2133: * most likely be the 'too many errors' error, although it

Line 2259: hr_data_pump.message('p_batch_id : ' || p_batch_id);

2255:
2256: -- Set any requested debug.
2257: set_debug;
2258:
2259: hr_data_pump.message('p_batch_id : ' || p_batch_id);
2260:
2261: -- Get startup information for this process.
2262: -- Return batch status while we are at it.
2263: get_startup_info(p_batch_id, p_pap_group_id, l_env, l_batch_status);

Line 2265: hr_data_pump.message('l_batch_status : ' || l_batch_status);

2261: -- Get startup information for this process.
2262: -- Return batch status while we are at it.
2263: get_startup_info(p_batch_id, p_pap_group_id, l_env, l_batch_status);
2264:
2265: hr_data_pump.message('l_batch_status : ' || l_batch_status);
2266:
2267: --
2268: -- Only enter main processing if we are not doing so already.
2269: --

Line 2399: hr_data_pump.message('HR_PUMP_BATCH_LINES:' || p_line_status);

2395: ,p_line_status in varchar2
2396: ) is
2397: l_work_to_do boolean;
2398: begin
2399: hr_data_pump.message('HR_PUMP_BATCH_LINES:' || p_line_status);
2400:
2401: l_work_to_do := true;
2402: while l_work_to_do loop
2403: delete

Line 2436: hr_data_pump.message('HR_PUMP_BATCH_LINE_USER_KEYS:BATCH_LINE_ID IS NULL');

2432: ) is
2433: l_work_to_do boolean;
2434: l_message fnd_new_messages.message_text%type;
2435: begin
2436: hr_data_pump.message('HR_PUMP_BATCH_LINE_USER_KEYS:BATCH_LINE_ID IS NULL');
2437:
2438: p_error_message := null;
2439:
2440: l_work_to_do := true;

Line 2464: hr_data_pump.message(l_message);

2460: if p_write_log then
2461: fnd_file.put_line(fnd_file.log, l_message);
2462: end if;
2463:
2464: hr_data_pump.message(l_message);
2465:
2466: exception
2467: when others then
2468: hr_utility.set_message(800, 'HR_33797_DP_USER_KEY_PURGE_ERR');

Line 2476: hr_data_pump.message(l_message);

2472: if p_write_log then
2473: fnd_file.put_line(fnd_file.log, l_message);
2474: end if;
2475:
2476: hr_data_pump.message(l_message);
2477: return;
2478: end purgeorphanuserkeys;
2479:
2480: ------------------------------- purgebatch ------------------------------------

Line 2535: hr_data_pump.message('PURGE: ' || l_batch_name);

2531: --
2532: return;
2533: end if;
2534:
2535: hr_data_pump.message('PURGE: ' || l_batch_name);
2536:
2537: -----------------------------------------------------
2538: -- 2. Preserve or delete user keys for this batch. --
2539: -----------------------------------------------------

Line 2540: hr_data_pump.message('HR_PUMP_BATCH_LINE_USER_KEYS');

2536:
2537: -----------------------------------------------------
2538: -- 2. Preserve or delete user keys for this batch. --
2539: -----------------------------------------------------
2540: hr_data_pump.message('HR_PUMP_BATCH_LINE_USER_KEYS');
2541:
2542: l_work_to_do := true;
2543: while l_work_to_do loop
2544: if p_preserve_user_keys then

Line 2577: hr_data_pump.message('HR_PUMP_BATCH_EXCEPTIONS');

2573:
2574: ----------------------------------------------------
2575: -- 3. Delete the batch exceptions for this batch. --
2576: ----------------------------------------------------
2577: hr_data_pump.message('HR_PUMP_BATCH_EXCEPTIONS');
2578:
2579: l_work_to_do := true;
2580: while l_work_to_do loop
2581: delete

Line 2656: hr_data_pump.message('HR_PUMP_RANGES');

2652:
2653: ----------------------------------------------
2654: -- 5. Delete the range rows for this batch. --
2655: ----------------------------------------------
2656: hr_data_pump.message('HR_PUMP_RANGES');
2657:
2658: l_work_to_do := true;
2659: while l_work_to_do loop
2660: delete

Line 2675: hr_data_pump.message('HR_PUMP_BATCH_HEADERS');

2671:
2672: ------------------------------------------------------------
2673: -- 6. Delete the batch header or update the batch status. --
2674: ------------------------------------------------------------
2675: hr_data_pump.message('HR_PUMP_BATCH_HEADERS');
2676:
2677: delete from hr_pump_requests
2678: where batch_id = p_batch_id;
2679: if p_delete_header then

Line 2718: hr_data_pump.message(l_message);

2714: if p_write_log then
2715: fnd_file.put_line(fnd_file.log, l_message);
2716: end if;
2717:
2718: hr_data_pump.message(l_message);
2719:
2720: exception
2721: when others then
2722: hr_utility.set_message(800, 'HR_33795_DP_PROCESSING_ERROR');

Line 2731: hr_data_pump.message(l_message);

2727: if p_write_log then
2728: fnd_file.put_line(fnd_file.log, l_message);
2729: end if;
2730:
2731: hr_data_pump.message(l_message);
2732:
2733: --
2734: -- Reset the batch header.
2735: --

Line 2805: hr_data_pump.message('THREAD_NUMBER:' || to_char(p_thread_number));

2801: -- Process debugging options.
2802: --
2803: set_debug;
2804:
2805: hr_data_pump.message('THREAD_NUMBER:' || to_char(p_thread_number));
2806: hr_data_pump.message('LOWER_BOUND:' || to_char(p_lower_bound));
2807: hr_data_pump.message('UPPER_BOUND:' || to_char(p_upper_bound));
2808:
2809: -- Note: interpret as restrictively as possible.

Line 2806: hr_data_pump.message('LOWER_BOUND:' || to_char(p_lower_bound));

2802: --
2803: set_debug;
2804:
2805: hr_data_pump.message('THREAD_NUMBER:' || to_char(p_thread_number));
2806: hr_data_pump.message('LOWER_BOUND:' || to_char(p_lower_bound));
2807: hr_data_pump.message('UPPER_BOUND:' || to_char(p_upper_bound));
2808:
2809: -- Note: interpret as restrictively as possible.
2810: l_all_batches := upper(p_all_batches) = 'Y';

Line 2807: hr_data_pump.message('UPPER_BOUND:' || to_char(p_upper_bound));

2803: set_debug;
2804:
2805: hr_data_pump.message('THREAD_NUMBER:' || to_char(p_thread_number));
2806: hr_data_pump.message('LOWER_BOUND:' || to_char(p_lower_bound));
2807: hr_data_pump.message('UPPER_BOUND:' || to_char(p_upper_bound));
2808:
2809: -- Note: interpret as restrictively as possible.
2810: l_all_batches := upper(p_all_batches) = 'Y';
2811: l_preserve_user_keys := upper(p_preserve_user_keys) <> 'N';

Line 3038: hr_data_pump.message('P_BATCH_ID:' || to_char(p_batch_id));

3034: else
3035: l_all_batches := 'N';
3036: end if;
3037:
3038: hr_data_pump.message('P_BATCH_ID:' || to_char(p_batch_id));
3039: hr_data_pump.message('P_ALL_BATCHES:' || l_all_batches);
3040: hr_data_pump.message('P_PRESERVE_USER_KEYS:' || p_preserve_user_keys);
3041: hr_data_pump.message('P_PURGE_UNPROCESSED:' || p_purge_unprocessed);
3042: hr_data_pump.message('P_PURGE_ERRORED:' || p_purge_errored);

Line 3039: hr_data_pump.message('P_ALL_BATCHES:' || l_all_batches);

3035: l_all_batches := 'N';
3036: end if;
3037:
3038: hr_data_pump.message('P_BATCH_ID:' || to_char(p_batch_id));
3039: hr_data_pump.message('P_ALL_BATCHES:' || l_all_batches);
3040: hr_data_pump.message('P_PRESERVE_USER_KEYS:' || p_preserve_user_keys);
3041: hr_data_pump.message('P_PURGE_UNPROCESSED:' || p_purge_unprocessed);
3042: hr_data_pump.message('P_PURGE_ERRORED:' || p_purge_errored);
3043: hr_data_pump.message('P_PURGE_COMPLETED:' || p_purge_completed);

Line 3040: hr_data_pump.message('P_PRESERVE_USER_KEYS:' || p_preserve_user_keys);

3036: end if;
3037:
3038: hr_data_pump.message('P_BATCH_ID:' || to_char(p_batch_id));
3039: hr_data_pump.message('P_ALL_BATCHES:' || l_all_batches);
3040: hr_data_pump.message('P_PRESERVE_USER_KEYS:' || p_preserve_user_keys);
3041: hr_data_pump.message('P_PURGE_UNPROCESSED:' || p_purge_unprocessed);
3042: hr_data_pump.message('P_PURGE_ERRORED:' || p_purge_errored);
3043: hr_data_pump.message('P_PURGE_COMPLETED:' || p_purge_completed);
3044: hr_data_pump.message('P_DELETE_HEADER:' || p_delete_header);

Line 3041: hr_data_pump.message('P_PURGE_UNPROCESSED:' || p_purge_unprocessed);

3037:
3038: hr_data_pump.message('P_BATCH_ID:' || to_char(p_batch_id));
3039: hr_data_pump.message('P_ALL_BATCHES:' || l_all_batches);
3040: hr_data_pump.message('P_PRESERVE_USER_KEYS:' || p_preserve_user_keys);
3041: hr_data_pump.message('P_PURGE_UNPROCESSED:' || p_purge_unprocessed);
3042: hr_data_pump.message('P_PURGE_ERRORED:' || p_purge_errored);
3043: hr_data_pump.message('P_PURGE_COMPLETED:' || p_purge_completed);
3044: hr_data_pump.message('P_DELETE_HEADER:' || p_delete_header);
3045: hr_data_pump.message('P_PAP_GROUP_ID:' || p_pap_group_id);

Line 3042: hr_data_pump.message('P_PURGE_ERRORED:' || p_purge_errored);

3038: hr_data_pump.message('P_BATCH_ID:' || to_char(p_batch_id));
3039: hr_data_pump.message('P_ALL_BATCHES:' || l_all_batches);
3040: hr_data_pump.message('P_PRESERVE_USER_KEYS:' || p_preserve_user_keys);
3041: hr_data_pump.message('P_PURGE_UNPROCESSED:' || p_purge_unprocessed);
3042: hr_data_pump.message('P_PURGE_ERRORED:' || p_purge_errored);
3043: hr_data_pump.message('P_PURGE_COMPLETED:' || p_purge_completed);
3044: hr_data_pump.message('P_DELETE_HEADER:' || p_delete_header);
3045: hr_data_pump.message('P_PAP_GROUP_ID:' || p_pap_group_id);
3046: hr_data_pump.message('THREADS:' || to_char(l_threads));

Line 3043: hr_data_pump.message('P_PURGE_COMPLETED:' || p_purge_completed);

3039: hr_data_pump.message('P_ALL_BATCHES:' || l_all_batches);
3040: hr_data_pump.message('P_PRESERVE_USER_KEYS:' || p_preserve_user_keys);
3041: hr_data_pump.message('P_PURGE_UNPROCESSED:' || p_purge_unprocessed);
3042: hr_data_pump.message('P_PURGE_ERRORED:' || p_purge_errored);
3043: hr_data_pump.message('P_PURGE_COMPLETED:' || p_purge_completed);
3044: hr_data_pump.message('P_DELETE_HEADER:' || p_delete_header);
3045: hr_data_pump.message('P_PAP_GROUP_ID:' || p_pap_group_id);
3046: hr_data_pump.message('THREADS:' || to_char(l_threads));
3047: hr_data_pump.message('CHUNK_SIZE:' || to_char(l_chunk_size));

Line 3044: hr_data_pump.message('P_DELETE_HEADER:' || p_delete_header);

3040: hr_data_pump.message('P_PRESERVE_USER_KEYS:' || p_preserve_user_keys);
3041: hr_data_pump.message('P_PURGE_UNPROCESSED:' || p_purge_unprocessed);
3042: hr_data_pump.message('P_PURGE_ERRORED:' || p_purge_errored);
3043: hr_data_pump.message('P_PURGE_COMPLETED:' || p_purge_completed);
3044: hr_data_pump.message('P_DELETE_HEADER:' || p_delete_header);
3045: hr_data_pump.message('P_PAP_GROUP_ID:' || p_pap_group_id);
3046: hr_data_pump.message('THREADS:' || to_char(l_threads));
3047: hr_data_pump.message('CHUNK_SIZE:' || to_char(l_chunk_size));
3048:

Line 3045: hr_data_pump.message('P_PAP_GROUP_ID:' || p_pap_group_id);

3041: hr_data_pump.message('P_PURGE_UNPROCESSED:' || p_purge_unprocessed);
3042: hr_data_pump.message('P_PURGE_ERRORED:' || p_purge_errored);
3043: hr_data_pump.message('P_PURGE_COMPLETED:' || p_purge_completed);
3044: hr_data_pump.message('P_DELETE_HEADER:' || p_delete_header);
3045: hr_data_pump.message('P_PAP_GROUP_ID:' || p_pap_group_id);
3046: hr_data_pump.message('THREADS:' || to_char(l_threads));
3047: hr_data_pump.message('CHUNK_SIZE:' || to_char(l_chunk_size));
3048:
3049: --

Line 3046: hr_data_pump.message('THREADS:' || to_char(l_threads));

3042: hr_data_pump.message('P_PURGE_ERRORED:' || p_purge_errored);
3043: hr_data_pump.message('P_PURGE_COMPLETED:' || p_purge_completed);
3044: hr_data_pump.message('P_DELETE_HEADER:' || p_delete_header);
3045: hr_data_pump.message('P_PAP_GROUP_ID:' || p_pap_group_id);
3046: hr_data_pump.message('THREADS:' || to_char(l_threads));
3047: hr_data_pump.message('CHUNK_SIZE:' || to_char(l_chunk_size));
3048:
3049: --
3050: -- Exit if there is nothing to do.

Line 3047: hr_data_pump.message('CHUNK_SIZE:' || to_char(l_chunk_size));

3043: hr_data_pump.message('P_PURGE_COMPLETED:' || p_purge_completed);
3044: hr_data_pump.message('P_DELETE_HEADER:' || p_delete_header);
3045: hr_data_pump.message('P_PAP_GROUP_ID:' || p_pap_group_id);
3046: hr_data_pump.message('THREADS:' || to_char(l_threads));
3047: hr_data_pump.message('CHUNK_SIZE:' || to_char(l_chunk_size));
3048:
3049: --
3050: -- Exit if there is nothing to do.
3051: --

Line 3054: hr_data_pump.message('NOTHING TO PURGE:ARGS');

3050: -- Exit if there is nothing to do.
3051: --
3052: if p_all_batches = 'N' and p_batch_id is null and
3053: upper(p_preserve_user_keys) <> 'N' then
3054: hr_data_pump.message('NOTHING TO PURGE:ARGS');
3055: return;
3056: end if;
3057:
3058: -----------------------------------------------

Line 3074: hr_data_pump.message('NOTHING TO PURGE:BATCHES');

3070: , l_min
3071: ;
3072: if csr_bh_minmax%notfound or l_max is null then
3073: close csr_bh_minmax;
3074: hr_data_pump.message('NOTHING TO PURGE:BATCHES');
3075: return;
3076: end if;
3077: close csr_bh_minmax;
3078:

Line 3087: hr_data_pump.message('THREADS(MODIFIED):BATCHES:' || to_char(l_threads));

3083: l_batch_count := l_max + 1 - l_min;
3084: if l_threads > l_batch_count then
3085: l_threads := ceil(l_batch_count / 2);
3086:
3087: hr_data_pump.message('THREADS(MODIFIED):BATCHES:' || to_char(l_threads));
3088: end if;
3089:
3090: l_increment := ceil((l_max + 1 - l_min) / l_threads);
3091:

Line 3092: hr_data_pump.message('INCREMENT:BATCHES:' || to_char(l_increment));

3088: end if;
3089:
3090: l_increment := ceil((l_max + 1 - l_min) / l_threads);
3091:
3092: hr_data_pump.message('INCREMENT:BATCHES:' || to_char(l_increment));
3093:
3094: --
3095: -- Case 2: Purging user keys not connected with any batch.
3096: --

Line 3105: hr_data_pump.message('NOTHING TO PURGE:USER_KEYS');

3101: , l_min
3102: ;
3103: if csr_uk_minmax%notfound or l_max is null then
3104: close csr_uk_minmax;
3105: hr_data_pump.message('NOTHING TO PURGE:USER_KEYS');
3106: return;
3107: end if;
3108: close csr_uk_minmax;
3109:

Line 3117: hr_data_pump.message('THREADS(MODIFIED):USER_KEYS:' || to_char(l_threads));

3113: l_batch_count := ceil((l_max + 1 - l_min) / PURGE_MIN_ROWS);
3114: if l_threads > l_batch_count then
3115: l_threads := l_batch_count;
3116:
3117: hr_data_pump.message('THREADS(MODIFIED):USER_KEYS:' || to_char(l_threads));
3118: end if;
3119:
3120: l_increment := ceil((l_max + 1 - l_min) / l_threads);
3121:

Line 3122: hr_data_pump.message('INCREMENT:USER_KEYS:' || to_char(l_increment));

3118: end if;
3119:
3120: l_increment := ceil((l_max + 1 - l_min) / l_threads);
3121:
3122: hr_data_pump.message('INCREMENT:USER_KEYS:' || to_char(l_increment));
3123: end if;
3124:
3125: --
3126: -- Start off the slave threads.

Line 3129: hr_data_pump.message('FND_REQUEST.SUBMIT_REQUEST: ' || thread);

3125: --
3126: -- Start off the slave threads.
3127: --
3128: for thread in 1 .. l_threads - 1 loop
3129: hr_data_pump.message('FND_REQUEST.SUBMIT_REQUEST: ' || thread);
3130:
3131: allocwork
3132: (p_increment => l_increment
3133: ,p_thread_no => thread

Line 3144: hr_data_pump.message('NO MORE THREADS REQUIRED:' || to_char(thread));

3140: --
3141: -- No need to proceed further as this and higher threads have no more work to do.
3142: --
3143: if l_lower is null then
3144: hr_data_pump.message('NO MORE THREADS REQUIRED:' || to_char(thread));
3145: exit;
3146: end if;
3147:
3148: l_request_id :=

Line 3234: end hr_data_pump;

3230: begin
3231: -- Any package init here.
3232: null;
3233:
3234: end hr_data_pump;