eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.EDW_DERIVED_FACT_COLLECT dependencies on EDW_OWB_COLLECTION_UTIL

Line 26: p_skip_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,

22: p_dlog varchar2,
23: p_forall_size number,
24: p_update_type varchar2,
25: p_fact_dlog varchar2,
26: p_skip_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,
27: p_number_skip_cols number,
28: p_load_fk number,
29: p_fresh_restart boolean,
30: p_op_table_space varchar2,

Line 31: p_bu_tables EDW_OWB_COLLECTION_UTIL.varcharTableType,--before update tables.prop dim change to derv

27: p_number_skip_cols number,
28: p_load_fk number,
29: p_fresh_restart boolean,
30: p_op_table_space varchar2,
31: p_bu_tables EDW_OWB_COLLECTION_UTIL.varcharTableType,--before update tables.prop dim change to derv
32: p_bu_dimensions EDW_OWB_COLLECTION_UTIL.varcharTableType,
33: p_number_bu_tables number,
34: p_bu_src_fact varchar2,--what table to look at as the src fact. if null, scan the actual src fact
35: p_load_mode varchar2,

Line 32: p_bu_dimensions EDW_OWB_COLLECTION_UTIL.varcharTableType,

28: p_load_fk number,
29: p_fresh_restart boolean,
30: p_op_table_space varchar2,
31: p_bu_tables EDW_OWB_COLLECTION_UTIL.varcharTableType,--before update tables.prop dim change to derv
32: p_bu_dimensions EDW_OWB_COLLECTION_UTIL.varcharTableType,
33: p_number_bu_tables number,
34: p_bu_src_fact varchar2,--what table to look at as the src fact. if null, scan the actual src fact
35: p_load_mode varchar2,
36: p_rollback varchar2,

Line 164: p_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType,

160: */
161: FUNCTION COLLECT_FACT_INC(
162: p_src_fact_name varchar2,
163: p_src_fact_id number,
164: p_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType,
165: p_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType,
166: p_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType,
167: p_number_derived_facts number,
168: p_conc_id in number,

Line 165: p_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType,

161: FUNCTION COLLECT_FACT_INC(
162: p_src_fact_name varchar2,
163: p_src_fact_id number,
164: p_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType,
165: p_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType,
166: p_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType,
167: p_number_derived_facts number,
168: p_conc_id in number,
169: p_conc_program_name in varchar2,

Line 166: p_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType,

162: p_src_fact_name varchar2,
163: p_src_fact_id number,
164: p_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType,
165: p_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType,
166: p_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType,
167: p_number_derived_facts number,
168: p_conc_id in number,
169: p_conc_program_name in varchar2,
170: p_debug boolean,

Line 175: p_load_pk out nocopy EDW_OWB_COLLECTION_UTIL.numberTableType,

171: p_collection_size number,
172: p_parallel number,
173: p_bis_owner varchar2,
174: p_table_owner varchar2,--src fact owner
175: p_load_pk out nocopy EDW_OWB_COLLECTION_UTIL.numberTableType,
176: p_ins_rows_processed out NOCOPY EDW_OWB_COLLECTION_UTIL.numberTableType,
177: p_status out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,
178: p_message out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,
179: p_number_derv_facts out nocopy number,

Line 176: p_ins_rows_processed out NOCOPY EDW_OWB_COLLECTION_UTIL.numberTableType,

172: p_parallel number,
173: p_bis_owner varchar2,
174: p_table_owner varchar2,--src fact owner
175: p_load_pk out nocopy EDW_OWB_COLLECTION_UTIL.numberTableType,
176: p_ins_rows_processed out NOCOPY EDW_OWB_COLLECTION_UTIL.numberTableType,
177: p_status out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,
178: p_message out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,
179: p_number_derv_facts out nocopy number,
180: p_forall_size number,

Line 177: p_status out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,

173: p_bis_owner varchar2,
174: p_table_owner varchar2,--src fact owner
175: p_load_pk out nocopy EDW_OWB_COLLECTION_UTIL.numberTableType,
176: p_ins_rows_processed out NOCOPY EDW_OWB_COLLECTION_UTIL.numberTableType,
177: p_status out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,
178: p_message out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,
179: p_number_derv_facts out nocopy number,
180: p_forall_size number,
181: p_update_type varchar2,

Line 178: p_message out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,

174: p_table_owner varchar2,--src fact owner
175: p_load_pk out nocopy EDW_OWB_COLLECTION_UTIL.numberTableType,
176: p_ins_rows_processed out NOCOPY EDW_OWB_COLLECTION_UTIL.numberTableType,
177: p_status out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,
178: p_message out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,
179: p_number_derv_facts out nocopy number,
180: p_forall_size number,
181: p_update_type varchar2,
182: p_fact_dlog varchar2,

Line 185: p_bu_tables EDW_OWB_COLLECTION_UTIL.varcharTableType,--before update tables.prop dim change to derv

181: p_update_type varchar2,
182: p_fact_dlog varchar2,
183: p_fresh_restart boolean,
184: p_op_table_space varchar2,
185: p_bu_tables EDW_OWB_COLLECTION_UTIL.varcharTableType,--before update tables.prop dim change to derv
186: p_bu_dimensions EDW_OWB_COLLECTION_UTIL.varcharTableType,
187: p_number_bu_tables number,
188: p_bu_src_fact varchar2,--what table to look at as the src fact. if null, scan the actual src fact
189: p_load_mode varchar2,

Line 186: p_bu_dimensions EDW_OWB_COLLECTION_UTIL.varcharTableType,

182: p_fact_dlog varchar2,
183: p_fresh_restart boolean,
184: p_op_table_space varchar2,
185: p_bu_tables EDW_OWB_COLLECTION_UTIL.varcharTableType,--before update tables.prop dim change to derv
186: p_bu_dimensions EDW_OWB_COLLECTION_UTIL.varcharTableType,
187: p_number_bu_tables number,
188: p_bu_src_fact varchar2,--what table to look at as the src fact. if null, scan the actual src fact
189: p_load_mode varchar2,
190: p_rollback varchar2,

Line 202: ll_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType;

198: p_trace boolean,
199: p_read_cfig_options boolean,
200: p_job_queue_processes number
201: )return boolean is
202: ll_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType;
203: ll_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
204: ll_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
205: ll_number_derived_facts number;
206: l_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType;

Line 203: ll_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType;

199: p_read_cfig_options boolean,
200: p_job_queue_processes number
201: )return boolean is
202: ll_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType;
203: ll_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
204: ll_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
205: ll_number_derived_facts number;
206: l_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType;
207: l_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType;

Line 204: ll_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType;

200: p_job_queue_processes number
201: )return boolean is
202: ll_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType;
203: ll_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
204: ll_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
205: ll_number_derived_facts number;
206: l_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType;
207: l_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
208: l_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType;

Line 206: l_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType;

202: ll_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType;
203: ll_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
204: ll_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
205: ll_number_derived_facts number;
206: l_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType;
207: l_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
208: l_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
209: l_number_derived_facts number;
210: i integer;

