RAP-128 Contruct full tables if there is no Full files in the package

Author: QuyenLy87

src/main/java/org/ihtsdo/rvf/core/service/ReleaseDataManager.java

@@ -760,4 +760,29 @@ public long getBinaryArchiveSchemaLastModifiedDate(String schemaName) {
 			return 0L;
 		}
 	}
+
+	public void insertIntoProspectiveFullTables(String schemaName) throws SQLException {
+		try (Connection connection = rvfDynamicDataSource.getConnection(schemaName)) {
+			DatabaseMetaData md = connection.getMetaData();
+			ResultSet rs = md.getTables(null, null, "%", null);
+			Set<String> snapShotTables = new HashSet<>();
+			while (rs.next()) {
+				if (rs.getString(3).endsWith("_s")) {
+					snapShotTables.add(rs.getString(3));
+				}
+			}
+			insertIntoProspectiveFullTables(snapShotTables, connection);
+		}
+	}
+
+	private void insertIntoProspectiveFullTables(Set<String> snapShotTables, Connection connection) throws SQLException {
+		for (String snapshotTable: snapShotTables) {
+			String fullTable = snapshotTable.replaceAll("_s$","_f");
+			StringBuilder insertSQL = new StringBuilder();
+			insertSQL.append(INSERT_INTO).append(fullTable).append(SQL_SELECT).append(snapshotTable);
+			try (PreparedStatement ps = connection.prepareStatement(insertSQL.toString())) {
+				ps.execute();
+			}
+		}
+	}
 }

src/main/java/org/ihtsdo/rvf/core/service/ValidationVersionLoader.java

@@ -109,11 +109,13 @@ public void loadProspectiveVersion(ValidationStatusReport statusReport, MysqlExe
 			//load prospective version alone now as used to combine with dependency for extension testing
 			uploadReleaseFileIntoDB(prospectiveVersion, null, validationConfig.getLocalProspectiveFile(), rf2FilesLoaded);
 		}
-
+		final String schemaName = prospectiveVersion.startsWith(RVF_DB_PREFIX) ? prospectiveVersion : RVF_DB_PREFIX + prospectiveVersion;
 		if (!validationConfig.isRf2DeltaOnly() && !checkDeltaFilesExist(validationConfig.getLocalProspectiveFile())) {
-			final String schemaName = prospectiveVersion.startsWith(RVF_DB_PREFIX) ? prospectiveVersion : RVF_DB_PREFIX + prospectiveVersion;
 			releaseDataManager.insertIntoProspectiveDeltaTables(schemaName, executionConfig);
 		}
+		if (!checkFullFilesExist(validationConfig.getLocalProspectiveFile())) {
+			releaseDataManager.insertIntoProspectiveFullTables(schemaName);
+		}
 
 		statusReport.setTotalRF2FilesLoaded(rf2FilesLoaded.size());
 		Collections.sort(rf2FilesLoaded);
@@ -141,6 +143,24 @@ private boolean checkDeltaFilesExist(File localProspectiveFile) throws ReleaseIm
 		return false;
 	}
 
+	private boolean checkFullFilesExist(File localProspectiveFile) throws ReleaseImportException {
+		try {
+			String deltaDirectoryPath = new ReleaseImporter().unzipRelease(new FileInputStream(localProspectiveFile), ReleaseImporter.ImportType.FULL).getAbsolutePath();
+			try(Stream<Path> pathStream = Files.find(new File(deltaDirectoryPath).toPath(), 50,
+					(path, basicFileAttributes) -> path.toFile().getName().matches("x?(sct|rel)2_Concept_[^_]*Full_.*.txt"))) {
+				if (pathStream.findFirst().isPresent()) {
+					return true;
+				}
+			}
+		} catch (IOException | IllegalStateException e) {
+			if (e.getMessage().contains("No Full files found")) {
+				return false;
+			}
+			throw new ReleaseImportException("Error while searching input files.", e);
+		}
+		return false;
+	}
+
 	private String loadRelease(String releaseVersion) throws IOException, BusinessServiceException {
 		if (releaseVersion != null && releaseVersion.endsWith(ZIP_FILE_EXTENSION)) {
 			String schemaName = RvfReleaseDbSchemaNameGenerator.generate(releaseVersion);
@@ -431,9 +451,9 @@ public void combineCurrentExtensionWithDependencySnapshot(MysqlExecutionConfig e
 		if (isExtension(validationConfig)) {
 			try {
 				releaseDataManager.copyTableData(extensionVersion, combinedVersion, DELTA_TABLE, null);
-				releaseDataManager.copyTableData(extensionVersion, combinedVersion,FULL_TABLE, null);
+				releaseDataManager.copyTableData(extensionVersion, combinedVersion, FULL_TABLE, null);
 				releaseDataManager.copyTableData(executionConfig.getExtensionDependencyVersion(),
-						extensionVersion, combinedVersion,SNAPSHOT_TABLE, null);
+						extensionVersion, combinedVersion, SNAPSHOT_TABLE, null);
 				resourceLoader.loadResourceData(combinedSchema);
 			} catch (Exception e) {
 				String errorMsg = e.getMessage();