DBA Data[Home] [Help]

APPS.EDW_OWB_COLLECTION_UTIL dependencies on EDW_OWB_COLLECTION_UTIL

Line 1: package BODY EDW_OWB_COLLECTION_UTIL AS

1: package BODY EDW_OWB_COLLECTION_UTIL AS
2: /*$Header: EDWCOLUB.pls 120.7 2007/08/20 10:27:45 karthmoh ship $*/
3:
4: l_mapping_id number;
5: l_mapping_name varchar2(200);

Line 1431: write_to_log_file_n('In EDW_OWB_COLLECTION_UTIL.insert_temp_log_table');

1427: p_number_ins_req_coll number) return boolean is
1428: l_stmt varchar2(10000);
1429: Begin
1430: if g_debug then
1431: write_to_log_file_n('In EDW_OWB_COLLECTION_UTIL.insert_temp_log_table');
1432: write_to_log_file('Object '||p_object_name||', object type '||p_object_type||' req '||p_concurrent_req_id);
1433: write_to_log_file('instance reqid ready processed collected dangling duplicate error number_ready '||
1434: 'number_insert number_update number_delete');
1435: for i in 1..p_number_ins_req_coll loop

Line 3215: write_to_log_file_n('In EDW_OWB_COLLECTION_UTIL.get_obj_obj_map_details');

3211: l_number_cols number;
3212: l_mapping_id number;
3213: Begin
3214: if g_debug then
3215: write_to_log_file_n('In EDW_OWB_COLLECTION_UTIL.get_obj_obj_map_details');
3216: write_to_log_file('p_src_object='||p_src_object||',p_tgt_object='||p_tgt_object||',p_map_name='||p_map_name);
3217: end if;
3218: p_number_cols:=0;
3219: l_mapping_id:=get_target_map(null,p_tgt_object);

Line 7181: p_skip_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,

7177: p_fact_dlog varchar2,
7178: p_key_set number,
7179: p_instance_type varchar2,
7180: p_load_pk number,
7181: p_skip_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,
7182: p_number_skip_cols number,
7183: p_fresh_restart boolean,
7184: p_op_table_space varchar2,
7185: p_da_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,

Line 7185: p_da_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,

7181: p_skip_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,
7182: p_number_skip_cols number,
7183: p_fresh_restart boolean,
7184: p_op_table_space varchar2,
7185: p_da_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,
7186: p_number_da_cols number,
7187: p_da_table varchar2,
7188: p_pp_table varchar2,
7189: p_master_instance varchar2,

Line 7191: p_skip_levels EDW_OWB_COLLECTION_UTIL.varcharTableType,

7187: p_da_table varchar2,
7188: p_pp_table varchar2,
7189: p_master_instance varchar2,
7190: p_rollback varchar2,
7191: p_skip_levels EDW_OWB_COLLECTION_UTIL.varcharTableType,
7192: p_number_skip_levels number,
7193: p_smart_update boolean,
7194: p_fk_use_nl number,
7195: p_fact_smart_update number,

Line 7199: p_smart_update_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,

7195: p_fact_smart_update number,
7196: p_auto_dang_table_extn varchar2,
7197: p_log_dang_keys boolean,
7198: p_create_parent_table_records boolean,
7199: p_smart_update_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,
7200: p_number_smart_update_cols number,
7201: p_check_fk_change boolean,
7202: p_stg_join_nl_percentage number,
7203: p_ok_switch_update number,

Line 7596: p_da_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,

7592:
7593: function create_da_load_input_table(
7594: p_da_cols_table varchar2,
7595: p_op_table_space varchar2,
7596: p_da_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,
7597: p_stg_da_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,
7598: p_number_da_cols number
7599: ) return boolean is
7600: Begin

Line 7597: p_stg_da_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,

7593: function create_da_load_input_table(
7594: p_da_cols_table varchar2,
7595: p_op_table_space varchar2,
7596: p_da_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,
7597: p_stg_da_cols EDW_OWB_COLLECTION_UTIL.varcharTableType,
7598: p_number_da_cols number
7599: ) return boolean is
7600: Begin
7601: if g_debug then

Line 7912: p_ok_low_end out NOCOPY EDW_OWB_COLLECTION_UTIL.numberTableType,

7908: p_ok_table varchar2,
7909: p_table_owner varchar2,
7910: p_max_threads number,
7911: p_min_job_load_size number,
7912: p_ok_low_end out NOCOPY EDW_OWB_COLLECTION_UTIL.numberTableType,
7913: p_ok_high_end out NOCOPY EDW_OWB_COLLECTION_UTIL.numberTableType,
7914: p_ok_end_count out NOCOPY integer
7915: ) return boolean is
7916: l_ok_size number;

Line 7913: p_ok_high_end out NOCOPY EDW_OWB_COLLECTION_UTIL.numberTableType,

7909: p_table_owner varchar2,
7910: p_max_threads number,
7911: p_min_job_load_size number,
7912: p_ok_low_end out NOCOPY EDW_OWB_COLLECTION_UTIL.numberTableType,
7913: p_ok_high_end out NOCOPY EDW_OWB_COLLECTION_UTIL.numberTableType,
7914: p_ok_end_count out NOCOPY integer
7915: ) return boolean is
7916: l_ok_size number;
7917: l_chunk_size integer;

Line 9003: l_ilog_tables EDW_OWB_COLLECTION_UTIL.varcharTableType;

8999: p_op_table_space varchar2,
9000: p_bis_owner varchar2,
9001: p_parallel number
9002: )return boolean is
9003: l_ilog_tables EDW_OWB_COLLECTION_UTIL.varcharTableType;
9004: l_number_ilog_tables number;
9005: Begin
9006: if g_debug then
9007: write_to_log_file_n('In merge_all_ilog_tables p_ilog_pattern '||p_ilog_pattern||

Line 9018: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog_table)=false then

9014: if l_number_ilog_tables>0 then --only if the prev run was multi threaded
9015: /*
9016: if these small ok tables exist, then g_ok_rowid_table cannot exist
9017: */
9018: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog_table)=false then
9019: null;
9020: end if;
9021: --just for safety
9022: if p_ilog_table2 is not null then

Line 9023: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog_table2)=false then

9019: null;
9020: end if;
9021: --just for safety
9022: if p_ilog_table2 is not null then
9023: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog_table2)=false then
9024: null;
9025: end if;
9026: end if;
9027: g_stmt:='create table '||p_ilog_table||' tablespace '||p_op_table_space;

Line 9076: l_ilog_tables EDW_OWB_COLLECTION_UTIL.varcharTableType;

9072: p_ilog_table varchar2,
9073: p_ilog_table_extn varchar2,
9074: p_bis_owner varchar2
9075: ) return boolean is
9076: l_ilog_tables EDW_OWB_COLLECTION_UTIL.varcharTableType;
9077: l_number_ilog_tables number;
9078: Begin
9079: if g_debug then
9080: write_to_log_file_n('In drop_ilog_tables');

Line 9104: p_ilog_tables out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,

9100: function get_ilog_tables_from_db(
9101: p_ilog_table varchar2,
9102: p_ilog_table_extn varchar2,
9103: p_bis_owner varchar2,
9104: p_ilog_tables out nocopy EDW_OWB_COLLECTION_UTIL.varcharTableType,
9105: p_number_ilog_tables out nocopy number
9106: )return boolean is
9107: TYPE CurTyp IS REF CURSOR;
9108: cv CurTyp;

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

9163: Begin
9164: if g_debug then
9165: write_to_log_file_n('In put_rownum_in_ilog_table p_ilog='||p_ilog||',p_ilog_old='||p_ilog_old);
9166: end if;
9167: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog)=false then
9168: null;
9169: end if;
9170: g_stmt:='create table '||p_ilog||' tablespace '||p_op_table_space;
9171: g_stmt:=g_stmt||' storage (initial 4M next 4M pctincrease 0) ';

Line 9184: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog_old)=false then

9180: if g_debug then
9181: write_to_log_file_n('Created with '||sql%rowcount||' rows '||get_time);
9182: end if;
9183: create_rownum_index_ilog(p_ilog,p_op_table_space,p_parallel);
9184: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog_old)=false then
9185: null;
9186: end if;
9187: EDW_OWB_COLLECTION_UTIL.analyze_table_stats(substr(p_ilog,instr(p_ilog,'.')+1,
9188: length(p_ilog)),substr(p_ilog,1,instr(p_ilog,'.')-1));