Line 207: l_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType;

203: ll_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
204: ll_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
205: ll_number_derived_facts number;
206: l_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType;
207: l_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
208: l_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
209: l_number_derived_facts number;
210: i integer;
211: l_end integer;

Line 208: l_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType;

204: ll_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
205: ll_number_derived_facts number;
206: l_derived_facts EDW_OWB_COLLECTION_UTIL.varcharTableType;
207: l_derived_fact_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
208: l_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
209: l_number_derived_facts number;
210: i integer;
211: l_end integer;
212: l_job_id EDW_OWB_COLLECTION_UTIL.numberTableType;

Line 212: l_job_id EDW_OWB_COLLECTION_UTIL.numberTableType;

208: l_map_ids EDW_OWB_COLLECTION_UTIL.numberTableType;
209: l_number_derived_facts number;
210: i integer;
211: l_end integer;
212: l_job_id EDW_OWB_COLLECTION_UTIL.numberTableType;
213: l_job_status EDW_OWB_COLLECTION_UTIL.varcharTableType;
214: l_count number;
215: l_diff number;
216: l_pre_hook varchar2(10);

Line 213: l_job_status EDW_OWB_COLLECTION_UTIL.varcharTableType;

209: l_number_derived_facts number;
210: i integer;
211: l_end integer;
212: l_job_id EDW_OWB_COLLECTION_UTIL.numberTableType;
213: l_job_status EDW_OWB_COLLECTION_UTIL.varcharTableType;
214: l_count number;
215: l_diff number;
216: l_pre_hook varchar2(10);
217: l_post_hook varchar2(10);

Line 218: l_skip_cols EDW_OWB_COLLECTION_UTIL.varcharTableType;

214: l_count number;
215: l_diff number;
216: l_pre_hook varchar2(10);
217: l_post_hook varchar2(10);
218: l_skip_cols EDW_OWB_COLLECTION_UTIL.varcharTableType;
219: l_number_skip_cols number;
220: l_found boolean;
221: l_job_status_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
222: l_input_table EDW_OWB_COLLECTION_UTIL.varcharTableType;

Line 221: l_job_status_table EDW_OWB_COLLECTION_UTIL.varcharTableType;

217: l_post_hook varchar2(10);
218: l_skip_cols EDW_OWB_COLLECTION_UTIL.varcharTableType;
219: l_number_skip_cols number;
220: l_found boolean;
221: l_job_status_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
222: l_input_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
223: l_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType;
224: l_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType;
225: l_start_date date;

Line 222: l_input_table EDW_OWB_COLLECTION_UTIL.varcharTableType;

218: l_skip_cols EDW_OWB_COLLECTION_UTIL.varcharTableType;
219: l_number_skip_cols number;
220: l_found boolean;
221: l_job_status_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
222: l_input_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
223: l_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType;
224: l_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType;
225: l_start_date date;
226: l_end_date date;

Line 223: l_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType;

219: l_number_skip_cols number;
220: l_found boolean;
221: l_job_status_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
222: l_input_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
223: l_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType;
224: l_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType;
225: l_start_date date;
226: l_end_date date;
227: l_looked_at EDW_OWB_COLLECTION_UTIL.numberTableType;

Line 224: l_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType;

220: l_found boolean;
221: l_job_status_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
222: l_input_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
223: l_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType;
224: l_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType;
225: l_start_date date;
226: l_end_date date;
227: l_looked_at EDW_OWB_COLLECTION_UTIL.numberTableType;
228: l_number_looked_at number;

Line 227: l_looked_at EDW_OWB_COLLECTION_UTIL.numberTableType;

223: l_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType;
224: l_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType;
225: l_start_date date;
226: l_end_date date;
227: l_looked_at EDW_OWB_COLLECTION_UTIL.numberTableType;
228: l_number_looked_at number;
229: l_bool_flag boolean;
230: l_log_file varchar2(200);
231: l_number_jobs number;

Line 269: if EDW_OWB_COLLECTION_UTIL.get_all_derived_facts(

265: l_bis_short_name:='BIS';
266: l_parallel_flag:='N';
267: --is derv facts are specified, use them. else use
268: if p_number_derived_facts=0 or p_number_derived_facts is null then
269: if EDW_OWB_COLLECTION_UTIL.get_all_derived_facts(
270: p_src_fact_name,
271: ll_derived_facts,
272: ll_derived_fact_ids,
273: ll_map_ids,--the map id of the derived fact and this source fact

Line 275: g_status_message:=EDW_OWB_COLLECTION_UTIL.g_status_message;

271: ll_derived_facts,
272: ll_derived_fact_ids,
273: ll_map_ids,--the map id of the derived fact and this source fact
274: ll_number_derived_facts)=false then
275: g_status_message:=EDW_OWB_COLLECTION_UTIL.g_status_message;
276: return false;
277: end if;
278: l_number_derived_facts:=0;
279: for i in 1..ll_number_derived_facts loop

Line 280: if EDW_OWB_COLLECTION_UTIL.is_inc_refresh_implemented(ll_derived_facts(i))=true then

276: return false;
277: end if;
278: l_number_derived_facts:=0;
279: for i in 1..ll_number_derived_facts loop
280: if EDW_OWB_COLLECTION_UTIL.is_inc_refresh_implemented(ll_derived_facts(i))=true then
281: l_number_derived_facts:=l_number_derived_facts+1;
282: l_derived_facts(l_number_derived_facts):=ll_derived_facts(i);
283: l_derived_fact_ids(l_number_derived_facts):=ll_derived_fact_ids(i);
284: l_map_ids(l_number_derived_facts):=ll_map_ids(i);

Line 368: p_load_pk(i):=EDW_OWB_COLLECTION_UTIL.inc_g_load_pk ;

364: g_number_fact_fks:=0;
365: if get_fact_fks = false then --get all the fks of the derived fact
366: return false;
367: end if;
368: p_load_pk(i):=EDW_OWB_COLLECTION_UTIL.inc_g_load_pk ;
369: if p_load_pk(i) is null then
370: return false;
371: end if;
372: l_number_skip_cols:=0;

Line 373: if EDW_OWB_COLLECTION_UTIL.find_skip_attributes(l_derived_facts(i),'DERIVED FACT',l_skip_cols,

369: if p_load_pk(i) is null then
370: return false;
371: end if;
372: l_number_skip_cols:=0;
373: if EDW_OWB_COLLECTION_UTIL.find_skip_attributes(l_derived_facts(i),'DERIVED FACT',l_skip_cols,
374: l_number_skip_cols)=false then
375: return false;
376: end if;
377: l_start_date:=sysdate;

Line 378: if EDW_OWB_COLLECTION_UTIL.log_collection_start(l_derived_facts(i),l_derived_fact_ids(i),

374: l_number_skip_cols)=false then
375: return false;
376: end if;
377: l_start_date:=sysdate;
378: if EDW_OWB_COLLECTION_UTIL.log_collection_start(l_derived_facts(i),l_derived_fact_ids(i),
379: 'FACT',l_start_date,p_conc_id,p_load_pk(i))=false then
380: return false;
381: end if;
382: p_ins_rows_processed(i):=0;

Line 385: l_ilog(i):=edw_owb_collection_util.get_fact_dfact_ilog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));

381: end if;
382: p_ins_rows_processed(i):=0;
383: --l_ilog(i):=g_bis_owner||'.I_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
384: --l_dlog(i):=g_bis_owner||'.D_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
385: l_ilog(i):=edw_owb_collection_util.get_fact_dfact_ilog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));
386: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));
387: l_input_table(i):=g_bis_owner||'.INP_TAB_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
388: l_log_file:='LOG_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
389: l_job_status_table(i):=g_bis_owner||'.JOB_STATUS_'||p_src_fact_id||'_'||l_derived_fact_ids(i);

Line 386: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));

382: p_ins_rows_processed(i):=0;
383: --l_ilog(i):=g_bis_owner||'.I_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
384: --l_dlog(i):=g_bis_owner||'.D_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
385: l_ilog(i):=edw_owb_collection_util.get_fact_dfact_ilog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));
386: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));
387: l_input_table(i):=g_bis_owner||'.INP_TAB_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
388: l_log_file:='LOG_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
389: l_job_status_table(i):=g_bis_owner||'.JOB_STATUS_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
390: if EDW_OWB_COLLECTION_UTIL.create_derv_fact_inp_table(

Line 390: if EDW_OWB_COLLECTION_UTIL.create_derv_fact_inp_table(

386: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));
387: l_input_table(i):=g_bis_owner||'.INP_TAB_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
388: l_log_file:='LOG_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
389: l_job_status_table(i):=g_bis_owner||'.JOB_STATUS_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
390: if EDW_OWB_COLLECTION_UTIL.create_derv_fact_inp_table(
391: l_derived_facts(i),
392: l_input_table(i),
393: l_derived_fact_ids(i),
394: l_map_ids(i),

Line 456: if EDW_OWB_COLLECTION_UTIL.update_inp_table_jobid(l_input_table(i),-1)=false then

452: l_pre_hook||''','''||l_post_hook||''','''||g_thread_type||''');');
453: end if;
454: l_flag:=true;
455: l_job_status(i):='R';
456: if EDW_OWB_COLLECTION_UTIL.update_inp_table_jobid(l_input_table(i),-1)=false then
457: return false;
458: end if;
459: l_job_id(i):=FND_REQUEST.SUBMIT_REQUEST(
460: application=>l_bis_short_name,

Line 471: if EDW_OWB_COLLECTION_UTIL.update_inp_table_concid(l_input_table(i),l_job_id(i))=false then

467: argument6=>l_dlog(i),
468: argument7=>l_pre_hook,
469: argument8=>l_post_hook,
470: argument9=>g_thread_type);
471: if EDW_OWB_COLLECTION_UTIL.update_inp_table_concid(l_input_table(i),l_job_id(i))=false then
472: return false;
473: end if;
474: if l_job_id(i)<=0 then
475: l_try_serial:=true;

Line 496: if EDW_OWB_COLLECTION_UTIL.update_inp_table_jobid(l_input_table(i),l_job_id(i))=false then

492: end if;
493: /*
494: update the inp table for the job id
495: */
496: if EDW_OWB_COLLECTION_UTIL.update_inp_table_jobid(l_input_table(i),l_job_id(i))=false then
497: return false;
498: end if;
499: if l_job_id(i)<=0 then
500: l_try_serial:=true;

Line 515: if EDW_OWB_COLLECTION_UTIL.update_inp_table_jobid(l_input_table(i),l_job_id(i))=false then

511: if g_debug then
512: write_to_log_file_n('Attempt serial load');
513: end if;
514: l_job_id(i):=0-i;--this is just a temp setting. There is really no job. we need this for log_collection_detail
515: if EDW_OWB_COLLECTION_UTIL.update_inp_table_jobid(l_input_table(i),l_job_id(i))=false then
516: return false;
517: end if;
518: commit;
519: l_job_status(i):='R';

Line 570: if l_job_status(j)<>'R' and EDW_OWB_COLLECTION_UTIL.value_in_table(l_looked_at,l_number_looked_at,

566: g_thread_type)=false then
567: return false;
568: end if;
569: for j in 1..l_number_jobs loop
570: if l_job_status(j)<>'R' and EDW_OWB_COLLECTION_UTIL.value_in_table(l_looked_at,l_number_looked_at,
571: l_job_id(j))=false then
572: if get_temp_log_data(g_fact_name,'FACT',p_load_pk(j),p_ins_rows_processed(j))=false then
573: null;
574: end if;

Line 625: if EDW_OWB_COLLECTION_UTIL.delete_conc_program(

621: end loop;
622: --dont delete the conc pgm. we may need the conc request log file
623: /*if g_thread_type='CONC' then
624: --drop the conc programs
625: if EDW_OWB_COLLECTION_UTIL.delete_conc_program(
626: l_temp_conc_short_name,
627: l_temp_exe_name,
628: l_bis_short_name,
629: 'SHORT')=false then

Line 644: p_load_pk(i):=EDW_OWB_COLLECTION_UTIL.inc_g_load_pk ;

640: g_src_object_ids(g_number_mapping_ids):=p_src_fact_id;
641: if get_fact_fks = false then --get all the fks of the derived fact
642: return false;
643: end if;
644: p_load_pk(i):=EDW_OWB_COLLECTION_UTIL.inc_g_load_pk ;
645: if p_load_pk(i) is null then
646: return false;
647: end if;
648: if EDW_OWB_COLLECTION_UTIL.find_skip_attributes(l_derived_facts(i),'DERIVED FACT',l_skip_cols,

Line 648: if EDW_OWB_COLLECTION_UTIL.find_skip_attributes(l_derived_facts(i),'DERIVED FACT',l_skip_cols,

644: p_load_pk(i):=EDW_OWB_COLLECTION_UTIL.inc_g_load_pk ;
645: if p_load_pk(i) is null then
646: return false;
647: end if;
648: if EDW_OWB_COLLECTION_UTIL.find_skip_attributes(l_derived_facts(i),'DERIVED FACT',l_skip_cols,
649: l_number_skip_cols)=false then
650: return false;
651: end if;
652: if EDW_OWB_COLLECTION_UTIL.log_collection_start(l_derived_facts(i),l_derived_fact_ids(i),

Line 652: if EDW_OWB_COLLECTION_UTIL.log_collection_start(l_derived_facts(i),l_derived_fact_ids(i),

648: if EDW_OWB_COLLECTION_UTIL.find_skip_attributes(l_derived_facts(i),'DERIVED FACT',l_skip_cols,
649: l_number_skip_cols)=false then
650: return false;
651: end if;
652: if EDW_OWB_COLLECTION_UTIL.log_collection_start(l_derived_facts(i),l_derived_fact_ids(i),
653: 'FACT',sysdate,p_conc_id,p_load_pk(i))=false then
654: return false;
655: end if;
656: p_ins_rows_processed(i):=0;

Line 660: l_ilog(i):=edw_owb_collection_util.get_fact_dfact_ilog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));

656: p_ins_rows_processed(i):=0;
657: l_start_date:=sysdate;
658: --l_ilog(i):=g_bis_owner||'.I_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
659: --l_dlog(i):=g_bis_owner||'.D_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
660: l_ilog(i):=edw_owb_collection_util.get_fact_dfact_ilog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));
661: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));
662: l_bool_flag:=EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT(
663: g_fact_name,
664: g_fact_id,

Line 661: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));

657: l_start_date:=sysdate;
658: --l_ilog(i):=g_bis_owner||'.I_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
659: --l_dlog(i):=g_bis_owner||'.D_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
660: l_ilog(i):=edw_owb_collection_util.get_fact_dfact_ilog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));
661: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));
662: l_bool_flag:=EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT(
663: g_fact_name,
664: g_fact_id,
665: g_mapping_ids(g_number_mapping_ids),

Line 789: p_skip_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,

785: p_table_owner varchar2,
786: p_ins_rows_processed out NOCOPY number,
787: p_forall_size number,
788: p_update_type varchar2,
789: p_skip_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,
790: p_number_skip_cols number,
791: p_load_fk number,
792: p_fresh_restart boolean,
793: p_op_table_space varchar2,

Line 806: l_bu_tables EDW_OWB_COLLECTION_UTIL.varcharTableType;

802: p_trace boolean,
803: p_read_cfig_options boolean
804: ) return boolean is
805: l_ins_rows_processed number;
806: l_bu_tables EDW_OWB_COLLECTION_UTIL.varcharTableType;
807: l_bu_dimensions EDW_OWB_COLLECTION_UTIL.varcharTableType;
808: l_number_bu_tables number:=0;
809: l_bu_src_fact varchar2(400):=null;
810: l_load_mode varchar2(400);

Line 807: l_bu_dimensions EDW_OWB_COLLECTION_UTIL.varcharTableType;

803: p_read_cfig_options boolean
804: ) return boolean is
805: l_ins_rows_processed number;
806: l_bu_tables EDW_OWB_COLLECTION_UTIL.varcharTableType;
807: l_bu_dimensions EDW_OWB_COLLECTION_UTIL.varcharTableType;
808: l_number_bu_tables number:=0;
809: l_bu_src_fact varchar2(400):=null;
810: l_load_mode varchar2(400);
811: l_input_table EDW_OWB_COLLECTION_UTIL.varcharTableType;

Line 811: l_input_table EDW_OWB_COLLECTION_UTIL.varcharTableType;

807: l_bu_dimensions EDW_OWB_COLLECTION_UTIL.varcharTableType;
808: l_number_bu_tables number:=0;
809: l_bu_src_fact varchar2(400):=null;
810: l_load_mode varchar2(400);
811: l_input_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
812: l_job_id EDW_OWB_COLLECTION_UTIL.numberTableType;
813: l_job_status EDW_OWB_COLLECTION_UTIL.varcharTableType;
814: l_number_jobs number;
815: l_count number;

Line 812: l_job_id EDW_OWB_COLLECTION_UTIL.numberTableType;

808: l_number_bu_tables number:=0;
809: l_bu_src_fact varchar2(400):=null;
810: l_load_mode varchar2(400);
811: l_input_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
812: l_job_id EDW_OWB_COLLECTION_UTIL.numberTableType;
813: l_job_status EDW_OWB_COLLECTION_UTIL.varcharTableType;
814: l_number_jobs number;
815: l_count number;
816: l_diff number;

Line 813: l_job_status EDW_OWB_COLLECTION_UTIL.varcharTableType;

809: l_bu_src_fact varchar2(400):=null;
810: l_load_mode varchar2(400);
811: l_input_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
812: l_job_id EDW_OWB_COLLECTION_UTIL.numberTableType;
813: l_job_status EDW_OWB_COLLECTION_UTIL.varcharTableType;
814: l_number_jobs number;
815: l_count number;
816: l_diff number;
817: i integer;

Line 823: l_job_status_table EDW_OWB_COLLECTION_UTIL.varcharTableType;

819: l_found boolean;
820: l_log_file varchar2(200);
821: l_pre_hook varchar2(10);
822: l_post_hook varchar2(10);
823: l_job_status_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
824: l_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType;
825: l_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType;
826: l_start_date date;
827: l_end_date date;

Line 824: l_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType;

820: l_log_file varchar2(200);
821: l_pre_hook varchar2(10);
822: l_post_hook varchar2(10);
823: l_job_status_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
824: l_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType;
825: l_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType;
826: l_start_date date;
827: l_end_date date;
828: l_status EDW_OWB_COLLECTION_UTIL.varcharTableType;

Line 825: l_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType;

821: l_pre_hook varchar2(10);
822: l_post_hook varchar2(10);
823: l_job_status_table EDW_OWB_COLLECTION_UTIL.varcharTableType;
824: l_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType;
825: l_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType;
826: l_start_date date;
827: l_end_date date;
828: l_status EDW_OWB_COLLECTION_UTIL.varcharTableType;
829: l_message EDW_OWB_COLLECTION_UTIL.varcharTableType;

Line 828: l_status EDW_OWB_COLLECTION_UTIL.varcharTableType;

824: l_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType;
825: l_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType;
826: l_start_date date;
827: l_end_date date;
828: l_status EDW_OWB_COLLECTION_UTIL.varcharTableType;
829: l_message EDW_OWB_COLLECTION_UTIL.varcharTableType;
830: -----------------------------------------
831: l_temp_conc_name varchar2(200);
832: l_temp_conc_short_name varchar2(200);

Line 829: l_message EDW_OWB_COLLECTION_UTIL.varcharTableType;

825: l_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType;
826: l_start_date date;
827: l_end_date date;
828: l_status EDW_OWB_COLLECTION_UTIL.varcharTableType;
829: l_message EDW_OWB_COLLECTION_UTIL.varcharTableType;
830: -----------------------------------------
831: l_temp_conc_name varchar2(200);
832: l_temp_conc_short_name varchar2(200);
833: l_temp_exe_name varchar2(200);

Line 933: l_ilog(i):=edw_owb_collection_util.get_fact_dfact_ilog(g_bis_owner,g_fact_id,g_src_object_ids(i));

929: end if;
930: l_ins_rows_processed:=0;
931: --l_ilog(i):=g_bis_owner||'.I_'||g_fact_id||'_'||g_src_object_ids(i);
932: --l_dlog(i):=g_bis_owner||'.D_'||g_fact_id||'_'||g_src_object_ids(i);
933: l_ilog(i):=edw_owb_collection_util.get_fact_dfact_ilog(g_bis_owner,g_fact_id,g_src_object_ids(i));
934: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,g_fact_id,g_src_object_ids(i));
935: l_input_table(i):=g_bis_owner||'.INP_TAB_'||g_fact_id||'_'||g_src_object_ids(i);
936: l_log_file:='LOG_'||g_fact_id||'_'||g_src_object_ids(i);
937: l_job_status_table(i):=g_bis_owner||'.JOB_STATUS_'||g_fact_id||'_'||g_src_object_ids(i);

Line 934: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,g_fact_id,g_src_object_ids(i));

930: l_ins_rows_processed:=0;
931: --l_ilog(i):=g_bis_owner||'.I_'||g_fact_id||'_'||g_src_object_ids(i);
932: --l_dlog(i):=g_bis_owner||'.D_'||g_fact_id||'_'||g_src_object_ids(i);
933: l_ilog(i):=edw_owb_collection_util.get_fact_dfact_ilog(g_bis_owner,g_fact_id,g_src_object_ids(i));
934: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,g_fact_id,g_src_object_ids(i));
935: l_input_table(i):=g_bis_owner||'.INP_TAB_'||g_fact_id||'_'||g_src_object_ids(i);
936: l_log_file:='LOG_'||g_fact_id||'_'||g_src_object_ids(i);
937: l_job_status_table(i):=g_bis_owner||'.JOB_STATUS_'||g_fact_id||'_'||g_src_object_ids(i);
938: if EDW_OWB_COLLECTION_UTIL.create_derv_fact_inp_table(

Line 938: if EDW_OWB_COLLECTION_UTIL.create_derv_fact_inp_table(

934: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,g_fact_id,g_src_object_ids(i));
935: l_input_table(i):=g_bis_owner||'.INP_TAB_'||g_fact_id||'_'||g_src_object_ids(i);
936: l_log_file:='LOG_'||g_fact_id||'_'||g_src_object_ids(i);
937: l_job_status_table(i):=g_bis_owner||'.JOB_STATUS_'||g_fact_id||'_'||g_src_object_ids(i);
938: if EDW_OWB_COLLECTION_UTIL.create_derv_fact_inp_table(
939: g_fact_name,
940: l_input_table(i),
941: g_fact_id,
942: g_mapping_ids(i),

Line 1017: if EDW_OWB_COLLECTION_UTIL.update_inp_table_jobid(l_input_table(i),l_job_id(l_number_jobs))=false then

1013: if g_debug then
1014: write_to_log_file_n('Concurrent Request '||l_job_id(l_number_jobs)||' launched for '||g_fact_name||' and '||
1015: g_src_objects(i)||get_time);
1016: end if;
1017: if EDW_OWB_COLLECTION_UTIL.update_inp_table_jobid(l_input_table(i),l_job_id(l_number_jobs))=false then
1018: return false;
1019: end if;
1020: if l_job_id(l_number_jobs)<=0 then
1021: l_try_serial:=true;

Line 1034: if EDW_OWB_COLLECTION_UTIL.update_inp_table_jobid(l_input_table(i),l_job_id(l_number_jobs))=false then

1030: if g_debug then
1031: write_to_log_file_n('Job '||l_job_id(l_number_jobs)||' launched for '||g_fact_name||' and '||
1032: g_src_objects(i)||get_time);
1033: end if;
1034: if EDW_OWB_COLLECTION_UTIL.update_inp_table_jobid(l_input_table(i),l_job_id(l_number_jobs))=false then
1035: return false;
1036: end if;
1037: if l_job_id(l_number_jobs)<=0 then
1038: l_try_serial:=true;

Line 1054: if EDW_OWB_COLLECTION_UTIL.update_inp_table_jobid(l_input_table(i),l_job_id(l_number_jobs))=false then

1050: if g_debug then
1051: write_to_log_file_n('Attempt serial load');
1052: end if;
1053: l_job_id(l_number_jobs):=0-i;--give negative ids
1054: if EDW_OWB_COLLECTION_UTIL.update_inp_table_jobid(l_input_table(i),l_job_id(l_number_jobs))=false then
1055: return false;
1056: end if;
1057: commit;--commit only after updating the inp table
1058: EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD(

Line 1125: l_ilog(i):=edw_owb_collection_util.get_fact_dfact_ilog(g_bis_owner,g_fact_id,g_src_object_ids(i));

1121: --call the detailed fact to fact collection
1122: l_ins_rows_processed:=0;
1123: --l_ilog(i):=g_bis_owner||'.I_'||g_fact_id||'_'||g_src_object_ids(i);
1124: --l_dlog(i):=g_bis_owner||'.D_'||g_fact_id||'_'||g_src_object_ids(i);
1125: l_ilog(i):=edw_owb_collection_util.get_fact_dfact_ilog(g_bis_owner,g_fact_id,g_src_object_ids(i));
1126: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,g_fact_id,g_src_object_ids(i));
1127: if g_debug then
1128: write_to_log_file_n('Going to collect mapping: id='||g_mapping_ids(i)||', src='||g_src_objects(i));
1129: end if;

Line 1126: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,g_fact_id,g_src_object_ids(i));

1122: l_ins_rows_processed:=0;
1123: --l_ilog(i):=g_bis_owner||'.I_'||g_fact_id||'_'||g_src_object_ids(i);
1124: --l_dlog(i):=g_bis_owner||'.D_'||g_fact_id||'_'||g_src_object_ids(i);
1125: l_ilog(i):=edw_owb_collection_util.get_fact_dfact_ilog(g_bis_owner,g_fact_id,g_src_object_ids(i));
1126: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,g_fact_id,g_src_object_ids(i));
1127: if g_debug then
1128: write_to_log_file_n('Going to collect mapping: id='||g_mapping_ids(i)||', src='||g_src_objects(i));
1129: end if;
1130: -- the last true is for yes to full refresh

Line 1186: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_ilog(

1182: end if;
1183: p_ins_rows_processed:=g_ins_rows_processed;
1184: --drop the ilog and dlog table
1185: for i in 1..g_number_mapping_ids loop
1186: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_ilog(
1187: g_bis_owner,g_fact_id,g_src_object_ids(i)))= false then
1188: null;
1189: end if;
1190: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_ilog(

Line 1190: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_ilog(

1186: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_ilog(
1187: g_bis_owner,g_fact_id,g_src_object_ids(i)))= false then
1188: null;
1189: end if;
1190: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_ilog(
1191: g_bis_owner,g_fact_id,g_src_object_ids(i))||'A') = false then
1192: null;
1193: end if;
1194: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_dlog(

Line 1194: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_dlog(

1190: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_ilog(
1191: g_bis_owner,g_fact_id,g_src_object_ids(i))||'A') = false then
1192: null;
1193: end if;
1194: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_dlog(
1195: g_bis_owner,g_fact_id,g_src_object_ids(i))) = false then
1196: null;
1197: end if;
1198: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_dlog(

Line 1198: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_dlog(

1194: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_dlog(
1195: g_bis_owner,g_fact_id,g_src_object_ids(i))) = false then
1196: null;
1197: end if;
1198: if EDW_OWB_COLLECTION_UTIL.drop_table(edw_owb_collection_util.get_fact_dfact_dlog(
1199: g_bis_owner,g_fact_id,g_src_object_ids(i))||'A') = false then
1200: null;
1201: end if;
1202: end loop;

Line 1226: l_snplog:=EDW_OWB_COLLECTION_UTIL.get_table_snapshot_log(g_fact_name);

1222: write_to_log_file_n('Going to execute '||l_stmt);
1223: end if;
1224: execute immediate l_stmt;
1225: --truncate any snapshot log also
1226: l_snplog:=EDW_OWB_COLLECTION_UTIL.get_table_snapshot_log(g_fact_name);
1227: if l_snplog is not null then
1228: l_stmt:='truncate table '||g_table_owner||'.'||l_snplog;
1229: if g_debug then
1230: write_to_log_file_n('Going to execute '||l_stmt);

Line 1272: l_fk_cons EDW_OWB_COLLECTION_UTIL.varcharTableType;

1268: function get_fact_fks return boolean is
1269: TYPE CurTyp IS REF CURSOR;
1270: cv CurTyp;
1271: l_stmt varchar2(10000);
1272: l_fk_cons EDW_OWB_COLLECTION_UTIL.varcharTableType;
1273: l_in_stmt varchar2(10000);
1274: l_lvl_name EDW_OWB_COLLECTION_UTIL.varcharTableType;
1275: l_lvl_prefix EDW_OWB_COLLECTION_UTIL.varcharTableType;
1276: l_lvl_dim EDW_OWB_COLLECTION_UTIL.varcharTableType;

Line 1274: l_lvl_name EDW_OWB_COLLECTION_UTIL.varcharTableType;

1270: cv CurTyp;
1271: l_stmt varchar2(10000);
1272: l_fk_cons EDW_OWB_COLLECTION_UTIL.varcharTableType;
1273: l_in_stmt varchar2(10000);
1274: l_lvl_name EDW_OWB_COLLECTION_UTIL.varcharTableType;
1275: l_lvl_prefix EDW_OWB_COLLECTION_UTIL.varcharTableType;
1276: l_lvl_dim EDW_OWB_COLLECTION_UTIL.varcharTableType;
1277: l_number_lvl number;
1278: l_prefix varchar2(100);

Line 1275: l_lvl_prefix EDW_OWB_COLLECTION_UTIL.varcharTableType;

1271: l_stmt varchar2(10000);
1272: l_fk_cons EDW_OWB_COLLECTION_UTIL.varcharTableType;
1273: l_in_stmt varchar2(10000);
1274: l_lvl_name EDW_OWB_COLLECTION_UTIL.varcharTableType;
1275: l_lvl_prefix EDW_OWB_COLLECTION_UTIL.varcharTableType;
1276: l_lvl_dim EDW_OWB_COLLECTION_UTIL.varcharTableType;
1277: l_number_lvl number;
1278: l_prefix varchar2(100);
1279: l_dim_fk EDW_OWB_COLLECTION_UTIL.varcharTableType;

Line 1276: l_lvl_dim EDW_OWB_COLLECTION_UTIL.varcharTableType;

1272: l_fk_cons EDW_OWB_COLLECTION_UTIL.varcharTableType;
1273: l_in_stmt varchar2(10000);
1274: l_lvl_name EDW_OWB_COLLECTION_UTIL.varcharTableType;
1275: l_lvl_prefix EDW_OWB_COLLECTION_UTIL.varcharTableType;
1276: l_lvl_dim EDW_OWB_COLLECTION_UTIL.varcharTableType;
1277: l_number_lvl number;
1278: l_prefix varchar2(100);
1279: l_dim_fk EDW_OWB_COLLECTION_UTIL.varcharTableType;
1280: l_prefix_fk EDW_OWB_COLLECTION_UTIL.varcharTableType;

Line 1279: l_dim_fk EDW_OWB_COLLECTION_UTIL.varcharTableType;

1275: l_lvl_prefix EDW_OWB_COLLECTION_UTIL.varcharTableType;
1276: l_lvl_dim EDW_OWB_COLLECTION_UTIL.varcharTableType;
1277: l_number_lvl number;
1278: l_prefix varchar2(100);
1279: l_dim_fk EDW_OWB_COLLECTION_UTIL.varcharTableType;
1280: l_prefix_fk EDW_OWB_COLLECTION_UTIL.varcharTableType;
1281: l_number_dim_fk number;
1282: begin
1283: if g_debug then

Line 1280: l_prefix_fk EDW_OWB_COLLECTION_UTIL.varcharTableType;

1276: l_lvl_dim EDW_OWB_COLLECTION_UTIL.varcharTableType;
1277: l_number_lvl number;
1278: l_prefix varchar2(100);
1279: l_dim_fk EDW_OWB_COLLECTION_UTIL.varcharTableType;
1280: l_prefix_fk EDW_OWB_COLLECTION_UTIL.varcharTableType;
1281: l_number_dim_fk number;
1282: begin
1283: if g_debug then
1284: write_to_log_file_n('Entered get_fact_fks');

Line 1406: g_level_pk(i):=EDW_OWB_COLLECTION_UTIL.get_user_key(l_dim_fk(j));

1402: end if;
1403: for j in 1..l_number_dim_fk loop
1404: if g_level_prefix(i)=l_prefix_fk(j) then
1405: g_level_pk_key(i):=l_dim_fk(j);
1406: g_level_pk(i):=EDW_OWB_COLLECTION_UTIL.get_user_key(l_dim_fk(j));
1407: if g_level_pk(i) is null then
1408: g_level_pk(i):=g_level_pk_key(i);
1409: g_level_pk_key(i):=g_level_pk(i)||'_KEY';
1410: end if;

Line 1502: EDW_OWB_COLLECTION_UTIL.write_to_log_file(p_message);

1498: End;
1499:
1500: procedure write_to_log_file(p_message varchar2) is
1501: begin
1502: EDW_OWB_COLLECTION_UTIL.write_to_log_file(p_message);
1503: Exception when others then
1504: null;
1505: End;
1506:

Line 1516: p_job_id EDW_OWB_COLLECTION_UTIL.numberTableType,

1512: null;
1513: End;
1514:
1515: function wait_on_jobs(
1516: p_job_id EDW_OWB_COLLECTION_UTIL.numberTableType,
1517: p_job_status in out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,
1518: p_number_jobs number,
1519: p_sleep_time number,
1520: p_mode varchar2

Line 1517: p_job_status in out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,

1513: End;
1514:
1515: function wait_on_jobs(
1516: p_job_id EDW_OWB_COLLECTION_UTIL.numberTableType,
1517: p_job_status in out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,
1518: p_number_jobs number,
1519: p_sleep_time number,
1520: p_mode varchar2
1521: ) return boolean is

Line 1540: l_status:=EDW_OWB_COLLECTION_UTIL.check_job_status(p_job_id(i));

1536: for i in 1..p_number_jobs loop
1537: if p_job_status(i)='R' then
1538: --the two api must be able to handle -ve p_job_id
1539: if p_mode='JOB' then
1540: l_status:=EDW_OWB_COLLECTION_UTIL.check_job_status(p_job_id(i));
1541: elsif p_mode='CONC' then
1542: l_status:=EDW_OWB_COLLECTION_UTIL.check_conc_process_status(p_job_id(i));
1543: end if;
1544: if l_status is null then

Line 1542: l_status:=EDW_OWB_COLLECTION_UTIL.check_conc_process_status(p_job_id(i));

1538: --the two api must be able to handle -ve p_job_id
1539: if p_mode='JOB' then
1540: l_status:=EDW_OWB_COLLECTION_UTIL.check_job_status(p_job_id(i));
1541: elsif p_mode='CONC' then
1542: l_status:=EDW_OWB_COLLECTION_UTIL.check_conc_process_status(p_job_id(i));
1543: end if;
1544: if l_status is null then
1545: return false;
1546: elsif l_status='N' then

Line 1593: if EDW_OWB_COLLECTION_UTIL.write_to_collection_log(

1589: p_status varchar2,
1590: p_load_pk number
1591: ) return boolean is
1592: Begin
1593: if EDW_OWB_COLLECTION_UTIL.write_to_collection_log(
1594: p_object_name,
1595: p_object_id,
1596: p_object_type,
1597: p_conc_program_id,

Line 1635: if EDW_OWB_COLLECTION_UTIL.get_temp_log_data(

1631: l_ins_rows_delete number;
1632: l_ins_instance_name varchar2(80);
1633: l_ins_request_id_table varchar2(80);
1634: Begin
1635: if EDW_OWB_COLLECTION_UTIL.get_temp_log_data(
1636: p_object_name,
1637: p_object_type,
1638: p_load_pk,
1639: l_rows_ready,

Line 1663: l_id EDW_OWB_COLLECTION_UTIL.numberTableType;

1659: p_job_status_table varchar2,
1660: p_status out nocopy varchar2,
1661: p_message out nocopy varchar2
1662: ) return boolean is
1663: l_id EDW_OWB_COLLECTION_UTIL.numberTableType;
1664: l_job_id EDW_OWB_COLLECTION_UTIL.numberTableType;
1665: l_status EDW_OWB_COLLECTION_UTIL.varcharTableType;
1666: l_message EDW_OWB_COLLECTION_UTIL.varcharTableType;
1667: l_number_jobs number;

Line 1664: l_job_id EDW_OWB_COLLECTION_UTIL.numberTableType;

1660: p_status out nocopy varchar2,
1661: p_message out nocopy varchar2
1662: ) return boolean is
1663: l_id EDW_OWB_COLLECTION_UTIL.numberTableType;
1664: l_job_id EDW_OWB_COLLECTION_UTIL.numberTableType;
1665: l_status EDW_OWB_COLLECTION_UTIL.varcharTableType;
1666: l_message EDW_OWB_COLLECTION_UTIL.varcharTableType;
1667: l_number_jobs number;
1668: Begin

Line 1665: l_status EDW_OWB_COLLECTION_UTIL.varcharTableType;

1661: p_message out nocopy varchar2
1662: ) return boolean is
1663: l_id EDW_OWB_COLLECTION_UTIL.numberTableType;
1664: l_job_id EDW_OWB_COLLECTION_UTIL.numberTableType;
1665: l_status EDW_OWB_COLLECTION_UTIL.varcharTableType;
1666: l_message EDW_OWB_COLLECTION_UTIL.varcharTableType;
1667: l_number_jobs number;
1668: Begin
1669: if EDW_OWB_COLLECTION_UTIL.get_child_job_status(

Line 1666: l_message EDW_OWB_COLLECTION_UTIL.varcharTableType;

1662: ) return boolean is
1663: l_id EDW_OWB_COLLECTION_UTIL.numberTableType;
1664: l_job_id EDW_OWB_COLLECTION_UTIL.numberTableType;
1665: l_status EDW_OWB_COLLECTION_UTIL.varcharTableType;
1666: l_message EDW_OWB_COLLECTION_UTIL.varcharTableType;
1667: l_number_jobs number;
1668: Begin
1669: if EDW_OWB_COLLECTION_UTIL.get_child_job_status(
1670: p_job_status_table,

Line 1669: if EDW_OWB_COLLECTION_UTIL.get_child_job_status(

1665: l_status EDW_OWB_COLLECTION_UTIL.varcharTableType;
1666: l_message EDW_OWB_COLLECTION_UTIL.varcharTableType;
1667: l_number_jobs number;
1668: Begin
1669: if EDW_OWB_COLLECTION_UTIL.get_child_job_status(
1670: p_job_status_table,
1671: null,
1672: l_id,
1673: l_job_id,

Line 1699: p_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType,

1695: p_src_fact varchar2,
1696: p_table_owner varchar2,
1697: p_bis_owner varchar2,
1698: p_fact_dlog varchar2,
1699: p_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType,
1700: p_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType,
1701: p_number_derv_fact number
1702: )return boolean is
1703: l_snp_log varchar2(400);

Line 1700: p_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType,

1696: p_table_owner varchar2,
1697: p_bis_owner varchar2,
1698: p_fact_dlog varchar2,
1699: p_ilog EDW_OWB_COLLECTION_UTIL.varcharTableType,
1700: p_dlog EDW_OWB_COLLECTION_UTIL.varcharTableType,
1701: p_number_derv_fact number
1702: )return boolean is
1703: l_snp_log varchar2(400);
1704: l_mv_fast_refresh number;

Line 1713: l_mv_fast_refresh:=edw_owb_collection_util.is_source_for_fast_refresh_mv(p_src_fact,p_table_owner);

1709: /*3529591
1710: before we truncate the mv log of the base fact, we need to check to see
1711: if this is a src for a fast refresh mv.
1712: */
1713: l_mv_fast_refresh:=edw_owb_collection_util.is_source_for_fast_refresh_mv(p_src_fact,p_table_owner);
1714: if l_mv_fast_refresh is null or l_mv_fast_refresh<>1 then
1715: l_snp_log:=EDW_OWB_COLLECTION_UTIL.get_table_snapshot_log(p_src_fact);
1716: if g_debug then
1717: write_to_log_file_n('l_snp_log is '||l_snp_log);

Line 1715: l_snp_log:=EDW_OWB_COLLECTION_UTIL.get_table_snapshot_log(p_src_fact);

1711: if this is a src for a fast refresh mv.
1712: */
1713: l_mv_fast_refresh:=edw_owb_collection_util.is_source_for_fast_refresh_mv(p_src_fact,p_table_owner);
1714: if l_mv_fast_refresh is null or l_mv_fast_refresh<>1 then
1715: l_snp_log:=EDW_OWB_COLLECTION_UTIL.get_table_snapshot_log(p_src_fact);
1716: if g_debug then
1717: write_to_log_file_n('l_snp_log is '||l_snp_log);
1718: end if;
1719: if l_snp_log is not null then

Line 1720: if EDW_OWB_COLLECTION_UTIL.truncate_table(l_snp_log,p_table_owner) = false then

1716: if g_debug then
1717: write_to_log_file_n('l_snp_log is '||l_snp_log);
1718: end if;
1719: if l_snp_log is not null then
1720: if EDW_OWB_COLLECTION_UTIL.truncate_table(l_snp_log,p_table_owner) = false then
1721: return false;
1722: end if;
1723: end if;
1724: if p_fact_dlog is not null then

Line 1726: if EDW_OWB_COLLECTION_UTIL.drop_table(p_fact_dlog)=false then

1722: end if;
1723: end if;
1724: if p_fact_dlog is not null then
1725: if instr(p_fact_dlog,p_bis_owner||'.') <> 0 then
1726: if EDW_OWB_COLLECTION_UTIL.drop_table(p_fact_dlog)=false then
1727: return false;
1728: end if;
1729: else
1730: if EDW_OWB_COLLECTION_UTIL.truncate_table(p_fact_dlog,p_table_owner)=false then

Line 1730: if EDW_OWB_COLLECTION_UTIL.truncate_table(p_fact_dlog,p_table_owner)=false then

1726: if EDW_OWB_COLLECTION_UTIL.drop_table(p_fact_dlog)=false then
1727: return false;
1728: end if;
1729: else
1730: if EDW_OWB_COLLECTION_UTIL.truncate_table(p_fact_dlog,p_table_owner)=false then
1731: return false;
1732: end if;
1733: end if;
1734: end if;

Line 1737: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog(i))=false then

1733: end if;
1734: end if;
1735: --drop the ilog and dlog tables
1736: for i in 1..p_number_derv_fact loop
1737: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog(i))=false then
1738: null;
1739: end if;
1740: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog(i)||'A')=false then
1741: null;

Line 1740: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog(i)||'A')=false then

1736: for i in 1..p_number_derv_fact loop
1737: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog(i))=false then
1738: null;
1739: end if;
1740: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog(i)||'A')=false then
1741: null;
1742: end if;
1743: if EDW_OWB_COLLECTION_UTIL.drop_ilog_tables(p_ilog(i)||'_IL',null,p_bis_owner)=false then
1744: return false;

Line 1743: if EDW_OWB_COLLECTION_UTIL.drop_ilog_tables(p_ilog(i)||'_IL',null,p_bis_owner)=false then

1739: end if;
1740: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog(i)||'A')=false then
1741: null;
1742: end if;
1743: if EDW_OWB_COLLECTION_UTIL.drop_ilog_tables(p_ilog(i)||'_IL',null,p_bis_owner)=false then
1744: return false;
1745: end if;
1746: if EDW_OWB_COLLECTION_UTIL.drop_table(p_dlog(i))=false then
1747: null;

Line 1746: if EDW_OWB_COLLECTION_UTIL.drop_table(p_dlog(i))=false then

1742: end if;
1743: if EDW_OWB_COLLECTION_UTIL.drop_ilog_tables(p_ilog(i)||'_IL',null,p_bis_owner)=false then
1744: return false;
1745: end if;
1746: if EDW_OWB_COLLECTION_UTIL.drop_table(p_dlog(i))=false then
1747: null;
1748: end if;
1749: if EDW_OWB_COLLECTION_UTIL.drop_table(p_dlog(i)||'A')=false then
1750: null;

Line 1749: if EDW_OWB_COLLECTION_UTIL.drop_table(p_dlog(i)||'A')=false then

1745: end if;
1746: if EDW_OWB_COLLECTION_UTIL.drop_table(p_dlog(i))=false then
1747: null;
1748: end if;
1749: if EDW_OWB_COLLECTION_UTIL.drop_table(p_dlog(i)||'A')=false then
1750: null;
1751: end if;
1752: if EDW_OWB_COLLECTION_UTIL.drop_ilog_tables(p_dlog(i)||'_DL',null,p_bis_owner)=false then
1753: return false;

Line 1752: if EDW_OWB_COLLECTION_UTIL.drop_ilog_tables(p_dlog(i)||'_DL',null,p_bis_owner)=false then

1748: end if;
1749: if EDW_OWB_COLLECTION_UTIL.drop_table(p_dlog(i)||'A')=false then
1750: null;
1751: end if;
1752: if EDW_OWB_COLLECTION_UTIL.drop_ilog_tables(p_dlog(i)||'_DL',null,p_bis_owner)=false then
1753: return false;
1754: end if;
1755: end loop;
1756: end if;--if l_mv_fast_refresh is null or l_mv_fast_refresh<>1 then

Line 1769: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table)=false then

1765: p_input_table varchar2,
1766: p_job_status_table varchar2
1767: )return boolean is
1768: Begin
1769: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table)=false then
1770: null;
1771: end if;
1772: if EDW_OWB_COLLECTION_UTIL.drop_table(p_job_status_table)=false then
1773: null;

Line 1772: if EDW_OWB_COLLECTION_UTIL.drop_table(p_job_status_table)=false then

1768: Begin
1769: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table)=false then
1770: null;
1771: end if;
1772: if EDW_OWB_COLLECTION_UTIL.drop_table(p_job_status_table)=false then
1773: null;
1774: end if;
1775: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table||'_FK')=false then
1776: null;

Line 1775: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table||'_FK')=false then

1771: end if;
1772: if EDW_OWB_COLLECTION_UTIL.drop_table(p_job_status_table)=false then
1773: null;
1774: end if;
1775: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table||'_FK')=false then
1776: null;
1777: end if;
1778: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table||'_SK')=false then
1779: null;

Line 1778: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table||'_SK')=false then

1774: end if;
1775: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table||'_FK')=false then
1776: null;
1777: end if;
1778: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table||'_SK')=false then
1779: null;
1780: end if;
1781: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table||'_BU')=false then
1782: null;

Line 1781: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table||'_BU')=false then

1777: end if;
1778: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table||'_SK')=false then
1779: null;
1780: end if;
1781: if EDW_OWB_COLLECTION_UTIL.drop_table(p_input_table||'_BU')=false then
1782: null;
1783: end if;
1784: return true;
1785: Exception when others then

Line 1798: l_parameter EDW_OWB_COLLECTION_UTIL.varcharTableType;

1794: p_temp_exe_name varchar2,
1795: p_bis_short_name varchar2
1796: ) return boolean is
1797: l_bis_long_name varchar2(240);
1798: l_parameter EDW_OWB_COLLECTION_UTIL.varcharTableType;
1799: l_parameter_value_set EDW_OWB_COLLECTION_UTIL.varcharTableType;
1800: l_number_parameters number;
1801: Begin
1802: if g_debug then

Line 1799: l_parameter_value_set EDW_OWB_COLLECTION_UTIL.varcharTableType;

1795: p_bis_short_name varchar2
1796: ) return boolean is
1797: l_bis_long_name varchar2(240);
1798: l_parameter EDW_OWB_COLLECTION_UTIL.varcharTableType;
1799: l_parameter_value_set EDW_OWB_COLLECTION_UTIL.varcharTableType;
1800: l_number_parameters number;
1801: Begin
1802: if g_debug then
1803: write_to_log_file_n('In create_conc_program '||get_time);

Line 1824: if EDW_OWB_COLLECTION_UTIL.create_conc_program(

1820: l_parameter_value_set(8):='FND_CHAR240';
1821: l_parameter(9):='p_thread_type';
1822: l_parameter_value_set(9):='FND_CHAR240';
1823: l_number_parameters:=9;
1824: if EDW_OWB_COLLECTION_UTIL.create_conc_program(
1825: p_temp_conc_name,
1826: p_temp_conc_short_name,
1827: p_temp_exe_name,
1828: 'EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD',