DBA Data[Home] [Help]

APPS.CZ_PB_SYNC dependencies on CZ_PB_SYNC

Line 1: PACKAGE BODY cz_pb_sync AS

1: PACKAGE BODY cz_pb_sync AS
2: /* $Header: czpbsynb.pls 120.4.12010000.3 2008/10/29 19:50:29 lamrute ship $ */
3:
4: --------package variable declaration
5: TYPE t_ref IS TABLE OF NUMBER INDEX BY BINARY_INTEGER;

Line 8: m_msg_tbl cz_pb_sync_util.message_list;

4: --------package variable declaration
5: TYPE t_ref IS TABLE OF NUMBER INDEX BY BINARY_INTEGER;
6: TYPE t_name IS TABLE OF VARCHAR2(255) INDEX BY BINARY_INTEGER;
7:
8: m_msg_tbl cz_pb_sync_util.message_list;
9: m_err_message VARCHAR2(2000);
10:
11: SRC_SERVER_FLAG cz_servers.source_server_flag%TYPE := '1';
12:

Line 106: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_SRC_INSTANCE', 'INSTANCE', l_instance_name);

102: FROM cz_servers
103: WHERE cz_servers.source_server_flag = SRC_SERVER_FLAG;
104:
105: IF (l_src_count <> 0) THEN
106: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_SRC_INSTANCE', 'INSTANCE', l_instance_name);
107: error_msg_populate(m_err_message ,'CZ_PB_SYNC.VERIFYSRCINST',21061);
108: RETURN FALSE;
109: END IF;
110:

Line 107: error_msg_populate(m_err_message ,'CZ_PB_SYNC.VERIFYSRCINST',21061);

103: WHERE cz_servers.source_server_flag = SRC_SERVER_FLAG;
104:
105: IF (l_src_count <> 0) THEN
106: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_SRC_INSTANCE', 'INSTANCE', l_instance_name);
107: error_msg_populate(m_err_message ,'CZ_PB_SYNC.VERIFYSRCINST',21061);
108: RETURN FALSE;
109: END IF;
110:
111: SELECT COUNT(*)

Line 118: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_SRC_INSTANCE','SRCINSTANCE',l_instance_name);

114: WHERE UPPER(host_name) = UPPER(l_hostname)
115: AND UPPER(instance_name) = UPPER(l_instance_name);
116:
117: IF (x_src_verification = 0) THEN
118: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_SRC_INSTANCE','SRCINSTANCE',l_instance_name);
119: error_msg_populate(m_err_message ,'CZ_PB_SYNC.VERIFYSRCINST',21061);
120: RETURN FALSE;
121: END IF;
122:

Line 119: error_msg_populate(m_err_message ,'CZ_PB_SYNC.VERIFYSRCINST',21061);

115: AND UPPER(instance_name) = UPPER(l_instance_name);
116:
117: IF (x_src_verification = 0) THEN
118: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_SRC_INSTANCE','SRCINSTANCE',l_instance_name);
119: error_msg_populate(m_err_message ,'CZ_PB_SYNC.VERIFYSRCINST',21061);
120: RETURN FALSE;
121: END IF;
122:
123: v_target_server_id := cz_pb_sync_util.get_target_instance_id(p_target_instance);

Line 123: v_target_server_id := cz_pb_sync_util.get_target_instance_id(p_target_instance);

119: error_msg_populate(m_err_message ,'CZ_PB_SYNC.VERIFYSRCINST',21061);
120: RETURN FALSE;
121: END IF;
122:
123: v_target_server_id := cz_pb_sync_util.get_target_instance_id(p_target_instance);
124: v_link_name := cz_pb_sync_util.retrieve_link_name(v_target_server_id);
125: IF (NOT verify_src_server_entry(v_link_name,l_instance_name) ) THEN
126: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_TGT_INSTANCE',
127: 'TGTINSTANCE', p_target_instance,

Line 124: v_link_name := cz_pb_sync_util.retrieve_link_name(v_target_server_id);

120: RETURN FALSE;
121: END IF;
122:
123: v_target_server_id := cz_pb_sync_util.get_target_instance_id(p_target_instance);
124: v_link_name := cz_pb_sync_util.retrieve_link_name(v_target_server_id);
125: IF (NOT verify_src_server_entry(v_link_name,l_instance_name) ) THEN
126: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_TGT_INSTANCE',
127: 'TGTINSTANCE', p_target_instance,
128: 'SRCINSTANCE', l_instance_name);

Line 126: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_TGT_INSTANCE',

122:
123: v_target_server_id := cz_pb_sync_util.get_target_instance_id(p_target_instance);
124: v_link_name := cz_pb_sync_util.retrieve_link_name(v_target_server_id);
125: IF (NOT verify_src_server_entry(v_link_name,l_instance_name) ) THEN
126: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_TGT_INSTANCE',
127: 'TGTINSTANCE', p_target_instance,
128: 'SRCINSTANCE', l_instance_name);
129: error_msg_populate(m_err_message ,'CZ_PB_SYNC.VERIFYSRCENTRY',21061);
130: RETURN FALSE;

Line 129: error_msg_populate(m_err_message ,'CZ_PB_SYNC.VERIFYSRCENTRY',21061);

125: IF (NOT verify_src_server_entry(v_link_name,l_instance_name) ) THEN
126: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_TGT_INSTANCE',
127: 'TGTINSTANCE', p_target_instance,
128: 'SRCINSTANCE', l_instance_name);
129: error_msg_populate(m_err_message ,'CZ_PB_SYNC.VERIFYSRCENTRY',21061);
130: RETURN FALSE;
131: END IF;
132:
133: RETURN v_flag;

Line 176: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_A_CLONE', 'INSTANCENAME',v_instance_name);

172: OR (UPPER(l_host_name) <> UPPER(v_host_name)) ) THEN
173: v_return_flg := FALSE;
174: ELSE
175: IF (v_notes IS NULL) THEN
176: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_A_CLONE', 'INSTANCENAME',v_instance_name);
177: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETLINKNAME',21011);
178: v_return_flg := TRUE;
179: ELSE
180: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_ALREADY_SYNCED','INSTANCENAME',v_instance_name, 'SYNCDATE',v_notes);

Line 177: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETLINKNAME',21011);

173: v_return_flg := FALSE;
174: ELSE
175: IF (v_notes IS NULL) THEN
176: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_A_CLONE', 'INSTANCENAME',v_instance_name);
177: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETLINKNAME',21011);
178: v_return_flg := TRUE;
179: ELSE
180: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_ALREADY_SYNCED','INSTANCENAME',v_instance_name, 'SYNCDATE',v_notes);
181: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETLINKNAME',21011);

Line 180: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_ALREADY_SYNCED','INSTANCENAME',v_instance_name, 'SYNCDATE',v_notes);

176: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NOT_A_CLONE', 'INSTANCENAME',v_instance_name);
177: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETLINKNAME',21011);
178: v_return_flg := TRUE;
179: ELSE
180: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_ALREADY_SYNCED','INSTANCENAME',v_instance_name, 'SYNCDATE',v_notes);
181: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETLINKNAME',21011);
182: v_return_flg := TRUE;
183: END IF;
184: END IF;

Line 181: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETLINKNAME',21011);

177: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETLINKNAME',21011);
178: v_return_flg := TRUE;
179: ELSE
180: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_ALREADY_SYNCED','INSTANCENAME',v_instance_name, 'SYNCDATE',v_notes);
181: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETLINKNAME',21011);
182: v_return_flg := TRUE;
183: END IF;
184: END IF;
185: RETURN v_return_flg;

Line 349: v_link_name := cz_pb_sync_util.retrieve_link_name(p_tgt_server_id);

345: BEGIN
346: FOR I IN 1..1
347: LOOP
348: ------get db link name for tgt instance
349: v_link_name := cz_pb_sync_util.retrieve_link_name(p_tgt_server_id);
350: IF ( NOT cz_pb_sync_util.check_db_link(v_link_name) ) THEN
351: v_sync_flag := FALSE;
352: EXIT;
353: END IF;

Line 350: IF ( NOT cz_pb_sync_util.check_db_link(v_link_name) ) THEN

346: FOR I IN 1..1
347: LOOP
348: ------get db link name for tgt instance
349: v_link_name := cz_pb_sync_util.retrieve_link_name(p_tgt_server_id);
350: IF ( NOT cz_pb_sync_util.check_db_link(v_link_name) ) THEN
351: v_sync_flag := FALSE;
352: EXIT;
353: END IF;
354:

Line 358: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NO_TGT_ID_FOUND', 'INSTANCENAME',v_link_name);

354:
355: ------verify that server ids on the source and target are the same
356: v_sync_flag := verify_src_tgt_instances(v_link_name);
357: IF (NOT v_sync_flag) THEN
358: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NO_TGT_ID_FOUND', 'INSTANCENAME',v_link_name);
359: error_msg_populate(m_err_message ,'CZ_PB_SYNC.NOTGTIDFOUND',21011);
360: EXIT;
361: END IF;
362:

Line 359: error_msg_populate(m_err_message ,'CZ_PB_SYNC.NOTGTIDFOUND',21011);

355: ------verify that server ids on the source and target are the same
356: v_sync_flag := verify_src_tgt_instances(v_link_name);
357: IF (NOT v_sync_flag) THEN
358: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NO_TGT_ID_FOUND', 'INSTANCENAME',v_link_name);
359: error_msg_populate(m_err_message ,'CZ_PB_SYNC.NOTGTIDFOUND',21011);
360: EXIT;
361: END IF;
362:
363: ----verify persistent model ids on source and target instances

Line 366: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_MODELS_ERR');

362:
363: ----verify persistent model ids on source and target instances
364: v_sync_flag := verify_src_tgt_models(v_link_name);
365: IF (NOT v_sync_flag) THEN
366: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_MODELS_ERR');
367: error_msg_populate(m_err_message ,'CZ_PB_SYNC.SRCTGTMODELS',21009);
368: v_sync_flag := FALSE;
369: EXIT;
370: END IF;

Line 367: error_msg_populate(m_err_message ,'CZ_PB_SYNC.SRCTGTMODELS',21009);

363: ----verify persistent model ids on source and target instances
364: v_sync_flag := verify_src_tgt_models(v_link_name);
365: IF (NOT v_sync_flag) THEN
366: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_MODELS_ERR');
367: error_msg_populate(m_err_message ,'CZ_PB_SYNC.SRCTGTMODELS',21009);
368: v_sync_flag := FALSE;
369: EXIT;
370: END IF;
371:

Line 375: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_REM_PB_ID_ERR', 'TGTINSTANCE',v_link_name );

371:
372: ----verify remote publication ids
373: v_sync_flag := verify_src_tgt_pb_ids(v_link_name);
374: IF (NOT v_sync_flag) THEN
375: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_REM_PB_ID_ERR', 'TGTINSTANCE',v_link_name );
376: error_msg_populate(m_err_message ,'CZ_PB_SYNC.VERIFYSRCTGTPBIDS',21010);
377: v_sync_flag := FALSE;
378: EXIT;
379: END IF;

Line 376: error_msg_populate(m_err_message ,'CZ_PB_SYNC.VERIFYSRCTGTPBIDS',21010);

372: ----verify remote publication ids
373: v_sync_flag := verify_src_tgt_pb_ids(v_link_name);
374: IF (NOT v_sync_flag) THEN
375: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_REM_PB_ID_ERR', 'TGTINSTANCE',v_link_name );
376: error_msg_populate(m_err_message ,'CZ_PB_SYNC.VERIFYSRCTGTPBIDS',21010);
377: v_sync_flag := FALSE;
378: EXIT;
379: END IF;
380: END LOOP;

Line 402: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_PB_REC_ERR', 'PUBID', p_publication_id, 'SQLERRM', SQLERRM);

398: /* DELETE FROM cz_model_publications
399: WHERE publication_id = p_publication_id; */
400: EXCEPTION
401: WHEN OTHERS THEN
402: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_PB_REC_ERR', 'PUBID', p_publication_id, 'SQLERRM', SQLERRM);
403: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRSRCPBRECORD',SQLCODE);
404: RAISE;
405: END clear_source_pb_record;
406:

Line 403: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRSRCPBRECORD',SQLCODE);

399: WHERE publication_id = p_publication_id; */
400: EXCEPTION
401: WHEN OTHERS THEN
402: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_PB_REC_ERR', 'PUBID', p_publication_id, 'SQLERRM', SQLERRM);
403: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRSRCPBRECORD',SQLCODE);
404: RAISE;
405: END clear_source_pb_record;
406:
407: ----------------------------------------------------

Line 417: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_PB_CLIENT_ERR', 'PUBID',p_publication_id, 'SQLERRM', SQLERRM);

413: DELETE FROM cz_pb_client_apps
414: WHERE publication_id = p_publication_id;
415: EXCEPTION
416: WHEN OTHERS THEN
417: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_PB_CLIENT_ERR', 'PUBID',p_publication_id, 'SQLERRM', SQLERRM);
418: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRPBCLIENTS',SQLCODE);
419: RAISE;
420: END clear_pb_clients;
421:

Line 418: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRPBCLIENTS',SQLCODE);

414: WHERE publication_id = p_publication_id;
415: EXCEPTION
416: WHEN OTHERS THEN
417: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_PB_CLIENT_ERR', 'PUBID',p_publication_id, 'SQLERRM', SQLERRM);
418: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRPBCLIENTS',SQLCODE);
419: RAISE;
420: END clear_pb_clients;
421:
422: -----------------------------------------------------

Line 432: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_LANG_ERR','PUBID',p_publication_id, 'SQLERRM', SQLERRM);

428: DELETE FROM cz_pb_languages
429: WHERE publication_id = p_publication_id;
430: EXCEPTION
431: WHEN OTHERS THEN
432: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_LANG_ERR','PUBID',p_publication_id, 'SQLERRM', SQLERRM);
433: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRPBCLIENTS',SQLCODE);
434: RAISE;
435: END clear_pb_lang;
436:

Line 433: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRPBCLIENTS',SQLCODE);

429: WHERE publication_id = p_publication_id;
430: EXCEPTION
431: WHEN OTHERS THEN
432: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_LANG_ERR','PUBID',p_publication_id, 'SQLERRM', SQLERRM);
433: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRPBCLIENTS',SQLCODE);
434: RAISE;
435: END clear_pb_lang;
436:
437: -----------------------------------------------------

Line 447: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_PB_USAGE_ERR','PUBID',p_publication_id, 'SQLERRM', SQLERRM);

443: DELETE FROM cz_publication_usages
444: WHERE publication_id = p_publication_id;
445: EXCEPTION
446: WHEN OTHERS THEN
447: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_PB_USAGE_ERR','PUBID',p_publication_id, 'SQLERRM', SQLERRM);
448: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRPBUSAGES',SQLCODE);
449: RAISE;
450: END clear_pb_usages;
451:

Line 448: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRPBUSAGES',SQLCODE);

444: WHERE publication_id = p_publication_id;
445: EXCEPTION
446: WHEN OTHERS THEN
447: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_PB_USAGE_ERR','PUBID',p_publication_id, 'SQLERRM', SQLERRM);
448: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRPBUSAGES',SQLCODE);
449: RAISE;
450: END clear_pb_usages;
451:
452: --------------------------------------------------------

Line 461: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_PB_EXPORTS_ERR', 'SQLERRM', SQLERRM);

457: BEGIN
458: delete from cz_pb_model_exports;
459: EXCEPTION
460: WHEN OTHERS THEN
461: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_PB_EXPORTS_ERR', 'SQLERRM', SQLERRM);
462: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRPBEXPORTS',SQLCODE);
463: RAISE;
464: END clear_pb_exports;
465:

Line 462: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRPBEXPORTS',SQLCODE);

458: delete from cz_pb_model_exports;
459: EXCEPTION
460: WHEN OTHERS THEN
461: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_PB_EXPORTS_ERR', 'SQLERRM', SQLERRM);
462: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CLRPBEXPORTS',SQLCODE);
463: RAISE;
464: END clear_pb_exports;
465:
466: ---------------------------------------------------------

Line 544: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETLOCALIDS',SQLCODE);

540: INTO p_org_id USING l_org_id;
541:
542: EXCEPTION WHEN NO_DATA_FOUND THEN
543: m_err_message := 'Unable to find organization definition in import source';
544: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETLOCALIDS',SQLCODE);
545: RAISE;
546: END;
547:
548: -- Transform Item ID

Line 575: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETLOCALIDS',SQLCODE);

571: CLOSE c_local_item_id;
572:
573: EXCEPTION WHEN NO_DATA_FOUND THEN
574: m_err_message := 'Unable to find item definition in import source .';
575: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETLOCALIDS',SQLCODE);
576: IF c_local_item_id%ISOPEN THEN
577: CLOSE c_local_item_id;
578: END IF;
579: RAISE;

Line 906: l_link_name := cz_pb_sync_util.retrieve_link_name(p_tgt_server_id);

902: OBJ_TYPE_ERR EXCEPTION;
903:
904: BEGIN
905: clear_publication_data(p_tgt_server_id);
906: l_link_name := cz_pb_sync_util.retrieve_link_name(p_tgt_server_id);
907:
908: l_tgt_src_pub_tbl.DELETE;
909: l_tgt_rem_pub_tbl.DELETE;
910: l_tgt_object_id_tbl.DELETE;

Line 993: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_TGT_PB',

989: WHERE cz_model_publications.publication_id = l_tgt_rem_pub_tbl(i);
990: EXCEPTION
991: WHEN NO_DATA_FOUND THEN
992: ----delete tgt_publication
993: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_DEL_TGT_PB',
994: 'TGTPBID',l_tgt_rem_pub_tbl(i));
995: error_msg_populate(m_err_message ,'CZ_PB_MGR.DELTGTPBID',SQLCODE);
996: delete_tgt_publication(l_tgt_src_pub_tbl(i),l_link_name);
997: WHEN OTHERS THEN

Line 1061: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_MODELS_ERR',

1057: EXCEPTION
1058: WHEN MODEL_MISMATCH_ERR THEN
1059: ----get source and target info
1060: get_src_tgt_info(p_tgt_server_id, l_src_instance,l_tgt_instance);
1061: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_MODELS_ERR',
1062: 'SRCMODEL',l_src_object_id,
1063: 'SRCINSTANCE',l_src_instance,
1064: 'TGTMODEL',l_tgt_object_id,
1065: 'TGTINSTANCE',l_tgt_instance);

Line 1081: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_UIS_ERR',

1077: RAISE;
1078: WHEN UI_MISMATCH_ERR THEN
1079: ----get source and target info
1080: get_src_tgt_info(p_tgt_server_id, l_src_instance,l_tgt_instance);
1081: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_UIS_ERR',
1082: 'SRCUIDEF',l_src_ui_def_id,
1083: 'SRCINSTANCE',l_src_instance,
1084: 'TGTUIDEF',l_tgt_ui_def_id,
1085: 'TGTINSTANCE',l_tgt_instance);

Line 1100: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_MODELNAME_ERR',

1096: RAISE;
1097: WHEN MODELNAME_MISMATCH_ERR THEN
1098: ----get source and target info
1099: get_src_tgt_info(p_tgt_server_id, l_src_instance,l_tgt_instance);
1100: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_MODELNAME_ERR',
1101: 'SRCMODEL',l_src_object_name,
1102: 'SRCINSTANCE',l_src_instance,
1103: 'TGTMODEL',l_tgt_object_name,
1104: 'TGTINSTANCE',l_tgt_instance);

Line 1119: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_TEMPLNAME_ERR',

1115: RAISE;
1116: WHEN TEMPLNAME_MISMATCH_ERR THEN
1117: ----get source and target info
1118: get_src_tgt_info(p_tgt_server_id, l_src_instance,l_tgt_instance);
1119: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_TEMPLNAME_ERR',
1120: 'SRCTEMPL',l_src_object_name,
1121: 'SRCINSTANCE',l_src_instance,
1122: 'TGTTEMPL',l_tgt_object_name,
1123: 'TGTINSTANCE',l_tgt_instance);

Line 1140: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_TYPE_ERR',

1136: RAISE;
1137: WHEN OBJ_TYPE_MISMATCH_ERR THEN
1138: ----get source and target info
1139: get_src_tgt_info(p_tgt_server_id, l_src_instance,l_tgt_instance);
1140: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_TYPE_ERR',
1141: 'TGTTYPE', l_tgt_object_type,
1142: 'TGTPUBID',l_publication_id,
1143: 'TGTINSTANCE',l_tgt_instance,
1144: 'SRCTYPE', l_src_object_type,

Line 1210: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_INPUT_INST_NULL');

1206: v_ret_flag BOOLEAN := TRUE;
1207:
1208: BEGIN
1209: IF (p_target_instance IS NULL) THEN
1210: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_INPUT_INST_NULL');
1211: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);
1212: v_ret_flag := FALSE;
1213: ELSE
1214: SELECT instance_name,hostname,db_listener_port,fndnam_link_name

Line 1211: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);

1207:
1208: BEGIN
1209: IF (p_target_instance IS NULL) THEN
1210: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_INPUT_INST_NULL');
1211: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);
1212: v_ret_flag := FALSE;
1213: ELSE
1214: SELECT instance_name,hostname,db_listener_port,fndnam_link_name
1215: INTO l_instance_name,l_host_name,l_listener_port,l_fndnam_link_name

Line 1220: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_INSTANCE_IS_NULL', 'TGTINSTANCE',p_target_instance);

1216: FROM cz_servers
1217: WHERE UPPER(cz_servers.local_name) = UPPER(p_target_instance);
1218:
1219: IF (l_instance_name IS NULL) THEN
1220: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_INSTANCE_IS_NULL', 'TGTINSTANCE',p_target_instance);
1221: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);
1222: v_ret_flag := FALSE;
1223: END IF;
1224:

Line 1221: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);

1217: WHERE UPPER(cz_servers.local_name) = UPPER(p_target_instance);
1218:
1219: IF (l_instance_name IS NULL) THEN
1220: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_INSTANCE_IS_NULL', 'TGTINSTANCE',p_target_instance);
1221: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);
1222: v_ret_flag := FALSE;
1223: END IF;
1224:
1225: IF (l_host_name IS NULL) THEN

Line 1226: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_HOST_IS_NULL','TGTINSTANCE',p_target_instance);

1222: v_ret_flag := FALSE;
1223: END IF;
1224:
1225: IF (l_host_name IS NULL) THEN
1226: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_HOST_IS_NULL','TGTINSTANCE',p_target_instance);
1227: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);
1228: v_ret_flag := FALSE;
1229: END IF;
1230:

Line 1227: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);

1223: END IF;
1224:
1225: IF (l_host_name IS NULL) THEN
1226: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_HOST_IS_NULL','TGTINSTANCE',p_target_instance);
1227: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);
1228: v_ret_flag := FALSE;
1229: END IF;
1230:
1231: IF (l_listener_port IS NULL) THEN

Line 1232: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_PORT_IS_NULL','TGTINSTANCE',p_target_instance);

1228: v_ret_flag := FALSE;
1229: END IF;
1230:
1231: IF (l_listener_port IS NULL) THEN
1232: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_PORT_IS_NULL','TGTINSTANCE',p_target_instance);
1233: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);
1234: v_ret_flag := FALSE;
1235: END IF;
1236:

Line 1233: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);

1229: END IF;
1230:
1231: IF (l_listener_port IS NULL) THEN
1232: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_PORT_IS_NULL','TGTINSTANCE',p_target_instance);
1233: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);
1234: v_ret_flag := FALSE;
1235: END IF;
1236:
1237: IF (l_fndnam_link_name IS NULL) THEN

Line 1238: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_LINK_IS_NULL','TGTINSTANCE',p_target_instance);

1234: v_ret_flag := FALSE;
1235: END IF;
1236:
1237: IF (l_fndnam_link_name IS NULL) THEN
1238: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_LINK_IS_NULL','TGTINSTANCE',p_target_instance);
1239: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);
1240: v_ret_flag := FALSE;
1241: END IF;
1242: END IF;

Line 1239: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);

1235: END IF;
1236:
1237: IF (l_fndnam_link_name IS NULL) THEN
1238: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_LINK_IS_NULL','TGTINSTANCE',p_target_instance);
1239: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);
1240: v_ret_flag := FALSE;
1241: END IF;
1242: END IF;
1243:

Line 1247: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NO_SVR_ENTRY','TGTINSTANCE',p_target_instance);

1243:
1244: RETURN v_ret_flag;
1245: EXCEPTION
1246: WHEN NO_DATA_FOUND THEN
1247: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NO_SVR_ENTRY','TGTINSTANCE',p_target_instance);
1248: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);
1249: v_ret_flag := FALSE;
1250: RETURN v_ret_flag;
1251: WHEN OTHERS THEN

Line 1248: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);

1244: RETURN v_ret_flag;
1245: EXCEPTION
1246: WHEN NO_DATA_FOUND THEN
1247: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NO_SVR_ENTRY','TGTINSTANCE',p_target_instance);
1248: error_msg_populate(m_err_message ,'CZ_PB_SYNC.INPUTPARAMS',21004);
1249: v_ret_flag := FALSE;
1250: RETURN v_ret_flag;
1251: WHEN OTHERS THEN
1252: v_ret_flag := FALSE;

Line 1284: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_UPD_SVR_ERR','SERVERID',p_target_server_id, 'SQLERRM',SQLERRM);

1280: ' t.notes = '''||l_sync_date||''' ' ||
1281: ' WHERE UPPER(t.local_name) = ''LOCAL'' ';
1282: EXCEPTION
1283: WHEN NO_DATA_FOUND THEN
1284: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_UPD_SVR_ERR','SERVERID',p_target_server_id, 'SQLERRM',SQLERRM);
1285: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETTGTINSTANCE',21004);
1286: RAISE;
1287: WHEN OTHERS THEN
1288: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_UPD_SVR_ERR','SERVERID',p_target_server_id, 'SQLERRM',SQLERRM);

Line 1285: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETTGTINSTANCE',21004);

1281: ' WHERE UPPER(t.local_name) = ''LOCAL'' ';
1282: EXCEPTION
1283: WHEN NO_DATA_FOUND THEN
1284: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_UPD_SVR_ERR','SERVERID',p_target_server_id, 'SQLERRM',SQLERRM);
1285: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETTGTINSTANCE',21004);
1286: RAISE;
1287: WHEN OTHERS THEN
1288: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_UPD_SVR_ERR','SERVERID',p_target_server_id, 'SQLERRM',SQLERRM);
1289: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETTGTINSTANCE',21004);

Line 1288: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_UPD_SVR_ERR','SERVERID',p_target_server_id, 'SQLERRM',SQLERRM);

1284: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_UPD_SVR_ERR','SERVERID',p_target_server_id, 'SQLERRM',SQLERRM);
1285: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETTGTINSTANCE',21004);
1286: RAISE;
1287: WHEN OTHERS THEN
1288: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_UPD_SVR_ERR','SERVERID',p_target_server_id, 'SQLERRM',SQLERRM);
1289: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETTGTINSTANCE',21004);
1290: RAISE;
1291: END;
1292:

Line 1289: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETTGTINSTANCE',21004);

1285: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETTGTINSTANCE',21004);
1286: RAISE;
1287: WHEN OTHERS THEN
1288: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_UPD_SVR_ERR','SERVERID',p_target_server_id, 'SQLERRM',SQLERRM);
1289: error_msg_populate(m_err_message ,'CZ_PB_SYNC.GETTGTINSTANCE',21004);
1290: RAISE;
1291: END;
1292:
1293: --------------------------------------------------------

Line 1315: v_link_name := cz_pb_sync_util.retrieve_link_name(p_target_server_id);

1311: ----clear pb exports
1312: clear_pb_exports;
1313:
1314: ----update server id in tgt publication record
1315: v_link_name := cz_pb_sync_util.retrieve_link_name(p_target_server_id);
1316: update_tgt_server_id(p_target_server_id,v_link_name);
1317:
1318: ----update target server information
1319: update_server_info(p_target_server_id,v_link_name);

Line 1323: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_INSERT_ERR', 'SQLERRM', SQLERRM);

1319: update_server_info(p_target_server_id,v_link_name);
1320:
1321: EXCEPTION
1322: WHEN OTHERS THEN
1323: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_INSERT_ERR', 'SQLERRM', SQLERRM);
1324: error_msg_populate(m_err_message ,'CZ_PB_SYNC.SYNCPBCLONE',21015);
1325: x_pb_clone_flg := FALSE;
1326: END sync_publication_clone;
1327:

Line 1324: error_msg_populate(m_err_message ,'CZ_PB_SYNC.SYNCPBCLONE',21015);

1320:
1321: EXCEPTION
1322: WHEN OTHERS THEN
1323: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_INSERT_ERR', 'SQLERRM', SQLERRM);
1324: error_msg_populate(m_err_message ,'CZ_PB_SYNC.SYNCPBCLONE',21015);
1325: x_pb_clone_flg := FALSE;
1326: END sync_publication_clone;
1327:
1328: -----------------------------------------------------

Line 1354: l_run_id := cz_pb_sync_util.get_run_id;

1350:
1351: FOR I IN 1..1
1352: LOOP
1353: ----get run id
1354: l_run_id := cz_pb_sync_util.get_run_id;
1355: x_run_id := l_run_id;
1356:
1357: IF (l_run_id = 0) THEN
1358: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SEQ_XFR');

Line 1359: error_msg_populate(m_err_message ,'CZ_PB_SYNC.XFRINFO',21001);

1355: x_run_id := l_run_id;
1356:
1357: IF (l_run_id = 0) THEN
1358: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SEQ_XFR');
1359: error_msg_populate(m_err_message ,'CZ_PB_SYNC.XFRINFO',21001);
1360: x_status := FND_API.G_RET_STS_ERROR;
1361: EXIT;
1362: END IF;
1363:

Line 1365: l_proc_name := cz_pb_sync_util.check_process;

1361: EXIT;
1362: END IF;
1363:
1364: ----check if another sync is in progress
1365: l_proc_name := cz_pb_sync_util.check_process;
1366: IF l_proc_name IS NOT NULL THEN
1367: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_PROCESS_EXISTS');
1368: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CHKPROCESS',21001);
1369: x_status := FND_API.G_RET_STS_ERROR;

Line 1367: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_PROCESS_EXISTS');

1363:
1364: ----check if another sync is in progress
1365: l_proc_name := cz_pb_sync_util.check_process;
1366: IF l_proc_name IS NOT NULL THEN
1367: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_PROCESS_EXISTS');
1368: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CHKPROCESS',21001);
1369: x_status := FND_API.G_RET_STS_ERROR;
1370: EXIT;
1371: ELSE

Line 1368: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CHKPROCESS',21001);

1364: ----check if another sync is in progress
1365: l_proc_name := cz_pb_sync_util.check_process;
1366: IF l_proc_name IS NOT NULL THEN
1367: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_PROCESS_EXISTS');
1368: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CHKPROCESS',21001);
1369: x_status := FND_API.G_RET_STS_ERROR;
1370: EXIT;
1371: ELSE
1372: ----register application

Line 1373: cz_pb_sync_util.set_dbms_info('CZ_PB_SYNC');

1369: x_status := FND_API.G_RET_STS_ERROR;
1370: EXIT;
1371: ELSE
1372: ----register application
1373: cz_pb_sync_util.set_dbms_info('CZ_PB_SYNC');
1374: END IF;
1375:
1376: ----validate input parameters
1377: IF (NOT verify_input_parameters(p_target_instance) ) THEN

Line 1383: l_target_server_id := cz_pb_sync_util.get_target_instance_id(p_target_instance);

1379: EXIT;
1380: END IF;
1381:
1382: ---verify schema versions on the source and target instances
1383: l_target_server_id := cz_pb_sync_util.get_target_instance_id(p_target_instance);
1384:
1385: ------check for active links
1386: l_link_name := cz_pb_sync_util.retrieve_link_name(l_target_server_id);
1387: IF ( NOT cz_pb_sync_util.check_db_link(l_link_name) ) THEN

Line 1386: l_link_name := cz_pb_sync_util.retrieve_link_name(l_target_server_id);

1382: ---verify schema versions on the source and target instances
1383: l_target_server_id := cz_pb_sync_util.get_target_instance_id(p_target_instance);
1384:
1385: ------check for active links
1386: l_link_name := cz_pb_sync_util.retrieve_link_name(l_target_server_id);
1387: IF ( NOT cz_pb_sync_util.check_db_link(l_link_name) ) THEN
1388: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NO_LINK_EXISTS','LINKNAME',l_link_name);
1389: error_msg_populate(m_err_message ,'CHECKDBLINK',21025);
1390: x_status := FND_API.G_RET_STS_ERROR;

Line 1387: IF ( NOT cz_pb_sync_util.check_db_link(l_link_name) ) THEN

1383: l_target_server_id := cz_pb_sync_util.get_target_instance_id(p_target_instance);
1384:
1385: ------check for active links
1386: l_link_name := cz_pb_sync_util.retrieve_link_name(l_target_server_id);
1387: IF ( NOT cz_pb_sync_util.check_db_link(l_link_name) ) THEN
1388: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NO_LINK_EXISTS','LINKNAME',l_link_name);
1389: error_msg_populate(m_err_message ,'CHECKDBLINK',21025);
1390: x_status := FND_API.G_RET_STS_ERROR;
1391: EXIT;

Line 1388: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NO_LINK_EXISTS','LINKNAME',l_link_name);

1384:
1385: ------check for active links
1386: l_link_name := cz_pb_sync_util.retrieve_link_name(l_target_server_id);
1387: IF ( NOT cz_pb_sync_util.check_db_link(l_link_name) ) THEN
1388: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NO_LINK_EXISTS','LINKNAME',l_link_name);
1389: error_msg_populate(m_err_message ,'CHECKDBLINK',21025);
1390: x_status := FND_API.G_RET_STS_ERROR;
1391: EXIT;
1392: END IF;

Line 1401: l_validate_flg := cz_pb_sync_util.validate_schema(l_target_server_id);

1397: x_status := FND_API.G_RET_STS_ERROR;
1398: EXIT;
1399: END IF;
1400:
1401: l_validate_flg := cz_pb_sync_util.validate_schema(l_target_server_id);
1402: IF (NOT l_validate_flg ) THEN
1403: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SCHEMA_COMPAT_ERR');
1404: error_msg_populate(m_err_message ,'VALIDATESCHEMA',21005);
1405: x_status := FND_API.G_RET_STS_ERROR;

Line 1437: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'INSTANCENAME',p_target_instance);

1433: END LOOP;
1434:
1435: ---log errors to cz_db_logs
1436: IF (x_status = FND_API.G_RET_STS_ERROR) THEN
1437: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'INSTANCENAME',p_target_instance);
1438: error_msg_populate(m_err_message ,'SYNCCLOTGTPBDATA',21014);
1439: END IF;
1440: cz_pb_sync_util.log_pb_sync_errors(m_msg_tbl,l_run_id);
1441:

Line 1440: cz_pb_sync_util.log_pb_sync_errors(m_msg_tbl,l_run_id);

1436: IF (x_status = FND_API.G_RET_STS_ERROR) THEN
1437: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'INSTANCENAME',p_target_instance);
1438: error_msg_populate(m_err_message ,'SYNCCLOTGTPBDATA',21014);
1439: END IF;
1440: cz_pb_sync_util.log_pb_sync_errors(m_msg_tbl,l_run_id);
1441:
1442: -----unregister application
1443: cz_pb_sync_util.reset_dbms_info;
1444: EXCEPTION

Line 1443: cz_pb_sync_util.reset_dbms_info;

1439: END IF;
1440: cz_pb_sync_util.log_pb_sync_errors(m_msg_tbl,l_run_id);
1441:
1442: -----unregister application
1443: cz_pb_sync_util.reset_dbms_info;
1444: EXCEPTION
1445: WHEN OTHERS THEN
1446: x_status := FND_API.G_RET_STS_UNEXP_ERROR;
1447: END sync_cloned_tgt_pub_data;

Line 1466: Errbuf := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'INSTANCENAME',p_target_instance);

1462: sync_cloned_tgt_pub_data(p_target_instance,v_run_id,v_sync_status);
1463:
1464: Errbuf := NULL;
1465: IF (v_sync_status = FND_API.G_RET_STS_ERROR) THEN
1466: Errbuf := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'INSTANCENAME',p_target_instance);
1467: Retcode:= 2;
1468: END IF;
1469:
1470: EXCEPTION

Line 1473: Errbuf := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'TGTINSTANCE',p_target_instance);

1469:
1470: EXCEPTION
1471: WHEN OTHERS THEN
1472: Retcode := 2;
1473: Errbuf := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'TGTINSTANCE',p_target_instance);
1474: END sync_cloned_tgt_pub_data_cp;
1475:
1476: ---------------------------------------------------------
1477: ----get local server information

Line 1562: v_run_id := cz_pb_sync_util.get_run_id;

1558:
1559: FOR I IN 1..1
1560: LOOP
1561: ----get run id for message
1562: v_run_id := cz_pb_sync_util.get_run_id;
1563: x_run_id := v_run_id;
1564:
1565: IF (v_run_id = 0) THEN
1566: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SEQ_XFR');

Line 1567: error_msg_populate(m_err_message ,'CZ_PB_SYNC.XFRINFO',21001);

1563: x_run_id := v_run_id;
1564:
1565: IF (v_run_id = 0) THEN
1566: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SEQ_XFR');
1567: error_msg_populate(m_err_message ,'CZ_PB_SYNC.XFRINFO',21001);
1568: x_status := FND_API.G_RET_STS_ERROR;
1569: EXIT;
1570: END IF;
1571:

Line 1573: l_proc_name := cz_pb_sync_util.check_process;

1569: EXIT;
1570: END IF;
1571:
1572: ----check if another sync is in progress
1573: l_proc_name := cz_pb_sync_util.check_process;
1574: IF l_proc_name IS NOT NULL THEN
1575: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_PROCESS_EXISTS');
1576: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CHKPROCESS',21001);
1577: x_status := FND_API.G_RET_STS_ERROR;

Line 1575: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_PROCESS_EXISTS');

1571:
1572: ----check if another sync is in progress
1573: l_proc_name := cz_pb_sync_util.check_process;
1574: IF l_proc_name IS NOT NULL THEN
1575: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_PROCESS_EXISTS');
1576: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CHKPROCESS',21001);
1577: x_status := FND_API.G_RET_STS_ERROR;
1578: EXIT;
1579: ELSE

Line 1576: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CHKPROCESS',21001);

1572: ----check if another sync is in progress
1573: l_proc_name := cz_pb_sync_util.check_process;
1574: IF l_proc_name IS NOT NULL THEN
1575: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_PROCESS_EXISTS');
1576: error_msg_populate(m_err_message ,'CZ_PB_SYNC.CHKPROCESS',21001);
1577: x_status := FND_API.G_RET_STS_ERROR;
1578: EXIT;
1579: ELSE
1580: ----register application

Line 1581: cz_pb_sync_util.set_dbms_info('CZ_PB_SYNC');

1577: x_status := FND_API.G_RET_STS_ERROR;
1578: EXIT;
1579: ELSE
1580: ----register application
1581: cz_pb_sync_util.set_dbms_info('CZ_PB_SYNC');
1582: END IF;
1583:
1584: ----validate input parameter
1585: IF (UPPER(p_decomm_flag) NOT IN ('YES','NO') ) THEN

Line 1586: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_INPUT_FLG_INVALID', 'FLAG', p_decomm_flag);

1582: END IF;
1583:
1584: ----validate input parameter
1585: IF (UPPER(p_decomm_flag) NOT IN ('YES','NO') ) THEN
1586: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_INPUT_FLG_INVALID', 'FLAG', p_decomm_flag);
1587: error_msg_populate(m_err_message ,'CZ_PB_SYNC.DECOMMFLG',21004);
1588: x_status := FND_API.G_RET_STS_ERROR;
1589: EXIT;
1590: END IF;

Line 1587: error_msg_populate(m_err_message ,'CZ_PB_SYNC.DECOMMFLG',21004);

1583:
1584: ----validate input parameter
1585: IF (UPPER(p_decomm_flag) NOT IN ('YES','NO') ) THEN
1586: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_INPUT_FLG_INVALID', 'FLAG', p_decomm_flag);
1587: error_msg_populate(m_err_message ,'CZ_PB_SYNC.DECOMMFLG',21004);
1588: x_status := FND_API.G_RET_STS_ERROR;
1589: EXIT;
1590: END IF;
1591:

Line 1621: IF ( NOT cz_pb_sync_util.check_db_link(v_link_name) ) THEN

1617: LOOP
1618: v_link_name := get_link_name(l_local_name_tbl(localName));
1619: IF (v_link_name IS NOT NULL) THEN
1620: v_link_name := '@'||v_link_name;
1621: IF ( NOT cz_pb_sync_util.check_db_link(v_link_name) ) THEN
1622: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NO_LINK_EXISTS','LINKNAME',v_link_name);
1623: error_msg_populate(m_err_message ,'CHECKDBLINK',21025);
1624: x_status := FND_API.G_RET_STS_ERROR;
1625: EXIT;

Line 1622: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NO_LINK_EXISTS','LINKNAME',v_link_name);

1618: v_link_name := get_link_name(l_local_name_tbl(localName));
1619: IF (v_link_name IS NOT NULL) THEN
1620: v_link_name := '@'||v_link_name;
1621: IF ( NOT cz_pb_sync_util.check_db_link(v_link_name) ) THEN
1622: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_NO_LINK_EXISTS','LINKNAME',v_link_name);
1623: error_msg_populate(m_err_message ,'CHECKDBLINK',21025);
1624: x_status := FND_API.G_RET_STS_ERROR;
1625: EXIT;
1626: END IF;

Line 1641: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'SRCINSTANCE',l_instance_name);

1637: END LOOP;
1638:
1639: ---log errors to cz_db_logs
1640: IF (x_status = FND_API.G_RET_STS_ERROR) THEN
1641: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'SRCINSTANCE',l_instance_name);
1642: error_msg_populate(m_err_message ,'SYNCCLOTGTPBDATA',21014);
1643: x_status := FND_API.G_RET_STS_ERROR;
1644: END IF;
1645: cz_pb_sync_util.log_pb_sync_errors(m_msg_tbl,v_run_id);

Line 1645: cz_pb_sync_util.log_pb_sync_errors(m_msg_tbl,v_run_id);

1641: m_err_message := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'SRCINSTANCE',l_instance_name);
1642: error_msg_populate(m_err_message ,'SYNCCLOTGTPBDATA',21014);
1643: x_status := FND_API.G_RET_STS_ERROR;
1644: END IF;
1645: cz_pb_sync_util.log_pb_sync_errors(m_msg_tbl,v_run_id);
1646:
1647: -----unregister application
1648: cz_pb_sync_util.reset_dbms_info;
1649: COMMIT;

Line 1648: cz_pb_sync_util.reset_dbms_info;

1644: END IF;
1645: cz_pb_sync_util.log_pb_sync_errors(m_msg_tbl,v_run_id);
1646:
1647: -----unregister application
1648: cz_pb_sync_util.reset_dbms_info;
1649: COMMIT;
1650: EXCEPTION
1651: WHEN OTHERS THEN
1652: x_status := FND_API.G_RET_STS_UNEXP_ERROR;

Line 1674: Errbuf := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'INSTANCENAME',l_src_instance );

1670:
1671: SELECT name INTO l_src_instance from v$database;
1672: sync_cloned_src_pub_data(p_decomm_flag,v_run_id,v_sync_status);
1673: IF (v_sync_status = FND_API.G_RET_STS_ERROR) THEN
1674: Errbuf := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'INSTANCENAME',l_src_instance );
1675: Retcode:= 2;
1676: END IF;
1677: EXCEPTION
1678: WHEN OTHERS THEN

Line 1680: Errbuf := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'TGTINSTANCE',l_src_instance );

1676: END IF;
1677: EXCEPTION
1678: WHEN OTHERS THEN
1679: Retcode := 2;
1680: Errbuf := CZ_UTILS.GET_TEXT('CZ_PB_SYNC_FAILURE', 'TGTINSTANCE',l_src_instance );
1681: END sync_cloned_src_pub_data_cp;
1682:
1683:
1684: ---------------------------------------------------------------------

Line 1686: END cz_pb_sync; /* end of package */

1682:
1683:
1684: ---------------------------------------------------------------------
1685:
1686: END cz_pb_sync; /* end of package */