49:
50:
51: -- zia: changed retcode to 0, since 1 means warning
52: --p_retcode := 1 ;
53: p_retcode := 0; /* Should be changed to proper constants from msd_dem_common_utilities */
54:
55: Exception
56: when others then
57: p_dblink := null ;
54:
55: Exception
56: when others then
57: p_dblink := null ;
58: p_retcode := -1 ; /* Should be changed to proper constants from msd_dem_common_utilities */
59:
60:
61: End get_db_link ;
62:
96: and mdeq.entity_name = p_entity_name;
97:
98: begin
99:
100: msd_dem_common_utilities.log_debug('In procedure: get_query');
101: get_db_link(p_instance_id, v_srdblink, retcode);
102:
103: /*msd_dem_common_utilities.log_message();*/
104: msd_dem_common_utilities.log_debug('The instance dblink for this query will be: '|| v_srdblink );
99:
100: msd_dem_common_utilities.log_debug('In procedure: get_query');
101: get_db_link(p_instance_id, v_srdblink, retcode);
102:
103: /*msd_dem_common_utilities.log_message();*/
104: msd_dem_common_utilities.log_debug('The instance dblink for this query will be: '|| v_srdblink );
105:
106:
107: open c_get_part1_query;
100: msd_dem_common_utilities.log_debug('In procedure: get_query');
101: get_db_link(p_instance_id, v_srdblink, retcode);
102:
103: /*msd_dem_common_utilities.log_message();*/
104: msd_dem_common_utilities.log_debug('The instance dblink for this query will be: '|| v_srdblink );
105:
106:
107: open c_get_part1_query;
108: fetch c_get_part1_query into l_part1_query;
121: l_final_query := replace(l_final_query, 'C_ADD_WHERE_CLAUSE', nvl(p_add_where_clause, ' 1 = 1 '));
122:
123: l_final_query := replace(l_final_query, 'DBLINK', v_srdblink);
124:
125: /*msd_dem_common_utilities.log_debug('The final query is: ' || l_final_query ); */
126:
127: query := l_final_query;
128:
129: exception
127: query := l_final_query;
128:
129: exception
130: when others then
131: msd_dem_common_utilities.log_message(substr(SQLERRM,1,150));
132: msd_dem_common_utilities.log_debug(substr(SQLERRM,1,150));
133: retcode := -1;
134:
135: end get_query;
128:
129: exception
130: when others then
131: msd_dem_common_utilities.log_message(substr(SQLERRM,1,150));
132: msd_dem_common_utilities.log_debug(substr(SQLERRM,1,150));
133: retcode := -1;
134:
135: end get_query;
136:
163: c_get_parts c_get_cursor;
164:
165: begin
166:
167: msd_dem_common_utilities.log_debug('In procedure: msd_dem_query_utilities.get_query2');
168: get_db_link(p_instance_id, v_srdblink, retcode);
169:
170: /*msd_dem_common_utilities.log_message();*/
171: msd_dem_common_utilities.log_debug('The instance dblink for this query will be: '|| v_srdblink );
166:
167: msd_dem_common_utilities.log_debug('In procedure: msd_dem_query_utilities.get_query2');
168: get_db_link(p_instance_id, v_srdblink, retcode);
169:
170: /*msd_dem_common_utilities.log_message();*/
171: msd_dem_common_utilities.log_debug('The instance dblink for this query will be: '|| v_srdblink );
172:
173: open c_get_parts for select query from msd_dem_queries mdq,msd_dem_entity_queries mdeq where mdeq.part1 = mdq.query_id and mdeq.entity_name = p_entity_name;
174: fetch c_get_parts into l_part1_query;
167: msd_dem_common_utilities.log_debug('In procedure: msd_dem_query_utilities.get_query2');
168: get_db_link(p_instance_id, v_srdblink, retcode);
169:
170: /*msd_dem_common_utilities.log_message();*/
171: msd_dem_common_utilities.log_debug('The instance dblink for this query will be: '|| v_srdblink );
172:
173: open c_get_parts for select query from msd_dem_queries mdq,msd_dem_entity_queries mdeq where mdeq.part1 = mdq.query_id and mdeq.entity_name = p_entity_name;
174: fetch c_get_parts into l_part1_query;
175: close c_get_parts;
211: value:=substr(keys_values,pos2+1,pos3-pos2-1);
212: exit when (instr(keys_values,'$',1,i+1)=0);
213: l_final_query := replace(l_final_query, key,value);
214: query := replace(query, key,value);
215: msd_dem_common_utilities.log_debug('key=' || key ||' value='||value || ' i = ' ||i);
216: end loop;
217: l_final_query := replace(l_final_query,'C_SOURCE_VIEW_NAME',cv_name);
218: query := replace(query,'C_DBLINK',v_srdblink);
219: query := replace(query,'C_SOURCE_VIEW_NAME',cv_name);
223: l_final_query:='
224: begin
225: MSD_DEM_SR_UTIL.EXECUTE_REMOTE_QUERY'||v_srdblink||'('''||l_final_query||''');
226: end;';
227: msd_dem_common_utilities.log_debug('The query is: ' || l_final_query );
228: execute immediate l_final_query;
229:
230: /* Check if the view created is VALID or NOT */
231: begin
234: when no_data_found then
235: null;
236: when others then
237: retcode := -1;
238: msd_dem_common_utilities.log_message ('Error: msd_dem_query_utilities.get_query2 - ');
239: msd_dem_common_utilities.log_message ('The source view ' || cv_name || ' was not created sucessfully');
240: end;
241: else
242: msd_dem_common_utilities.log_message('In msd_dem_query_utilities.get_query - ');
235: null;
236: when others then
237: retcode := -1;
238: msd_dem_common_utilities.log_message ('Error: msd_dem_query_utilities.get_query2 - ');
239: msd_dem_common_utilities.log_message ('The source view ' || cv_name || ' was not created sucessfully');
240: end;
241: else
242: msd_dem_common_utilities.log_message('In msd_dem_query_utilities.get_query - ');
243: msd_dem_common_utilities.log_message('Custom View ' || cv_name || ' used.');
238: msd_dem_common_utilities.log_message ('Error: msd_dem_query_utilities.get_query2 - ');
239: msd_dem_common_utilities.log_message ('The source view ' || cv_name || ' was not created sucessfully');
240: end;
241: else
242: msd_dem_common_utilities.log_message('In msd_dem_query_utilities.get_query - ');
243: msd_dem_common_utilities.log_message('Custom View ' || cv_name || ' used.');
244: end if;
245: exception
246: when others then
239: msd_dem_common_utilities.log_message ('The source view ' || cv_name || ' was not created sucessfully');
240: end;
241: else
242: msd_dem_common_utilities.log_message('In msd_dem_query_utilities.get_query - ');
243: msd_dem_common_utilities.log_message('Custom View ' || cv_name || ' used.');
244: end if;
245: exception
246: when others then
247: msd_dem_common_utilities.log_message(substr(SQLERRM,1,150));
243: msd_dem_common_utilities.log_message('Custom View ' || cv_name || ' used.');
244: end if;
245: exception
246: when others then
247: msd_dem_common_utilities.log_message(substr(SQLERRM,1,150));
248: msd_dem_common_utilities.log_debug(substr(SQLERRM,1,150));
249: retcode := -1;
250:
251: end get_query2;
244: end if;
245: exception
246: when others then
247: msd_dem_common_utilities.log_message(substr(SQLERRM,1,150));
248: msd_dem_common_utilities.log_debug(substr(SQLERRM,1,150));
249: retcode := -1;
250:
251: end get_query2;
252:
464: x_value VARCHAR2(500) := NULL;
465:
466: BEGIN
467:
468: msd_dem_common_utilities.log_debug ('Entering: msd_dem_query_utilities.execute_query - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
469:
470: /* Log the parameters */
471: msd_dem_common_utilities.log_debug (' Entity Name - ' || p_entity_name);
472: msd_dem_common_utilities.log_debug (' Instance Id - ' || to_char(p_sr_instance_id));
467:
468: msd_dem_common_utilities.log_debug ('Entering: msd_dem_query_utilities.execute_query - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
469:
470: /* Log the parameters */
471: msd_dem_common_utilities.log_debug (' Entity Name - ' || p_entity_name);
472: msd_dem_common_utilities.log_debug (' Instance Id - ' || to_char(p_sr_instance_id));
473: msd_dem_common_utilities.log_debug (' Key Values Pairs - ' || p_key_values);
474:
475:
468: msd_dem_common_utilities.log_debug ('Entering: msd_dem_query_utilities.execute_query - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
469:
470: /* Log the parameters */
471: msd_dem_common_utilities.log_debug (' Entity Name - ' || p_entity_name);
472: msd_dem_common_utilities.log_debug (' Instance Id - ' || to_char(p_sr_instance_id));
473: msd_dem_common_utilities.log_debug (' Key Values Pairs - ' || p_key_values);
474:
475:
476: OPEN xc_get_parts FOR SELECT query
469:
470: /* Log the parameters */
471: msd_dem_common_utilities.log_debug (' Entity Name - ' || p_entity_name);
472: msd_dem_common_utilities.log_debug (' Instance Id - ' || to_char(p_sr_instance_id));
473: msd_dem_common_utilities.log_debug (' Key Values Pairs - ' || p_key_values);
474:
475:
476: OPEN xc_get_parts FOR SELECT query
477: FROM msd_dem_entity_queries mdeq,
498: CLOSE xc_get_parts;
499:
500: x_query := x_query_part1 || x_query_part2 || x_query_part3;
501:
502: msd_dem_common_utilities.log_debug (' The query v1 is - ');
503: msd_dem_common_utilities.log_debug (x_query);
504:
505:
506: /* Replace the constants */
499:
500: x_query := x_query_part1 || x_query_part2 || x_query_part3;
501:
502: msd_dem_common_utilities.log_debug (' The query v1 is - ');
503: msd_dem_common_utilities.log_debug (x_query);
504:
505:
506: /* Replace the constants */
507: IF (p_key_values IS NOT NULL)
521:
522: EXIT WHEN (instr ( p_key_values, '$', 1, i + 1) = 0);
523:
524: x_query := replace (x_query, x_key, x_value);
525: msd_dem_common_utilities.log_debug ('KEY = ' || x_key || ', VALUE = ' || x_value || ', i = ' || i);
526:
527: END LOOP;
528: END IF;
529:
529:
530: x_query := replace (x_query, 'C_SR_INSTANCE_ID', to_char(p_sr_instance_id));
531: x_query := replace (x_query, 'C_SCHEMANAME', fnd_profile.value('MSD_DEM_SCHEMA'));
532:
533: msd_dem_common_utilities.log_debug (' The query v2 is - ');
534: msd_dem_common_utilities.log_debug (x_query);
535:
536: msd_dem_common_utilities.log_debug ('Query Start Time - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
537: EXECUTE IMMEDIATE x_query;
530: x_query := replace (x_query, 'C_SR_INSTANCE_ID', to_char(p_sr_instance_id));
531: x_query := replace (x_query, 'C_SCHEMANAME', fnd_profile.value('MSD_DEM_SCHEMA'));
532:
533: msd_dem_common_utilities.log_debug (' The query v2 is - ');
534: msd_dem_common_utilities.log_debug (x_query);
535:
536: msd_dem_common_utilities.log_debug ('Query Start Time - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
537: EXECUTE IMMEDIATE x_query;
538: COMMIT;
532:
533: msd_dem_common_utilities.log_debug (' The query v2 is - ');
534: msd_dem_common_utilities.log_debug (x_query);
535:
536: msd_dem_common_utilities.log_debug ('Query Start Time - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
537: EXECUTE IMMEDIATE x_query;
538: COMMIT;
539: msd_dem_common_utilities.log_debug ('Query End Time - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
540:
535:
536: msd_dem_common_utilities.log_debug ('Query Start Time - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
537: EXECUTE IMMEDIATE x_query;
538: COMMIT;
539: msd_dem_common_utilities.log_debug ('Query End Time - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
540:
541: msd_dem_common_utilities.log_debug ('Exiting: msd_dem_query_utilities.execute_query - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
542:
543: retcode := 0;
537: EXECUTE IMMEDIATE x_query;
538: COMMIT;
539: msd_dem_common_utilities.log_debug ('Query End Time - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
540:
541: msd_dem_common_utilities.log_debug ('Exiting: msd_dem_query_utilities.execute_query - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
542:
543: retcode := 0;
544:
545: EXCEPTION
546: WHEN OTHERS THEN
547: errbuf := substr(SQLERRM,1,150);
548: retcode := -1;
549:
550: msd_dem_common_utilities.log_message ('Exception(1): msd_dem_query_utilities.execute_query - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
551: msd_dem_common_utilities.log_message (errbuf);
552: RETURN;
553:
554: END EXECUTE_QUERY;
547: errbuf := substr(SQLERRM,1,150);
548: retcode := -1;
549:
550: msd_dem_common_utilities.log_message ('Exception(1): msd_dem_query_utilities.execute_query - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
551: msd_dem_common_utilities.log_message (errbuf);
552: RETURN;
553:
554: END EXECUTE_QUERY;
555:
575:
576:
577: BEGIN
578:
579: msd_dem_common_utilities.log_debug ('Entering: msd_dem_query_utilities.truncate_table - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
580:
581: /* Log the parameters */
582: msd_dem_common_utilities.log_debug (' Table Name - ' || p_table_name);
583: msd_dem_common_utilities.log_debug (' Owner - ' || to_char(p_owner));
578:
579: msd_dem_common_utilities.log_debug ('Entering: msd_dem_query_utilities.truncate_table - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
580:
581: /* Log the parameters */
582: msd_dem_common_utilities.log_debug (' Table Name - ' || p_table_name);
583: msd_dem_common_utilities.log_debug (' Owner - ' || to_char(p_owner));
584: msd_dem_common_utilities.log_debug (' Truncate - ' || to_char(p_truncate));
585:
586: IF (p_owner = 1)
579: msd_dem_common_utilities.log_debug ('Entering: msd_dem_query_utilities.truncate_table - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
580:
581: /* Log the parameters */
582: msd_dem_common_utilities.log_debug (' Table Name - ' || p_table_name);
583: msd_dem_common_utilities.log_debug (' Owner - ' || to_char(p_owner));
584: msd_dem_common_utilities.log_debug (' Truncate - ' || to_char(p_truncate));
585:
586: IF (p_owner = 1)
587: THEN
580:
581: /* Log the parameters */
582: msd_dem_common_utilities.log_debug (' Table Name - ' || p_table_name);
583: msd_dem_common_utilities.log_debug (' Owner - ' || to_char(p_owner));
584: msd_dem_common_utilities.log_debug (' Truncate - ' || to_char(p_truncate));
585:
586: IF (p_owner = 1)
587: THEN
588: x_schema := fnd_profile.value('MSD_DEM_SCHEMA');
589: ELSE
590: x_retval := fnd_installation.get_app_info ( 'MSD', x_dummy1, x_dummy2, x_schema );
591: END IF;
592:
593: msd_dem_common_utilities.log_debug (' Schema - ' || x_schema);
594:
595: IF (p_truncate = 1)
596: THEN
597: x_sql := 'TRUNCATE TABLE ' || x_schema || '.' || p_table_name;
598: ELSE
599: x_sql := 'DELETE FROM ' || x_schema || '.' || p_table_name;
600: END IF;
601:
602: msd_dem_common_utilities.log_debug ('Query - ');
603: msd_dem_common_utilities.log_debug (x_sql);
604:
605: msd_dem_common_utilities.log_debug ('Query Start Time - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
606: IF (p_truncate = 1)
599: x_sql := 'DELETE FROM ' || x_schema || '.' || p_table_name;
600: END IF;
601:
602: msd_dem_common_utilities.log_debug ('Query - ');
603: msd_dem_common_utilities.log_debug (x_sql);
604:
605: msd_dem_common_utilities.log_debug ('Query Start Time - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
606: IF (p_truncate = 1)
607: THEN
601:
602: msd_dem_common_utilities.log_debug ('Query - ');
603: msd_dem_common_utilities.log_debug (x_sql);
604:
605: msd_dem_common_utilities.log_debug ('Query Start Time - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
606: IF (p_truncate = 1)
607: THEN
608: EXECUTE IMMEDIATE x_sql;
609: ELSE
609: ELSE
610: EXECUTE IMMEDIATE x_sql;
611: COMMIT;
612: END IF;
613: msd_dem_common_utilities.log_debug ('Query End Time - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
614:
615: msd_dem_common_utilities.log_debug ('Exiting: msd_dem_query_utilities.truncate_table - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
616:
617: retcode := 0;
611: COMMIT;
612: END IF;
613: msd_dem_common_utilities.log_debug ('Query End Time - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
614:
615: msd_dem_common_utilities.log_debug ('Exiting: msd_dem_query_utilities.truncate_table - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
616:
617: retcode := 0;
618:
619: EXCEPTION
620: WHEN OTHERS THEN
621: errbuf := substr(SQLERRM,1,150);
622: retcode := -1;
623:
624: msd_dem_common_utilities.log_message ('Exception(1): msd_dem_query_utilities.truncate_table - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
625: msd_dem_common_utilities.log_message (errbuf);
626: RETURN;
627:
628: END TRUNCATE_TABLE;
621: errbuf := substr(SQLERRM,1,150);
622: retcode := -1;
623:
624: msd_dem_common_utilities.log_message ('Exception(1): msd_dem_query_utilities.truncate_table - ' || TO_CHAR(systimestamp, 'DD-MON-YYYY HH24:MI:SS'));
625: msd_dem_common_utilities.log_message (errbuf);
626: RETURN;
627:
628: END TRUNCATE_TABLE;
629: