DBA Data[Home] [Help]

APPS.EDW_MAPPING_COLLECT dependencies on EDW_MAPPING_COLLECT

Line 1: package body EDW_MAPPING_COLLECT AS

1: package body EDW_MAPPING_COLLECT AS
2: /*$Header: EDWMAPFB.pls 120.1 2006/04/25 15:17:08 vsurendr noship $*/
3:
4: /*
5: This is the first point of entry called from edw_all_collect

Line 500: write_to_log_file_n('EDW_MAPPING_COLLECT.COLLECT('''||p_object_name||''','||

496: l_number_jobs:=l_number_jobs+1;
497: l_job_id(l_number_jobs):=null;
498: l_rownum_for_seq_num:=g_rownum_for_seq_num+l_ok_low_end(j);
499: if g_debug then
500: write_to_log_file_n('EDW_MAPPING_COLLECT.COLLECT('''||p_object_name||''','||
501: ''''||p_primary_target_name||''','''||l_input_table||''','||l_number_jobs||','||
502: l_ok_low_end(j)||','||l_ok_high_end(j)||','||l_rownum_for_seq_num||');');
503: end if;
504: begin

Line 525: DBMS_JOB.SUBMIT(l_job_id(l_number_jobs),'EDW_MAPPING_COLLECT.COLLECT('''||p_object_name||''','||

521: if l_job_id(l_number_jobs)<=0 then
522: l_try_serial:=true;
523: end if;
524: else
525: DBMS_JOB.SUBMIT(l_job_id(l_number_jobs),'EDW_MAPPING_COLLECT.COLLECT('''||p_object_name||''','||
526: ''''||p_primary_target_name||''','''||l_input_table||''','||l_number_jobs||','||
527: l_ok_low_end(j)||','||l_ok_high_end(j)||','||l_rownum_for_seq_num||');');
528: commit;--this commit is very imp
529: if g_debug then

Line 547: EDW_MAPPING_COLLECT.COLLECT(

543: if g_debug then
544: write_to_log_file_n('Attempt serial load');
545: end if;
546: l_job_id(l_number_jobs):=0-l_number_jobs;
547: EDW_MAPPING_COLLECT.COLLECT(
548: l_errbuf,
549: l_retcode,
550: p_object_name,
551: p_primary_target_name,

Line 2964: write_to_log_file_n('EDW_MAPPING_COLLECT.execute_duplicate_stmt_multi('''||

2960: for i in 1..l_ok_end_count loop
2961: l_number_jobs:=l_number_jobs+1;
2962: l_status_table(l_number_jobs):=l_dup_hold_table||'_'||l_number_jobs||'_STS';
2963: if g_debug then
2964: write_to_log_file_n('EDW_MAPPING_COLLECT.execute_duplicate_stmt_multi('''||
2965: g_object_name||''','||''''||g_primary_target_name||''','''||g_fstgTableName||''','||l_number_jobs||','||
2966: l_ok_low_end(i)||','||l_ok_high_end(i)||','''||l_dup_hold_table||''','''||l_debug||''','''||
2967: g_bis_owner||''','''||g_op_table_space||''','||l_parallel||','''||l_duplicate_collect||''','''||
2968: g_update_type||''','''||l_low_system_mem||''','''||l_rollback||''','''||l_status_table(l_number_jobs)||''');');

Line 3000: DBMS_JOB.SUBMIT(l_job_id(l_number_jobs),'EDW_MAPPING_COLLECT.execute_duplicate_stmt_multi('''||

2996: if l_job_id(l_number_jobs)<=0 then
2997: l_try_serial:=true;
2998: end if;
2999: else
3000: DBMS_JOB.SUBMIT(l_job_id(l_number_jobs),'EDW_MAPPING_COLLECT.execute_duplicate_stmt_multi('''||
3001: g_object_name||''','||''''||g_primary_target_name||''','''||g_fstgTableName||''','||l_number_jobs||','||
3002: l_ok_low_end(i)||','||l_ok_high_end(i)||','''||l_dup_hold_table||''','''||l_debug||''','''||
3003: g_bis_owner||''','''||g_op_table_space||''','||l_parallel||','''||l_duplicate_collect||''','''||
3004: g_update_type||''','''||l_low_system_mem||''','''||l_rollback||''','''||l_status_table(l_number_jobs)||''');');

Line 3024: EDW_MAPPING_COLLECT.execute_duplicate_stmt_multi(

3020: if g_debug then
3021: write_to_log_file_n('Attempt serial load');
3022: end if;
3023: l_job_id(l_number_jobs):=0-l_number_jobs;
3024: EDW_MAPPING_COLLECT.execute_duplicate_stmt_multi(
3025: l_errbuf,
3026: l_retcode,
3027: g_object_name,
3028: g_primary_target_name,

Line 4185: write_to_log_file_n('EDW_MAPPING_COLLECT.execute_dangling_collected('||

4181: else
4182: l_version_GT_1159:='N';
4183: end if;
4184: if g_debug then
4185: write_to_log_file_n('EDW_MAPPING_COLLECT.execute_dangling_collected('||
4186: ''||g_primary_target||','||
4187: ''''||g_primary_target_name||''','||
4188: ''''||g_fstgTableName||''','||
4189: ''''||g_fstgPKName||''','||

Line 4214: DBMS_JOB.SUBMIT(p_job_id,'EDW_MAPPING_COLLECT.execute_dangling_collected('||

4210: ''''||nvl(g_rollback,'null')||''','||
4211: ''''||l_version_GT_1159||''','||
4212: ''''||p_table||''');');
4213: end if;
4214: DBMS_JOB.SUBMIT(p_job_id,'EDW_MAPPING_COLLECT.execute_dangling_collected('||
4215: ''||g_primary_target||','||
4216: ''''||g_primary_target_name||''','||
4217: ''''||g_fstgTableName||''','||
4218: ''''||g_fstgPKName||''','||

Line 9265: write_to_log_file('EDW_MAPPING_COLLECT.analyze_target_tables('||

9261: end if;
9262: if l_use_job then
9263: if g_debug then
9264: write_to_log_file_n('Going to launch dbms job for analyze '||get_time);
9265: write_to_log_file('EDW_MAPPING_COLLECT.analyze_target_tables('||
9266: ''||g_load_pk||','||
9267: ''''||g_table_owner||''','||
9268: ''''||g_primary_target_name||''','||
9269: ''||g_primary_target||','||

Line 9278: DBMS_JOB.SUBMIT(l_job_id,'EDW_MAPPING_COLLECT.analyze_target_tables('||

9274: ''||nvl(g_number_da_cols,0)||','||
9275: ''''||nvl(g_da_table,'null')||''','||
9276: ''''||nvl(g_pp_table,'null')||''');');
9277: end if;
9278: DBMS_JOB.SUBMIT(l_job_id,'EDW_MAPPING_COLLECT.analyze_target_tables('||
9279: ''||g_load_pk||','||
9280: ''''||g_table_owner||''','||
9281: ''''||g_primary_target_name||''','||
9282: ''||g_primary_target||','||

Line 13543: l_exe_file_name:='EDW_MAPPING_COLLECT.COLLECT';

13539: l_parameter EDW_OWB_COLLECTION_UTIL.varcharTableType;
13540: l_parameter_value_set EDW_OWB_COLLECTION_UTIL.varcharTableType;
13541: l_number_parameters number;
13542: Begin
13543: l_exe_file_name:='EDW_MAPPING_COLLECT.COLLECT';
13544: l_parameter(1):='p_object_name';
13545: l_parameter_value_set(1):='FND_CHAR240';
13546: l_parameter(2):='p_target_name';
13547: l_parameter_value_set(2):='FND_CHAR240';

Line 13589: l_exe_file_name:=upper('EDW_MAPPING_COLLECT.execute_duplicate_stmt_multi');

13585: l_parameter EDW_OWB_COLLECTION_UTIL.varcharTableType;
13586: l_parameter_value_set EDW_OWB_COLLECTION_UTIL.varcharTableType;
13587: l_number_parameters number;
13588: Begin
13589: l_exe_file_name:=upper('EDW_MAPPING_COLLECT.execute_duplicate_stmt_multi');
13590: l_parameter(1):='p_object_name';
13591: l_parameter_value_set(1):='FND_CHAR240';
13592: l_parameter(2):='p_primary_target_name';
13593: l_parameter_value_set(2):='FND_CHAR240';

Line 13967: write_to_log_file_n('EDW_MAPPING_COLLECT.drill_parent_to_children('||

13963: g_ltc_drill_down_job_id:=null;
13964: --for the lowest level, we dont want to launch a job
13965: if g_job_queue_processes>0 and g_temp_log=false then --this is not the lowest level
13966: if g_debug then
13967: write_to_log_file_n('EDW_MAPPING_COLLECT.drill_parent_to_children('||
13968: ''''||g_primary_target_name||''','||
13969: ''||g_primary_target||','||
13970: ''''||g_dd_status_table||''','||
13971: ''''||g_ul_table||''','||

Line 13986: DBMS_JOB.SUBMIT(g_ltc_drill_down_job_id,'EDW_MAPPING_COLLECT.drill_parent_to_children('||

13982: ''||g_load_pk||','||
13983: ''||nvl(edw_owb_collection_util.g_conc_program_id,0)||','||
13984: '1);');
13985: end if;
13986: DBMS_JOB.SUBMIT(g_ltc_drill_down_job_id,'EDW_MAPPING_COLLECT.drill_parent_to_children('||
13987: ''''||g_primary_target_name||''','||
13988: ''||g_primary_target||','||
13989: ''''||g_dd_status_table||''','||
13990: ''''||g_ul_table||''','||

Line 14686: END EDW_MAPPING_COLLECT;

14682: write_to_log_file_n('Error in merge_pci_snplog '||g_status_message);
14683: return false;
14684: End;
14685:
14686: END EDW_MAPPING_COLLECT;