DBA Data[Home] [Help]

APPS.MSC_CL_EXCHANGE_PARTTBL dependencies on MSC_CL_COLLECTION

Line 164: IF ( (MSC_CL_COLLECTION.v_apps_ver >= MSC_UTIL.G_EAM_CMRO_SUP_VER)

160: /* concatenate the tempTblList with the instance_code to be the exact
161: temp table name */
162: IF NOT v_is_TTL_initialized THEN
163: trc( 'ST:V_PARTtBLlIST COUNT = '|| to_char(v_partTblList.COUNT));
164: IF ( (MSC_CL_COLLECTION.v_apps_ver >= MSC_UTIL.G_EAM_CMRO_SUP_VER)
165: AND (MSC_UTIL.G_CMRO_EAM_INT_ENABLED = 'Y')) THEN
166: FOR i IN 1..v_partTblList.COUNT LOOP
167: v_tempTblList(i):= v_tempTblList(i)||v_instance_code;
168: END LOOP;

Line 539: MSC_CL_COLLECTION.G_WARNING

535: v_tempTblList(i),
536: v_instance_code,
537: v_instance_id,
538: SYS_NO,
539: MSC_CL_COLLECTION.G_WARNING
540: );
541:
542: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
543: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during unique index creation on table, ' || v_tempTblList(i));

Line 542: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN

538: SYS_NO,
539: MSC_CL_COLLECTION.G_WARNING
540: );
541:
542: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
543: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during unique index creation on table, ' || v_tempTblList(i));
544: ELSIF lv_crt_ind_status = MSC_CL_COLLECTION.G_ERROR THEN
545: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Error during unique index creation on table, ' || v_tempTblList(i));
546: RETURN FALSE;

Line 544: ELSIF lv_crt_ind_status = MSC_CL_COLLECTION.G_ERROR THEN

540: );
541:
542: IF lv_crt_ind_status = MSC_CL_COLLECTION.G_WARNING THEN
543: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Warning during unique index creation on table, ' || v_tempTblList(i));
544: ELSIF lv_crt_ind_status = MSC_CL_COLLECTION.G_ERROR THEN
545: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Error during unique index creation on table, ' || v_tempTblList(i));
546: RETURN FALSE;
547: ELSE
548: trc('Unique index creation successful on table, ' || v_tempTblList(i));

Line 616: || v_swapTblList(i).column_name || ' = ' || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_2

612: END IF;
613:
614: --if the table is in the ods-staging swap table list.
615: EXECUTE IMMEDIATE ' update msc_coll_parameters set '
616: || v_swapTblList(i).column_name || ' = ' || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_2
617: || ' where instance_id = ' || v_instance_id;
618:
619: END LOOP;
620:

Line 912: || v_swapTblList(j).column_name || ' = ' || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_2

908:
909: --if the table is in the ods-staging swap table list.
910: if lv_is_swap_table then
911: EXECUTE IMMEDIATE ' update msc_coll_parameters set '
912: || v_swapTblList(j).column_name || ' = ' || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_2
913: || ' where instance_id = ' || v_instance_id;
914: end if;
915:
916: END LOOP;

Line 973: EXECUTE IMMEDIATE ' select nvl(' ||v_swapTblList(i).column_name || ',' || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0 || ') from msc_coll_parameters '

969: BEGIN
970:
971: FOR i IN 1..v_swapTblList.COUNT LOOP
972:
973: EXECUTE IMMEDIATE ' select nvl(' ||v_swapTblList(i).column_name || ',' || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0 || ') from msc_coll_parameters '
974: || ' where instance_id = ' || v_instance_id
975: INTO lv_swap_status;
976:
977: If lv_swap_status = MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_2 then

Line 977: If lv_swap_status = MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_2 then

973: EXECUTE IMMEDIATE ' select nvl(' ||v_swapTblList(i).column_name || ',' || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0 || ') from msc_coll_parameters '
974: || ' where instance_id = ' || v_instance_id
975: INTO lv_swap_status;
976:
977: If lv_swap_status = MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_2 then
978:
979: msc_manage_plan_partitions.get_partition_name
980: ( -1,
981: v_instance_id,

Line 999: If lv_swap_status <> MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0 then

995: FOR j IN i..v_swapTblList.COUNT LOOP
996: EXECUTE IMMEDIATE ' select ' ||v_swapTblList(j).column_name || ' from msc_coll_parameters '
997: || ' where instance_id = ' || v_instance_id
998: INTO lv_swap_status;
999: If lv_swap_status <> MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0 then
1000: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,v_swapTblList(j).entity_name );
1001: End if;
1002: END LOOP;
1003:

Line 1006: lv_swap_status := MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1;

1002: END LOOP;
1003:
1004: return FALSE;
1005: END IF;
1006: lv_swap_status := MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1;
1007: End if;
1008:
1009: If lv_swap_status = MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1 then
1010:

Line 1009: If lv_swap_status = MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1 then

1005: END IF;
1006: lv_swap_status := MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1;
1007: End if;
1008:
1009: If lv_swap_status = MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1 then
1010:
1011: if NOT EXCHANGE_SINGLE_TAB_PARTN ( v_swapTblList(i).stg_table_name ,
1012: v_swapTblList(i).stg_table_partn_name ,
1013: v_swapTblList(i).temp_table_name,

Line 1021: If lv_swap_status <> MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0 then

1017: FOR j IN i..v_swapTblList.COUNT LOOP
1018: EXECUTE IMMEDIATE ' select ' ||v_swapTblList(j).column_name || ' from msc_coll_parameters '
1019: || ' where instance_id = ' || v_instance_id
1020: INTO lv_swap_status;
1021: If lv_swap_status <> MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0 then
1022: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,v_swapTblList(j).entity_name );
1023: End if;
1024: END LOOP;
1025:

