DBA Data[Home] [Help]

APPS.HR_DM_GEN_MAIN dependencies on HR_DM_UTILITY

Line 59: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.chk_long_column', 5);

55: l_pay_owner,
56: l_per_owner);
57:
58: begin
59: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.chk_long_column', 5);
60: hr_dm_utility.message('PARA','(p_table_name - ' || p_table_name ||
61: ')', 10);
62:
63: open csr_apps_name;

Line 60: hr_dm_utility.message('PARA','(p_table_name - ' || p_table_name ||

56: l_per_owner);
57:
58: begin
59: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.chk_long_column', 5);
60: hr_dm_utility.message('PARA','(p_table_name - ' || p_table_name ||
61: ')', 10);
62:
63: open csr_apps_name;
64: fetch csr_apps_name into l_apps_name;

Line 77: hr_dm_utility.message('INFO','HR_DM_GEN_MAIN - check whether table has any long column',15);

73: l_return_flag := 'N';
74: end if;
75: close csr_chk_long_column;
76:
77: hr_dm_utility.message('INFO','HR_DM_GEN_MAIN - check whether table has any long column',15);
78:
79: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.chk_long_column', 25);
80: hr_dm_utility.message('PARA','(l_return_flag - ' || l_return_flag || ')' ,30);
81: return l_return_flag;

Line 79: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.chk_long_column', 25);

75: close csr_chk_long_column;
76:
77: hr_dm_utility.message('INFO','HR_DM_GEN_MAIN - check whether table has any long column',15);
78:
79: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.chk_long_column', 25);
80: hr_dm_utility.message('PARA','(l_return_flag - ' || l_return_flag || ')' ,30);
81: return l_return_flag;
82: exception
83: when others then

Line 80: hr_dm_utility.message('PARA','(l_return_flag - ' || l_return_flag || ')' ,30);

76:
77: hr_dm_utility.message('INFO','HR_DM_GEN_MAIN - check whether table has any long column',15);
78:
79: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.chk_long_column', 25);
80: hr_dm_utility.message('PARA','(l_return_flag - ' || l_return_flag || ')' ,30);
81: return l_return_flag;
82: exception
83: when others then
84: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.chk_long_column',

Line 84: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.chk_long_column',

80: hr_dm_utility.message('PARA','(l_return_flag - ' || l_return_flag || ')' ,30);
81: return l_return_flag;
82: exception
83: when others then
84: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.chk_long_column',
85: '(none)','R');
86: raise;
87: end chk_long_column;
88:

Line 129: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.get_hierarchy_info', 5);

125: and hir.hierarchy_type = p_hierarchy_type;
126:
127:
128: begin
129: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.get_hierarchy_info', 5);
130: hr_dm_utility.message('PARA','(p_table_id - ' || p_table_id ||
131: ')(p_hierarchy_type - ' || p_hierarchy_type ||
132: ')', 10);
133:

Line 130: hr_dm_utility.message('PARA','(p_table_id - ' || p_table_id ||

126:
127:
128: begin
129: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.get_hierarchy_info', 5);
130: hr_dm_utility.message('PARA','(p_table_id - ' || p_table_id ||
131: ')(p_hierarchy_type - ' || p_hierarchy_type ||
132: ')', 10);
133:
134: if (p_hierarchy_type = 'R')

Line 161: hr_dm_utility.message('INFO','HR_DM_GEN_MAIN - get whether a given hierarchy type'||

157: close csr_get_hierarchy_info;
158:
159: end if;
160:
161: hr_dm_utility.message('INFO','HR_DM_GEN_MAIN - get whether a given hierarchy type'||
162: ' is valid for table ' ||
163: 'in hr_dm_dt_deletes table ',15);
164:
165: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.get_hierarchy_info',

Line 165: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.get_hierarchy_info',

161: hr_dm_utility.message('INFO','HR_DM_GEN_MAIN - get whether a given hierarchy type'||
162: ' is valid for table ' ||
163: 'in hr_dm_dt_deletes table ',15);
164:
165: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.get_hierarchy_info',
166: 25);
167: hr_dm_utility.message('PARA','(l_return_flag - ' || l_return_flag || ')' ,30);
168: return l_return_flag;
169: exception

Line 167: hr_dm_utility.message('PARA','(l_return_flag - ' || l_return_flag || ')' ,30);

163: 'in hr_dm_dt_deletes table ',15);
164:
165: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.get_hierarchy_info',
166: 25);
167: hr_dm_utility.message('PARA','(l_return_flag - ' || l_return_flag || ')' ,30);
168: return l_return_flag;
169: exception
170: when others then
171: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.get_hierarchy_info',

Line 171: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.get_hierarchy_info',

167: hr_dm_utility.message('PARA','(l_return_flag - ' || l_return_flag || ')' ,30);
168: return l_return_flag;
169: exception
170: when others then
171: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.get_hierarchy_info',
172: '(none)','R');
173: raise;
174: end get_hierarchy_info;
175:

Line 202: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.chk_ins_resolve_pk', 5);

198: select nvl(upload_table_name, table_name)
199: from hr_dm_tables
200: where table_id = p_table_id));
201: begin
202: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.chk_ins_resolve_pk', 5);
203: hr_dm_utility.message('PARA','(p_table_id - ' || p_table_id ||
204: ')', 10);
205:
206: open csr_chk_ins_resolve_pk (p_table_id);

Line 203: hr_dm_utility.message('PARA','(p_table_id - ' || p_table_id ||

199: from hr_dm_tables
200: where table_id = p_table_id));
201: begin
202: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.chk_ins_resolve_pk', 5);
203: hr_dm_utility.message('PARA','(p_table_id - ' || p_table_id ||
204: ')', 10);
205:
206: open csr_chk_ins_resolve_pk (p_table_id);
207: fetch csr_chk_ins_resolve_pk into l_dummy;

Line 215: hr_dm_utility.message('INFO','HR_DM_GEN_MAIN - get whether a table has child table'||

211: l_return_flag := 'N';
212: end if;
213: close csr_chk_ins_resolve_pk;
214:
215: hr_dm_utility.message('INFO','HR_DM_GEN_MAIN - get whether a table has child table'||
216: ' with hierarchy type L',15);
217:
218: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.chk_ins_resolve_pk',
219: 25);

Line 218: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.chk_ins_resolve_pk',

214:
215: hr_dm_utility.message('INFO','HR_DM_GEN_MAIN - get whether a table has child table'||
216: ' with hierarchy type L',15);
217:
218: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.chk_ins_resolve_pk',
219: 25);
220: hr_dm_utility.message('PARA','(l_return_flag - ' || l_return_flag || ')' ,30);
221: return l_return_flag;
222: exception

Line 220: hr_dm_utility.message('PARA','(l_return_flag - ' || l_return_flag || ')' ,30);

216: ' with hierarchy type L',15);
217:
218: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.chk_ins_resolve_pk',
219: 25);
220: hr_dm_utility.message('PARA','(l_return_flag - ' || l_return_flag || ')' ,30);
221: return l_return_flag;
222: exception
223: when others then
224: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.chk_ins_resolve_pk',

Line 224: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.chk_ins_resolve_pk',

220: hr_dm_utility.message('PARA','(l_return_flag - ' || l_return_flag || ')' ,30);
221: return l_return_flag;
222: exception
223: when others then
224: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.chk_ins_resolve_pk',
225: '(none)','R');
226: raise;
227: end chk_ins_resolve_pk;
228:

Line 321: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.post_generate_validate', 5);

317:
318:
319: begin
320: -- return;
321: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.post_generate_validate', 5);
322: hr_dm_utility.message('PARA','(p_migration_id - ' || p_migration_id ||
323: ')', 10);
324:
325: for csr_get_table_rec in csr_get_table loop

