From: Toine Siebelink Date: Tue, 9 Nov 2021 10:57:21 +0000 (+0000) Subject: Merge "Fix for get anchor identifiers by module names" X-Git-Tag: mr/823/126723/7~34 X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=7a9e0f81770f2aa2793e241cee3a3c6c9bb40d9d;hp=-c;p=cps.git Merge "Fix for get anchor identifiers by module names" --- 7a9e0f81770f2aa2793e241cee3a3c6c9bb40d9d diff --combined cps-ri/src/main/java/org/onap/cps/spi/impl/CpsAdminPersistenceServiceImpl.java index 9f33b2fa5,e5df9c5ca..b1bd03c25 --- a/cps-ri/src/main/java/org/onap/cps/spi/impl/CpsAdminPersistenceServiceImpl.java +++ b/cps-ri/src/main/java/org/onap/cps/spi/impl/CpsAdminPersistenceServiceImpl.java @@@ -30,7 -30,6 +30,7 @@@ import javax.transaction.Transactional import org.onap.cps.spi.CpsAdminPersistenceService; import org.onap.cps.spi.entities.AnchorEntity; import org.onap.cps.spi.entities.DataspaceEntity; +import org.onap.cps.spi.entities.YangResourceModuleReference; import org.onap.cps.spi.exceptions.AlreadyDefinedException; import org.onap.cps.spi.exceptions.ModuleNamesNotFoundException; import org.onap.cps.spi.model.Anchor; @@@ -97,8 -96,9 +97,9 @@@ public class CpsAdminPersistenceService @Override public Collection queryAnchors(final String dataspaceName, final Collection inputModuleNames) { validateDataspaceAndModuleNames(dataspaceName, inputModuleNames); - final Collection anchorEntities = - anchorRepository.getAnchorsByDataspaceNameAndModuleNames(dataspaceName, inputModuleNames); + final DataspaceEntity dataspaceEntity = dataspaceRepository.getByName(dataspaceName); + final Collection anchorEntities = anchorRepository + .getAnchorsByDataspaceIdAndModuleNames(dataspaceEntity.getId(), inputModuleNames, inputModuleNames.size()); return anchorEntities.stream().map(CpsAdminPersistenceServiceImpl::toAnchor).collect(Collectors.toSet()); } @@@ -132,7 -132,7 +133,7 @@@ final Collection inputModuleNames) { final Collection retrievedModuleNames = yangResourceRepository.findAllModuleReferences(dataspaceName, inputModuleNames) - .stream().map(module -> module.getModuleName()) + .stream().map(YangResourceModuleReference::getModuleName) .collect(Collectors.toList()); if (retrievedModuleNames.isEmpty()) { dataspaceRepository.getByName(dataspaceName);