DBA Data[Home] [Help]

APPS.MSC_CL_COLLECTION dependencies on MSC_CL_EXCHANGE_PARTTBL

Line 1379: prec in MSC_CL_EXCHANGE_PARTTBL.CollParamRec);

1375: /** PREPLACE CHANGE START **/
1376: --agmcont:
1377: PROCEDURE EXECUTE_PARTIAL_TASK( pSTATUS OUT NOCOPY NUMBER,
1378: pTASKNUM IN NUMBER,
1379: prec in MSC_CL_EXCHANGE_PARTTBL.CollParamRec);
1380: -- This procedure provides a separate flow for
1381: -- Partial Replacement.
1382:
1383:

Line 1993: prec in MSC_CL_EXCHANGE_PARTTBL.CollParamRec)

1989: /*************** PREPLACE CHANGE START *****************/
1990:
1991: PROCEDURE EXECUTE_PARTIAL_TASK( pSTATUS OUT NOCOPY NUMBER,
1992: pTASKNUM IN NUMBER,
1993: prec in MSC_CL_EXCHANGE_PARTTBL.CollParamRec)
1994:
1995: IS
1996:
1997: lv_task_start_time DATE;

Line 3594: IF MSC_CL_EXCHANGE_PARTTBL.Initialize( v_instance_id,

3590: v_so_exchange_mode:= MSC_UTIL.SYS_NO;
3591:
3592: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'check4 ');
3593: IF v_is_complete_refresh AND is_msctbl_partitioned('MSC_SYSTEM_ITEMS') THEN
3594: IF MSC_CL_EXCHANGE_PARTTBL.Initialize( v_instance_id,
3595: v_instance_code,
3596: v_is_so_complete_refresh) THEN
3597: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Initialized');
3598: IF MSC_CL_EXCHANGE_PARTTBL.Create_Temp_Tbl THEN

Line 3598: IF MSC_CL_EXCHANGE_PARTTBL.Create_Temp_Tbl THEN

3594: IF MSC_CL_EXCHANGE_PARTTBL.Initialize( v_instance_id,
3595: v_instance_code,
3596: v_is_so_complete_refresh) THEN
3597: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Initialized');
3598: IF MSC_CL_EXCHANGE_PARTTBL.Create_Temp_Tbl THEN
3599: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, ' CREATE TEMP TABLES DONE ');
3600: v_exchange_mode:= MSC_UTIL.SYS_YES;
3601:
3602: IF v_is_so_complete_refresh THEN

Line 4300: IF NOT MSC_CL_EXCHANGE_PARTTBL.Exchange_Partition THEN

4296: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'successfully altered phase 2 tables.' );
4297: NULL;
4298: END IF;
4299:
4300: IF NOT MSC_CL_EXCHANGE_PARTTBL.Exchange_Partition THEN
4301: RETCODE:= MSC_UTIL.G_ERROR;
4302: END IF;
4303: IF NOT MSC_CL_EXCHANGE_PARTTBL.Drop_Temp_Tbl THEN
4304: v_warning_flag:=MSC_UTIL.SYS_YES;

Line 4303: IF NOT MSC_CL_EXCHANGE_PARTTBL.Drop_Temp_Tbl THEN

4299:
4300: IF NOT MSC_CL_EXCHANGE_PARTTBL.Exchange_Partition THEN
4301: RETCODE:= MSC_UTIL.G_ERROR;
4302: END IF;
4303: IF NOT MSC_CL_EXCHANGE_PARTTBL.Drop_Temp_Tbl THEN
4304: v_warning_flag:=MSC_UTIL.SYS_YES;
4305: END IF;
4306: END IF;
4307:

Line 4601: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

4597:
4598: IF RETCODE= MSC_UTIL.G_ERROR THEN
4599:
4600: --Rollback swap partitions
4601: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
4602: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
4603: END IF;
4604:
4605: RETURN;

Line 4630: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

4626: END IF;
4627:
4628: RETCODE := MSC_UTIL.G_ERROR;
4629: --Rollback swap partitions
4630: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
4631: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
4632: END IF;
4633:
4634: COMMIT;

Line 4652: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

4648: ERRBUF:= FND_MESSAGE.GET;
4649:
4650: RETCODE := MSC_UTIL.G_ERROR;
4651: --Rollback swap partitions
4652: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
4653: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
4654: END IF;
4655:
4656: COMMIT;

Line 4675: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

4671:
4672: RETCODE := MSC_UTIL.G_ERROR;
4673:
4674: --Rollback swap partitions
4675: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
4676: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
4677: END IF;
4678:
4679: COMMIT;

Line 4697: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

4693: ERRBUF := SQLERRM;
4694: RETCODE := MSC_UTIL.G_ERROR;
4695:
4696: --Rollback swap partitions
4697: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
4698: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
4699: END IF;
4700:
4701: COMMIT;

Line 4739: prec MSC_CL_EXCHANGE_PARTTBL.CollParamREC;

4735: FUNCTION Q_PARTIAL_TASK (p_instance_id NUMBER,
4736: p_task_num NUMBER)
4737: RETURN BOOLEAN AS
4738:
4739: prec MSC_CL_EXCHANGE_PARTTBL.CollParamREC;
4740: PTASK_DEMAND NUMBER;
4741:
4742: BEGIN
4743:

Line 5176: MSC_CL_EXCHANGE_PARTTBL.Initialize( v_instance_id,

5172: -- agmcont
5173: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, ' CREATE PARTITIONS ');
5174: IF (v_is_partial_refresh or v_is_cont_refresh) AND
5175: is_msctbl_partitioned('MSC_SYSTEM_ITEMS') AND
5176: MSC_CL_EXCHANGE_PARTTBL.Initialize( v_instance_id,
5177: v_instance_code,
5178: v_is_so_complete_refresh) THEN
5179: IF MSC_CL_EXCHANGE_PARTTBL.Create_Temp_Tbl THEN
5180: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, ' CREATE TEMP TABLES DONE ');

Line 5179: IF MSC_CL_EXCHANGE_PARTTBL.Create_Temp_Tbl THEN

5175: is_msctbl_partitioned('MSC_SYSTEM_ITEMS') AND
5176: MSC_CL_EXCHANGE_PARTTBL.Initialize( v_instance_id,
5177: v_instance_code,
5178: v_is_so_complete_refresh) THEN
5179: IF MSC_CL_EXCHANGE_PARTTBL.Create_Temp_Tbl THEN
5180: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, ' CREATE TEMP TABLES DONE ');
5181: v_exchange_mode:= MSC_UTIL.SYS_YES;
5182:
5183: IF v_is_so_complete_refresh THEN

Line 6072: IF NOT MSC_CL_EXCHANGE_PARTTBL.Exchange_Partition

6068: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'successfully altered phase 2 tables.' );
6069: END IF;
6070:
6071: MSC_CL_SETUP_ODS_LOAD.GET_COLL_PARAM (pINSTANCE_ID, v_coll_prec);
6072: IF NOT MSC_CL_EXCHANGE_PARTTBL.Exchange_Partition
6073: (v_coll_prec,
6074: v_is_cont_refresh) THEN
6075: /* Only those tables that have partial
6076: // replacement data loaded will be exchanged.

Line 6081: IF NOT MSC_CL_EXCHANGE_PARTTBL.Drop_Temp_Tbl THEN

6077: */
6078: RETCODE:= MSC_UTIL.G_ERROR;
6079: END IF;
6080: IF RETCODE <> MSC_UTIL.G_ERROR THEN
6081: IF NOT MSC_CL_EXCHANGE_PARTTBL.Drop_Temp_Tbl THEN
6082: v_warning_flag:=MSC_UTIL.SYS_YES;
6083: END IF;
6084: END IF;
6085: END IF;

Line 6478: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

6474: COMMIT;
6475: END IF;
6476: RETCODE:= MSC_UTIL.G_ERROR ;
6477: --Rollback swap partitions
6478: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
6479: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
6480: END IF;
6481:
6482: RETURN;

Line 6504: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

6500: END IF;
6501: END IF;
6502:
6503: --Rollback swap partitions
6504: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
6505: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
6506: END IF;
6507:
6508: -- DELETE SESSION INFO FROM MSC_COLL_PARAMETERS

Line 6531: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

6527: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
6528: ERRBUF:= FND_MESSAGE.GET;
6529:
6530: --Rollback swap partitions
6531: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
6532: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
6533: END IF;
6534:
6535: -- DELETE SESSION INFO FROM MSC_COLL_PARAMETERS

Line 6557: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

6553: FND_MESSAGE.SET_NAME('MSC', 'MSC_TIMEOUT');
6554: ERRBUF:= FND_MESSAGE.GET;
6555:
6556: --Rollback swap partitions
6557: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
6558: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
6559: END IF;
6560:
6561: -- DELETE SESSION INFO FROM MSC_COLL_PARAMETERS

Line 6582: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN

6578:
6579: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, SQLERRM);
6580:
6581: --Rollback swap partitions
6582: IF NOT MSC_CL_EXCHANGE_PARTTBL.UNDO_STG_ODS_SWAP THEN
6583: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,' Exchange partition failed ');
6584: END IF;
6585:
6586: -- DELETE SESSION INFO FROM MSC_COLL_PARAMETERS

Line 6762: IF MSC_CL_EXCHANGE_PARTTBL.Initialize( lv_instance_id,

6758: INTO lv_instance_id
6759: FROM msc_apps_instances
6760: WHERE upper(instance_code) = p_instance_code;
6761:
6762: IF MSC_CL_EXCHANGE_PARTTBL.Initialize( lv_instance_id,
6763: p_instance_code,
6764: FALSE) THEN
6765: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'MSC_CL_EXCHANGE_PARTTBL.Initialize successful');
6766: ELSE

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

6761:
6762: IF MSC_CL_EXCHANGE_PARTTBL.Initialize( lv_instance_id,
6763: p_instance_code,
6764: FALSE) THEN
6765: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'MSC_CL_EXCHANGE_PARTTBL.Initialize successful');
6766: ELSE
6767: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,'MSC_CL_EXCHANGE_PARTTBL.Initialize - failed');
6768: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, sqlerrm);
6769: RAISE EXCHG_PRT_ERROR;

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

6763: p_instance_code,
6764: FALSE) THEN
6765: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'MSC_CL_EXCHANGE_PARTTBL.Initialize successful');
6766: ELSE
6767: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR,'MSC_CL_EXCHANGE_PARTTBL.Initialize - failed');
6768: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, sqlerrm);
6769: RAISE EXCHG_PRT_ERROR;
6770: END IF;
6771:

Line 6776: lv_crt_ind_status := MSC_CL_EXCHANGE_PARTTBL.create_temp_table_index

6772: lv_temp_tbl_name := SUBSTR(p_part_table, 5, LENGTH(p_part_table)) || '_' || p_instance_code;
6773:
6774: msc_analyse_tables_pk.analyse_table(lv_temp_tbl_name);
6775:
6776: lv_crt_ind_status := MSC_CL_EXCHANGE_PARTTBL.create_temp_table_index
6777: ('UNIQUE',
6778: p_part_table,
6779: lv_temp_tbl_name,
6780: p_instance_code,

Line 6814: lv_crt_ind_status := MSC_CL_EXCHANGE_PARTTBL.create_temp_table_index

6810:
6811: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,FND_MESSAGE.GET);
6812: END IF;
6813:
6814: lv_crt_ind_status := MSC_CL_EXCHANGE_PARTTBL.create_temp_table_index
6815: ('NONUNIQUE',
6816: p_part_table,
6817: lv_temp_tbl_name,
6818: p_instance_code,