DBA Data[Home] [Help]

APPS.MSC_CL_EXCHANGE_PARTTBL dependencies on MSC_UTIL

Line 82: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '')||pBUFF);

78: PROCEDURE TRC( pBUFF IN VARCHAR2)
79: IS
80: BEGIN
81: IF fnd_global.conc_request_id > 0 THEN
82: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '')||pBUFF);
83: ELSE
84: --DBMS_OUTPUT.PUT_LINE( ' 85: null;
86: END IF;

Line 120: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

116: EXCEPTION
117: WHEN OTHERS THEN
118: IF c_msc%ISOPEN THEN CLOSE c_msc; END IF;
119:
120: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
121: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
122: RETURN FALSE;
123: END Initialize_Schema_PVT;
124:

Line 121: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

117: WHEN OTHERS THEN
118: IF c_msc%ISOPEN THEN CLOSE c_msc; END IF;
119:
120: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
121: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
122: RETURN FALSE;
123: END Initialize_Schema_PVT;
124:
125: /* =========== Initialize Temporary Table List ============= */

Line 146: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

142: trc( 'en:Initialize_TTL_List_PVT');
143: RETURN TRUE;
144: EXCEPTION
145: WHEN OTHERS THEN
146: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
147: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
148: RETURN FALSE;
149: END Initialize_TTL_List_PVT;
150:

Line 147: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

143: RETURN TRUE;
144: EXCEPTION
145: WHEN OTHERS THEN
146: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
147: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
148: RETURN FALSE;
149: END Initialize_TTL_List_PVT;
150:
151:

Line 200: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

196:
197: RETURN TRUE;
198: EXCEPTION
199: WHEN OTHERS THEN
200: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
201: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
202: RETURN FALSE;
203: END Initialize_SWAP_Tbl_List;
204:

Line 201: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

197: RETURN TRUE;
198: EXCEPTION
199: WHEN OTHERS THEN
200: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
201: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
202: RETURN FALSE;
203: END Initialize_SWAP_Tbl_List;
204:
205: FUNCTION Drop_Temp_Tab_PVT(pTableName VARCHAR2) RETURN BOOLEAN

Line 237: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

233: RETURN TRUE;
234:
235: EXCEPTION
236: WHEN OTHERS THEN
237: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
238: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
239: RETURN FALSE;
240: END Drop_Temp_Tab_PVT;
241:

Line 238: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

234:
235: EXCEPTION
236: WHEN OTHERS THEN
237: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
238: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
239: RETURN FALSE;
240: END Drop_Temp_Tab_PVT;
241:
242: FUNCTION get_block_size RETURN NUMBER

Line 327: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

323: AND table_owner = v_msc_schema
324: AND partition_name=lv_partition_name;
325:
326: IF lv_part_exists = 0 THEN
327: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
328: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Specified partition: ' || lv_partition_name || ' on table: '|| pTableName ||' does not exist');
329: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Please create all the missing partitions');
330: RETURN FALSE;
331: END IF;

Line 328: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Specified partition: ' || lv_partition_name || ' on table: '|| pTableName ||' does not exist');

324: AND partition_name=lv_partition_name;
325:
326: IF lv_part_exists = 0 THEN
327: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
328: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Specified partition: ' || lv_partition_name || ' on table: '|| pTableName ||' does not exist');
329: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Please create all the missing partitions');
330: RETURN FALSE;
331: END IF;
332:

Line 329: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Please create all the missing partitions');

325:
326: IF lv_part_exists = 0 THEN
327: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
328: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Specified partition: ' || lv_partition_name || ' on table: '|| pTableName ||' does not exist');
329: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Please create all the missing partitions');
330: RETURN FALSE;
331: END IF;
332:
333: OPEN c_part_para( v_msc_schema, pTableName,lv_partition_name);

Line 394: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

390:
391: EXCEPTION
392: WHEN OTHERS THEN
393: IF c_part_para%ISOPEN THEN CLOSE c_part_para; END IF;
394: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
395: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
396: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
397: RETURN FALSE;
398: END Create_Temp_Tab_PVT;

Line 395: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);

391: EXCEPTION
392: WHEN OTHERS THEN
393: IF c_part_para%ISOPEN THEN CLOSE c_part_para; END IF;
394: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
395: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
396: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
397: RETURN FALSE;
398: END Create_Temp_Tab_PVT;
399:

Line 396: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

392: WHEN OTHERS THEN
393: IF c_part_para%ISOPEN THEN CLOSE c_part_para; END IF;
394: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
395: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
396: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
397: RETURN FALSE;
398: END Create_Temp_Tab_PVT;
399:
400: /* =========== Create Indexes on Temporary Tables ========== */

Line 423: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during unique index creation on table, ' || v_tempTblList(i));

419: MSC_CL_COLLECTION.G_WARNING
420: );
421:
422: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
423: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during unique index creation on table, ' || v_tempTblList(i));
424: ELSIF lv_crt_ind_status = MSC_CL_COLLECTION.G_ERROR THEN
425: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Error during unique index creation on table, ' || v_tempTblList(i));
426: RETURN FALSE;
427: ELSE

Line 425: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Error during unique index creation on table, ' || v_tempTblList(i));

