16: l_length number(15);
17: l_proc varchar2(73) := g_package || 'insert_xml_into_table';
18:
19: BEGIN
20: hr_utility.set_location('Entering:'|| l_proc, 10);
21: if dbms_lob.getlength(p_locator) > length('' || p_table_name|| '>') + length('
22: l_saveCtx := DBMS_XMLSave.newContext(p_table_name);
23: DBMS_XMLSave.setDateFormat(l_saveCtx,null);
24: l_rows := DBMS_XMLSave.insertXML(l_saveCtx,p_locator);
24: l_rows := DBMS_XMLSave.insertXML(l_saveCtx,p_locator);
25: DBMS_XMLSave.closeContext(l_saveCtx);
26: end if;
27: --
28: hr_utility.set_location('Leaving:'|| l_proc, 20);
29: END insert_xml_into_table;
30:
31: function get_clob_locator (p_table_name in varchar2) return clob is
32:
38: l_xmldoc_loc clob;
39: l_proc varchar2(73) := g_package || 'get_clob_locator';
40:
41: BEGIN
42: hr_utility.set_location('Entering:'|| l_proc, 10);
43:
44: l_clob_rec.table_name := p_table_name;
45: l_clob_rec.xmldoc := null;
46: l_xmldoc_loc := l_clob_rec.xmldoc;
43:
44: l_clob_rec.table_name := p_table_name;
45: l_clob_rec.xmldoc := null;
46: l_xmldoc_loc := l_clob_rec.xmldoc;
47: hr_utility.set_location('Leaving:'|| l_proc, 20);
48: return l_xmldoc_loc;
49:
50: EXCEPTION
51: when no_data_found then
61: l_from_business_group_id NUMBER(15);
62: l_proc VARCHAR2(72) := g_package||'get_from_business_group_id';
63:
64: BEGIN
65: hr_utility.set_location('Entering:'|| l_proc, 10);
66: l_from_business_group_id := hr_h2pi_map.get_from_id
67: (p_table_name => 'HR_ALL_ORGANIZATION_UNITS',
68: p_to_id => hr_h2pi_upload.g_to_business_group_id);
69: IF l_from_business_group_id = -1 THEN
66: l_from_business_group_id := hr_h2pi_map.get_from_id
67: (p_table_name => 'HR_ALL_ORGANIZATION_UNITS',
68: p_to_id => hr_h2pi_upload.g_to_business_group_id);
69: IF l_from_business_group_id = -1 THEN
70: hr_utility.set_location(l_proc, 20);
71: hr_h2pi_error.data_error
72: (p_from_id => hr_h2pi_upload.g_to_business_group_id,
73: p_table_name => 'HR_H2PI_BG_AND_GRE',
74: p_message_level => 'FATAL',
74: p_message_level => 'FATAL',
75: p_message_name => 'HR_289241_MAPPING_ID_MISSING');
76: END IF;
77:
78: hr_utility.set_location('Leaving:'|| l_proc, 30);
79: RETURN l_from_business_group_id;
80: END;
81: */
82:
86: l_from_client_id VARCHAR2(60);
87: l_proc VARCHAR2(72) := g_package||'get_from_client_id';
88:
89: BEGIN
90: hr_utility.set_location('Entering:'|| l_proc, 10);
91: -- special case of getting from client id
92: l_from_client_id := hr_h2pi_map.get_from_id
93: (p_table_name => 'CLIENT_ID',
94: p_to_id => hr_h2pi_upload.g_to_business_group_id);
92: l_from_client_id := hr_h2pi_map.get_from_id
93: (p_table_name => 'CLIENT_ID',
94: p_to_id => hr_h2pi_upload.g_to_business_group_id);
95: IF l_from_client_id = -1 THEN
96: hr_utility.set_location(l_proc, 20);
97: hr_h2pi_error.data_error
98: (p_from_id => hr_h2pi_upload.g_to_business_group_id,
99: p_table_name => 'HR_H2PI_BG_AND_GRE',
100: p_message_level => 'FATAL',
100: p_message_level => 'FATAL',
101: p_message_name => 'HR_289241_MAPPING_ID_MISSING');
102: END IF;
103:
104: hr_utility.set_location('Leaving:'|| l_proc, 30);
105: RETURN l_from_client_id;
106: END;
107:
108:
125: l_message varchar2(240);
126: --
127:
128: BEGIN
129: hr_utility.set_location('Entering:'|| l_proc, 10);
130:
131: -- check for previous incomplete uploads
132: /*
133: BEGIN
150: --
151: l_dest_clob_loc := get_clob_locator('HR_H2PI_EMPLOYEES');
152: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
153: --
154: hr_utility.set_location(l_proc, 20);
155: <
156: loop
157: utl_file.get_line(l_fp,l_line);
158: l_text := l_line;
174: --
175: l_dest_clob_loc := get_clob_locator('HR_H2PI_ADDRESSES');
176: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
177: --
178: hr_utility.set_location('Entering:'|| l_proc, 30);
179: <
180: loop
181: utl_file.get_line(l_fp,l_line);
182: l_text := l_line;
198: --
199: l_dest_clob_loc := get_clob_locator('HR_H2PI_LOCATIONS');
200: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
201: --
202: hr_utility.set_location('Entering:'|| l_proc, 40);
203: <
204: loop
205: utl_file.get_line(l_fp,l_line);
206: l_text := l_line;
222: --
223: l_dest_clob_loc := get_clob_locator('HR_H2PI_ASSIGNMENTS');
224: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
225: --
226: hr_utility.set_location('Entering:'|| l_proc, 50);
227: <
228: loop
229: utl_file.get_line(l_fp,l_line);
230: l_text := l_line;
245: --
246: l_dest_clob_loc := get_clob_locator('HR_H2PI_PAY_BASES');
247: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
248: --
249: hr_utility.set_location('Entering:'|| l_proc, 60);
250: <
251: loop
252: utl_file.get_line(l_fp,l_line);
253: l_text := l_line;
268: --
269: l_dest_clob_loc := get_clob_locator('HR_H2PI_HR_ORGANIZATIONS');
270: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
271: --
272: hr_utility.set_location('Entering:'|| l_proc, 70);
273: <
274: loop
275: utl_file.get_line(l_fp,l_line);
276: l_text := l_line;
293: --
294: l_dest_clob_loc := get_clob_locator('HR_H2PI_PAYROLLS');
295: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
296: --
297: hr_utility.set_location('Entering:'|| l_proc, 80);
298: <
299: loop
300: utl_file.get_line(l_fp,l_line);
301: l_text := l_line;
317: --
318: l_dest_clob_loc := get_clob_locator('HR_H2PI_ELEMENT_TYPES');
319: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
320: --
321: hr_utility.set_location('Entering:'|| l_proc, 90);
322: <
323: loop
324: utl_file.get_line(l_fp,l_line);
325: l_text := l_line;
341: --
342: l_dest_clob_loc := get_clob_locator('HR_H2PI_INPUT_VALUES');
343: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
344: --
345: hr_utility.set_location('Entering:'|| l_proc, 100);
346: <
347: loop
348: utl_file.get_line(l_fp,l_line);
349: l_text := l_line;
364: -- FOR HR_H2PI_ELEMENT_LINKS table.
365: --
366: l_dest_clob_loc := get_clob_locator('HR_H2PI_ELEMENT_LINKS');
367: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
368: hr_utility.set_location('Entering:'|| l_proc,110);
369: --
370: <
371: loop
372: utl_file.get_line(l_fp,l_line);
389: --
390: l_dest_clob_loc := get_clob_locator('HR_H2PI_BG_AND_GRE');
391: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
392: --
393: hr_utility.set_location('Entering:'|| l_proc, 120);
394: <
395: loop
396: utl_file.get_line(l_fp,l_line);
397: l_text := l_line;
414: --
415: l_dest_clob_loc := get_clob_locator('HR_H2PI_ORG_PAYMENT_METHODS');
416: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
417: --
418: hr_utility.set_location('Entering:'|| l_proc, 130);
419: <
420: loop
421: utl_file.get_line(l_fp,l_line);
422: l_text := l_line;
438: --
439: l_dest_clob_loc := get_clob_locator('HR_H2PI_PATCH_STATUS');
440: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
441: --
442: hr_utility.set_location('Entering:'|| l_proc, 140);
443: <
444: loop
445: utl_file.get_line(l_fp,l_line);
446: l_text := l_line;
462: --
463: l_dest_clob_loc := get_clob_locator('HR_H2PI_FEDERAL_TAX_RULES');
464: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
465: --
466: hr_utility.set_location('Entering:'|| l_proc, 150);
467: <
468: loop
469: utl_file.get_line(l_fp,l_line);
470: l_text := l_line;
486: --
487: l_dest_clob_loc := get_clob_locator('HR_H2PI_STATE_TAX_RULES');
488: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
489: --
490: hr_utility.set_location('Entering:'|| l_proc, 160);
491: <
492: loop
493: utl_file.get_line(l_fp,l_line);
494: l_text := l_line;
510: --
511: l_dest_clob_loc := get_clob_locator('HR_H2PI_COUNTY_TAX_RULES');
512: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
513: --
514: hr_utility.set_location('Entering:'|| l_proc, 170);
515: <
516: loop
517: utl_file.get_line(l_fp,l_line);
518: l_text := l_line;
534: --
535: l_dest_clob_loc := get_clob_locator('HR_H2PI_CITY_TAX_RULES');
536: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
537: --
538: hr_utility.set_location('Entering:'|| l_proc, 180);
539: <
540: loop
541: utl_file.get_line(l_fp,l_line);
542: l_text := l_line;
558: --
559: l_dest_clob_loc := get_clob_locator('HR_H2PI_ORGANIZATION_CLASS');
560: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
561: --
562: hr_utility.set_location('Entering:'|| l_proc, 190);
563: <
564: loop
565: utl_file.get_line(l_fp,l_line);
566: l_text := l_line;
582: --
583: l_dest_clob_loc := get_clob_locator('HR_H2PI_PERIODS_OF_SERVICE');
584: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
585: --
586: hr_utility.set_location('Entering:'|| l_proc, 200);
587: <
588: loop
589: utl_file.get_line(l_fp,l_line);
590: l_text := l_line;
605: --
606: l_dest_clob_loc := get_clob_locator('HR_H2PI_SALARIES');
607: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
608: --
609: hr_utility.set_location('Entering:'|| l_proc, 210);
610: <
611: loop
612: utl_file.get_line(l_fp,l_line);
613: l_text := l_line;
629: --
630: l_dest_clob_loc := get_clob_locator('HR_H2PI_ORGANIZATION_INFO');
631: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
632: --
633: hr_utility.set_location('Entering:'|| l_proc, 220);
634: <
635: loop
636: utl_file.get_line(l_fp,l_line);
637: l_text := l_line;
653: --
654: l_dest_clob_loc := get_clob_locator('HR_H2PI_COST_ALLOCATIONS');
655: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
656: --
657: hr_utility.set_location('Entering:'|| l_proc, 230);
658: <
659: loop
660: utl_file.get_line(l_fp,l_line);
661: l_text := l_line;
677: --
678: l_dest_clob_loc := get_clob_locator('HR_H2PI_PAYMENT_METHODS');
679: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
680: --
681: hr_utility.set_location('Entering:'|| l_proc, 240);
682: <
683: loop
684: utl_file.get_line(l_fp,l_line);
685: l_text := l_line;
701: --
702: l_dest_clob_loc := get_clob_locator('HR_H2PI_ELEMENT_NAMES');
703: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
704: --
705: hr_utility.set_location('Entering:'|| l_proc, 250);
706: <
707: loop
708: utl_file.get_line(l_fp,l_line);
709: l_text := l_line;
725: --
726: l_dest_clob_loc := get_clob_locator('HR_H2PI_ELEMENT_ENTRIES');
727: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
728: --
729: hr_utility.set_location('Entering:'|| l_proc, 260);
730: <
731: loop
732: utl_file.get_line(l_fp,l_line);
733: l_text := l_line;
751: l_dest_clob_loc := get_clob_locator('HR_H2PI_ELEMENT_ENTRY_VALUES');
752: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
753: --
754: <
755: hr_utility.set_location('Entering:'|| l_proc, 270);
756: loop
757: utl_file.get_line(l_fp,l_line);
758: l_text := l_line;
759: if l_text is not null then
777: l_dest_clob_loc := get_clob_locator('HR_H2PI_US_MODIFIED_GEOCODES');
778: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
779: --
780: <
781: hr_utility.set_location('Entering:'|| l_proc, 280);
782: loop
783: utl_file.get_line(l_fp,l_line);
784: l_text := l_line;
785: if l_text is not null then
802: l_dest_clob_loc := get_clob_locator('HR_H2PI_US_CITY_NAMES');
803: dbms_lob.createtemporary(l_dest_clob_loc,TRUE);
804: --
805: <
806: hr_utility.set_location('Entering:'|| l_proc, 290);
807: loop
808: utl_file.get_line(l_fp,l_line);
809: l_text := l_line;
810: if l_text is not null then
822: --
823: utl_file.fclose(l_fp);
824:
825: --commit;
826: hr_utility.set_location('Leaving:'|| l_proc, 300);
827:
828: EXCEPTION
829: WHEN UTL_FILE.INVALID_PATH THEN
830: fnd_message.set_name('PER','HR_52089_NOT_OPEN_FILE');