Line 9187: EDW_OWB_COLLECTION_UTIL.analyze_table_stats(substr(p_ilog,instr(p_ilog,'.')+1,

9183: create_rownum_index_ilog(p_ilog,p_op_table_space,p_parallel);
9184: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog_old)=false then
9185: null;
9186: end if;
9187: EDW_OWB_COLLECTION_UTIL.analyze_table_stats(substr(p_ilog,instr(p_ilog,'.')+1,
9188: length(p_ilog)),substr(p_ilog,1,instr(p_ilog,'.')-1));
9189: return true;
9190: Exception when others then
9191: g_status_message:=sqlerrm;

Line 10015: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog_rowid_table)=false then

10011: end loop;
10012: g_stmt:=substr(g_stmt,1,length(g_stmt)-1);
10013: g_stmt:=g_stmt||' from '||p_ilog_table||' where row_num between '||
10014: p_low_end||' and '||p_high_end;
10015: if EDW_OWB_COLLECTION_UTIL.drop_table(p_ilog_rowid_table)=false then
10016: null;
10017: end if;
10018: if g_debug then
10019: write_to_log_file_n(g_stmt||get_time);

Line 10026: EDW_OWB_COLLECTION_UTIL.analyze_table_stats(substr(p_ilog_rowid_table,instr(p_ilog_rowid_table,'.')+1,

10022: p_ilog_rowid_number:=sql%rowcount;
10023: if g_debug then
10024: write_to_log_file_n('Created with '||p_ilog_rowid_number||' rows '||get_time);
10025: end if;
10026: EDW_OWB_COLLECTION_UTIL.analyze_table_stats(substr(p_ilog_rowid_table,instr(p_ilog_rowid_table,'.')+1,
10027: length(p_ilog_rowid_table)),substr(p_ilog_rowid_table,1,instr(p_ilog_rowid_table,'.')-1));
10028: return true;
10029: Exception when others then
10030: g_status_message:=sqlerrm;

Line 10599: l_parameter EDW_OWB_COLLECTION_UTIL.varcharTableType;

10595: p_parameter_value_set varcharTableType,
10596: p_number_parameters number
10597: ) return boolean is
10598: l_bis_long_name varchar2(240);
10599: l_parameter EDW_OWB_COLLECTION_UTIL.varcharTableType;
10600: l_parameter_value_set EDW_OWB_COLLECTION_UTIL.varcharTableType;
10601: l_number_parameters number;
10602: Begin
10603: if g_debug then

Line 10600: l_parameter_value_set EDW_OWB_COLLECTION_UTIL.varcharTableType;

10596: p_number_parameters number
10597: ) return boolean is
10598: l_bis_long_name varchar2(240);
10599: l_parameter EDW_OWB_COLLECTION_UTIL.varcharTableType;
10600: l_parameter_value_set EDW_OWB_COLLECTION_UTIL.varcharTableType;
10601: l_number_parameters number;
10602: Begin
10603: if g_debug then
10604: write_to_log_file_n('In create_conc_program '||get_time);

Line 10613: g_status_message:=EDW_OWB_COLLECTION_UTIL.g_status_message;

10609: write_to_log_file(p_parameter(i)||' '||p_parameter_value_set(i));
10610: end loop;
10611: end if;
10612: if get_app_long_name(p_bis_short_name,l_bis_long_name)=false then
10613: g_status_message:=EDW_OWB_COLLECTION_UTIL.g_status_message;
10614: return false;
10615: end if;
10616: if delete_conc_program(p_conc_short_name,p_exe_name,l_bis_long_name,'LONG')=false then
10617: null;

Line 10956: if edw_owb_collection_util.terminate_job(p_job_id)=false then

10952: return true;
10953: end if;
10954: if query_table_cols(p_status_table,'status||''+++''||message',p_where,l_status,l_num_status)=false then
10955: --this means that the job did not start, kill the job
10956: if edw_owb_collection_util.terminate_job(p_job_id)=false then
10957: return false;
10958: end if;
10959: p_status:='NO JOB';
10960: return true;

Line 11469: END EDW_OWB_COLLECTION_UTIL;

11465: WHEN OTHERS THEN
11466: RETURN NULL;
11467: END get_apps_schema_name;
11468:
11469: END EDW_OWB_COLLECTION_UTIL;