421:
422: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
423: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during unique index creation on table, ' || v_tempTblList(i));
424: ELSIF lv_crt_ind_status = MSC_CL_COLLECTION.G_ERROR THEN
425: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Error during unique index creation on table, ' || v_tempTblList(i));
426: RETURN FALSE;
427: ELSE
428: trc('Unique index creation successful on table, ' || v_tempTblList(i));
429: END IF;

Line 438: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

434: RETURN TRUE;
435:
436: EXCEPTION
437: WHEN OTHERS THEN
438: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
439: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
440: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
441: RETURN FALSE;
442: END Create_Index_PVT;

Line 439: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);

435:
436: EXCEPTION
437: WHEN OTHERS THEN
438: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
439: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
440: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
441: RETURN FALSE;
442: END Create_Index_PVT;
443:

Line 440: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

436: EXCEPTION
437: WHEN OTHERS THEN
438: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
439: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
440: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
441: RETURN FALSE;
442: END Create_Index_PVT;
443:
444: /* ========= Exchange Partitions =========== */

Line 471: MSC_UTIL.SYS_YES) THEN

467:
468: if NOT EXCHANGE_SINGLE_TAB_PARTN ( v_partTblList(i) ,
469: lv_partition_name ,
470: v_tempTblList(i),
471: MSC_UTIL.SYS_YES) THEN
472: return FALSE;
473: END IF;
474: END LOOP;
475:

Line 490: MSC_UTIL.SYS_YES) THEN

486:
487: if NOT EXCHANGE_SINGLE_TAB_PARTN ( v_swapTblList(i).ods_table_name ,
488: lv_partition_name ,
489: v_swapTblList(i).temp_table_name,
490: MSC_UTIL.SYS_YES) THEN
491: return FALSE;
492: END IF;
493:
494: --if the table is in the ods-staging swap table list.

Line 506: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

502: RETURN TRUE;
503:
504: EXCEPTION
505: WHEN OTHERS THEN
506: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
507: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
508: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
509: RETURN FALSE;
510: END Exchange_Partition_PVT;

Line 507: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);

503:
504: EXCEPTION
505: WHEN OTHERS THEN
506: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
507: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
508: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
509: RETURN FALSE;
510: END Exchange_Partition_PVT;
511:

Line 508: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

504: EXCEPTION
505: WHEN OTHERS THEN
506: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
507: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
508: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
509: RETURN FALSE;
510: END Exchange_Partition_PVT;
511:
512: /* ========== Analyse Temporary Table =========== */

Line 531: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

527: RETURN TRUE;
528:
529: EXCEPTION
530: WHEN OTHERS THEN
531: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
532: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
533: RETURN FALSE;
534: END Analyse_Temp_Tab_PVT;
535:

Line 532: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

528:
529: EXCEPTION
530: WHEN OTHERS THEN
531: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
532: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
533: RETURN FALSE;
534: END Analyse_Temp_Tab_PVT;
535:
536:

Line 561: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

557: RETURN TRUE;
558:
559: EXCEPTION
560: WHEN OTHERS THEN
561: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
562: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
563: RETURN FALSE;
564: END Create_Temp_Tbl;
565:

Line 562: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

558:
559: EXCEPTION
560: WHEN OTHERS THEN
561: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
562: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
563: RETURN FALSE;
564: END Create_Temp_Tbl;
565:
566: FUNCTION Exchange_Partition RETURN BOOLEAN

Line 576: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

572:
573: RETURN TRUE;
574: EXCEPTION
575: WHEN OTHERS THEN
576: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
577: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
578: RETURN FALSE;
579: END Exchange_Partition;
580:

Line 577: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

573: RETURN TRUE;
574: EXCEPTION
575: WHEN OTHERS THEN
576: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
577: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
578: RETURN FALSE;
579: END Exchange_Partition;
580:
581: /* ========== Drop Temporary Tables =========== */

Line 600: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

596: RETURN TRUE;
597:
598: EXCEPTION
599: WHEN OTHERS THEN
600: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
601: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
602: RETURN FALSE;
603: END Drop_Temp_Tbl;
604:

Line 601: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

597:
598: EXCEPTION
599: WHEN OTHERS THEN
600: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
601: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
602: RETURN FALSE;
603: END Drop_Temp_Tbl;
604:
605: FUNCTION Create_Unique_Index RETURN BOOLEAN

Line 614: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

610:
611: RETURN TRUE;
612: EXCEPTION
613: WHEN OTHERS THEN
614: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
615: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
616: RETURN FALSE;
617: END Create_Unique_Index;
618:

Line 615: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

611: RETURN TRUE;
612: EXCEPTION
613: WHEN OTHERS THEN
614: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
615: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
616: RETURN FALSE;
617: END Create_Unique_Index;
618:
619: FUNCTION Create_NonUnique_Index RETURN BOOLEAN

Line 629: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

625:
626: RETURN TRUE;
627: EXCEPTION
628: WHEN OTHERS THEN
629: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
630: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
631: RETURN FALSE;
632: END Create_NonUnique_Index;
633:

Line 630: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

626: RETURN TRUE;
627: EXCEPTION
628: WHEN OTHERS THEN
629: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
630: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
631: RETURN FALSE;
632: END Create_NonUnique_Index;
633:
634: FUNCTION Analyse_Temp_Tbl RETURN BOOLEAN

Line 644: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

640:
641: RETURN TRUE;
642: EXCEPTION
643: WHEN OTHERS THEN
644: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
645: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
646: RETURN FALSE;
647: END Analyse_Temp_Tbl;
648:

Line 645: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

641: RETURN TRUE;
642: EXCEPTION
643: WHEN OTHERS THEN
644: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
645: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
646: RETURN FALSE;
647: END Analyse_Temp_Tbl;
648:
649: FUNCTION Initialize( p_instance_id IN NUMBER,

Line 675: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

671:
672: RETURN v_is_initialized;
673: EXCEPTION
674: WHEN OTHERS THEN
675: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
676: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
677: RETURN v_is_initialized;
678: END Initialize;
679:

Line 676: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

672: RETURN v_is_initialized;
673: EXCEPTION
674: WHEN OTHERS THEN
675: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
676: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
677: RETURN v_is_initialized;
678: END Initialize;
679:
680: /*********************** PREPLACE CHANGE START ***********************/

Line 776: MSC_UTIL.SYS_YES) THEN

772:
773: if NOT EXCHANGE_SINGLE_TAB_PARTN ( lv_partn_tbl_name ,
774: lv_partition_name ,
775: p_tempTblList(i),
776: MSC_UTIL.SYS_YES) THEN
777: return FALSE;
778: END IF;
779:
780: --if the table is in the ods-staging swap table list.

Line 794: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

790: RETURN TRUE;
791:
792: EXCEPTION
793: WHEN OTHERS THEN
794: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
795: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
796: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
797: RETURN FALSE;
798: END Exchange_Partition_PARTIAL;

Line 795: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);

791:
792: EXCEPTION
793: WHEN OTHERS THEN
794: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
795: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
796: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
797: RETURN FALSE;
798: END Exchange_Partition_PARTIAL;
799:

Line 796: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

792: EXCEPTION
793: WHEN OTHERS THEN
794: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
795: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
796: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
797: RETURN FALSE;
798: END Exchange_Partition_PARTIAL;
799:
800: FUNCTION Exchange_Single_Tab_Partn ( pPartitionedTableName IN VARCHAR2,

Line 803: pIncludeIndexes IN NUMBER DEFAULT MSC_UTIL.SYS_YES ) RETURN BOOLEAN

799:
800: FUNCTION Exchange_Single_Tab_Partn ( pPartitionedTableName IN VARCHAR2,
801: pPartitionName IN VARCHAR2,
802: pUnPartitionedTableName IN VARCHAR2,
803: pIncludeIndexes IN NUMBER DEFAULT MSC_UTIL.SYS_YES ) RETURN BOOLEAN
804: IS
805: BEGIN
806:
807: trc('st:EXCHANGE_SINGLE_TAB_PARTN ' || pPartitionedTableName);

Line 814: IF ( pIncludeIndexes = MSC_UTIL.SYS_YES )THEN

810: 'ALTER TABLE '|| pPartitionedTableName
811: ||' EXCHANGE PARTITION '||pPartitionName
812: ||' WITH TABLE '|| pUnPartitionedTableName;
813:
814: IF ( pIncludeIndexes = MSC_UTIL.SYS_YES )THEN
815: v_sql_stmt:= v_sql_stmt ||' INCLUDING INDEXES';
816: END IF;
817:
818: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'exchange part:-'||v_sql_stmt);

Line 818: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'exchange part:-'||v_sql_stmt);

814: IF ( pIncludeIndexes = MSC_UTIL.SYS_YES )THEN
815: v_sql_stmt:= v_sql_stmt ||' INCLUDING INDEXES';
816: END IF;
817:
818: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'exchange part:-'||v_sql_stmt);
819:
820: /* execute the sql statement */
821: ad_ddl.do_ddl( applsys_schema => v_applsys_schema,
822: application_short_name => 'MSC',

Line 831: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, sqlerrm);

827: trc('en:EXCHANGE_SINGLE_TAB_PARTN' || pPartitionedTableName);
828: RETURN TRUE;
829: EXCEPTION
830: WHEN OTHERS THEN
831: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, sqlerrm);
832: RETURN FALSE;
833: END EXCHANGE_SINGLE_TAB_PARTN;
834:
835:

Line 863: MSC_UTIL.SYS_YES) then

859:
860: if NOT EXCHANGE_SINGLE_TAB_PARTN ( v_swapTblList(i).ods_table_name ,
861: lv_partition_name ,
862: v_swapTblList(i).temp_table_name,
863: MSC_UTIL.SYS_YES) then
864: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Error while exchanging partition for table :' || v_swapTblList(i).ods_table_name );
865: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Please launch targetted collections for following entities :' );
866:
867: FOR j IN i..v_swapTblList.COUNT LOOP

Line 864: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Error while exchanging partition for table :' || v_swapTblList(i).ods_table_name );

860: if NOT EXCHANGE_SINGLE_TAB_PARTN ( v_swapTblList(i).ods_table_name ,
861: lv_partition_name ,
862: v_swapTblList(i).temp_table_name,
863: MSC_UTIL.SYS_YES) then
864: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Error while exchanging partition for table :' || v_swapTblList(i).ods_table_name );
865: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Please launch targetted collections for following entities :' );
866:
867: FOR j IN i..v_swapTblList.COUNT LOOP
868: EXECUTE IMMEDIATE ' select ' ||v_swapTblList(j).column_name || 'from msc_coll_parameters '

Line 865: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Please launch targetted collections for following entities :' );

