DBA Data[Home] [Help]

APPS.EDW_DERIVED_FACT_FACT_COLLECT dependencies on DBMS_JOB

Line 60: g_dbms_job_id:=-1;

56: ) is
57: Begin
58: g_fact_name:=p_fact_name;
59: g_fact_id:=p_fact_id;
60: g_dbms_job_id:=-1;
61: g_ilog:=p_ilog;
62: g_dlog:=p_dlog;
63: g_log_file:=p_log_file;
64: g_pre_hook:=p_pre_hook;

Line 246: DBMS_JOB.SUBMIT(l_job_id(l_number_jobs),'EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT(''ILOG'','''||

242: l_try_serial:=true;
243: end if;
244: commit;--this commit is very imp
245: else
246: DBMS_JOB.SUBMIT(l_job_id(l_number_jobs),'EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT(''ILOG'','''||
247: g_fact_name||''','||''''||p_input_table||''','||l_number_jobs||','||l_log_low_end(j)||','||
248: l_log_high_end(j)||','''||l_ilog||''','''||l_dlog||''','''||g_log_file||''','''||g_thread_type||''');');
249: if g_debug then
250: write_to_log_file_n('Job '||l_job_id(l_number_jobs)||' launched '||get_time);

Line 364: DBMS_JOB.SUBMIT(l_job_id(l_number_jobs),'EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT(''DLOG'','''||

360: l_try_serial:=true;
361: end if;
362: commit;--this commit is very imp
363: else
364: DBMS_JOB.SUBMIT(l_job_id(l_number_jobs),'EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT(''DLOG'','''||
365: g_fact_name||''','||''''||p_input_table||''','||l_number_jobs||','||l_log_low_end(j)||','||
366: l_log_high_end(j)||','''||l_ilog||''','''||l_dlog||''','''||g_log_file||''','''||g_thread_type||''');');
367: if g_debug then
368: write_to_log_file_n('Job '||l_job_id(l_number_jobs)||' launched '||get_time);

Line 941: g_dbms_job_id:=-1;

937: end if;
938: g_src_join_nl_percentage:=p_src_join_nl_percentage;
939: g_pre_hook:=p_pre_hook;
940: g_post_hook:=p_post_hook;
941: g_dbms_job_id:=-1;
942: /*
943: g_load_mode is BU-DELETE when inc dim changes are propogated to derived/summary facts
944: */
945: write_to_log_file_n('In EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT'||get_time);

Line 4926: 'dbms_job_id '||

4922: 'src_object_dlog,'||
4923: 'src_snplog_has_pk,'||
4924: 'err_rec_flag,'||
4925: 'err_rec_flag_d,'||
4926: 'dbms_job_id '||
4927: ' from '||p_table;
4928: if g_debug then
4929: write_to_log_file_n(g_stmt);
4930: end if;

Line 4973: ,g_dbms_job_id;

4969: ,g_src_object_dlog
4970: ,l_src_snplog_has_pk
4971: ,l_err_rec_flag
4972: ,l_err_rec_flag_d
4973: ,g_dbms_job_id;
4974: close cv;
4975: if g_load_mode is null then
4976: g_load_mode:='NORMAL';
4977: end if;

Line 5020: write_to_log_file('g_dbms_job_id='||g_dbms_job_id);

5016: write_to_log_file('g_src_object_dlog='||g_src_object_dlog);
5017: write_to_log_file('l_src_snplog_has_pk='||l_src_snplog_has_pk);
5018: write_to_log_file('l_err_rec_flag='||l_err_rec_flag);
5019: write_to_log_file('l_err_rec_flag_d='||l_err_rec_flag_d);
5020: write_to_log_file('g_dbms_job_id='||g_dbms_job_id);
5021: --g_dbms_job_id can the id of a dbms job or conc process. depends on g_thread_type
5022: end if;
5023: g_debug:=false;
5024: g_full_refresh:=false;

Line 5021: --g_dbms_job_id can the id of a dbms job or conc process. depends on g_thread_type

5017: write_to_log_file('l_src_snplog_has_pk='||l_src_snplog_has_pk);
5018: write_to_log_file('l_err_rec_flag='||l_err_rec_flag);
5019: write_to_log_file('l_err_rec_flag_d='||l_err_rec_flag_d);
5020: write_to_log_file('g_dbms_job_id='||g_dbms_job_id);
5021: --g_dbms_job_id can the id of a dbms job or conc process. depends on g_thread_type
5022: end if;
5023: g_debug:=false;
5024: g_full_refresh:=false;
5025: g_fresh_restart:=false;

Line 5262: l_dbms_job_id number;

5258: l_stmt varchar2(2000);
5259: TYPE CurTyp IS REF CURSOR;
5260: cv CurTyp;
5261: l_conc_id number;
5262: l_dbms_job_id number;
5263: l_status varchar2(20);
5264: ----------------------------
5265: l_my_conc_id number;
5266: l_my_job_id number;

Line 5275: if g_dbms_job_id is null then

5271: end if;
5272: if g_conc_id is null then
5273: g_conc_id:=-1;
5274: end if;
5275: if g_dbms_job_id is null then
5276: g_dbms_job_id:=-1;
5277: end if;
5278: -------------------------------------------------------
5279: l_my_conc_id:=FND_GLOBAL.Conc_request_id;--my conc id

Line 5276: g_dbms_job_id:=-1;

5272: if g_conc_id is null then
5273: g_conc_id:=-1;
5274: end if;
5275: if g_dbms_job_id is null then
5276: g_dbms_job_id:=-1;
5277: end if;
5278: -------------------------------------------------------
5279: l_my_conc_id:=FND_GLOBAL.Conc_request_id;--my conc id
5280: if l_my_conc_id is null or l_my_conc_id<=0 then

Line 5282: l_my_job_id:=g_dbms_job_id;

5278: -------------------------------------------------------
5279: l_my_conc_id:=FND_GLOBAL.Conc_request_id;--my conc id
5280: if l_my_conc_id is null or l_my_conc_id<=0 then
5281: l_my_conc_id:=-1;
5282: l_my_job_id:=g_dbms_job_id;
5283: else
5284: l_my_job_id:=-1;
5285: end if;
5286: -------------------------------------------------------

Line 5288: ' as select nvl('||l_my_conc_id||',-1) conc_id, nvl('||l_my_job_id||',-1) dbms_job_id from dual';

5284: l_my_job_id:=-1;
5285: end if;
5286: -------------------------------------------------------
5287: g_stmt:='create table '||g_insert_lock_table||' tablespace '||g_op_table_space||
5288: ' as select nvl('||l_my_conc_id||',-1) conc_id, nvl('||l_my_job_id||',-1) dbms_job_id from dual';
5289: l_stmt:='select conc_id,dbms_job_id from '||g_insert_lock_table;
5290: if g_debug then
5291: write_to_log_file_n(g_stmt);
5292: end if;

Line 5289: l_stmt:='select conc_id,dbms_job_id from '||g_insert_lock_table;

5285: end if;
5286: -------------------------------------------------------
5287: g_stmt:='create table '||g_insert_lock_table||' tablespace '||g_op_table_space||
5288: ' as select nvl('||l_my_conc_id||',-1) conc_id, nvl('||l_my_job_id||',-1) dbms_job_id from dual';
5289: l_stmt:='select conc_id,dbms_job_id from '||g_insert_lock_table;
5290: if g_debug then
5291: write_to_log_file_n(g_stmt);
5292: end if;
5293: loop

Line 5313: fetch cv into l_conc_id,l_dbms_job_id;

5309: if g_debug then
5310: write_to_log_file_n(l_stmt);
5311: end if;
5312: open cv for l_stmt;
5313: fetch cv into l_conc_id,l_dbms_job_id;
5314: close cv;
5315: if g_debug then
5316: write_to_log_file(l_conc_id||' '||l_dbms_job_id);
5317: end if;

Line 5316: write_to_log_file(l_conc_id||' '||l_dbms_job_id);

5312: open cv for l_stmt;
5313: fetch cv into l_conc_id,l_dbms_job_id;
5314: close cv;
5315: if g_debug then
5316: write_to_log_file(l_conc_id||' '||l_dbms_job_id);
5317: end if;
5318: --for single threaded case, g_thread_type is null
5319: if l_dbms_job_id <> -1 then
5320: l_status:=EDW_OWB_COLLECTION_UTIL.check_job_status(l_dbms_job_id);

Line 5319: if l_dbms_job_id <> -1 then

5315: if g_debug then
5316: write_to_log_file(l_conc_id||' '||l_dbms_job_id);
5317: end if;
5318: --for single threaded case, g_thread_type is null
5319: if l_dbms_job_id <> -1 then
5320: l_status:=EDW_OWB_COLLECTION_UTIL.check_job_status(l_dbms_job_id);
5321: if l_status is null then
5322: return false;
5323: elsif l_status='N' then

Line 5320: l_status:=EDW_OWB_COLLECTION_UTIL.check_job_status(l_dbms_job_id);

5316: write_to_log_file(l_conc_id||' '||l_dbms_job_id);
5317: end if;
5318: --for single threaded case, g_thread_type is null
5319: if l_dbms_job_id <> -1 then
5320: l_status:=EDW_OWB_COLLECTION_UTIL.check_job_status(l_dbms_job_id);
5321: if l_status is null then
5322: return false;
5323: elsif l_status='N' then
5324: if EDW_OWB_COLLECTION_UTIL.drop_table(g_insert_lock_table)=false then