in ddm-rrm-data-model-management/src/main/java/com/epam/digital/data/platform/management/service/impl/ReadDataBaseTablesServiceImpl.java [88:113]
private Catalog getCatalog(String versionId, boolean isSuccessBuild) {
Catalog catalog = cacheService.getCatalogCache(versionId);
if (Objects.nonNull(catalog)){
log.trace("getting schema catalog for version '{}' from cache", versionId);
return catalog;
}
try {
log.trace("trying getting schema catalog for version '{}' from db", versionId);
catalog = versionContextComponentManager.getComponent(versionId, Catalog.class);
if (isSuccessBuild) {
log.trace("updating schema catalog in cache");
cacheService.updateCatalogCache(versionId, catalog);
}
return catalog;
} catch (VersionComponentCreationException e) {
if (gerritPropertiesConfig.getHeadBranch().equals(versionId)) {
log.error("Couldn't connect to master version data-base: {}", e.getMessage());
throw registryDataBaseConnectionException(e);
} else {
log.warn("Couldn't connect to version-candidate {} data-base: {}", versionId,
e.getMessage());
checkMainDataBaseConnection();
return null;
}
}
}