861: lv_partition_name ,
862: v_swapTblList(i).temp_table_name,
863: MSC_UTIL.SYS_YES) then
864: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Error while exchanging partition for table :' || v_swapTblList(i).ods_table_name );
865: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Please launch targetted collections for following entities :' );
866:
867: FOR j IN i..v_swapTblList.COUNT LOOP
868: EXECUTE IMMEDIATE ' select ' ||v_swapTblList(j).column_name || 'from msc_coll_parameters '
869: || ' where instance_id = ' || v_instance_id

Line 872: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,v_swapTblList(j).entity_name );

868: EXECUTE IMMEDIATE ' select ' ||v_swapTblList(j).column_name || 'from msc_coll_parameters '
869: || ' where instance_id = ' || v_instance_id
870: INTO lv_swap_status;
871: If lv_swap_status <> MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0 then
872: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,v_swapTblList(j).entity_name );
873: End if;
874: END LOOP;
875:
876: return FALSE;

Line 886: MSC_UTIL.SYS_NO) then

882:
883: if NOT EXCHANGE_SINGLE_TAB_PARTN ( v_swapTblList(i).stg_table_name ,
884: v_swapTblList(i).stg_table_partn_name ,
885: v_swapTblList(i).temp_table_name,
886: MSC_UTIL.SYS_NO) then
887: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Error while exchanging partition for table :' || v_swapTblList(i).stg_table_name );
888: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Please launch planning data pull again for following entities :' );
889: FOR j IN i..v_swapTblList.COUNT LOOP
890: EXECUTE IMMEDIATE ' select ' ||v_swapTblList(j).column_name || 'from msc_coll_parameters '

Line 887: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Error while exchanging partition for table :' || v_swapTblList(i).stg_table_name );

883: if NOT EXCHANGE_SINGLE_TAB_PARTN ( v_swapTblList(i).stg_table_name ,
884: v_swapTblList(i).stg_table_partn_name ,
885: v_swapTblList(i).temp_table_name,
886: MSC_UTIL.SYS_NO) then
887: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Error while exchanging partition for table :' || v_swapTblList(i).stg_table_name );
888: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Please launch planning data pull again for following entities :' );
889: FOR j IN i..v_swapTblList.COUNT LOOP
890: EXECUTE IMMEDIATE ' select ' ||v_swapTblList(j).column_name || 'from msc_coll_parameters '
891: || ' where instance_id = ' || v_instance_id

Line 888: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Please launch planning data pull again for following entities :' );

884: v_swapTblList(i).stg_table_partn_name ,
885: v_swapTblList(i).temp_table_name,
886: MSC_UTIL.SYS_NO) then
887: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Error while exchanging partition for table :' || v_swapTblList(i).stg_table_name );
888: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,' Please launch planning data pull again for following entities :' );
889: FOR j IN i..v_swapTblList.COUNT LOOP
890: EXECUTE IMMEDIATE ' select ' ||v_swapTblList(j).column_name || 'from msc_coll_parameters '
891: || ' where instance_id = ' || v_instance_id
892: INTO lv_swap_status;

Line 894: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,v_swapTblList(j).entity_name );

890: EXECUTE IMMEDIATE ' select ' ||v_swapTblList(j).column_name || 'from msc_coll_parameters '
891: || ' where instance_id = ' || v_instance_id
892: INTO lv_swap_status;
893: If lv_swap_status <> MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0 then
894: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,v_swapTblList(j).entity_name );
895: End if;
896: END LOOP;
897:
898: return FALSE;

Line 933: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'payback flag:-'||prec.payback_demand_supply_flag);

929:
930: /* Add entries to the Temp Table List */
931:
932: -- agmcont
933: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'payback flag:-'||prec.payback_demand_supply_flag);
934: IF prec.item_flag = SYS_YES THEN
935: if (p_is_cont_refresh and
936: (prec.item_sn_flag = SYS_INCR or prec.item_sn_flag = SYS_NO)) then
937: null;

Line 1145: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<< '||TO_CHAR(i) ||' '||lv_TblList(i)||' >>');

1141: END LOOP;
1142:
1143: FOR i IN 1..lv_TblList.COUNT LOOP
1144:
1145: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<< '||TO_CHAR(i) ||' '||lv_TblList(i)||' >>');
1146:
1147: END LOOP;
1148:
1149:

Line 1157: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

1153:
1154: RETURN TRUE;
1155: EXCEPTION
1156: WHEN OTHERS THEN
1157: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
1158: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1159: RETURN FALSE;
1160: END Exchange_Partition;
1161:

Line 1158: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

1154: RETURN TRUE;
1155: EXCEPTION
1156: WHEN OTHERS THEN
1157: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
1158: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1159: RETURN FALSE;
1160: END Exchange_Partition;
1161:
1162: /*

Line 1262: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'ERROR in procedure create_partition ');

1258: END IF;
1259:
1260: EXCEPTION
1261: WHEN OTHERS THEN
1262: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'ERROR in procedure create_partition ');
1263: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1264:
1265: END create_partition;
1266:

Line 1263: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

1259:
1260: EXCEPTION
1261: WHEN OTHERS THEN
1262: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'ERROR in procedure create_partition ');
1263: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1264:
1265: END create_partition;
1266:
1267: /*-----------------------------------------------------------------------------

Line 1756: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'ERROR');

1752: /* handle unique index violation exception */
1753:
1754: IF SQLCODE IN (-00001, -01452, -12801) THEN
1755: IF p_error_level = MSC_CL_COLLECTION.G_ERROR THEN
1756: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'ERROR');
1757: ELSE
1758: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'WARNING');
1759: END IF;
1760:

Line 1758: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'WARNING');

1754: IF SQLCODE IN (-00001, -01452, -12801) THEN
1755: IF p_error_level = MSC_CL_COLLECTION.G_ERROR THEN
1756: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'ERROR');
1757: ELSE
1758: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'WARNING');
1759: END IF;
1760:
1761: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Unique index violated - ' || lv_temp_index_name);
1762: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

Line 1761: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Unique index violated - ' || lv_temp_index_name);

1757: ELSE
1758: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'WARNING');
1759: END IF;
1760:
1761: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Unique index violated - ' || lv_temp_index_name);
1762: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1763:
1764: lv_sql_stmt2 := 'SELECT ';
1765: lv_sql_stmt3 := 'WHERE ';

Line 1762: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

1758: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'WARNING');
1759: END IF;
1760:
1761: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Unique index violated - ' || lv_temp_index_name);
1762: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1763:
1764: lv_sql_stmt2 := 'SELECT ';
1765: lv_sql_stmt3 := 'WHERE ';
1766:

Line 1798: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '======= Below records violate the unique constraint =======');

1794: lv_sql_stmt2 := lv_sql_stmt2 || ' err_text FROM ' || p_temp_table || ' t1 WHERE EXISTS '
1795: || '(SELECT 1 FROM ' || p_temp_table || ' t2 ' || lv_sql_stmt3
1796: || 't1.rowid < t2.rowid)';
1797:
1798: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '======= Below records violate the unique constraint =======');
1799:
1800: EXECUTE IMMEDIATE lv_sql_stmt2 BULK COLLECT INTO lv_error_msg;
1801:
1802: FOR j IN 1..lv_error_msg.COUNT LOOP

Line 1803: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_error_msg(j) );

1799:
1800: EXECUTE IMMEDIATE lv_sql_stmt2 BULK COLLECT INTO lv_error_msg;
1801:
1802: FOR j IN 1..lv_error_msg.COUNT LOOP
1803: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_error_msg(j) );
1804: END LOOP;
1805:
1806: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '===========================================================');
1807:

Line 1806: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '===========================================================');

1802: FOR j IN 1..lv_error_msg.COUNT LOOP
1803: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_error_msg(j) );
1804: END LOOP;
1805:
1806: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '===========================================================');
1807:
1808: IF p_error_level = MSC_CL_COLLECTION.G_ERROR THEN
1809: lv_retval := MSC_CL_COLLECTION.G_ERROR;
1810: RAISE;

Line 1813: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The above records would not be collected');

1809: lv_retval := MSC_CL_COLLECTION.G_ERROR;
1810: RAISE;
1811: ELSE
1812: lv_retval := MSC_CL_COLLECTION.G_WARNING;
1813: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The above records would not be collected');
1814: lv_sql_stmt4 := 'DELETE FROM ' || p_temp_table || ' t1 WHERE EXISTS '
1815: || '(SELECT 1 FROM ' || p_temp_table || ' t2 ' || lv_sql_stmt3
1816: || 't1.rowid < t2.rowid)';
1817:

Line 1818: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'deleting the duplicate row ' ||lv_sql_stmt4 );

1814: lv_sql_stmt4 := 'DELETE FROM ' || p_temp_table || ' t1 WHERE EXISTS '
1815: || '(SELECT 1 FROM ' || p_temp_table || ' t2 ' || lv_sql_stmt3
1816: || 't1.rowid < t2.rowid)';
1817:
1818: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'deleting the duplicate row ' ||lv_sql_stmt4 );
1819:
1820: EXECUTE IMMEDIATE lv_sql_stmt4;
1821: COMMIT;
1822:

Line 1851: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');

1847:
1848: EXCEPTION
1849: WHEN OTHERS THEN
1850: lv_retval := MSC_CL_COLLECTION.G_ERROR;
1851: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
1852: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
1853: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1854: RETURN lv_retval;
1855: END create_temp_table_index;

Line 1852: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);

1848: EXCEPTION
1849: WHEN OTHERS THEN
1850: lv_retval := MSC_CL_COLLECTION.G_ERROR;
1851: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
1852: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
1853: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1854: RETURN lv_retval;
1855: END create_temp_table_index;
1856:

Line 1853: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);

1849: WHEN OTHERS THEN
1850: lv_retval := MSC_CL_COLLECTION.G_ERROR;
1851: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
1852: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
1853: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1854: RETURN lv_retval;
1855: END create_temp_table_index;
1856:
1857:

Line 1863: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1,qry);

