diff options
Diffstat (limited to 'cps-ri/src/test/java/org/onap/cps/spi/impl/CpsModulePersistenceServiceTest.java')
| -rwxr-xr-x | cps-ri/src/test/java/org/onap/cps/spi/impl/CpsModulePersistenceServiceTest.java | 251 |
1 files changed, 0 insertions, 251 deletions
diff --git a/cps-ri/src/test/java/org/onap/cps/spi/impl/CpsModulePersistenceServiceTest.java b/cps-ri/src/test/java/org/onap/cps/spi/impl/CpsModulePersistenceServiceTest.java deleted file mode 100755 index 0705fc4e6..000000000 --- a/cps-ri/src/test/java/org/onap/cps/spi/impl/CpsModulePersistenceServiceTest.java +++ /dev/null @@ -1,251 +0,0 @@ -/* - * ============LICENSE_START======================================================= - * Copyright (C) 2020 Pantheon.tech - * ================================================================================ - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.cps.spi.impl; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertFalse; -import static org.junit.Assert.assertNotNull; -import static org.junit.Assert.assertTrue; -import static org.onap.cps.spi.CascadeDeleteAllowed.CASCADE_DELETE_ALLOWED; -import static org.onap.cps.spi.CascadeDeleteAllowed.CASCADE_DELETE_PROHIBITED; - -import com.google.common.collect.ImmutableMap; -import java.util.Map; -import java.util.Set; -import org.junit.ClassRule; -import org.junit.Test; -import org.junit.runner.RunWith; -import org.onap.cps.DatabaseTestContainer; -import org.onap.cps.spi.CpsAdminPersistenceService; -import org.onap.cps.spi.CpsModulePersistenceService; -import org.onap.cps.spi.entities.DataspaceEntity; -import org.onap.cps.spi.entities.SchemaSetEntity; -import org.onap.cps.spi.entities.YangResourceEntity; -import org.onap.cps.spi.exceptions.DataspaceNotFoundException; -import org.onap.cps.spi.exceptions.SchemaSetAlreadyDefinedException; -import org.onap.cps.spi.exceptions.SchemaSetInUseException; -import org.onap.cps.spi.exceptions.SchemaSetNotFoundException; -import org.onap.cps.spi.repository.AnchorRepository; -import org.onap.cps.spi.repository.DataspaceRepository; -import org.onap.cps.spi.repository.FragmentRepository; -import org.onap.cps.spi.repository.SchemaSetRepository; -import org.onap.cps.spi.repository.YangResourceRepository; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.boot.test.context.SpringBootTest; -import org.springframework.test.context.jdbc.Sql; -import org.springframework.test.context.junit4.SpringRunner; - -@RunWith(SpringRunner.class) -@SpringBootTest -public class CpsModulePersistenceServiceTest { - - private static final String CLEAR_DATA = "/data/clear-all.sql"; - private static final String SET_DATA = "/data/schemaset.sql"; - - private static final String ANCHOR_NAME = "ANCHOR-001"; - private static final String DATASPACE_NAME = "DATASPACE-001"; - private static final String DATASPACE_NAME_INVALID = "DATASPACE-X"; - private static final String SCHEMA_SET_NAME = "SCHEMA-SET-001"; - private static final String SCHEMA_SET_NAME_NEW = "SCHEMA-SET-NEW"; - private static final String SCHEMA_SET_NAME_NO_ANCHORS = "SCHEMA-SET-100"; - private static final String SCHEMA_SET_NAME_WITH_ANCHORS_AND_DATA = "SCHEMA-SET-101"; - - private static final String EXISTING_RESOURCE_NAME = "module1@2020-02-02.yang"; - private static final String EXISTING_RESOURCE_CONTENT = "CONTENT-001"; - private static final String EXISTING_RESOURCE_CHECKSUM = "877e65a9f36d54e7702c3f073f6bc42b"; - private static final Long EXISTING_RESOURCE_ID = 3001L; - - private static final String NEW_RESOURCE_NAME = "new-module@2020-02-02.yang"; - private static final String NEW_RESOURCE_CONTENT = "CONTENT-NEW"; - private static final String NEW_RESOURCE_CHECKSUM = "c94d40a1350eb1c0b1c1949eac84fc59"; - private static final Long NEW_RESOURCE_ABSTRACT_ID = 0L; - - private static final Long SHARED_RESOURCE_ID1 = 3003L; - private static final Long SHARED_RESOURCE_ID2 = 3004L; - private static final Long ORPHAN_RESOURCE_ID = 3100L; - private static final Integer REMOVED_ANCHOR_ID1 = 6001; - private static final Integer REMOVED_ANCHOR_ID2 = 6002; - private static final Long REMOVED_FRAGMENT_ID = 7001L; - - @ClassRule - public static DatabaseTestContainer testContainer = DatabaseTestContainer.getInstance(); - - @Autowired - private CpsModulePersistenceService cpsModulePersistenceService; - - @Autowired - private CpsAdminPersistenceService cpsAdminPersistenceService; - - @Autowired - DataspaceRepository dataspaceRepository; - - @Autowired - private SchemaSetRepository schemaSetRepository; - - @Autowired - private YangResourceRepository yangResourceRepository; - - @Autowired - private AnchorRepository anchorRepository; - - @Autowired - private FragmentRepository fragmentRepository; - - @Test(expected = DataspaceNotFoundException.class) - @Sql(CLEAR_DATA) - public void testStoreSchemaSetToInvalidDataspace() { - cpsModulePersistenceService.storeSchemaSet(DATASPACE_NAME_INVALID, SCHEMA_SET_NAME_NEW, - toMap(NEW_RESOURCE_NAME, NEW_RESOURCE_CONTENT)); - } - - @Test(expected = SchemaSetAlreadyDefinedException.class) - @Sql({CLEAR_DATA, SET_DATA}) - public void testStoreDuplicateSchemaSet() { - cpsModulePersistenceService.storeSchemaSet(DATASPACE_NAME, SCHEMA_SET_NAME, - toMap(NEW_RESOURCE_NAME, NEW_RESOURCE_CONTENT)); - } - - @Test - @Sql({CLEAR_DATA, SET_DATA}) - public void testStoreSchemaSetWithNewYangResource() { - final Map<String, String> yangResourcesNameToContentMap = toMap(NEW_RESOURCE_NAME, NEW_RESOURCE_CONTENT); - cpsModulePersistenceService.storeSchemaSet(DATASPACE_NAME, SCHEMA_SET_NAME_NEW, - yangResourcesNameToContentMap); - assertSchemaSetPersisted(DATASPACE_NAME, SCHEMA_SET_NAME_NEW, - NEW_RESOURCE_ABSTRACT_ID, NEW_RESOURCE_NAME, NEW_RESOURCE_CONTENT, NEW_RESOURCE_CHECKSUM); - assertEquals(yangResourcesNameToContentMap, - cpsModulePersistenceService.getYangSchemaResources(DATASPACE_NAME, SCHEMA_SET_NAME_NEW)); - } - - @Test - @Sql({CLEAR_DATA, SET_DATA}) - public void testGetYangResourcesWithAnchorName() { - final Map<String, String> yangResourcesNameToContentMap = - toMap(NEW_RESOURCE_NAME, NEW_RESOURCE_CONTENT); - cpsModulePersistenceService.storeSchemaSet(DATASPACE_NAME, SCHEMA_SET_NAME_NEW, - yangResourcesNameToContentMap); - - cpsAdminPersistenceService.createAnchor(DATASPACE_NAME, SCHEMA_SET_NAME_NEW, ANCHOR_NAME); - assertEquals(yangResourcesNameToContentMap, - cpsModulePersistenceService.getYangSchemaSetResources(DATASPACE_NAME, ANCHOR_NAME)); - } - - @Test - @Sql({CLEAR_DATA, SET_DATA}) - public void testStoreSchemaSetWithExistingYangResourceReuse() { - cpsModulePersistenceService.storeSchemaSet(DATASPACE_NAME, SCHEMA_SET_NAME_NEW, - toMap(NEW_RESOURCE_NAME, EXISTING_RESOURCE_CONTENT)); - assertSchemaSetPersisted(DATASPACE_NAME, SCHEMA_SET_NAME_NEW, - EXISTING_RESOURCE_ID, EXISTING_RESOURCE_NAME, EXISTING_RESOURCE_CONTENT, EXISTING_RESOURCE_CHECKSUM); - } - - private void assertSchemaSetPersisted(final String expectedDataspaceName, final String expectedSchemaSetName, - final Long expectedYangResourceId, final String expectedYangResourceName, - final String expectedYangResourceContent, - final String expectedYangResourceChecksum) { - - // assert the schema set is persisted - final SchemaSetEntity schemaSetEntity = getSchemaSetFromDatabase(expectedDataspaceName, expectedSchemaSetName); - assertEquals(expectedDataspaceName, schemaSetEntity.getDataspace().getName()); - assertEquals(expectedSchemaSetName, schemaSetEntity.getName()); - - // assert the attached yang resource is persisted - final Set<YangResourceEntity> yangResourceEntities = schemaSetEntity.getYangResources(); - assertNotNull(yangResourceEntities); - assertEquals(1, yangResourceEntities.size()); - - // assert the attached yang resource content - final YangResourceEntity yangResourceEntity = yangResourceEntities.iterator().next(); - assertNotNull(yangResourceEntity.getId()); - if (expectedYangResourceId != NEW_RESOURCE_ABSTRACT_ID) { - // existing resource with known id - assertEquals(expectedYangResourceId, yangResourceEntity.getId()); - } - assertEquals(expectedYangResourceName, yangResourceEntity.getName()); - assertEquals(expectedYangResourceContent, yangResourceEntity.getContent()); - assertEquals(expectedYangResourceChecksum, yangResourceEntity.getChecksum()); - } - - @Test - @Sql({CLEAR_DATA, SET_DATA}) - public void testStrictDeleteSchemaSetNoAnchors() { - cpsModulePersistenceService.deleteSchemaSet(DATASPACE_NAME, SCHEMA_SET_NAME_NO_ANCHORS, - CASCADE_DELETE_PROHIBITED); - - // validate schema set removed - final DataspaceEntity dataspaceEntity = dataspaceRepository.getByName(DATASPACE_NAME); - assertFalse(schemaSetRepository - .findByDataspaceAndName(dataspaceEntity, SCHEMA_SET_NAME_NO_ANCHORS).isPresent()); - - // validate shared resource remain, but orphan one is removed - assertTrue(yangResourceRepository.findById(SHARED_RESOURCE_ID1).isPresent()); - assertFalse(yangResourceRepository.findById(ORPHAN_RESOURCE_ID).isPresent()); - } - - - @Test - @Sql({CLEAR_DATA, SET_DATA}) - public void testFullDeleteSchemaSetWithAnchorsAndData() { - cpsModulePersistenceService - .deleteSchemaSet(DATASPACE_NAME, SCHEMA_SET_NAME_WITH_ANCHORS_AND_DATA, CASCADE_DELETE_ALLOWED); - - // validate schema set removed - final DataspaceEntity dataspaceEntity = dataspaceRepository.getByName(DATASPACE_NAME); - assertFalse(schemaSetRepository - .findByDataspaceAndName(dataspaceEntity, SCHEMA_SET_NAME_WITH_ANCHORS_AND_DATA).isPresent()); - - // validate shared resources remain - assertTrue(yangResourceRepository.findById(SHARED_RESOURCE_ID1).isPresent()); - assertTrue(yangResourceRepository.findById(SHARED_RESOURCE_ID2).isPresent()); - - // validate associated anchors and data are removed - assertFalse(anchorRepository.findById(REMOVED_ANCHOR_ID1).isPresent()); - assertFalse(anchorRepository.findById(REMOVED_ANCHOR_ID2).isPresent()); - assertFalse(fragmentRepository.findById(REMOVED_FRAGMENT_ID).isPresent()); - } - - @Test(expected = DataspaceNotFoundException.class) - @Sql(CLEAR_DATA) - public void testDeleteSchemaSetWithinInvalidDataspace() { - cpsModulePersistenceService.deleteSchemaSet(DATASPACE_NAME_INVALID, SCHEMA_SET_NAME, CASCADE_DELETE_ALLOWED); - } - - @Test(expected = SchemaSetNotFoundException.class) - @Sql({CLEAR_DATA, SET_DATA}) - public void testDeleteNonExistingSchemaSet() { - cpsModulePersistenceService.deleteSchemaSet(DATASPACE_NAME, SCHEMA_SET_NAME_NEW, CASCADE_DELETE_ALLOWED); - } - - @Test(expected = SchemaSetInUseException.class) - @Sql({CLEAR_DATA, SET_DATA}) - public void testStrictDeleteSchemaSetInUse() { - cpsModulePersistenceService - .deleteSchemaSet(DATASPACE_NAME, SCHEMA_SET_NAME_WITH_ANCHORS_AND_DATA, CASCADE_DELETE_PROHIBITED); - } - - private static Map<String, String> toMap(final String key, final String value) { - return ImmutableMap.<String, String>builder().put(key, value).build(); - } - - private SchemaSetEntity getSchemaSetFromDatabase(final String dataspaceName, final String schemaSetName) { - final DataspaceEntity dataspaceEntity = dataspaceRepository.findByName(dataspaceName).orElseThrow(); - return schemaSetRepository.findByDataspaceAndName(dataspaceEntity, schemaSetName).orElseThrow(); - } -} |