DBA Data[Home] [Help]

APPS.MSC_CL_COLLECTION dependencies on MSC_CL_EXCHANGE_PARTTBL

Line 1397: prec in MSC_CL_EXCHANGE_PARTTBL.CollParamRec);

1393: /** PREPLACE CHANGE START **/
1394: --agmcont:
1395: PROCEDURE EXECUTE_PARTIAL_TASK( pSTATUS OUT NOCOPY NUMBER,
1396: pTASKNUM IN NUMBER,
1397: prec in MSC_CL_EXCHANGE_PARTTBL.CollParamRec);
1398: -- This procedure provides a separate flow for
1399: -- Partial Replacement.
1400:
1401:

Line 2290: prec in MSC_CL_EXCHANGE_PARTTBL.CollParamRec)

2286: /*************** PREPLACE CHANGE START *****************/
2287:
2288: PROCEDURE EXECUTE_PARTIAL_TASK( pSTATUS OUT NOCOPY NUMBER,
2289: pTASKNUM IN NUMBER,
2290: prec in MSC_CL_EXCHANGE_PARTTBL.CollParamRec)
2291:
2292: IS
2293:
2294: lv_task_start_time DATE;

Line 4197: IF MSC_CL_EXCHANGE_PARTTBL.Initialize( v_instance_id,

4193: v_so_exchange_mode:= MSC_UTIL.SYS_NO;
4194:
4195: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'check4 ');
4196: IF v_is_complete_refresh AND is_msctbl_partitioned('MSC_SYSTEM_ITEMS') THEN
4197: IF MSC_CL_EXCHANGE_PARTTBL.Initialize( v_instance_id,
4198: v_instance_code,
4199: v_is_so_complete_refresh) THEN
4200: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Initialized');
4201: IF MSC_CL_EXCHANGE_PARTTBL.Create_Temp_Tbl THEN

Line 4201: IF MSC_CL_EXCHANGE_PARTTBL.Create_Temp_Tbl THEN

4197: IF MSC_CL_EXCHANGE_PARTTBL.Initialize( v_instance_id,
4198: v_instance_code,
4199: v_is_so_complete_refresh) THEN
4200: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Initialized');
4201: IF MSC_CL_EXCHANGE_PARTTBL.Create_Temp_Tbl THEN
4202: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, ' CREATE TEMP TABLES DONE ');
4203: v_exchange_mode:= MSC_UTIL.SYS_YES;
4204:
4205: IF v_is_so_complete_refresh THEN

Line 4926: IF NOT MSC_CL_EXCHANGE_PARTTBL.Exchange_Partition THEN

4922: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'successfully altered phase 2 tables.' );
4923: NULL;
4924: END IF;
4925:
4926: IF NOT MSC_CL_EXCHANGE_PARTTBL.Exchange_Partition THEN
4927: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,
4928: 'Fatal Error in Exchange Partition.' );
4929: RETCODE:= MSC_UTIL.G_ERROR;
4930: END IF;

Line 4931: IF NOT MSC_CL_EXCHANGE_PARTTBL.Drop_Temp_Tbl THEN

4927: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,
4928: 'Fatal Error in Exchange Partition.' );
4929: RETCODE:= MSC_UTIL.G_ERROR;
4930: END IF;
4931: IF NOT MSC_CL_EXCHANGE_PARTTBL.Drop_Temp_Tbl THEN
4932: v_warning_flag:=MSC_UTIL.SYS_YES;
4933: END IF;
4934:
4935: END IF;

Line 5292: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

5288:
5289: IF RETCODE= MSC_UTIL.G_ERROR THEN
5290:
5291: --Rollback swap partitions
5292: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
5293: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
5294: END IF;
5295:
5296: RETURN;

Line 5321: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

5317: END IF;
5318:
5319: RETCODE := MSC_UTIL.G_ERROR;
5320: --Rollback swap partitions
5321: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
5322: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
5323: END IF;
5324:
5325: COMMIT;

Line 5343: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

5339: ERRBUF:= FND_MESSAGE.GET;
5340:
5341: RETCODE := MSC_UTIL.G_ERROR;
5342: --Rollback swap partitions
5343: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
5344: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
5345: END IF;
5346:
5347: COMMIT;

Line 5366: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

5362:
5363: RETCODE := MSC_UTIL.G_ERROR;
5364:
5365: --Rollback swap partitions
5366: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
5367: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
5368: END IF;
5369:
5370: COMMIT;

Line 5388: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

5384: ERRBUF := SQLERRM;
5385: RETCODE := MSC_UTIL.G_ERROR;
5386:
5387: --Rollback swap partitions
5388: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
5389: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
5390: END IF;
5391:
5392: COMMIT;

Line 5430: prec MSC_CL_EXCHANGE_PARTTBL.CollParamREC;

5426: FUNCTION Q_PARTIAL_TASK (p_instance_id NUMBER,
5427: p_task_num NUMBER)
5428: RETURN BOOLEAN AS
5429:
5430: prec MSC_CL_EXCHANGE_PARTTBL.CollParamREC;
5431: PTASK_DEMAND NUMBER;
5432:
5433: BEGIN
5434:

Line 5942: MSC_CL_EXCHANGE_PARTTBL.Initialize( v_instance_id,

5938: -- agmcont
5939: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, ' CREATE PARTITIONS ');
5940: IF (v_is_partial_refresh or v_is_cont_refresh) AND
5941: is_msctbl_partitioned('MSC_SYSTEM_ITEMS') AND
5942: MSC_CL_EXCHANGE_PARTTBL.Initialize( v_instance_id,
5943: v_instance_code,
5944: v_is_so_complete_refresh) THEN
5945: IF MSC_CL_EXCHANGE_PARTTBL.Create_Temp_Tbl THEN
5946: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, ' CREATE TEMP TABLES DONE ');

Line 5945: IF MSC_CL_EXCHANGE_PARTTBL.Create_Temp_Tbl THEN

5941: is_msctbl_partitioned('MSC_SYSTEM_ITEMS') AND
5942: MSC_CL_EXCHANGE_PARTTBL.Initialize( v_instance_id,
5943: v_instance_code,
5944: v_is_so_complete_refresh) THEN
5945: IF MSC_CL_EXCHANGE_PARTTBL.Create_Temp_Tbl THEN
5946: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, ' CREATE TEMP TABLES DONE ');
5947: v_exchange_mode:= MSC_UTIL.SYS_YES;
5948:
5949: IF v_is_so_complete_refresh THEN

Line 6882: IF NOT MSC_CL_EXCHANGE_PARTTBL.Exchange_Partition

6878: END IF;
6879:
6880: IF v_exchange_mode= MSC_UTIL.SYS_YES THEN
6881: MSC_CL_SETUP_ODS_LOAD.GET_COLL_PARAM (pINSTANCE_ID, v_coll_prec);
6882: IF NOT MSC_CL_EXCHANGE_PARTTBL.Exchange_Partition
6883: (v_coll_prec,
6884: v_is_cont_refresh) THEN
6885: /* Only those tables that have partial
6886: // replacement data loaded will be exchanged.

Line 6891: IF NOT MSC_CL_EXCHANGE_PARTTBL.Drop_Temp_Tbl THEN

6887: */
6888: RETCODE:= MSC_UTIL.G_ERROR;
6889: END IF;
6890: IF RETCODE <> MSC_UTIL.G_ERROR THEN
6891: IF NOT MSC_CL_EXCHANGE_PARTTBL.Drop_Temp_Tbl THEN
6892: v_warning_flag:=MSC_UTIL.SYS_YES;
6893: END IF;
6894: END IF;
6895:

Line 7353: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

7349: COMMIT;
7350: END IF;
7351: RETCODE:= MSC_UTIL.G_ERROR ;
7352: --Rollback swap partitions
7353: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
7354: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
7355: END IF;
7356:
7357: RETURN;

Line 7379: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

7375: END IF;
7376: END IF;
7377:
7378: --Rollback swap partitions
7379: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
7380: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
7381: END IF;
7382:
7383: -- DELETE SESSION INFO FROM MSC_COLL_PARAMETERS

Line 7406: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

7402: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
7403: ERRBUF:= FND_MESSAGE.GET;
7404:
7405: --Rollback swap partitions
7406: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
7407: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
7408: END IF;
7409:
7410: -- DELETE SESSION INFO FROM MSC_COLL_PARAMETERS

Line 7432: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

7428: FND_MESSAGE.SET_NAME('MSC', 'MSC_TIMEOUT');
7429: ERRBUF:= FND_MESSAGE.GET;
7430:
7431: --Rollback swap partitions
7432: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
7433: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
7434: END IF;
7435:
7436: -- DELETE SESSION INFO FROM MSC_COLL_PARAMETERS

Line 7457: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

7453:
7454: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, SQLERRM);
7455:
7456: --Rollback swap partitions
7457: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
7458: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
7459: END IF;
7460:
7461: -- DELETE SESSION INFO FROM MSC_COLL_PARAMETERS

Line 7639: IF MSC_CL_EXCHANGE_PARTTBL.Initialize( lv_instance_id,

7635: INTO lv_instance_id
7636: FROM msc_apps_instances
7637: WHERE upper(instance_code) = p_instance_code;
7638:
7639: IF MSC_CL_EXCHANGE_PARTTBL.Initialize( lv_instance_id,
7640: p_instance_code,
7641: FALSE) THEN
7642: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'MSC_CL_EXCHANGE_PARTTBL.Initialize successful');
7643: ELSE

Line 7642: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'MSC_CL_EXCHANGE_PARTTBL.Initialize successful');

7638:
7639: IF MSC_CL_EXCHANGE_PARTTBL.Initialize( lv_instance_id,
7640: p_instance_code,
7641: FALSE) THEN
7642: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'MSC_CL_EXCHANGE_PARTTBL.Initialize successful');
7643: ELSE
7644: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,'MSC_CL_EXCHANGE_PARTTBL.Initialize - failed');
7645: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, sqlerrm);
7646: RAISE EXCHG_PRT_ERROR;

Line 7644: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,'MSC_CL_EXCHANGE_PARTTBL.Initialize - failed');

7640: p_instance_code,
7641: FALSE) THEN
7642: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'MSC_CL_EXCHANGE_PARTTBL.Initialize successful');
7643: ELSE
7644: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,'MSC_CL_EXCHANGE_PARTTBL.Initialize - failed');
7645: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, sqlerrm);
7646: RAISE EXCHG_PRT_ERROR;
7647: END IF;
7648:

Line 7653: lv_crt_ind_status := MSC_CL_EXCHANGE_PARTTBL.create_temp_table_index

7649: lv_temp_tbl_name := SUBSTR(p_part_table, 5, LENGTH(p_part_table)) || '_' || p_instance_code;
7650:
7651: msc_analyse_tables_pk.analyse_table(lv_temp_tbl_name);
7652:
7653: lv_crt_ind_status := MSC_CL_EXCHANGE_PARTTBL.create_temp_table_index
7654: ('UNIQUE',
7655: p_part_table,
7656: lv_temp_tbl_name,
7657: p_instance_code,

Line 7691: lv_crt_ind_status := MSC_CL_EXCHANGE_PARTTBL.create_temp_table_index

7687:
7688: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,FND_MESSAGE.GET);
7689: END IF;
7690:
7691: lv_crt_ind_status := MSC_CL_EXCHANGE_PARTTBL.create_temp_table_index
7692: ('NONUNIQUE',
7693: p_part_table,
7694: lv_temp_tbl_name,
7695: p_instance_code,