Line 322: hr_dm_utility.message('PARA','(p_migration_id - ' || p_migration_id ||

318:
319: begin
320: -- return;
321: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.post_generate_validate', 5);
322: hr_dm_utility.message('PARA','(p_migration_id - ' || p_migration_id ||
323: ')', 10);
324:
325: for csr_get_table_rec in csr_get_table loop
326: l_phase_item_id := csr_get_table_rec.phase_item_id;

Line 369: hr_dm_utility.message('INFO','checking HR_DMV% views',12);

365:
366:
367: -- now check HR_DMV% views
368: -- for inclusion of null business_group check in where clause
369: hr_dm_utility.message('INFO','checking HR_DMV% views',12);
370: l_view_error := 'N';
371: open csr_apps_name;
372: fetch csr_apps_name into l_apps_name;
373: close csr_apps_name;

Line 384: hr_dm_utility.message('INFO','The view ' || l_view_name

380: exit when csr_view_info%notfound;
381:
382: if instr(l_text, 'business_group_id is null') = 0 then
383: l_view_error := 'Y';
384: hr_dm_utility.message('INFO','The view ' || l_view_name
385: || ' is missing a business_group_id ' ||
386: 'is null clause.',15);
387: hr_dm_utility.update_phase_items(p_new_status => 'E',
388: p_id => l_phase_item_id);

Line 387: hr_dm_utility.update_phase_items(p_new_status => 'E',

383: l_view_error := 'Y';
384: hr_dm_utility.message('INFO','The view ' || l_view_name
385: || ' is missing a business_group_id ' ||
386: 'is null clause.',15);
387: hr_dm_utility.update_phase_items(p_new_status => 'E',
388: p_id => l_phase_item_id);
389: end if;
390: end loop;
391: close csr_view_info;

Line 403: hr_dm_utility.message('INFO','HR_DM_GEN_MAIN - post generate validation ',15);

399: raise e_fatal_error;
400: end if;
401:
402:
403: hr_dm_utility.message('INFO','HR_DM_GEN_MAIN - post generate validation ',15);
404: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.post_generate_validate',
405: 25);
406:
407: -- error handling

Line 404: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.post_generate_validate',

400: end if;
401:
402:
403: hr_dm_utility.message('INFO','HR_DM_GEN_MAIN - post generate validation ',15);
404: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.post_generate_validate',
405: 25);
406:
407: -- error handling
408: exception

Line 410: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.post_generate_validate',

406:
407: -- error handling
408: exception
409: when e_fatal_error then
410: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.post_generate_validate',
411: l_fatal_error_message,'R');
412: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.post_generate_validate',
413: '(none)','R');
414: when others then

Line 412: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.post_generate_validate',

