[Home] [Help]
35:
36: retcode := CONCURRENT_ERROR;
37:
38: --'Migration setup cannot continue due to the previous errors. Please see log for details.'
39: errbuf := CZ_UTILS.GET_TEXT('CZ_MIGR_CANNOT_SETUP');
40: report(errbuf, URGENCY_ERROR);
41:
42: ELSIF(xError = SKIPPABLE_ERROR)THEN
43:
41:
42: ELSIF(xError = SKIPPABLE_ERROR)THEN
43:
44: --'Migration setup completed successfully with warnings. Please see log for details.'
45: errbuf := CZ_UTILS.GET_TEXT('CZ_MIGR_WARNING_SETUP');
46: report(errbuf, URGENCY_WARNING);
47: END IF;
48:
49: DBMS_APPLICATION_INFO.SET_MODULE('','');
66:
67: retcode := CONCURRENT_ERROR;
68:
69: --'Migration cannot continue due to the previous errors. Please see log for details.'
70: errbuf := CZ_UTILS.GET_TEXT('CZ_MIGR_CANNOT_CONTINUE');
71: report(errbuf, URGENCY_ERROR);
72:
73: ELSIF(xError = SKIPPABLE_ERROR)THEN
74:
72:
73: ELSIF(xError = SKIPPABLE_ERROR)THEN
74:
75: --'Migration completed successfully with warnings. Please see log for details.'
76: errbuf := CZ_UTILS.GET_TEXT('CZ_MIGR_WARNING_RUN');
77: report(errbuf, URGENCY_WARNING);
78: END IF;
79:
80: DBMS_APPLICATION_INFO.SET_MODULE('','');
88: FROM cz_servers WHERE UPPER(local_name) = UPPER(p_local_name);
89:
90: IF(x_link_name IS NULL)THEN
91: --'No database link is associated with the specified server name ''%LOCALNAME''.'
92: report(CZ_UTILS.GET_TEXT('CZ_MIGR_EMPTY_LINK', 'LOCALNAME', p_local_name), URGENCY_ERROR);
93: RETURN FATAL_ERROR;
94: END IF;
95:
96: RETURN NO_ERROR;
96: RETURN NO_ERROR;
97: EXCEPTION
98: WHEN OTHERS THEN
99: --'Unable to retrieve database link name for the specified server name ''%LOCALNAME'': %ERRORTEXT.'
100: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_DATABASE_LINK', 'LOCALNAME', p_local_name, 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
101: RETURN FATAL_ERROR;
102: END;
103: ---------------------------------------------------------------------------------------
104: FUNCTION verify_database_link(p_link_name IN VARCHAR2)
110:
111: EXCEPTION
112: WHEN OTHERS THEN
113: --'Database link ''%LINKNAME'' is not functional: %ERRORTEXT.'
114: report(CZ_UTILS.GET_TEXT('CZ_MIGR_BAD_DATABASE_LINK', 'LINKNAME', p_link_name, 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
115: RETURN FATAL_ERROR;
116: END;
117: ---------------------------------------------------------------------------------------
118: FUNCTION migrate_setup(x_run_id IN OUT NOCOPY PLS_INTEGER,
137: thisRunId := x_run_id;
138: EXCEPTION
139: WHEN OTHERS THEN
140: --'Unable to generate identification number for this process, database objects are missing or invalid: %ERRORTEXT.'
141: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_RUN_ID', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
142: RETURN FATAL_ERROR;
143: END;
144:
145: --Check for other running migration/setup sessions.
156: CZ_RULE_IMPORT.CZRI_MODULE_NAME)) LOOP
157:
158: --'Unable to start a new migration session because another migration session or an incompatible concurrent'
159: --'program is currently running.'
160: report(CZ_UTILS.GET_TEXT('CZ_MIGR_SESSION_EXISTS'), URGENCY_ERROR);
161: RETURN FATAL_ERROR;
162: END LOOP;
163:
164: DBMS_APPLICATION_INFO.SET_MODULE('CZMIGRATION', TO_CHAR(x_run_id));
171: --No setting is normal.
172: NULL;
173: WHEN OTHERS THEN
174: --'Unable to read the migration status because of %ERRORTEXT.'
175: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_STATUS', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
176: RETURN FATAL_ERROR;
177: END;
178:
179: IF(verify_server_entry(p_local_name, dbLinkName) = FATAL_ERROR)THEN RETURN FATAL_ERROR; END IF;
188: IF(xError = SKIPPABLE_ERROR)THEN
189: IF(UPPER(MigrationStatus) IN ('STARTED', 'COMPLETED'))THEN
190:
191: --'Migration setup cannot be started after the migration has been run.'
192: report(CZ_UTILS.GET_TEXT('CZ_MIGR_CANNOT_RUN_SETUP'), URGENCY_ERROR);
193: RETURN FATAL_ERROR;
194: ELSIF(UPPER(p_force_run) = 'NO')THEN
195:
196: --'The target database is not a fresh installed Applications database, running migration may cause data corruption.'
193: RETURN FATAL_ERROR;
194: ELSIF(UPPER(p_force_run) = 'NO')THEN
195:
196: --'The target database is not a fresh installed Applications database, running migration may cause data corruption.'
197: report(CZ_UTILS.GET_TEXT('CZ_MIGR_TARGET_NOT_EMPTY'), URGENCY_ERROR);
198: RETURN FATAL_ERROR;
199: END IF;
200: END IF;
201: EXCEPTION
200: END IF;
201: EXCEPTION
202: WHEN OTHERS THEN
203: --'Unable to verify the target database: %ERRORTEXT.'
204: report(CZ_UTILS.GET_TEXT('CZ_MIGR_TARGET_VERIFY', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
205: RETURN FATAL_ERROR;
206: END;
207:
208: xError := compare_versions;
232: EXCEPTION
233: WHEN OTHERS THEN
234: ROLLBACK;
235: --'Unable to populate migration control table: %ERRORTEXT.'
236: report(CZ_UTILS.GET_TEXT('CZ_MIGR_CONTROL_ERROR', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
237: RETURN FATAL_ERROR;
238: END;
239:
240: errorFlag := 0;
271: EXCEPTION
272: WHEN OTHERS THEN
273: ROLLBACK;
274: --'Unable to update the migration status because of %ERRORTEXT.'
275: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_STATUS_UPDATE', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
276: RETURN FATAL_ERROR;
277: END;
278: RETURN NO_ERROR;
279: END migrate_setup;
324: thisRunId := x_run_id;
325: EXCEPTION
326: WHEN OTHERS THEN
327: --'Unable to generate identification number for this process, database objects are missing or invalid: %ERRORTEXT.'
328: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_RUN_ID', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
329: RETURN FATAL_ERROR;
330: END;
331:
332: --Check for other running migration/setup sessions.
343: CZ_RULE_IMPORT.CZRI_MODULE_NAME)) LOOP
344:
345: --'Unable to start a new migration session because another migration session or an incompatible concurrent'
346: --'program is currently running.'
347: report(CZ_UTILS.GET_TEXT('CZ_MIGR_SESSION_EXISTS'), URGENCY_ERROR);
348: RETURN FATAL_ERROR;
349: END LOOP;
350:
351: DBMS_APPLICATION_INFO.SET_MODULE('CZMIGRATION', TO_CHAR(x_run_id));
356: EXCEPTION
357: WHEN NO_DATA_FOUND THEN
358: --'Unable to read the migration status, no record exists. Please make sure the migration setup
359: -- concurrent program has been properly run.'
360: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_STATUS_DATA'), URGENCY_ERROR);
361: RETURN FATAL_ERROR;
362: WHEN OTHERS THEN
363: --'Unable to read the migration status because of %ERRORTEXT.'
364: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_STATUS', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
360: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_STATUS_DATA'), URGENCY_ERROR);
361: RETURN FATAL_ERROR;
362: WHEN OTHERS THEN
363: --'Unable to read the migration status because of %ERRORTEXT.'
364: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_STATUS', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
365: RETURN FATAL_ERROR;
366: END;
367:
368: BEGIN
371: EXCEPTION
372: WHEN NO_DATA_FOUND THEN
373: --'Unable to read the source server name, no record exists. Please make sure the migration setup
374: -- concurrent program has been properly run.'
375: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_SERVER_NAME'), URGENCY_ERROR);
376: RETURN FATAL_ERROR;
377: WHEN OTHERS THEN
378: --'Unable to read the source server name because of %ERRORTEXT.'
379: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_SERVER', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
375: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_SERVER_NAME'), URGENCY_ERROR);
376: RETURN FATAL_ERROR;
377: WHEN OTHERS THEN
378: --'Unable to read the source server name because of %ERRORTEXT.'
379: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_SERVER', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
380: RETURN FATAL_ERROR;
381: END;
382:
383: IF(verify_server_entry(serverLocalName, dbLinkName) = FATAL_ERROR)THEN RETURN FATAL_ERROR; END IF;
392: IF(xError = SKIPPABLE_ERROR)THEN
393: IF(UPPER(MigrationStatus) = 'COMPLETED')THEN
394:
395: --'Migration has successfully completed for this database. Running the migration again may cause data corruption.'
396: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COMPLETED_BEFORE'), URGENCY_ERROR);
397: RETURN FATAL_ERROR;
398: ELSIF(UPPER(p_force_run) = 'NO')THEN
399:
400: --'The target database is not a fresh installed Applications database, running migration may cause data corruption.'
397: RETURN FATAL_ERROR;
398: ELSIF(UPPER(p_force_run) = 'NO')THEN
399:
400: --'The target database is not a fresh installed Applications database, running migration may cause data corruption.'
401: report(CZ_UTILS.GET_TEXT('CZ_MIGR_TARGET_NOT_EMPTY'), URGENCY_ERROR);
402: RETURN FATAL_ERROR;
403: END IF;
404: END IF;
405: EXCEPTION
404: END IF;
405: EXCEPTION
406: WHEN OTHERS THEN
407: --'Unable to verify the target database: %ERRORTEXT.'
408: report(CZ_UTILS.GET_TEXT('CZ_MIGR_TARGET_VERIFY', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
409: RETURN FATAL_ERROR;
410: END;
411:
412: begin
414: where UPPER(section_name) = 'MIGRATE' and UPPER(setting_id) = 'MIGRATIONSTATUS';
415: exception
416: when others then
417: --'Unable to update the migration status because of %ERRORTEXT.'
418: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_STATUS_UPDATE', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
419: RETURN FATAL_ERROR;
420: end;
421:
422: xError := compare_versions;
457: EXCEPTION
458: WHEN OTHERS THEN
459:
460: --'Error in table-specific data preparation for the table ''%TABLENAME'': %ERRORTEXT.'
461: report(CZ_UTILS.GET_TEXT('CZ_MIGR_PREPARE_ERROR', 'TABLENAME', 'CZ_SERVERS', 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
462:
463: IF(StopOnSkippable = 1)THEN RETURN FATAL_ERROR; END IF;
464: END;
465: END LOOP;
519: FETCH l_src_sessn_cur INTO srcPbSessionCnt;
520: EXIT WHEN l_src_sessn_cur%NOTFOUND;
521: IF (srcPbSessionCnt > 0) THEN
522: ----'An existing sync or publishing process is in progress. Re run after these processes complete.'
523: report(CZ_UTILS.GET_TEXT('CZ_PB_SYNC_PROCESS_EXISTS'), URGENCY_ERROR);
524: RETURN FATAL_ERROR;
525: END IF;
526: END LOOP;
527: CLOSE l_src_sessn_cur;
577: where section_name='MIGRATE' and setting_id='MigrationStatus';
578: exception
579: when others then
580: --'Migration was unable to update the migration status because of %ERRORTEXT.'
581: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_STATUS_COMPLETE', 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
582: RETURN SKIPPABLE_ERROR;
583: end;
584:
585: if(DeleteDbLink = 1)then
594: exception
595: when others then
596: if(dbms_sql.is_open(cdyn))then dbms_sql.close_cursor(cdyn); end if;
597: --'Migration was unable to delete the database link because of %ERRORTEXT.'
598: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_LINK_DELETE', 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
599: RETURN SKIPPABLE_ERROR;
600: end;
601: end if;
602: RETURN NO_ERROR;
623:
624: EXCEPTION
625: WHEN OTHERS THEN
626: --'Unable to read the target schema version settings because of %ERRORTEXT.'
627: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_TARGET_VERSION', 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
628: return SKIPPABLE_ERROR;
629: END;
630:
631: BEGIN
641:
642: EXCEPTION
643: WHEN OTHERS THEN
644: --'Unable to read the source schema version settings because of %ERRORTEXT.'
645: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_SOURCE_VERSION', 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
646: return SKIPPABLE_ERROR;
647: END;
648:
649: IF(NOT((sMajorVersion IS NOT NULL) AND (tMajorVersion IS NOT NULL) AND
661: )
662: ))THEN
663: --'The source and target schema versions are incompatible. The source schema is at
664: -- version ''%SOURCEVERSION''; the target schema is at version ''%TARGETVERSION''.'
665: report(CZ_UTILS.GET_TEXT('CZ_MIGR_DIFFERENT_VERSIONS', 'SOURCEVERSION', sMajorVersion || LOWER(sMinorVersion),
666: 'TARGETVERSION', tMajorVersion || LOWER(tMinorVersion)), URGENCY_WARNING);
667: return SKIPPABLE_ERROR;
668: END IF;
669:
671:
672: EXCEPTION
673: WHEN OTHERS THEN
674: --'Unable to compare schema versions because of %ERRORTEXT.'
675: report(CZ_UTILS.GET_TEXT('CZ_MIGR_NO_VERSIONS', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
676: return FATAL_ERROR;
677: END;
678: ------------------------------------------------------------------------------------------------------------
679: function compare_columns(inTableName in varchar2)
724:
725: if(rdyn > 0)then
726:
727: --'Definition of the table ''%TABLENAME'' is different in source and target schema.'
728: report(CZ_UTILS.GET_TEXT('CZ_MIGR_DIFFERENT_TABLES', 'TABLENAME', inTableName), URGENCY_WARNING);
729: --'Start of the list of differences for the table ''%TABLENAME'':'
730: report(CZ_UTILS.GET_TEXT('CZ_MIGR_LIST_START', 'TABLENAME', inTableName), URGENCY_WARNING);
731:
732: for i in 1..rdyn loop
726:
727: --'Definition of the table ''%TABLENAME'' is different in source and target schema.'
728: report(CZ_UTILS.GET_TEXT('CZ_MIGR_DIFFERENT_TABLES', 'TABLENAME', inTableName), URGENCY_WARNING);
729: --'Start of the list of differences for the table ''%TABLENAME'':'
730: report(CZ_UTILS.GET_TEXT('CZ_MIGR_LIST_START', 'TABLENAME', inTableName), URGENCY_WARNING);
731:
732: for i in 1..rdyn loop
733:
734: --'Column name: ''%COLUMNNAME'', data type: ''%DATATYPE'', nullable: ''%NULLABLE'', data length: ''%DATALENGTH''.'
731:
732: for i in 1..rdyn loop
733:
734: --'Column name: ''%COLUMNNAME'', data type: ''%DATATYPE'', nullable: ''%NULLABLE'', data length: ''%DATALENGTH''.'
735: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COLUMNS_DIFF', 'COLUMNNAME', ColumnName(i), 'DATATYPE', DataType(i), 'NULLABLE', Nullable(i), 'DATALENGTH', TO_CHAR(DataLength(i))), URGENCY_WARNING);
736: end loop;
737:
738: --'End of the list of differences for the table ''%TABLENAME'':'
739: report(CZ_UTILS.GET_TEXT('CZ_MIGR_LIST_END', 'TABLENAME', inTableName), URGENCY_WARNING);
735: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COLUMNS_DIFF', 'COLUMNNAME', ColumnName(i), 'DATATYPE', DataType(i), 'NULLABLE', Nullable(i), 'DATALENGTH', TO_CHAR(DataLength(i))), URGENCY_WARNING);
736: end loop;
737:
738: --'End of the list of differences for the table ''%TABLENAME'':'
739: report(CZ_UTILS.GET_TEXT('CZ_MIGR_LIST_END', 'TABLENAME', inTableName), URGENCY_WARNING);
740: end if;
741:
742: rpkc := compare_pk_columns(inTableName);
743:
748: exception
749: when others then
750: if(dbms_sql.is_open(cdyn))then dbms_sql.close_cursor(cdyn); end if;
751: --'Unable to compare columns for the table ''%TABLENAME'': %ERRORTEXT.'
752: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COLUMNS_COMPARE', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
753: return FATAL_ERROR;
754: end;
755: ------------------------------------------------------------------------------------------------------------
756: function get_table_columns(inTableName in varchar2, outNamesArray OUT NOCOPY ColumnNameArray)
776: exception
777: when others then
778: if(c_getcolumns%isopen)then close c_getcolumns; end if;
779: --'Unable to retrieve the list of columns for the table ''%TABLENAME'': %ERRORTEXT.'
780: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COLUMNS_UNABLE', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
781: return FATAL_ERROR;
782: end;
783: ------------------------------------------------------------------------------------------------------------
784: function compare_pk_columns(inTableName in varchar2)
828:
829: if(rdyn > 0)then
830:
831: --'Primary key definition for the table ''%TABLENAME'' is different in source and target schema.'
832: report(CZ_UTILS.GET_TEXT('CZ_MIGR_DIFFERENT_PK', 'TABLENAME', inTableName), URGENCY_WARNING);
833: --'Start of the list of primary key differences for the table ''%TABLENAME'':'
834: report(CZ_UTILS.GET_TEXT('CZ_MIGR_PK_START', 'TABLENAME', inTableName), URGENCY_WARNING);
835:
836: for i in 1..rdyn loop
830:
831: --'Primary key definition for the table ''%TABLENAME'' is different in source and target schema.'
832: report(CZ_UTILS.GET_TEXT('CZ_MIGR_DIFFERENT_PK', 'TABLENAME', inTableName), URGENCY_WARNING);
833: --'Start of the list of primary key differences for the table ''%TABLENAME'':'
834: report(CZ_UTILS.GET_TEXT('CZ_MIGR_PK_START', 'TABLENAME', inTableName), URGENCY_WARNING);
835:
836: for i in 1..rdyn loop
837:
838: --'The following column is missing from the primary key: ''%COLUMNNAME''.'
835:
836: for i in 1..rdyn loop
837:
838: --'The following column is missing from the primary key: ''%COLUMNNAME''.'
839: report(CZ_UTILS.GET_TEXT('CZ_MIGR_PK_DIFF', 'COLUMNNAME', ColumnName(i)), URGENCY_WARNING);
840: end loop;
841:
842: --'End of the list of primary key differences for the table ''%TABLENAME'':'
843: report(CZ_UTILS.GET_TEXT('CZ_MIGR_PK_END', 'TABLENAME', inTableName), URGENCY_WARNING);
839: report(CZ_UTILS.GET_TEXT('CZ_MIGR_PK_DIFF', 'COLUMNNAME', ColumnName(i)), URGENCY_WARNING);
840: end loop;
841:
842: --'End of the list of primary key differences for the table ''%TABLENAME'':'
843: report(CZ_UTILS.GET_TEXT('CZ_MIGR_PK_END', 'TABLENAME', inTableName), URGENCY_WARNING);
844: return SKIPPABLE_ERROR;
845: end if;
846:
847: return NO_ERROR;
849: exception
850: when others then
851: if(dbms_sql.is_open(cdyn))then dbms_sql.close_cursor(cdyn); end if;
852: --'Unable to compare primary key columns for the table ''%TABLENAME'': %ERRORTEXT.'
853: report(CZ_UTILS.GET_TEXT('CZ_MIGR_PK_COMPARE', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
854: return FATAL_ERROR;
855: end;
856: ------------------------------------------------------------------------------------------------------------
857: function get_table_pk_columns(inTableName in varchar2, outNamesArray OUT NOCOPY PkColumnNameArray)
881: exception
882: when others then
883: if(c_getpkcolumns%isopen)then close c_getpkcolumns; end if;
884: --'Unable to retrieve the list of primary key columns for the table ''%TABLENAME'': %ERRORTEXT.'
885: report(CZ_UTILS.GET_TEXT('CZ_MIGR_PK_UNABLE', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
886: return FATAL_ERROR;
887: end;
888: ------------------------------------------------------------------------------------------------------------
889: function copy_table(inTableName in varchar2,
909: exception
910: when others then
911: if(dbms_sql.is_open(cdyn))then dbms_sql.close_cursor(cdyn); end if;
912: --'Verification of the table ''%TABLENAME'' in the target schema failed: %ERRORTEXT.'
913: report(CZ_UTILS.GET_TEXT('CZ_MIGR_TARGET_TABLE', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
914: return SKIPPABLE_ERROR;
915: end;
916:
917: begin
924: exception
925: when others then
926: if(dbms_sql.is_open(cdyn))then dbms_sql.close_cursor(cdyn); end if;
927: --'Verification of the table ''%TABLENAME'' in the source schema failed: %ERRORTEXT.'
928: report(CZ_UTILS.GET_TEXT('CZ_MIGR_SOURCE_TABLE', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
929: return SKIPPABLE_ERROR;
930: end;
931:
932: if((nCountLocal = nCountRemote) and (inForceProcess = 0))then
931:
932: if((nCountLocal = nCountRemote) and (inForceProcess = 0))then
933:
934: --'Table ''%TABLENAME'' has the same number of records in the source and target schema, the table will be skipped.'
935: report(CZ_UTILS.GET_TEXT('CZ_MIGR_SKIP_TABLE', 'TABLENAME', inTableName), URGENCY_MESSAGE);
936: return NO_ERROR;
937: end if;
938:
939: if((nCountLocal = 0) and (inForceSlowMode = 0))then
938:
939: if((nCountLocal = 0) and (inForceSlowMode = 0))then
940:
941: --'Fast copy mode is selected for the table ''%TABLENAME''. Number of records in the source table: %SOURCERECORDS.'
942: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COPY_FAST', 'TABLENAME', inTableName, 'SOURCERECORDS', TO_CHAR(nCountRemote)), URGENCY_MESSAGE);
943: return copy_table_fastmode(inTableName,inStopOnskippable);
944: end if;
945:
946: if((inRefreshable = 0) and (inForceSlowMode = 0))then
946: if((inRefreshable = 0) and (inForceSlowMode = 0))then
947:
948: --'Fast copy mode without refresh is selected for the table ''%TABLENAME''. Number of records in the source table: %SOURCERECORDS.
949: -- Number of records in the target table: %TARGETRECORDS.'
950: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COPY_FASTNOREFRESH', 'TABLENAME', inTableName, 'SOURCERECORDS', TO_CHAR(nCountRemote), 'TARGETRECORDS', TO_CHAR(nCountLocal)), URGENCY_MESSAGE);
951: return copy_table_fastnorefresh(inTableName,inStopOnskippable);
952: end if;
953:
954: if((inRefreshable = 1) and (inForceSlowMode = 0))then
954: if((inRefreshable = 1) and (inForceSlowMode = 0))then
955:
956: --'Override mode is selected for the table ''%TABLENAME''. Number of records in the source table: %SOURCERECORDS.
957: -- Number of records in the target table: %TARGETRECORDS.'
958: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COPY_FASTREFRESH', 'TABLENAME', inTableName, 'SOURCERECORDS', TO_CHAR(nCountRemote), 'TARGETRECORDS', TO_CHAR(nCountLocal)), URGENCY_MESSAGE);
959: return copy_table_fastrefresh(inTableName,inStopOnskippable);
960: end if;
961:
962: --'Slow copy mode is selected for the table ''%TABLENAME''. Number of records in the source table: %SOURCERECORDS.
960: end if;
961:
962: --'Slow copy mode is selected for the table ''%TABLENAME''. Number of records in the source table: %SOURCERECORDS.
963: -- Number of records in the target table: %TARGETRECORDS.'
964: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COPY_SLOW', 'TABLENAME', inTableName, 'SOURCERECORDS', TO_CHAR(nCountRemote), 'TARGETRECORDS', TO_CHAR(nCountLocal)), URGENCY_MESSAGE);
965: return copy_table_slowmode(inTableName,inCommitSize,inStopOnskippable,inRefreshable);
966:
967: exception
968: when others then
966:
967: exception
968: when others then
969: --'Unable to copy the table ''%TABLENAME'' : %ERRORTEXT.'
970: report(CZ_UTILS.GET_TEXT('CZ_MIGR_TABLE_ERROR', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
971: return FATAL_ERROR;
972: end;
973: ------------------------------------------------------------------------------------------------------------
974: FUNCTION copy_table_override(inTableName IN VARCHAR2,
983: EXECUTE IMMEDIATE 'SELECT COUNT(*) FROM ' || inTableName INTO nCountTarget;
984: EXCEPTION
985: WHEN OTHERS THEN
986: --'Verification of the table ''%TABLENAME'' in the target schema failed: %ERRORTEXT.'
987: report(CZ_UTILS.GET_TEXT('CZ_MIGR_TARGET_TABLE', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
988: return SKIPPABLE_ERROR;
989: END;
990:
991: BEGIN
992: EXECUTE IMMEDIATE 'SELECT COUNT(*) FROM ' || inTableName || '@' || dbLinkName INTO nCountSource;
993: EXCEPTION
994: WHEN OTHERS THEN
995: --'Verification of the table ''%TABLENAME'' in the source schema failed: %ERRORTEXT.'
996: report(CZ_UTILS.GET_TEXT('CZ_MIGR_SOURCE_TABLE', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
997: return SKIPPABLE_ERROR;
998: END;
999:
1000: IF(nCountTarget = 0 AND nCountSource = 0)THEN
999:
1000: IF(nCountTarget = 0 AND nCountSource = 0)THEN
1001:
1002: --'Table ''%TABLENAME'' has no data in the source and target schema, the table will be skipped.'
1003: report(CZ_UTILS.GET_TEXT('CZ_MIGR_TABLE_NO_DATA', 'TABLENAME', inTableName), URGENCY_MESSAGE);
1004: return NO_ERROR;
1005:
1006: ELSIF(nCountTarget = 0)THEN
1007:
1005:
1006: ELSIF(nCountTarget = 0)THEN
1007:
1008: --'Fast copy mode is selected for the table ''%TABLENAME''. Number of records in the source table: %SOURCERECORDS.'
1009: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COPY_FAST', 'TABLENAME', inTableName, 'SOURCERECORDS', TO_CHAR(nCountSource)), URGENCY_MESSAGE);
1010: return copy_table_fastmode(inTableName, inStopOnskippable);
1011: ELSE
1012:
1013: --'Override mode is selected for the table ''%TABLENAME''. Number of records in the source table: %SOURCERECORDS.
1011: ELSE
1012:
1013: --'Override mode is selected for the table ''%TABLENAME''. Number of records in the source table: %SOURCERECORDS.
1014: -- Number of records in the target table: %TARGETRECORDS.'
1015: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COPY_FASTREFRESH', 'TABLENAME', inTableName, 'SOURCERECORDS', TO_CHAR(nCountSource), 'TARGETRECORDS', TO_CHAR(nCountTarget)), URGENCY_MESSAGE);
1016: return copy_table_fastrefresh(inTableName, inStopOnskippable);
1017: END IF;
1018:
1019: EXCEPTION
1018:
1019: EXCEPTION
1020: WHEN OTHERS THEN
1021: --'Unable to copy the table ''%TABLENAME'' : %ERRORTEXT.'
1022: report(CZ_UTILS.GET_TEXT('CZ_MIGR_TABLE_ERROR', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
1023: return FATAL_ERROR;
1024: END copy_table_override;
1025: ------------------------------------------------------------------------------------------------------------
1026: function copy_all_tables(inCommitSize in pls_integer,
1064: return NO_ERROR;
1065: exception
1066: when others then
1067: --'Error while migrating data: %ERRORTEXT.'
1068: report(CZ_UTILS.GET_TEXT('CZ_MIGR_MIGRATE_ERROR', 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
1069: return FATAL_ERROR;
1070: end;
1071: ------------------------------------------------------------------------------------------------------------
1072: function copy_table_slowmode(inTableName in varchar2,
1146: tableUpdateStatement||
1147: ' nUpdates := nUpdates + 1; '||
1148: ' exception '||
1149: ' when others then '||
1150: ' cz_migrate.report(CZ_UTILS.GET_TEXT(''CZ_MIGR_UNABLE_UPDATE'', ''TABLENAME'', ''' || inTableName || ''', ''ERRORTEXT'', SQLERRM), cz_migrate.URGENCY_WARNING); ' ||
1151: ' if((sqlcode between -999 and -900) or '||
1152: ' (sqlcode between -1489 and -1400) or '||
1153: ' sqlcode = -1)then '||
1154: ' if(:StopOnSkippable = 1)then raise cz_migrate.CZ_MIGR_SKIPPABLE_EXCEPTION; end if; '||
1156: ' raise cz_migrate.CZ_MIGR_FATAL_EXCEPTION; '||
1157: ' end if; '||
1158: ' end; '||
1159: ' else '||
1160: ' cz_migrate.report(CZ_UTILS.GET_TEXT(''CZ_MIGR_UNABLE_INSERT'', ''TABLENAME'', ''' || inTableName || ''', ''ERRORTEXT'', SQLERRM), cz_migrate.URGENCY_WARNING); ' ||
1161: ' if(:StopOnSkippable = 1)then raise cz_migrate.CZ_MIGR_SKIPPABLE_EXCEPTION; end if; '||
1162: ' end if; '||
1163: ' else '||
1164: ' raise cz_migrate.CZ_MIGR_FATAL_EXCEPTION; '||
1165: ' end if; '||
1166: ' end; '||
1167: ' end loop; '||
1168: ' commit; '||
1169: ' cz_migrate.report(CZ_UTILS.GET_TEXT(''CZ_MIGR_COPY_SUCCESS'', ''TABLENAME'', ''' || inTableName || ''', ''INSERTROWS'', TO_CHAR(nInserts), ''UPDATEROWS'', TO_CHAR(nUpdates)), cz_migrate.URGENCY_MESSAGE); ' ||
1170: 'end;',
1171: dbms_sql.native);
1172:
1173: dbms_sql.bind_variable(cdyn, ':Refreshable', inRefreshable);
1187: return FATAL_ERROR;
1188: when OTHERS then
1189: if(dbms_sql.is_open(cdyn))then dbms_sql.close_cursor(cdyn); end if;
1190: --'Unable to copy the table ''%TABLENAME'' in the selected mode: %ERRORTEXT.'
1191: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COPY_ERROR', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
1192: return FATAL_ERROR;
1193: end;
1194: ------------------------------------------------------------------------------------------------------------
1195: function copy_table_fastmode(inTableName in varchar2,
1223: dbms_sql.close_cursor(cdyn);
1224: commit;
1225:
1226: --'Source records are successfully inserted into the target table ''%TABLENAME''.'
1227: report(CZ_UTILS.GET_TEXT('CZ_MIGR_FAST_INSERTED', 'TABLENAME', inTableName), URGENCY_MESSAGE);
1228: return NO_ERROR;
1229:
1230: exception
1231: when OTHERS then
1230: exception
1231: when OTHERS then
1232: if(dbms_sql.is_open(cdyn))then dbms_sql.close_cursor(cdyn); end if;
1233: --'Unable to copy the table ''%TABLENAME'' in the selected mode: %ERRORTEXT.'
1234: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COPY_ERROR', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
1235: if((sqlcode between -999 and -900) or (sqlcode between -1489 and -1400) or sqlcode = -1)then
1236: return SKIPPABLE_ERROR;
1237: else
1238: return FATAL_ERROR;
1285: dbms_sql.close_cursor(cdyn);
1286: commit;
1287:
1288: --'%INSERTROWS records successfully inserted into the target table ''%TABLENAME''.'
1289: report(CZ_UTILS.GET_TEXT('CZ_MIGR_INSERT_SUCCESS', 'TABLENAME', inTableName, 'INSERTROWS', TO_CHAR(rdyn)), URGENCY_MESSAGE);
1290: return NO_ERROR;
1291:
1292: exception
1293: when OTHERS then
1292: exception
1293: when OTHERS then
1294: if(dbms_sql.is_open(cdyn))then dbms_sql.close_cursor(cdyn); end if;
1295: --'Unable to copy the table ''%TABLENAME'' in the selected mode: %ERRORTEXT.'
1296: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COPY_ERROR', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
1297: if((sqlcode between -999 and -900) or (sqlcode between -1489 and -1400) or sqlcode = -1)then
1298: return SKIPPABLE_ERROR;
1299: else
1300: return FATAL_ERROR;
1319: exception
1320: when OTHERS then
1321: if(dbms_sql.is_open(cdyn))then dbms_sql.close_cursor(cdyn); end if;
1322: --'Unable to copy the table ''%TABLENAME'' in the selected mode: %ERRORTEXT.'
1323: report(CZ_UTILS.GET_TEXT('CZ_MIGR_COPY_ERROR', 'TABLENAME', inTableName, 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
1324: if((sqlcode between -999 and -900) or (sqlcode between -1489 and -1400) or sqlcode = -1)then
1325: return SKIPPABLE_ERROR;
1326: else
1327: return FATAL_ERROR;
1342: exception
1343: when others then
1344: if(dbms_sql.is_open(cdyn))then dbms_sql.close_cursor(cdyn); end if;
1345: --'Error while disabling triggers: %ERRORTEXT.'
1346: report(CZ_UTILS.GET_TEXT('CZ_MIGR_TRIGGERS_ERROR', 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
1347: if(inStopOnSkippable = 1)then return SKIPPABLE_ERROR; end if;
1348: end;
1349: end loop;
1350: return NO_ERROR;
1364: exception
1365: when others then
1366: if(dbms_sql.is_open(cdyn))then dbms_sql.close_cursor(cdyn); end if;
1367: --'Error while enabling triggers: %ERRORTEXT.'
1368: report(CZ_UTILS.GET_TEXT('CZ_MIGR_ENABLE_ERROR', 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
1369: if(inStopOnSkippable = 1)then return SKIPPABLE_ERROR; end if;
1370: end;
1371: end loop;
1372: return NO_ERROR;
1393: exception
1394: when others then
1395: if(dbms_sql.is_open(cdyn))then dbms_sql.close_cursor(cdyn); end if;
1396: --'Skipping sequence ''%SEQUENCENAME'', unable to retrieve the last primary key value: %ERRORTEXT.'
1397: report(CZ_UTILS.GET_TEXT('CZ_MIGR_SEQUENCE_MAX', 'SEQUENCENAME', sequenceName, 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
1398: return SKIPPABLE_ERROR;
1399: end;
1400:
1401: IF((p_increment = 0) OR (nMaximum is null))THEN
1400:
1401: IF((p_increment = 0) OR (nMaximum is null))THEN
1402:
1403: --'Skipping sequence ''%SEQUENCENAME'', no adjustment is required.'
1404: report(CZ_UTILS.GET_TEXT('CZ_MIGR_SEQUENCE_SKIP', 'SEQUENCENAME', sequenceName), URGENCY_MESSAGE);
1405: return NO_ERROR;
1406: END IF;
1407:
1408: BEGIN
1416: END IF;
1417: EXCEPTION
1418: WHEN OTHERS THEN
1419: --'Skipping sequence ''%SEQUENCENAME'', unable to adjust: %ERRORTEXT.'
1420: report(CZ_UTILS.GET_TEXT('CZ_MIGR_SEQUENCE_ADJUST', 'SEQUENCENAME', sequenceName, 'ERRORTEXT', SQLERRM), URGENCY_WARNING);
1421: RETURN SKIPPABLE_ERROR;
1422: END;
1423:
1424: COMMIT;
1423:
1424: COMMIT;
1425:
1426: --'Sequence ''%SEQUENCENAME'' adjusted.'
1427: report(CZ_UTILS.GET_TEXT('CZ_MIGR_SEQUENCE_READY', 'SEQUENCENAME', sequenceName), URGENCY_MESSAGE);
1428: RETURN NO_ERROR;
1429:
1430: exception
1431: when others then
1429:
1430: exception
1431: when others then
1432: --'Fatal error while adjusting sequence ''%SEQUENCENAME'': %ERRORTEXT.'
1433: report(CZ_UTILS.GET_TEXT('CZ_MIGR_SEQUENCE_ERROR', 'SEQUENCENAME', sequenceName, 'ERRORTEXT', SQLERRM), URGENCY_ERROR);
1434: return FATAL_ERROR;
1435: END;
1436: ------------------------------------------------------------------------------------------------------------
1437: FUNCTION adjust_all_sequences(inStopOnSkippable IN NUMBER)
1456: END adjust_all_sequences;
1457: ------------------------------------------------------------------------------------------------------------
1458: PROCEDURE report(inMessage IN VARCHAR2, inUrgency IN PLS_INTEGER) IS
1459: BEGIN
1460: cz_utils.log_report('cz_migrate', null, thisStatusCode, inMessage, fnd_log.LEVEL_ERROR);
1461:
1462: --Bug #4347347.
1463:
1464: IF(FND_GLOBAL.CONC_REQUEST_ID > 0)THEN
1894: EXECUTE IMMEDIATE 'SELECT COUNT(*) FROM ' || noRecords(i) INTO nCount;
1895: IF(nCount > 0)THEN
1896:
1897: --'Table ''%TABLENAME'' is not empty, %RECORDCOUNT records found.'
1898: report(CZ_UTILS.GET_TEXT('CZ_MIGR_TABLE_NOT_EMPTY', 'TABLENAME', noRecords(i), 'RECORDCOUNT', nCount), URGENCY_MESSAGE);
1899: errorFlag := 1;
1900: END IF;
1901: END LOOP;
1902:
2077: EXCEPTION
2078: WHEN NO_DATA_FOUND THEN
2079: x_return_status := FND_API.G_RET_STS_ERROR;
2080: x_msg_count := 1;
2081: x_msg_data := CZ_UTILS.GET_TEXT('CZ_NO_JRADDOC_EXISTS','DOC',p_ui_def_id );
2082: WHEN EXPLORETREE_ERROR THEN
2083: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
2084: x_msg_count := 1;
2085:
2091: x_msg_data := fnd_message.get;
2092: WHEN OTHERS THEN
2093: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
2094: x_msg_count := 1;
2095: x_msg_data := CZ_UTILS.GET_TEXT('CZ_JRADDOC_EXPERR', 'ERR', SQLERRM);
2096: END import_jrad_docs;
2097:
2098: ----------------------------------
2099: -----This procedure imports all the JRAD docs