Line 1032: || v_swapTblList(i).column_name || ' = ' || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0

1028: End if;
1029:
1030:
1031: EXECUTE IMMEDIATE ' update msc_coll_parameters set '
1032: || v_swapTblList(i).column_name || ' = ' || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0
1033: || ' where instance_id = ' || v_instance_id;
1034:
1035: End loop;
1036:

Line 1394: EXECUTE IMMEDIATE ' select nvl(' ||v_swapTblList(i).column_name || ',' || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0 || ') from msc_coll_parameters '

1390:
1391: /* EAM ends */
1392: FOR i IN 1..v_swapTblList.COUNT LOOP
1393:
1394: EXECUTE IMMEDIATE ' select nvl(' ||v_swapTblList(i).column_name || ',' || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0 || ') from msc_coll_parameters '
1395: || ' where instance_id = ' || v_instance_id
1396: INTO lv_swap_status;
1397:
1398: If lv_swap_status = MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1 then

Line 1398: If lv_swap_status = MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1 then

1394: EXECUTE IMMEDIATE ' select nvl(' ||v_swapTblList(i).column_name || ',' || MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_0 || ') from msc_coll_parameters '
1395: || ' where instance_id = ' || v_instance_id
1396: INTO lv_swap_status;
1397:
1398: If lv_swap_status = MSC_CL_COLLECTION.G_STG_ODS_SWP_PHASE_1 then
1399: lv_TblList.EXTEND; -- Extend the size
1400: tbl_count := tbl_count + 1;
1401: lv_TblList(tbl_count) := v_swapTblList(i).temp_table_name;
1402: END if;

Line 1856: lv_retval NUMBER := MSC_CL_COLLECTION.G_SUCCESS;

1852: lv_ind_stmt VARCHAR2(2048);
1853: lv_sql_stmt2 VARCHAR2(2048);
1854: lv_sql_stmt3 VARCHAR2(2048);
1855: lv_sql_stmt4 VARCHAR2(2048);
1856: lv_retval NUMBER := MSC_CL_COLLECTION.G_SUCCESS;
1857: TYPE CharTblTyp IS TABLE OF VARCHAR2(4000);
1858: lv_error_msg CharTblTyp;
1859: lv_extent_management VARCHAR2(10);
1860: lv_allocation_type VARCHAR2(9);

Line 2027: IF p_error_level = MSC_CL_COLLECTION.G_ERROR THEN

2023: WHEN OTHERS THEN
2024: /* handle unique index violation exception */
2025:
2026: IF SQLCODE IN (-00001, -01452, -12801) THEN
2027: IF p_error_level = MSC_CL_COLLECTION.G_ERROR THEN
2028: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'ERROR');
2029: ELSE
2030: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'WARNING');
2031: END IF;

Line 2080: IF p_error_level = MSC_CL_COLLECTION.G_ERROR THEN

2076: END LOOP;
2077:
2078: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '===========================================================');
2079:
2080: IF p_error_level = MSC_CL_COLLECTION.G_ERROR THEN
2081: lv_retval := MSC_CL_COLLECTION.G_ERROR;
2082: RAISE;
2083: ELSE
2084: lv_retval := MSC_CL_COLLECTION.G_WARNING;

Line 2081: lv_retval := MSC_CL_COLLECTION.G_ERROR;

2077:
2078: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '===========================================================');
2079:
2080: IF p_error_level = MSC_CL_COLLECTION.G_ERROR THEN
2081: lv_retval := MSC_CL_COLLECTION.G_ERROR;
2082: RAISE;
2083: ELSE
2084: lv_retval := MSC_CL_COLLECTION.G_WARNING;
2085: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The above records would not be collected');

Line 2084: lv_retval := MSC_CL_COLLECTION.G_WARNING;

2080: IF p_error_level = MSC_CL_COLLECTION.G_ERROR THEN
2081: lv_retval := MSC_CL_COLLECTION.G_ERROR;
2082: RAISE;
2083: ELSE
2084: lv_retval := MSC_CL_COLLECTION.G_WARNING;
2085: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The above records would not be collected');
2086: lv_sql_stmt4 := 'DELETE FROM ' || p_temp_table || ' t1 WHERE EXISTS '
2087: || '(SELECT 1 FROM ' || p_temp_table || ' t2 ' || lv_sql_stmt3
2088: || 't1.rowid < t2.rowid)';

Line 2103: lv_retval := MSC_CL_COLLECTION.G_ERROR;

2099: statement => v_sql_stmt,
2100: object_name => lv_temp_index_name);
2101: EXCEPTION
2102: WHEN OTHERS THEN
2103: lv_retval := MSC_CL_COLLECTION.G_ERROR;
2104: RAISE;
2105: END;
2106: END IF;
2107: ELSE

Line 2108: lv_retval := MSC_CL_COLLECTION.G_ERROR;

2104: RAISE;
2105: END;
2106: END IF;
2107: ELSE
2108: lv_retval := MSC_CL_COLLECTION.G_ERROR;
2109: RAISE;
2110: END IF;
2111: END;
2112: trc('Index creation done - ' || lv_temp_index_name);

Line 2122: lv_retval := MSC_CL_COLLECTION.G_ERROR;

2118: RETURN lv_retval;
2119:
2120: EXCEPTION
2121: WHEN OTHERS THEN
2122: lv_retval := MSC_CL_COLLECTION.G_ERROR;
2123: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>');
2124: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<>'||v_sql_stmt);
2125: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
2126: RETURN lv_retval;