408: exception
409: when e_fatal_error then
410: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.post_generate_validate',
411: l_fatal_error_message,'R');
412: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.post_generate_validate',
413: '(none)','R');
414: when others then
415: -- update status to error
416: hr_dm_utility.update_phase_items(p_new_status => 'E',

Line 416: hr_dm_utility.update_phase_items(p_new_status => 'E',

412: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.post_generate_validate',
413: '(none)','R');
414: when others then
415: -- update status to error
416: hr_dm_utility.update_phase_items(p_new_status => 'E',
417: p_id => l_phase_item_id);
418: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.post_generate_validate','(none)','R');
419: end post_generate_validate;
420:

Line 418: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.post_generate_validate','(none)','R');

414: when others then
415: -- update status to error
416: hr_dm_utility.update_phase_items(p_new_status => 'E',
417: p_id => l_phase_item_id);
418: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.post_generate_validate','(none)','R');
419: end post_generate_validate;
420:
421: -- ------------------------- slave_generator_for_tbl --------------------
422: -- Description:

Line 510: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.slave_generator_for_tbl ', 5);

506: l_parent_table_id number;
507:
508: begin
509:
510: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.slave_generator_for_tbl ', 5);
511: hr_dm_utility.message('PARA','(p_phase_item_id - ' || p_phase_item_id ||
512: ')', 10);
513: -- initialise the counter.
514: l_count := 1;

Line 511: hr_dm_utility.message('PARA','(p_phase_item_id - ' || p_phase_item_id ||

507:
508: begin
509:
510: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.slave_generator_for_tbl ', 5);
511: hr_dm_utility.message('PARA','(p_phase_item_id - ' || p_phase_item_id ||
512: ')', 10);
513: -- initialise the counter.
514: l_count := 1;
515: --

Line 520: hr_dm_utility.message('INFO','Started Generating TUPS/TDS for ' ||

516: -- Get the table for which TUPS/TDS has to be generated
517: --
518: open csr_get_table;
519: fetch csr_get_table into l_csr_get_table_rec;
520: hr_dm_utility.message('INFO','Started Generating TUPS/TDS for ' ||
521: l_csr_get_table_rec.table_name || ', Table Id - ' ||
522: l_csr_get_table_rec.table_id,20);
523:
524: hr_dm_utility.message('SUMM','Started Generating TUPS/TDS for ' ||

Line 524: hr_dm_utility.message('SUMM','Started Generating TUPS/TDS for ' ||

520: hr_dm_utility.message('INFO','Started Generating TUPS/TDS for ' ||
521: l_csr_get_table_rec.table_name || ', Table Id - ' ||
522: l_csr_get_table_rec.table_id,20);
523:
524: hr_dm_utility.message('SUMM','Started Generating TUPS/TDS for ' ||
525: l_csr_get_table_rec.table_name || ', Table Id - ' ||
526: l_csr_get_table_rec.table_id,30);
527: l_phase_item_id := l_csr_get_table_rec.phase_item_id;
528: --l_phase_id := l_csr_get_table_rec.phase_id;

Line 535: l_current_phase_status := nvl(hr_dm_utility.get_phase_status('G',

531: -- get status of generate phase. If phase has error status set by other slave
532: -- process then we need to stop the processing of this slave.
533: -- if null returned, then assume it is not started.
534: --
535: l_current_phase_status := nvl(hr_dm_utility.get_phase_status('G',
536: l_csr_get_table_rec.migration_id),
537: 'NS');
538: -- if status is error, then raise an exception
539: if (l_current_phase_status = 'E') then

Line 544: hr_dm_utility.update_phase_items(p_new_status => 'S',

540: l_fatal_error_message := 'error in generator phase - slave exiting';
541: raise e_fatal_error;
542: end if;
543: -- update status to started
544: hr_dm_utility.update_phase_items(p_new_status => 'S',
545: p_id => l_phase_item_id);
546: --
547: -- store the information of the table properties into pl/sql record
548: --

Line 728: hr_dm_utility.message('INFO',' Information about ' ||

724: l_missing_who_info);
725:
726: l_table_info.missing_who_info := l_missing_who_info;
727:
728: hr_dm_utility.message('INFO',' Information about ' ||
729: 'l_table_info.table_name :' ||
730: ')(datetrack - ' || l_table_info.datetrack ||
731: ')(surrogate_primary_key - ' || l_table_info.surrogate_primary_key ||
732: ')(surrogate_pk_column_name - ' || l_table_info.surrogate_pk_column_name ||

Line 761: hr_dm_utility.message('INFO',' Started Generating TUPS for ' ||

757:
758: --
759: -- Call TUPS genrator to create TUPS for the table
760: --
761: hr_dm_utility.message('INFO',' Started Generating TUPS for ' ||
762: l_table_info.table_name,50);
763: hr_dm_gen_tups.create_tups_pacakge (l_table_info,
764: l_columns_tbl,
765: l_parameters_tbl,

Line 769: hr_dm_utility.message('INFO',' Successfully Generated TUPS for ' ||

765: l_parameters_tbl,
766: l_aol_columns_tbl,
767: l_aol_parameters_tbl,
768: l_fk_to_aol_columns_tbl);
769: hr_dm_utility.message('INFO',' Successfully Generated TUPS for ' ||
770: l_table_info.table_name,60);
771: --
772: -- Seed the data for TUPS into data pump table.
773: --

Line 774: hr_dm_utility.message('INFO',' Started seeding data into ' ||

770: l_table_info.table_name,60);
771: --
772: -- Seed the data for TUPS into data pump table.
773: --
774: hr_dm_utility.message('INFO',' Started seeding data into ' ||
775: 'Data Pump tables for ' || l_table_info.table_name,70);
776: hr_dm_seed_dp.main (l_table_info ,
777: l_columns_tbl);
778: hr_dm_utility.message('INFO',' Successfully seeded data into ' ||

Line 778: hr_dm_utility.message('INFO',' Successfully seeded data into ' ||

774: hr_dm_utility.message('INFO',' Started seeding data into ' ||
775: 'Data Pump tables for ' || l_table_info.table_name,70);
776: hr_dm_seed_dp.main (l_table_info ,
777: l_columns_tbl);
778: hr_dm_utility.message('INFO',' Successfully seeded data into ' ||
779: 'Data Pump tables for ' || l_table_info.table_name,80);
780: --
781: -- Call TDS generator to create TDS for the table
782: --

Line 784: hr_dm_utility.message('INFO',' Started Generating TDS for ' ||

780: --
781: -- Call TDS generator to create TDS for the table
782: --
783:
784: hr_dm_utility.message('INFO',' Started Generating TDS for ' ||
785: l_table_info.table_name,90);
786: hr_dm_gen_tds.create_tds_pacakge (l_table_info,
787: l_columns_tbl,
788: l_parameters_tbl,

Line 792: hr_dm_utility.message('INFO',' Successfully Generated TDS for ' ||

788: l_parameters_tbl,
789: l_aol_columns_tbl,
790: l_aol_parameters_tbl,
791: l_fk_to_aol_columns_tbl);
792: hr_dm_utility.message('INFO',' Successfully Generated TDS for ' ||
793: l_table_info.table_name,100);
794:
795: l_count := l_count + 1;
796:

Line 809: hr_dm_utility.update_phase_items(p_new_status => 'C',

805: generator_version = l_generator_version
806: where table_id = l_csr_get_table_rec.table_id;
807:
808: -- update status to completed
809: hr_dm_utility.update_phase_items(p_new_status => 'C',
810: p_id => l_phase_item_id);
811:
812: hr_dm_utility.message('INFO','Generated TUPS/TDS succesfully for ' ||
813: l_csr_get_table_rec.table_name || ', Table Id - ' ||

Line 812: hr_dm_utility.message('INFO','Generated TUPS/TDS succesfully for ' ||

808: -- update status to completed
809: hr_dm_utility.update_phase_items(p_new_status => 'C',
810: p_id => l_phase_item_id);
811:
812: hr_dm_utility.message('INFO','Generated TUPS/TDS succesfully for ' ||
813: l_csr_get_table_rec.table_name || ', Table Id - ' ||
814: l_csr_get_table_rec.table_id,110);
815:
816: hr_dm_utility.message('SUMM','Generated TUPS/TDS successfully for ' ||

Line 816: hr_dm_utility.message('SUMM','Generated TUPS/TDS successfully for ' ||

812: hr_dm_utility.message('INFO','Generated TUPS/TDS succesfully for ' ||
813: l_csr_get_table_rec.table_name || ', Table Id - ' ||
814: l_csr_get_table_rec.table_id,110);
815:
816: hr_dm_utility.message('SUMM','Generated TUPS/TDS successfully for ' ||
817: l_csr_get_table_rec.table_name || ', Table Id - ' ||
818: l_csr_get_table_rec.table_id,115);
819: close csr_get_table;
820:

Line 821: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.slave_generator_for_tbl',

817: l_csr_get_table_rec.table_name || ', Table Id - ' ||
818: l_csr_get_table_rec.table_id,115);
819: close csr_get_table;
820:
821: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.slave_generator_for_tbl',
822: 120);
823:
824: -- error handling
825: exception

Line 830: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator_for_tbl',

826: when e_fatal_error then
827: if csr_get_table%isopen then
828: close csr_get_table;
829: end if;
830: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator_for_tbl',
831: l_fatal_error_message,'R');
832: hr_dm_utility.update_phase_items(p_new_status => 'E',
833: p_id => l_phase_item_id);
834:

Line 832: hr_dm_utility.update_phase_items(p_new_status => 'E',

828: close csr_get_table;
829: end if;
830: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator_for_tbl',
831: l_fatal_error_message,'R');
832: hr_dm_utility.update_phase_items(p_new_status => 'E',
833: p_id => l_phase_item_id);
834:
835: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator_for_tbl','(none)','R');
836: when others then

Line 835: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator_for_tbl','(none)','R');

831: l_fatal_error_message,'R');
832: hr_dm_utility.update_phase_items(p_new_status => 'E',
833: p_id => l_phase_item_id);
834:
835: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator_for_tbl','(none)','R');
836: when others then
837: if csr_get_table%isopen then
838: close csr_get_table;
839: end if;

Line 841: hr_dm_utility.update_phase_items(p_new_status => 'E',

837: if csr_get_table%isopen then
838: close csr_get_table;
839: end if;
840: -- update status to error
841: hr_dm_utility.update_phase_items(p_new_status => 'E',
842: p_id => l_phase_item_id);
843: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator_for_tbl','(none)','R');
844:
845: end slave_generator_for_tbl ;

Line 843: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator_for_tbl','(none)','R');

839: end if;
840: -- update status to error
841: hr_dm_utility.update_phase_items(p_new_status => 'E',
842: p_id => l_phase_item_id);
843: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator_for_tbl','(none)','R');
844:
845: end slave_generator_for_tbl ;
846:
847: -- ------------------------- slave_generator --------------------------

Line 999: hr_dm_utility.message_init;

995: begin
996:
997: -- initialize messaging
998: if p_concurrent_process = 'Y' then
999: hr_dm_utility.message_init;
1000: end if;
1001:
1002: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.slave_generator', 5);
1003: hr_dm_utility.message('PARA','(errbuf - ' || errbuf ||

Line 1002: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.slave_generator', 5);

998: if p_concurrent_process = 'Y' then
999: hr_dm_utility.message_init;
1000: end if;
1001:
1002: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.slave_generator', 5);
1003: hr_dm_utility.message('PARA','(errbuf - ' || errbuf ||
1004: ')(retcode - ' || retcode ||
1005: ')(p_migration_id - ' || p_migration_id ||
1006: ')(p_concurrent_process - ' || p_concurrent_process ||

Line 1003: hr_dm_utility.message('PARA','(errbuf - ' || errbuf ||

999: hr_dm_utility.message_init;
1000: end if;
1001:
1002: hr_dm_utility.message('ROUT','entry:hr_dm_gen_main.slave_generator', 5);
1003: hr_dm_utility.message('PARA','(errbuf - ' || errbuf ||
1004: ')(retcode - ' || retcode ||
1005: ')(p_migration_id - ' || p_migration_id ||
1006: ')(p_concurrent_process - ' || p_concurrent_process ||
1007: ')(p_last_migration_date - '|| p_last_migration_date ||

Line 1021: l_no_of_threads := hr_dm_utility.number_of_threads(l_business_group_id);

1017: raise e_fatal_error2;
1018: end if;
1019: close csr_migration_info;
1020:
1021: l_no_of_threads := hr_dm_utility.number_of_threads(l_business_group_id);
1022:
1023: -- initialise the counter.
1024: l_count := 1;
1025: --

Line 1036: l_current_phase_status := nvl(hr_dm_utility.get_phase_status('G',

1032: -- get status of generate phase. If phase has error status set by other slave
1033: -- process then we need to stop the processing of this slave.
1034: -- if null returned, then assume it is not started.
1035: --
1036: l_current_phase_status := nvl(hr_dm_utility.get_phase_status('G',
1037: p_migration_id),
1038: 'NS');
1039:
1040: -- if status is error, then raise an exception

Line 1055: hr_dm_utility.update_phase_items(p_new_status => 'S',

1051: exit;
1052: end if;
1053:
1054: -- update status to started
1055: hr_dm_utility.update_phase_items(p_new_status => 'S',
1056: p_id => l_csr_get_table_rec.phase_item_id);
1057:
1058: l_phase_item_id := l_csr_get_table_rec.phase_item_id;
1059: l_phase_id := l_csr_get_table_rec.phase_id;

Line 1063: hr_dm_utility.message('INFO','Started Generating TUPS/TDS for ' ||

1059: l_phase_id := l_csr_get_table_rec.phase_id;
1060:
1061: close csr_get_table;
1062:
1063: hr_dm_utility.message('INFO','Started Generating TUPS/TDS for ' ||
1064: l_csr_get_table_rec.table_name || ', Table Id - ' ||
1065: l_csr_get_table_rec.table_id,20);
1066:
1067: hr_dm_utility.message('SUMM','Started Generating TUPS/TDS for ' ||

Line 1067: hr_dm_utility.message('SUMM','Started Generating TUPS/TDS for ' ||

1063: hr_dm_utility.message('INFO','Started Generating TUPS/TDS for ' ||
1064: l_csr_get_table_rec.table_name || ', Table Id - ' ||
1065: l_csr_get_table_rec.table_id,20);
1066:
1067: hr_dm_utility.message('SUMM','Started Generating TUPS/TDS for ' ||
1068: l_csr_get_table_rec.table_name || ', Table Id - ' ||
1069: l_csr_get_table_rec.table_id,30);
1070: --
1071: -- store the information of the table properties into pl/sql record

Line 1270: hr_dm_utility.message('INFO',' Information about ' ||

1266:
1267:
1268: l_table_info.missing_who_info := l_missing_who_info;
1269:
1270: hr_dm_utility.message('INFO',' Information about ' ||
1271: 'l_table_info.table_name :' ||
1272: ')(datetrack - ' || l_table_info.datetrack ||
1273: ')(surrogate_primary_key - ' || l_table_info.surrogate_primary_key ||
1274: ')(surrogate_pk_column_name - ' || l_table_info.surrogate_pk_column_name ||

Line 1334: l_fatal_error_message := 'error in hr_dm_utility.create_view - for ' ||

1330: hr_dm_library.create_view(l_table_info);
1331:
1332: exception
1333: when others then
1334: l_fatal_error_message := 'error in hr_dm_utility.create_view - for ' ||
1335: l_table_info.table_name || '. Exiting slave';
1336: raise e_fatal_error;
1337: end;
1338: end if;

Line 1343: hr_dm_utility.message('INFO',' Started Generating TUPS for ' ||

1339:
1340: --
1341: -- Call TUPS genrator to create TUPS for the table
1342: --
1343: hr_dm_utility.message('INFO',' Started Generating TUPS for ' ||
1344: l_table_info.table_name,50);
1345:
1346: hr_dm_gen_tups.create_tups_pacakge (l_table_info,
1347: l_columns_tbl,

Line 1353: hr_dm_utility.message('INFO',' Successfully Generated TUPS for ' ||

1349: l_aol_columns_tbl,
1350: l_aol_parameters_tbl,
1351: l_fk_to_aol_columns_tbl);
1352:
1353: hr_dm_utility.message('INFO',' Successfully Generated TUPS for ' ||
1354: l_table_info.table_name,60);
1355: --
1356: -- Seed the data for TUPS into data pump table.
1357: --

Line 1358: hr_dm_utility.message('INFO',' Started seeding data into ' ||

1354: l_table_info.table_name,60);
1355: --
1356: -- Seed the data for TUPS into data pump table.
1357: --
1358: hr_dm_utility.message('INFO',' Started seeding data into ' ||
1359: 'Data Pump tables for ' || l_table_info.table_name,70);
1360:
1361:
1362: hr_dm_seed_dp.main (l_table_info ,

Line 1364: hr_dm_utility.message('INFO',' Successfully seeded data into ' ||

1360:
1361:
1362: hr_dm_seed_dp.main (l_table_info ,
1363: l_columns_tbl);
1364: hr_dm_utility.message('INFO',' Successfully seeded data into ' ||
1365: 'Data Pump tables for ' || l_table_info.table_name,80);
1366: --
1367: -- Call TDS generator to create TDS for the table
1368: --

Line 1369: hr_dm_utility.message('INFO',' Started Generating TDS for ' ||

1365: 'Data Pump tables for ' || l_table_info.table_name,80);
1366: --
1367: -- Call TDS generator to create TDS for the table
1368: --
1369: hr_dm_utility.message('INFO',' Started Generating TDS for ' ||
1370: l_table_info.table_name,90);
1371:
1372:
1373: hr_dm_gen_tds.create_tds_pacakge (l_table_info,

Line 1379: hr_dm_utility.message('INFO',' Successfully Generated TDS for ' ||

1375: l_parameters_tbl,
1376: l_aol_columns_tbl,
1377: l_aol_parameters_tbl,
1378: l_fk_to_aol_columns_tbl);
1379: hr_dm_utility.message('INFO',' Successfully Generated TDS for ' ||
1380: l_table_info.table_name,100);
1381:
1382: l_count := l_count + 1;
1383:

Line 1395: hr_dm_utility.update_phase_items(p_new_status => 'C',

1391: generator_version = l_generator_version
1392: where table_id = l_csr_get_table_rec.table_id;
1393:
1394: -- update status to completed
1395: hr_dm_utility.update_phase_items(p_new_status => 'C',
1396: p_id => l_phase_item_id);
1397:
1398: hr_dm_utility.message('INFO','Generated TUPS/TDS succesfully for ' ||
1399: l_csr_get_table_rec.table_name || ', Table Id - ' ||

Line 1398: hr_dm_utility.message('INFO','Generated TUPS/TDS succesfully for ' ||

1394: -- update status to completed
1395: hr_dm_utility.update_phase_items(p_new_status => 'C',
1396: p_id => l_phase_item_id);
1397:
1398: hr_dm_utility.message('INFO','Generated TUPS/TDS succesfully for ' ||
1399: l_csr_get_table_rec.table_name || ', Table Id - ' ||
1400: l_csr_get_table_rec.table_id,110);
1401:
1402: hr_dm_utility.message('SUMM','Generated TUPS/TDS successfully for ' ||

Line 1402: hr_dm_utility.message('SUMM','Generated TUPS/TDS successfully for ' ||

1398: hr_dm_utility.message('INFO','Generated TUPS/TDS succesfully for ' ||
1399: l_csr_get_table_rec.table_name || ', Table Id - ' ||
1400: l_csr_get_table_rec.table_id,110);
1401:
1402: hr_dm_utility.message('SUMM','Generated TUPS/TDS successfully for ' ||
1403: l_csr_get_table_rec.table_name || ', Table Id - ' ||
1404: l_csr_get_table_rec.table_id,120);
1405:
1406: end loop;

Line 1412: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.slave_generator',

1408: -- set up return values to concurrent manager
1409: retcode := 0;
1410: errbuf := 'No errors - examine logfiles for detailed reports.';
1411:
1412: hr_dm_utility.message('ROUT','exit:hr_dm_gen_main.slave_generator',
1413: 125);
1414: -- error handling
1415: exception
1416: when e_fatal_error then

Line 1422: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator',

1418: close csr_get_table;
1419: end if;
1420: retcode := 2;
1421: errbuf := 'An error occurred during the migration - examine logfiles for detailed reports.';
1422: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator',
1423: l_fatal_error_message,'R');
1424:
1425: -- if the error is caused because the other process has set the generator phase to 'Error'
1426: -- then the phase_item_id is 'NULL' , otherwise, the error is caused within this process

Line 1430: hr_dm_utility.update_phase_items(p_new_status => 'E',

1426: -- then the phase_item_id is 'NULL' , otherwise, the error is caused within this process
1427: -- while generating TUPS/TDS.
1428:
1429: if l_phase_item_id is not null then
1430: hr_dm_utility.update_phase_items(p_new_status => 'E',
1431: p_id => l_phase_item_id);
1432: else
1433: hr_dm_utility.update_phases(p_new_status => 'E',
1434: p_id => l_phase_id);

Line 1433: hr_dm_utility.update_phases(p_new_status => 'E',

1429: if l_phase_item_id is not null then
1430: hr_dm_utility.update_phase_items(p_new_status => 'E',
1431: p_id => l_phase_item_id);
1432: else
1433: hr_dm_utility.update_phases(p_new_status => 'E',
1434: p_id => l_phase_id);
1435: end if;
1436:
1437: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator','(none)','R');

Line 1437: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator','(none)','R');

1433: hr_dm_utility.update_phases(p_new_status => 'E',
1434: p_id => l_phase_id);
1435: end if;
1436:
1437: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator','(none)','R');
1438: when e_fatal_error2 then
1439: if csr_get_table%isopen then
1440: close csr_get_table;
1441: end if;

Line 1444: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator',

1440: close csr_get_table;
1441: end if;
1442: retcode := 0;
1443: errbuf := 'An error occurred during the migration - examine logfiles for detailed reports.';
1444: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator',
1445: l_fatal_error_message,'R');
1446:
1447: -- if the error is caused because the other process has set the generator phase to 'Error'
1448: -- then the phase_item_id is 'NULL' , otherwise, the error is caused within this process

Line 1452: hr_dm_utility.update_phase_items(p_new_status => 'E',

1448: -- then the phase_item_id is 'NULL' , otherwise, the error is caused within this process
1449: -- while generating TUPS/TDS.
1450:
1451: if l_phase_item_id is not null then
1452: hr_dm_utility.update_phase_items(p_new_status => 'E',
1453: p_id => l_phase_item_id);
1454: else
1455: hr_dm_utility.update_phases(p_new_status => 'E',
1456: p_id => l_phase_id);

Line 1455: hr_dm_utility.update_phases(p_new_status => 'E',

1451: if l_phase_item_id is not null then
1452: hr_dm_utility.update_phase_items(p_new_status => 'E',
1453: p_id => l_phase_item_id);
1454: else
1455: hr_dm_utility.update_phases(p_new_status => 'E',
1456: p_id => l_phase_id);
1457: end if;
1458:
1459: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator','(none)','R');

Line 1459: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator','(none)','R');

1455: hr_dm_utility.update_phases(p_new_status => 'E',
1456: p_id => l_phase_id);
1457: end if;
1458:
1459: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator','(none)','R');
1460: when others then
1461: if csr_get_table%isopen then
1462: close csr_get_table;
1463: end if;

Line 1467: hr_dm_utility.update_phase_items(p_new_status => 'E',

1463: end if;
1464: retcode := 2;
1465: errbuf := 'An error occurred during the migration - examine logfiles for detailed reports.';
1466: -- update status to error
1467: hr_dm_utility.update_phase_items(p_new_status => 'E',
1468: p_id => l_phase_item_id);
1469: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator','(none)','R');
1470:
1471:

Line 1469: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator','(none)','R');

1465: errbuf := 'An error occurred during the migration - examine logfiles for detailed reports.';
1466: -- update status to error
1467: hr_dm_utility.update_phase_items(p_new_status => 'E',
1468: p_id => l_phase_item_id);
1469: hr_dm_utility.error(SQLCODE,'hr_dm_gen_main.slave_generator','(none)','R');
1470:
1471:
1472: end slave_generator ;
1473: end hr_dm_gen_main;