1859: ------------- Clean Repaiir junk inst Part--------------------------------
1860: PROCEDURE EXEC_DDL(qry varchar2)
1861: IS
1862: BEGIN
1863: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1,qry);
1864: EXECUTE IMMEDIATE qry ;
1865: END EXEC_DDL;
1866:
1867: PROCEDURE list_create_def_part_stg ( ERRBUF OUT NOCOPY VARCHAR2,

Line 1874: lv_schema:=msc_util.get_schema_name(724);

1870: IS
1871: lv_qry_add_part varchar2(2000);
1872: lv_schema varchar2(30);
1873: BEGIN
1874: lv_schema:=msc_util.get_schema_name(724);
1875: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Following DEFAULT partitions are missing');
1876: FOR tab in (select table_name
1877: from MSC_STAGING_TABLE_V mst
1878: where partition_type <> 'U'

Line 1875: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Following DEFAULT partitions are missing');

1871: lv_qry_add_part varchar2(2000);
1872: lv_schema varchar2(30);
1873: BEGIN
1874: lv_schema:=msc_util.get_schema_name(724);
1875: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Following DEFAULT partitions are missing');
1876: FOR tab in (select table_name
1877: from MSC_STAGING_TABLE_V mst
1878: where partition_type <> 'U'
1879: and not exists (select 1 from all_tab_partitions ATP

Line 1884: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,tab.table_name||'.'||substr(tab.table_name,5)||'_DEF');

1880: where ATP.table_owner = lv_schema
1881: and atp.table_name=mst.table_name
1882: and partition_name like '%_DEF') )
1883: loop
1884: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,tab.table_name||'.'||substr(tab.table_name,5)||'_DEF');
1885: lv_qry_add_part := 'ALTER TABLE '||lv_schema||'.'||tab.table_name||' ADD PARTITION '||substr(tab.table_name,5)||'_DEF VALUES (DEFAULT)';
1886: IF p_mode = 1 then
1887: EXEC_DDL(lv_qry_add_part);
1888: end if;

Line 1941: lv_schema:=msc_util.get_schema_name(724);

1937:
1938:
1939: BEGIN
1940:
1941: lv_schema:=msc_util.get_schema_name(724);
1942: --
1943: -- Generate List of Instances passed --
1944: lv_inst_str := ',';
1945: lv_leg_inst_str := ', ';

Line 1956: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'List of Junk Stg Partitions:-');

1952: end if;
1953: END LOOP;
1954:
1955: --End Generate List of Instances passed --
1956: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'List of Junk Stg Partitions:-');
1957: FOR tab in c_tab_part(lv_schema)
1958: LOOP
1959: --
1960: IF ( (INSTR(lv_inst_str,','||SUBSTR(tab.partition_name,INSTR(tab.partition_name,'_',-1)+1)||',') < 1

Line 1974: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_2,'Leg part marked as wrong1:-'||tab.table_name||'.'||tab.partition_name);

1970: ELSIF tab.partition_name = substr(tab.table_name,5)||'_LEG' THEN
1971: for inst in (select instance_id from msc_apps_instances where instance_type = 3 ) loop
1972: if instr(', '||substr(tab.high_value,1,tab.high_value_length)||',' , ', '||inst.instance_id||',') < 1 then
1973: IS_BAD_PARTITION := TRUE;
1974: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_2,'Leg part marked as wrong1:-'||tab.table_name||'.'||tab.partition_name);
1975: end if;
1976: end loop;
1977:
1978: -- check if there is any extra value in the high_value of leg part

Line 1981: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'lv_high_val_str--'||lv_high_val_str);

1977:
1978: -- check if there is any extra value in the high_value of leg part
1979: lv_high_val_str := ','||substr(tab.high_value,1,tab.high_value_length)||',';
1980: i := 0;
1981: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'lv_high_val_str--'||lv_high_val_str);
1982: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'lv_leg_inst_str--'||lv_leg_inst_str);
1983: LOOP
1984: i := i+1;
1985: lv_str := substr (lv_high_val_str,instr(lv_high_val_str,',',1,i) +1

Line 1982: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'lv_leg_inst_str--'||lv_leg_inst_str);

1978: -- check if there is any extra value in the high_value of leg part
1979: lv_high_val_str := ','||substr(tab.high_value,1,tab.high_value_length)||',';
1980: i := 0;
1981: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'lv_high_val_str--'||lv_high_val_str);
1982: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'lv_leg_inst_str--'||lv_leg_inst_str);
1983: LOOP
1984: i := i+1;
1985: lv_str := substr (lv_high_val_str,instr(lv_high_val_str,',',1,i) +1
1986: ,instr(lv_high_val_str,',',1,i+1)-instr(lv_high_val_str,',',1,i) -1);

Line 1987: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'lv_str--'||lv_str);

1983: LOOP
1984: i := i+1;
1985: lv_str := substr (lv_high_val_str,instr(lv_high_val_str,',',1,i) +1
1986: ,instr(lv_high_val_str,',',1,i+1)-instr(lv_high_val_str,',',1,i) -1);
1987: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'lv_str--'||lv_str);
1988: exit when lv_str is null;
1989: if lv_str in ('0',' NULL') then
1990: NULL;
1991: ELSIF instr(lv_leg_inst_str,','||lv_str||',') < 1 then

Line 1993: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Leg part marked as wrong2:-'||tab.table_name||'.'||tab.partition_name);

1989: if lv_str in ('0',' NULL') then
1990: NULL;
1991: ELSIF instr(lv_leg_inst_str,','||lv_str||',') < 1 then
1992: IS_BAD_PARTITION := TRUE;
1993: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Leg part marked as wrong2:-'||tab.table_name||'.'||tab.partition_name);
1994: end if;
1995: END LOOP;
1996:
1997:

Line 2005: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,tab.table_name||'.'||tab.partition_name);

2001: END IF;
2002:
2003: IF IS_BAD_PARTITION THEN
2004: BEGIN
2005: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,tab.table_name||'.'||tab.partition_name);
2006: lv_qry_drop_part := 'ALTER TABLE '||lv_schema||'.'||tab.table_name||' DROP PARTITION '||tab.partition_name;
2007: IF p_mode = 1 then
2008: EXEC_DDL(lv_qry_drop_part);
2009: end if;

