APPS.HR_DATA_PUMP dependencies on HR_PUMP_RANGES

Line 123: * Types for different fetching and locking from HR_PUMP_RANGES. In the

119: arg_values varchar2(2000)
120: );
121:
122: /*
123: * Types for different fetching and locking from HR_PUMP_RANGES. In the
124: * single-threaded case, an ORDER BY statement is used, but not in the
125: * multi-threaded case.
126: */
127: type range_fetch_info_r is record

Line 1061: insert into hr_pump_ranges (

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
1061: insert into hr_pump_ranges (
1062: batch_id,
1063: range_number,
1064: range_status,
1065: starting_process_sequence,

Line 2015: from hr_pump_ranges hpr,

2011: open l_csr_range_rows for
2012: select hpr.rowid,
2013: hpr.starting_process_sequence,
2014: hpr.ending_process_sequence
2015: from hr_pump_ranges hpr,
2016: hr_pump_batch_headers pbh
2017: where hpr.batch_id = p_batch_id
2018: and hpr.range_status = 'U'
2019: and pbh.batch_id = hpr.batch_id

Line 2032: from hr_pump_ranges hpr,

2028: open l_csr_range_rows for
2029: select hpr.rowid,
2030: hpr.starting_process_sequence,
2031: hpr.ending_process_sequence
2032: from hr_pump_ranges hpr,
2033: hr_pump_batch_headers pbh
2034: where hpr.batch_id = p_batch_id
2035: and hpr.range_status = 'U'
2036: and pbh.batch_id = hpr.batch_id

Line 2060: update hr_pump_ranges hpr

2056: end if;
2057: close l_csr_range_rows;
2058:
2059: -- Change status to show we are processing this.
2060: update hr_pump_ranges hpr
2061: set hpr.range_status = 'P'
2062: where hpr.rowid = l_range_rowid;
2063:
2064: commit; -- release the lock.

Line 2074: delete from hr_pump_ranges hpr

2070: l_atomic_calls,
2071: l_range_start, l_range_end);
2072:
2073: -- Finished with range, so remove it and commit.
2074: delete from hr_pump_ranges hpr
2075: where hpr.rowid = l_range_rowid;
2076: commit;
2077:
2078: end loop;

Line 2103: from hr_pump_ranges hpr

2099: -- still working. See if this is so by
2100: -- looking for any ranges still processing.
2101: select count(*)
2102: into l_range_count
2103: from hr_pump_ranges hpr
2104: where hpr.batch_id = p_batch_id;
2105:
2106: if(l_range_count = 0) then
2107: -- We are the last, so update the batch status.

Line 2145: delete from hr_pump_ranges hpr

2141:
2142: rollback;
2143:
2144: if l_range_rowid is not null then
2145: delete from hr_pump_ranges hpr
2146: where hpr.rowid = l_range_rowid;
2147: end if;
2148:
2149: errbuf := post_error(sqlcode, sqlerrm, null, 'F', 'BATCH_HEADER',

Line 2287: delete from hr_pump_ranges where batch_id = p_batch_id;

2283: and e.source_type = 'BATCH_HEADER';
2284:
2285: -- We delete any existing range rows for this batch_id each time
2286: -- the process runs.
2287: delete from hr_pump_ranges where batch_id = p_batch_id;
2288: commit;
2289:
2290: -- Call the appropriate function
2291: -- to insert new range rows.

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 2661: from hr_pump_ranges r

2657:
2658: l_work_to_do := true;
2659: while l_work_to_do loop
2660: delete
2661: from hr_pump_ranges r
2662: where r.batch_id = p_batch_id
2663: and rownum <= p_chunk_size
2664: ;
2665: --