DBA Data[Home] [Help]

APPS.HR_DATA_PUMP dependencies on HR_PUMP_BATCH_LINES

Line 768: update hr_pump_batch_lines pbl

764: update hr_pump_batch_headers pbh
765: set pbh.batch_status = 'E'
766: where pbh.batch_id = p_id;
767: elsif (p_type <> 'BATCH_HEADER') then
768: update hr_pump_batch_lines pbl
769: set pbl.line_status = 'E'
770: where pbl.batch_line_id = p_id;
771: end if;
772:

Line 1092: from hr_pump_batch_lines pbl

1088: -- Cursor returning rows to process.
1089: cursor c1 is
1090: select pbl.batch_line_id,
1091: pbl.link_value
1092: from hr_pump_batch_lines pbl
1093: where pbl.batch_id = p_batch_id
1094: and pbl.line_status <> 'C'
1095: order by nvl(pbl.user_sequence, pbl.batch_line_id);
1096:

Line 1101: l_prv_link_val hr_pump_batch_lines.link_value%type;

1097: c1rec c1%rowtype;
1098:
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.

Line 1143: update hr_pump_batch_lines pbl

1139:
1140: if(c1%found) then
1141: -- This update will control the order in which
1142: -- rows are processed by the slave process.
1143: update hr_pump_batch_lines pbl
1144: set pbl.process_sequence = l_proc_seq
1145: where pbl.batch_line_id = c1rec.batch_line_id;
1146: end if;
1147:

Line 1333: * UPDATE HR_PUMP_BATCH_LINES LINE_STATUS.

1329: /*
1330: * Updates results for a range. Used at after the API have been executed
1331: * to:
1332: * DELETE existing rows from HR_PUMP_BATCH_EXCEPTIONS.
1333: * UPDATE HR_PUMP_BATCH_LINES LINE_STATUS.
1334: * INSERT rows into HR_PUMP_BATCH_EXCEPTIONS.
1335: */
1336: procedure update_range_results
1337: (p_failed_lines in dbms_sql.number_table

Line 1367: -- Update HR_PUMP_BATCH_LINES LINE_STATUS values.

1363:
1364: lbound := lbound + nrows;
1365: end loop;
1366:
1367: -- Update HR_PUMP_BATCH_LINES LINE_STATUS values.
1368: lbound := 1;
1369: nrows := 500;
1370: while lbound <= p_ls_ids.count loop
1371: ubound := lbound + nrows - 1;

Line 1377: update hr_pump_batch_lines bl

1373: ubound := p_ls_ids.count;
1374: end if;
1375:
1376: FORALL i IN lbound .. ubound
1377: update hr_pump_batch_lines bl
1378: set bl.line_status = p_ls_statuses(i)
1379: where bl.batch_line_id = p_ls_ids(i);
1380:
1381: lbound := lbound + nrows;

Line 1508: from hr_pump_batch_lines pbl

1504: , pbl.link_value
1505: , grp.business_group_id
1506: , grp.security_group_id
1507: , pbl.business_group_name
1508: from hr_pump_batch_lines pbl
1509: , hr_api_modules ham
1510: , per_business_groups_perf grp
1511: where pbl.batch_id = p_batch_id
1512: and ham.api_module_id = pbl.api_module_id

Line 1526: l_prv_link_val hr_pump_batch_lines.link_value%type;

1522: from per_business_groups_perf
1523: where name = p_business_group_name
1524: ;
1525:
1526: l_prv_link_val hr_pump_batch_lines.link_value%type;
1527: l_err_mode boolean;
1528: l_err_count number; -- count for this range only.
1529: l_bus_group_id number;
1530: l_sec_group_id number;

Line 1539: -- List of HR_PUMP_BATCH_LINES rows previously in error. This is

1535: -- Maximum errors exceeded during this execution.
1536: l_max_errors boolean;
1537:
1538: --
1539: -- List of HR_PUMP_BATCH_LINES rows previously in error. This is
1540: -- used to delete existing exception lines.
1541: --
1542: l_failed_lines dbms_sql.number_table;
1543:

Line 1551: -- List for holding HR_PUMP_BATCH_LINES LINE_STATUS. This is used

1547: l_exc_ids dbms_sql.number_table;
1548: l_exc_text dbms_sql.varchar2_table;
1549:
1550: --
1551: -- List for holding HR_PUMP_BATCH_LINES LINE_STATUS. This is used
1552: -- to update the LINE_STATUS column.
1553: --
1554: l_ls_statuses dbms_sql.varchar2s;
1555: l_ls_ids dbms_sql.number_table;

Line 2390: Purge HR_PUMP_BATCH_LINES rows with a specified status.

2386: /*
2387: NAME
2388: purgelines
2389: Description
2390: Purge HR_PUMP_BATCH_LINES rows with a specified status.
2391: */
2392: procedure purgelines
2393: (p_batch_id in number
2394: ,p_chunk_size in number

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 2404: from hr_pump_batch_lines l

2400:
2401: l_work_to_do := true;
2402: while l_work_to_do loop
2403: delete
2404: from hr_pump_batch_lines l
2405: where l.batch_id = p_batch_id
2406: and l.line_status = p_line_status
2407: and rownum <= p_chunk_size
2408: ;

Line 2550: from hr_pump_batch_lines bl

2546: set uk.batch_line_id = null
2547: where uk.batch_line_id in
2548: (
2549: select bl.batch_line_id
2550: from hr_pump_batch_lines bl
2551: where bl.batch_id = p_batch_id
2552: )
2553: and rownum <= p_chunk_size
2554: ;

Line 2561: from hr_pump_batch_lines l

2557: from hr_pump_batch_line_user_keys uk
2558: where uk.batch_line_id in
2559: (
2560: select l.batch_line_id
2561: from hr_pump_batch_lines l
2562: where l.batch_id = p_batch_id
2563: )
2564: and rownum <= p_chunk_size
2565: ;

Line 2592: from hr_pump_batch_lines l

2588: (
2589: e.source_id in
2590: (
2591: select l.batch_line_id
2592: from hr_pump_batch_lines l
2593: where l.batch_id = p_batch_id
2594: ) and
2595: e.source_type = 'BATCH_LINE'
2596: )

Line 2686: from hr_pump_batch_lines

2682: -- Only do the delete if there are no remaining batch lines.
2683: --
2684: select count(*)
2685: into l_count
2686: from hr_pump_batch_lines
2687: where batch_id = p_batch_id
2688: ;
2689:
2690: if l_count = 0 then