Line 2012: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'ERROR while executing --'||lv_qry_drop_part);

2008: EXEC_DDL(lv_qry_drop_part);
2009: end if;
2010: EXCEPTION
2011: WHEN OTHERS THEN
2012: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'ERROR while executing --'||lv_qry_drop_part);
2013: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,SQLERRM);
2014: RAISE;
2015: END;
2016: IS_BAD_PARTITION := FALSE;

Line 2013: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,SQLERRM);

2009: end if;
2010: EXCEPTION
2011: WHEN OTHERS THEN
2012: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'ERROR while executing --'||lv_qry_drop_part);
2013: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,SQLERRM);
2014: RAISE;
2015: END;
2016: IS_BAD_PARTITION := FALSE;
2017: END IF;

Line 2057: lv_schema:=msc_util.get_schema_name(724);

2053: AND b.partition_name like substr( a.table_name,5)||'%'
2054: AND INSTR(b.partition_name,'__') > 0;
2055: BEGIN
2056:
2057: lv_schema:=msc_util.get_schema_name(724);
2058:
2059: -- row_limit := TO_NUMBER( FND_PROFILE.VALUE('MRP_PURGE_BATCH_SIZE'));
2060: --
2061: -- Generate List of Instances passed --

Line 2069: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'List of junk ODS Partitions');

2065: lv_inst_str := lv_inst_str || inst.instance_id || ',' ;
2066: END LOOP;
2067:
2068: --End Generate List of Instances passed --
2069: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'List of junk ODS Partitions');
2070: FOR tab in c_tab_part(lv_schema)
2071: LOOP
2072: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'|tab.part_inst_id:-'||tab.part_inst_id||';');
2073: --IF SUBSTR(tabs.partition_name,INSTR(tabs.partition_name,'__')+2) NOT IN lv_inst_str then

Line 2072: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'|tab.part_inst_id:-'||tab.part_inst_id||';');

2068: --End Generate List of Instances passed --
2069: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'List of junk ODS Partitions');
2070: FOR tab in c_tab_part(lv_schema)
2071: LOOP
2072: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'|tab.part_inst_id:-'||tab.part_inst_id||';');
2073: --IF SUBSTR(tabs.partition_name,INSTR(tabs.partition_name,'__')+2) NOT IN lv_inst_str then
2074: IF INSTR(lv_inst_str,','||SUBSTR(tab.partition_name,INSTR(tab.partition_name,'__')+2)||',') < 1 then -- not in list
2075: BEGIN
2076: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,tab.table_name||'.'||tab.partition_name);

Line 2076: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,tab.table_name||'.'||tab.partition_name);

2072: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'|tab.part_inst_id:-'||tab.part_inst_id||';');
2073: --IF SUBSTR(tabs.partition_name,INSTR(tabs.partition_name,'__')+2) NOT IN lv_inst_str then
2074: IF INSTR(lv_inst_str,','||SUBSTR(tab.partition_name,INSTR(tab.partition_name,'__')+2)||',') < 1 then -- not in list
2075: BEGIN
2076: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,tab.table_name||'.'||tab.partition_name);
2077: lv_qry_drop_part := 'ALTER TABLE '||lv_schema||'.'||tab.table_name||' DROP PARTITION '||tab.partition_name;
2078: IF p_mode = 1 then
2079: EXEC_DDL(lv_qry_drop_part);
2080: end if;

Line 2083: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'ERROR while executing --'||lv_qry_drop_part);

2079: EXEC_DDL(lv_qry_drop_part);
2080: end if;
2081: EXCEPTION
2082: WHEN OTHERS THEN
2083: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'ERROR while executing --'||lv_qry_drop_part);
2084: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,SQLERRM);
2085: RAISE;
2086: END;
2087: ELSE

Line 2084: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,SQLERRM);

2080: end if;
2081: EXCEPTION
2082: WHEN OTHERS THEN
2083: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'ERROR while executing --'||lv_qry_drop_part);
2084: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,SQLERRM);
2085: RAISE;
2086: END;
2087: ELSE
2088:

Line 2097: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,tab.table_name||'.'||tab.partition_name);

2093: end if;
2094:
2095: if substr(tab.high_value,1,tab.high_value_length) <> lv_Part_inst_id then
2096: BEGIN
2097: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,tab.table_name||'.'||tab.partition_name);
2098: lv_qry_drop_part := 'ALTER TABLE '||lv_schema||'.'||tab.table_name||' DROP PARTITION '||tab.partition_name;
2099: IF p_mode = 1 then
2100: EXEC_DDL(lv_qry_drop_part);
2101: end if;

Line 2104: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'ERROR while executing --'||lv_qry_drop_part);

2100: EXEC_DDL(lv_qry_drop_part);
2101: end if;
2102: EXCEPTION
2103: WHEN OTHERS THEN
2104: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'ERROR while executing --'||lv_qry_drop_part);
2105: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,SQLERRM);
2106: RAISE;
2107: END;
2108: end if;

Line 2105: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,SQLERRM);

2101: end if;
2102: EXCEPTION
2103: WHEN OTHERS THEN
2104: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'ERROR while executing --'||lv_qry_drop_part);
2105: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,SQLERRM);
2106: RAISE;
2107: END;
2108: end if;
2109: END IF;

Line 2143: lv_schema:=msc_util.get_schema_name(724);

2139: lv_part_name varchar2(1000);
2140: lv_schema VARCHAR2(30);
2141:
2142: BEGIN
2143: lv_schema:=msc_util.get_schema_name(724);
2144: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Following Partitions to be created');
2145: FOR tab IN missing_ods_part(lv_schema)
2146: LOOP
2147: if tab.instance_id_flag = 'Y' and tab.plan_id_flag = 'Y' then

Line 2144: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Following Partitions to be created');

2140: lv_schema VARCHAR2(30);
2141:
2142: BEGIN
2143: lv_schema:=msc_util.get_schema_name(724);
2144: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Following Partitions to be created');
2145: FOR tab IN missing_ods_part(lv_schema)
2146: LOOP
2147: if tab.instance_id_flag = 'Y' and tab.plan_id_flag = 'Y' then
2148: lv_high_value := '-1, ' || to_char(tab.instance_id+1);

Line 2152: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Partitioned ODS Table '||tab.table_name||' does not have Instance_id as expected. Pls investigate');

2148: lv_high_value := '-1, ' || to_char(tab.instance_id+1);
2149: elsif tab.instance_id_flag = 'Y' and tab.plan_id_flag = 'N' then
2150: lv_high_value := to_char(tab.instance_id+1);
2151: else
2152: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Partitioned ODS Table '||tab.table_name||' does not have Instance_id as expected. Pls investigate');
2153: ERRBUF := 'Partitioned ODS Table '||tab.table_name||' does not have Instance_id as expected. Pls investigate';
2154: RETCODE := G_WARNING;
2155: end if;
2156: lv_part_name := substr(tab.table_name, 5) || '__' || tab.instance_id;

Line 2157: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Create Part:-'||tab.table_name||'.'||lv_part_name);

2153: ERRBUF := 'Partitioned ODS Table '||tab.table_name||' does not have Instance_id as expected. Pls investigate';
2154: RETCODE := G_WARNING;
2155: end if;
2156: lv_part_name := substr(tab.table_name, 5) || '__' || tab.instance_id;
2157: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Create Part:-'||tab.table_name||'.'||lv_part_name);
2158: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,tab.table_name||'.'||lv_part_name);
2159: IF p_mode = 1 THEN
2160: --GET_NEXT_PART(lv_high_value)
2161: MSC_CL_EXCHANGE_PARTTBL.create_partition(tab.table_name,

Line 2158: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,tab.table_name||'.'||lv_part_name);

2154: RETCODE := G_WARNING;
2155: end if;
2156: lv_part_name := substr(tab.table_name, 5) || '__' || tab.instance_id;
2157: --MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Create Part:-'||tab.table_name||'.'||lv_part_name);
2158: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,tab.table_name||'.'||lv_part_name);
2159: IF p_mode = 1 THEN
2160: --GET_NEXT_PART(lv_high_value)
2161: MSC_CL_EXCHANGE_PARTTBL.create_partition(tab.table_name,
2162: lv_part_name,

Line 2218: lv_schema:=msc_util.get_schema_name(724);

2214: lv_count number;
2215:
2216: BEGIN
2217:
2218: lv_schema:=msc_util.get_schema_name(724);
2219:
2220: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Following Partitions to be created');
2221: for stg_tab in (select table_name from msc_staging_table_v where PARTITION_TYPE = 'L' ) loop
2222:

Line 2220: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Following Partitions to be created');

2216: BEGIN
2217:
2218: lv_schema:=msc_util.get_schema_name(724);
2219:
2220: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,'Following Partitions to be created');
2221: for stg_tab in (select table_name from msc_staging_table_v where PARTITION_TYPE = 'L' ) loop
2222:
2223: open c_leg_part (lv_schema,stg_tab.table_name);
2224: fetch c_leg_part into lv_count;

Line 2230: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,stg_tab.table_name||'.'||substr(stg_tab.table_name,5)||'_LEG');

2226: lv_sql_stmt :='ALTER TABLE '||lv_schema||'.'||stg_tab.table_name
2227: ||' SPLIT PARTITION '||substr(stg_tab.table_name,5)||'_DEF'
2228: ||' VALUES (0, NULL) INTO (PARTITION '||substr(stg_tab.table_name,5)||'_LEG, PARTITION '|| substr(stg_tab.table_name,5)||'_DEF )';
2229:
2230: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,stg_tab.table_name||'.'||substr(stg_tab.table_name,5)||'_LEG');
2231: IF p_mode = 1 then
2232: EXEC_DDL(lv_sql_stmt);
2233: end if;
2234: end if;

Line 2248: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, c_rec.table_name||'.'||SUBSTR(c_rec.table_name, 8) || '_' || to_char(c_rec.instance_id));

2244: || ' VALUES (' || c_rec.instance_id || ') INTO (PARTITION '
2245: || SUBSTR(c_rec.table_name, 8) || '_' || to_char(c_rec.instance_id)
2246: || ' , PARTITION ' || SUBSTR(c_rec.table_name, 5) || '_DEF )';
2247:
2248: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, c_rec.table_name||'.'||SUBSTR(c_rec.table_name, 8) || '_' || to_char(c_rec.instance_id));
2249: IF p_mode = 1 then
2250: EXEC_DDL(lv_sql_stmt);
2251: end if;
2252: ELSE