diff options
Diffstat (limited to 'blueprints-processor/adaptors/data-adaptor-provider/src')
12 files changed, 838 insertions, 0 deletions
diff --git a/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/dao/ConfigPropertyMapDaoTest.java b/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/dao/ConfigPropertyMapDaoTest.java new file mode 100644 index 000000000..487bcd932 --- /dev/null +++ b/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/dao/ConfigPropertyMapDaoTest.java @@ -0,0 +1,48 @@ +/*
+ * Copyright © 2017-2018 AT&T Intellectual Property.
+ *
+ * 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.
+ */
+
+package org.onap.ccsdk.config.data.adaptor.dao;
+
+import org.junit.Assert;
+import org.junit.FixMethodOrder;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.MethodSorters;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = {"classpath:test-context-h2db.xml"})
+@FixMethodOrder(MethodSorters.NAME_ASCENDING)
+public class ConfigPropertyMapDaoTest {
+
+ @Autowired
+ private ConfigPropertyMapDao configPropertyMapDao;
+
+ @Autowired
+ private QueryExecutorDao queryExecutorDao;
+
+ @Test
+ public void testConfigResourcesData() throws Exception {
+ String sql = "INSERT INTO CONFIG_PROPERTY_MAP (reference_key, reference_value) VALUES ( ?, ?)";
+ Object[] data = new Object[] {"dummy123", "username123"};
+ int result = queryExecutorDao.update(sql, data);
+ Assert.assertNotNull("Failed to get Query Result", result);
+
+ String propKeyValye = configPropertyMapDao.getConfigPropertyByKey("org.onap.ccsdk.config.rest.adaptors.test");
+ Assert.assertNull("propKeyValue is null", propKeyValye);
+ }
+
+}
diff --git a/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/dao/ConfigResourceDaoTest.java b/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/dao/ConfigResourceDaoTest.java new file mode 100644 index 000000000..ae493e692 --- /dev/null +++ b/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/dao/ConfigResourceDaoTest.java @@ -0,0 +1,122 @@ +/*
+ * Copyright © 2017-2018 AT&T Intellectual Property.
+ *
+ * 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.
+ */
+
+package org.onap.ccsdk.config.data.adaptor.dao;
+
+import java.nio.charset.Charset;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import org.apache.commons.io.IOUtils;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.FixMethodOrder;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.MethodSorters;
+import org.onap.ccsdk.config.data.adaptor.domain.ConfigResource;
+import org.onap.ccsdk.config.data.adaptor.domain.ResourceAssignmentData;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = {"classpath:test-context-h2db.xml"})
+@FixMethodOrder(MethodSorters.NAME_ASCENDING)
+public class ConfigResourceDaoTest {
+
+ private static EELFLogger logger = EELFManager.getInstance().getLogger(ConfigResourceDaoTest.class);
+
+ @Autowired
+ private ConfigResourceDao configResourceDao;
+
+ @Before
+ public void initialise() {
+
+ }
+
+ @Test
+ public void testAssignmentResourceData() throws Exception {
+ ConfigResource configResource = new ConfigResource();
+ String resourceData = IOUtils.toString(
+ ConfigResourceDaoTest.class.getClassLoader().getResourceAsStream("reference/resource_data.json"),
+ Charset.defaultCharset());
+
+ logger.trace("resourceData = " + resourceData);
+ configResource.setResourceData(resourceData);
+ configResource.setServiceTemplateName("sample-name");
+ configResource.setServiceTemplateVersion("1.0.0");
+ configResource.setResourceId("123456");
+ configResource.setResourceType("vUSP - vDBE-IPX HUB");
+ configResource.setRequestId("123456");
+ configResource.setRecipeName("activate-action");
+ configResource.setTemplateName("vrr-service-template");
+ configResource.setMaskData(null);
+ configResource.setStatus("success");
+ configResource.setCreatedDate(new Date(System.currentTimeMillis()));
+ configResource.setUpdatedBy("an188a");
+
+ List<ResourceAssignmentData> resourceAssignments = new ArrayList<>();
+ ResourceAssignmentData resourceAssignmentData = new ResourceAssignmentData();
+ resourceAssignmentData.setDataType("string");
+ resourceAssignmentData.setStatus("success");
+ resourceAssignmentData.setMessage("success");
+ resourceAssignmentData.setTemplateKeyName("sample");
+ resourceAssignmentData.setResourceName("sample");
+ // resourceAssignmentData.setResourceValue("sample123");
+ resourceAssignmentData.setSource("input");
+ resourceAssignments.add(resourceAssignmentData);
+ configResource.setResourceAssignments(resourceAssignments);
+
+ ConfigResource dbConfigResource = configResourceDao.save(configResource);
+ logger.info("Saved sucessfully : " + dbConfigResource.toString());
+ Assert.assertNotNull("ConfigResource is null", dbConfigResource);
+ Assert.assertNotNull("Resource Assignment Data is null", dbConfigResource.getResourceAssignments());
+ Assert.assertEquals("Resource Assignment Data count missmatch", true,
+ dbConfigResource.getResourceAssignments().size() > 0);
+ }
+
+ @Test
+ public void testConfigResourcesData() throws Exception {
+ ConfigResource configResourceInput = new ConfigResource();
+ configResourceInput.setResourceId("123456");
+ List<ConfigResource> dbConfigResources = configResourceDao.findByConfigResource(configResourceInput);
+ Assert.assertNotNull("ConfigResources is null", dbConfigResources);
+ Assert.assertEquals("ConfigResources size missmatch", true, dbConfigResources.size() > 0);
+
+ for (ConfigResource configResource : dbConfigResources) {
+ Assert.assertNotNull("ConfigResources Assignments is null", configResource.getResourceAssignments());
+ Assert.assertTrue("ConfigResources Assignments size miss mathch ",
+ configResource.getResourceAssignments().size() > 0);
+ logger.trace("ResourceAssignments = " + configResource.getResourceAssignments());
+ }
+ }
+
+ @Test
+ public void testDeleteByConfigResource() throws Exception {
+ ConfigResource configResourceInput = new ConfigResource();
+ configResourceInput.setResourceId("123456");
+
+ List<ConfigResource> dbConfigResources = configResourceDao.findByConfigResource(configResourceInput);
+ Assert.assertTrue("ConfigResources is null", !dbConfigResources.isEmpty());
+
+ configResourceInput.setConfigResourceId(dbConfigResources.get(0).getConfigResourceId());
+ configResourceDao.deleteByConfigResource(configResourceInput);
+
+ dbConfigResources = configResourceDao.findByConfigResource(configResourceInput);
+ Assert.assertTrue("ConfigResources is not null", dbConfigResources.isEmpty());
+ }
+}
diff --git a/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/dao/ConfigTransactionLogDaoTest.java b/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/dao/ConfigTransactionLogDaoTest.java new file mode 100644 index 000000000..1fceccebf --- /dev/null +++ b/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/dao/ConfigTransactionLogDaoTest.java @@ -0,0 +1,76 @@ +/*
+ * Copyright © 2017-2018 AT&T Intellectual Property.
+ *
+ * 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.
+ */
+
+package org.onap.ccsdk.config.data.adaptor.dao;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.FixMethodOrder;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.MethodSorters;
+import org.onap.ccsdk.config.data.adaptor.DataAdaptorConstants;
+import org.onap.ccsdk.config.data.adaptor.domain.TransactionLog;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = {"classpath:test-context-h2db.xml"})
+@FixMethodOrder(MethodSorters.NAME_ASCENDING)
+public class ConfigTransactionLogDaoTest {
+ private static EELFLogger logger = EELFManager.getInstance().getLogger(ConfigTransactionLogDaoTest.class);
+
+ @Autowired
+ private TransactionLogDao transactionLogDao;
+
+ @Autowired
+ private NamedQueryExecutorDao namedQueryExecutorDao;
+
+ @Before
+ public void initialise() {
+
+ }
+
+ @Test
+ public void testQueryExecution() throws Exception {
+ String requestId = "12345";
+
+ transactionLogDao
+ .save(new TransactionLog(requestId, DataAdaptorConstants.LOG_MESSAGE_TYPE_LOG, "Received Request"));
+
+ List<TransactionLog> result = transactionLogDao.getTransactionsByRequestId(requestId);
+ logger.info("DB ArtifactReference :" + result);
+ Assert.assertNotNull("Failed to get Query Result", result);
+
+ List<TransactionLog> result2 =
+ transactionLogDao.getTransactionsByRequestId(requestId, DataAdaptorConstants.LOG_MESSAGE_TYPE_LOG);
+ logger.info("DB ArtifactReference :" + result2);
+ Assert.assertNotNull("Failed to get Query Result", result2);
+
+ String namedsql = "SELECT * FROM CONFIG_TRANSACTION_LOG WHERE request_id = :request_id";
+ Map<String, Object> parameters = new HashMap<>();
+ parameters.put("request_id", "12345");
+ List<Map<String, Object>> namedresult = namedQueryExecutorDao.query(namedsql, parameters);
+ logger.info("DB ArtifactReference :" + namedresult);
+ Assert.assertNotNull("Failed to get Query Result", namedresult);
+
+ }
+
+}
diff --git a/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/dao/QueryExecutorDaoTest.java b/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/dao/QueryExecutorDaoTest.java new file mode 100644 index 000000000..ce3e95224 --- /dev/null +++ b/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/dao/QueryExecutorDaoTest.java @@ -0,0 +1,78 @@ +/*
+ * Copyright © 2017-2018 AT&T Intellectual Property.
+ *
+ * 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.
+ */
+
+package org.onap.ccsdk.config.data.adaptor.dao;
+
+import java.util.Date;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.FixMethodOrder;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.MethodSorters;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = {"classpath:test-context-h2db.xml"})
+@FixMethodOrder(MethodSorters.NAME_ASCENDING)
+public class QueryExecutorDaoTest {
+ private static EELFLogger logger = EELFManager.getInstance().getLogger(QueryExecutorDaoTest.class);
+
+ @Autowired
+ private QueryExecutorDao queryExecutorDao;
+
+ @Before
+ public void initialise() {
+
+ }
+
+ @Test
+ public void testInsertQueryExecution() throws Exception {
+
+ String sql = "INSERT INTO CONFIG_RESOURCE"
+ + "(config_resource_id, resource_id, resource_type, template_name, recipe_name, request_id, resource_data, mask_data, created_date, updated_by) "
+ + "VALUES ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )";
+ Object[] data =
+ new Object[] {"12345", "vUSP - vDBE-IPX HUB", "1234567", "activate-action", "vrr-service-template",
+ "resource-data", "mask-data", null, new Date(System.currentTimeMillis()), "ab1234"};
+ int result = queryExecutorDao.update(sql, data);
+ logger.info("Updated successfully rows :" + result);
+ Assert.assertNotNull("Failed to get Query Result", result);
+ }
+
+ @Test
+ public void testUpdateQueryExecution() throws Exception {
+
+ String sql = "UPDATE CONFIG_RESOURCE set recipe_name=? where config_resource_id=?";
+ Object[] data = new Object[] {"vce-service-template", "12345"};
+ int result = queryExecutorDao.update(sql, data);
+ logger.info("Updated successfully rows :" + result);
+ Assert.assertNotNull("Failed to get Query Result", result);
+ }
+
+ @Test
+ public void testDeleteQueryExecution() throws Exception {
+
+ String sql = "DELETE FROM CONFIG_RESOURCE where config_resource_id=?";
+ Object[] data = new Object[] {"12345"};
+ int result = queryExecutorDao.update(sql, data);
+ logger.info("Updated successfully rows :" + result);
+ Assert.assertNotNull("Failed to get Query Result", result);
+ }
+
+}
diff --git a/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/service/ConfigResourceNodeTest.java b/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/service/ConfigResourceNodeTest.java new file mode 100644 index 000000000..847d5ed42 --- /dev/null +++ b/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/service/ConfigResourceNodeTest.java @@ -0,0 +1,83 @@ +/*
+ * Copyright © 2017-2018 AT&T Intellectual Property.
+ *
+ * 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.
+ */
+
+package org.onap.ccsdk.config.data.adaptor.service;
+
+import java.util.HashMap;
+import java.util.Map;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.onap.ccsdk.config.data.adaptor.DataAdaptorConstants;
+import org.onap.ccsdk.config.data.adaptor.dao.ConfigPropertyMapDao;
+import org.onap.ccsdk.config.data.adaptor.dao.ConfigResourceDao;
+import org.onap.ccsdk.config.data.adaptor.dao.NamedQueryExecutorDao;
+import org.onap.ccsdk.config.data.adaptor.dao.QueryExecutorDao;
+import org.onap.ccsdk.config.data.adaptor.dao.TransactionLogDao;
+import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
+import org.onap.ccsdk.sli.core.sli.SvcLogicException;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = {"classpath:test-context-h2db.xml"})
+public class ConfigResourceNodeTest {
+
+ ConfigResourceNode configResourceNode;
+
+ ConfigResourceService configResourceService;
+
+ @Autowired
+ TransactionLogDao transactionLogDao;
+
+ @Autowired
+ ConfigResourceDao configResourceDao;
+
+ @Autowired
+ QueryExecutorDao queryExecutorDao;
+
+ @Autowired
+ NamedQueryExecutorDao namedQueryExecutorDao;
+
+ @Autowired
+ ConfigPropertyMapDao configPropertyMapDao;
+
+ @Before
+ public void before() {
+ configResourceService = new ConfigResourceServiceImpl(transactionLogDao, configResourceDao, queryExecutorDao,
+ namedQueryExecutorDao, configPropertyMapDao);
+ configResourceNode = new ConfigResourceNode(configResourceService);
+ }
+
+ @Test
+ public void testSaveConfigTransactionLog() throws Exception {
+ Map<String, String> inParams = new HashMap<>();
+ inParams.put(DataAdaptorConstants.INPUT_PARAM_MESSAGE_TYPE, "messageType");
+ inParams.put(DataAdaptorConstants.INPUT_PARAM_MESSAGE, "message");
+ SvcLogicContext ctx = new SvcLogicContext();
+ ctx.setAttribute("request-id", "requestId12345");
+
+ configResourceNode.saveConfigTransactionLog(inParams, ctx);
+
+ Assert.assertTrue(!transactionLogDao.getTransactionsByRequestId("requestId12345").isEmpty());
+ }
+
+ @Test(expected = SvcLogicException.class)
+ public void testSaveConfigTransactionLogException() throws Exception {
+ configResourceNode = new ConfigResourceNode(null);
+ configResourceNode.saveConfigTransactionLog(new HashMap<>(), new SvcLogicContext());
+ }
+}
diff --git a/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/service/ConfigResourceServiceTest.java b/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/service/ConfigResourceServiceTest.java new file mode 100644 index 000000000..1240ca237 --- /dev/null +++ b/blueprints-processor/adaptors/data-adaptor-provider/src/test/java/org/onap/ccsdk/config/data/adaptor/service/ConfigResourceServiceTest.java @@ -0,0 +1,189 @@ +/*
+ * Copyright © 2017-2018 AT&T Intellectual Property.
+ *
+ * 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.
+ */
+
+package org.onap.ccsdk.config.data.adaptor.service;
+
+import java.nio.charset.Charset;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+import org.apache.commons.io.IOUtils;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.onap.ccsdk.config.data.adaptor.dao.ConfigPropertyMapDao;
+import org.onap.ccsdk.config.data.adaptor.dao.ConfigResourceDao;
+import org.onap.ccsdk.config.data.adaptor.dao.ConfigResourceDaoTest;
+import org.onap.ccsdk.config.data.adaptor.dao.NamedQueryExecutorDao;
+import org.onap.ccsdk.config.data.adaptor.dao.QueryExecutorDao;
+import org.onap.ccsdk.config.data.adaptor.dao.TransactionLogDao;
+import org.onap.ccsdk.config.data.adaptor.domain.ConfigResource;
+import org.onap.ccsdk.config.data.adaptor.domain.ResourceAssignmentData;
+import org.onap.ccsdk.config.data.adaptor.domain.TransactionLog;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = {"classpath:test-context-h2db.xml"})
+public class ConfigResourceServiceTest {
+
+ ConfigResourceService configResourceService;
+
+ @Autowired
+ TransactionLogDao transactionLogDao;
+
+ @Autowired
+ ConfigResourceDao configResourceDao;
+
+ @Autowired
+ QueryExecutorDao queryExecutorDao;
+
+ @Autowired
+ NamedQueryExecutorDao namedQueryExecutorDao;
+
+ @Autowired
+ ConfigPropertyMapDao configPropertyMapDao;
+
+ @Before
+ public void before() {
+ configResourceService = new ConfigResourceServiceImpl(transactionLogDao, configResourceDao, queryExecutorDao,
+ namedQueryExecutorDao, configPropertyMapDao);
+ }
+
+ @Test
+ public void testUpdate() throws Exception {
+ String sql = "INSERT INTO CONFIG_RESOURCE"
+ + "(config_resource_id, resource_id, resource_type, template_name, recipe_name, request_id, resource_data, mask_data, created_date, updated_by) "
+ + "VALUES ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )";
+ Object[] data =
+ new Object[] {"54321", "vUSP - vDBE-IPX HUB", "1234567", "activate-action", "vrr-service-template",
+ "resource-data", "mask-data", null, new Date(System.currentTimeMillis()), "ab1234"};
+ int result = configResourceService.update(sql, data);
+ Assert.assertTrue(result == 1);
+
+ sql = "SELECT * FROM CONFIG_RESOURCE WHERE config_resource_id = ?";
+ data = new Object[] {"54321"};
+ List<Map<String, Object>> queryResult = configResourceService.query(sql, data);
+ Assert.assertTrue(queryResult.size() == 1);
+ }
+
+ @Test
+ public void testSaveAndGetConfigResource() throws Exception {
+ ConfigResource configResource = new ConfigResource();
+ String resourceData = IOUtils.toString(
+ ConfigResourceDaoTest.class.getClassLoader().getResourceAsStream("reference/resource_data.json"),
+ Charset.defaultCharset());
+
+ configResource.setResourceData(resourceData);
+ configResource.setServiceTemplateName("sample-name");
+ configResource.setServiceTemplateVersion("1.0.0");
+ configResource.setResourceId("123456");
+ configResource.setResourceType("vUSP - vDBE-IPX HUB");
+ configResource.setRequestId("123456");
+ configResource.setRecipeName("activate-action");
+ configResource.setTemplateName("vrr-service-template");
+ configResource.setMaskData(null);
+ configResource.setStatus("success");
+ configResource.setCreatedDate(new Date(System.currentTimeMillis()));
+ configResource.setUpdatedBy("an188a");
+
+ List<ResourceAssignmentData> resourceAssignments = new ArrayList<>();
+ ResourceAssignmentData resourceAssignmentData = new ResourceAssignmentData();
+ resourceAssignmentData.setDataType("string");
+ resourceAssignmentData.setStatus("success");
+ resourceAssignmentData.setMessage("success");
+ resourceAssignmentData.setTemplateKeyName("sample");
+ resourceAssignmentData.setResourceName("sample");
+ // resourceAssignmentData.setResourceValue("sample123");
+ resourceAssignmentData.setSource("input");
+ resourceAssignments.add(resourceAssignmentData);
+ configResource.setResourceAssignments(resourceAssignments);
+
+ // save
+ ConfigResource dbConfigResource = configResourceService.saveConfigResource(configResource);
+ Assert.assertNotNull("ConfigResource is null", dbConfigResource);
+ Assert.assertNotNull("Resource Assignment Data is null", dbConfigResource.getResourceAssignments());
+ Assert.assertEquals("Resource Assignment Data count missmatch", true,
+ dbConfigResource.getResourceAssignments().size() > 0);
+ Assert.assertEquals(configResource.getServiceTemplateVersion(), dbConfigResource.getServiceTemplateVersion());
+
+ // update
+ configResource.setServiceTemplateVersion("1.0.1");
+ dbConfigResource = configResourceService.saveConfigResource(configResource);
+ Assert.assertNotNull("ConfigResource is null", dbConfigResource);
+ Assert.assertNotNull("Resource Assignment Data is null", dbConfigResource.getResourceAssignments());
+ Assert.assertEquals("Resource Assignment Data count missmatch", true,
+ dbConfigResource.getResourceAssignments().size() > 0);
+ Assert.assertEquals(configResource.getServiceTemplateVersion(), dbConfigResource.getServiceTemplateVersion());
+
+ // find
+ ConfigResource configResourceInput = new ConfigResource();
+ configResourceInput.setResourceId(configResource.getResourceId());
+ configResourceInput.setTemplateName(configResource.getTemplateName());
+ configResourceInput.setServiceTemplateName(configResource.getServiceTemplateName());
+ configResourceInput.setServiceTemplateVersion(configResource.getServiceTemplateVersion());
+ configResourceInput.setRequestId(configResource.getRequestId());
+ configResourceInput.setRecipeName(configResource.getRecipeName());
+ configResourceInput.setResourceType(configResource.getResourceType());
+ List<ConfigResource> dbConfigResources = configResourceService.getConfigResource(configResourceInput);
+ Assert.assertNotNull("ConfigResources is null", dbConfigResources);
+ Assert.assertEquals("ConfigResources size missmatch", true, dbConfigResources.size() > 0);
+
+ for (ConfigResource dbConfigResouce : dbConfigResources) {
+ Assert.assertNotNull("ConfigResources Assignments is null", dbConfigResouce.getResourceAssignments());
+ Assert.assertTrue("ConfigResources Assignments size miss mathch ",
+ dbConfigResouce.getResourceAssignments().size() > 0);
+ }
+ }
+
+ @Test
+ public void testSaveAndGetTransactionLog() throws Exception {
+ TransactionLog transactionLog = new TransactionLog();
+ transactionLog.setMessage("message");
+ transactionLog.setMessageType("messageType");
+ transactionLog.setRequestId("requestId");
+
+ configResourceService.save(transactionLog);
+
+ List<TransactionLog> transactions =
+ configResourceService.getTransactionsByRequestId(transactionLog.getRequestId());
+ Assert.assertTrue(transactions.size() == 1);
+ transactions = configResourceService.getTransactionsByRequestId(transactionLog.getRequestId(),
+ transactionLog.getMessageType());
+ Assert.assertTrue(transactions.size() == 1);
+ }
+
+ @Test
+ public void testNamedQueryExecutorUpdateNQuery() throws Exception {
+ Map<String, Object> parameters = new HashMap<>();
+ parameters.put("config_transaction_log_id", UUID.randomUUID().toString());
+ parameters.put("request_id", "requestId123");
+ parameters.put("message_type", "messageType");
+ parameters.put("message", "message");
+ configResourceService.update(
+ "INSERT INTO CONFIG_TRANSACTION_LOG ( config_transaction_log_id, request_id, message_type, message ) VALUES (:config_transaction_log_id, :request_id, :message_type, :message) ",
+ parameters);
+
+ List<Map<String, Object>> result = configResourceService
+ .query("SELECT * FROM CONFIG_TRANSACTION_LOG WHERE request_id = :request_id", parameters);
+
+ Assert.assertTrue(!result.isEmpty());
+ Assert.assertNotNull(configResourceService.getNamedParameterJdbcTemplate());
+ }
+}
diff --git a/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/log4j.properties b/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/log4j.properties new file mode 100644 index 000000000..ce75592ff --- /dev/null +++ b/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/log4j.properties @@ -0,0 +1,5 @@ +log4j.rootLogger=INFO, A1 +log4j.appender.A1=org.apache.log4j.ConsoleAppender +log4j.appender.A1.layout=org.apache.log4j.PatternLayout +log4j.appender.A1.layout.ConversionPattern=%d{ISO8601} %5p %t %X{UUID} %c{3}:%L - %m%n +log4j.logger.org.hibernate=INFO diff --git a/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/mappings/service-mapping.json b/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/mappings/service-mapping.json new file mode 100644 index 000000000..e595e1613 --- /dev/null +++ b/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/mappings/service-mapping.json @@ -0,0 +1,11 @@ +{
+ "resource": {
+ "name": "bundle-mac",
+ "searchCriteriaDefintion": {
+ "sourceSystemResourceResolution": {
+ "searchCriteriaValue": "$ptnni_equip_name",
+ "searchCriteriaType": "equipment"
+ }
+ }
+ }
+}
diff --git a/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/reference/resource_data.json b/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/reference/resource_data.json new file mode 100644 index 000000000..32162ecaf --- /dev/null +++ b/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/reference/resource_data.json @@ -0,0 +1,3 @@ +{
+ "group-name": "AG_AUTORP_NOOVERRIDE"
+}
diff --git a/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/sql/schema.sql b/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/sql/schema.sql new file mode 100644 index 000000000..15d22e242 --- /dev/null +++ b/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/sql/schema.sql @@ -0,0 +1,46 @@ + +CREATE TABLE IF NOT EXISTS CONFIG_RESOURCE ( + config_resource_id VARCHAR(50) PRIMARY KEY, + resource_id VARCHAR(50) NOT NULL, + resource_type VARCHAR(50) NOT NULL, + service_template_name VARCHAR(50) NULL DEFAULT NULL, + service_template_version VARCHAR(50) NULL DEFAULT NULL, + template_name VARCHAR(50) NOT NULL, + recipe_name VARCHAR(50) NOT NULL, + request_id VARCHAR(50) NOT NULL, + resource_data LONGTEXT NULL DEFAULT NULL, + mask_data LONGTEXT NULL DEFAULT NULL, + created_date DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, + status VARCHAR(20) NOT NULL, + updated_by VARCHAR(50) NOT NULL +); + +CREATE TABLE IF NOT EXISTS CONFIG_RESOURCE_ASSIGNMENT_DATA ( + config_resource_assignment_data_id VARCHAR(50) PRIMARY KEY, + config_resource_id VARCHAR(50) NOT NULL, + version INT(11) NOT NULL, + updated_date DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, + updated_by VARCHAR(50) NOT NULL, + template_key_name VARCHAR(50) NOT NULL, + resource_name VARCHAR(50) NOT NULL, + data_type VARCHAR(100) NOT NULL, + entry_schema VARCHAR(100) NULL DEFAULT NULL, + resource_value LONGTEXT NOT NULL, + source VARCHAR(50) NOT NULL, + status VARCHAR(50) NOT NULL, + message LONGTEXT NOT NULL +); + +CREATE TABLE IF NOT EXISTS CONFIG_TRANSACTION_LOG ( + config_transaction_log_id VARCHAR(50) PRIMARY KEY, + request_id VARCHAR(50) NULL DEFAULT NULL, + message_type VARCHAR(100) NULL DEFAULT NULL, + creation_date DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, + message LONGTEXT NULL DEFAULT NULL +); + +CREATE TABLE IF NOT EXISTS CONFIG_PROPERTY_MAP ( + reference_key VARCHAR(100) NOT NULL, + reference_value VARCHAR(250) NOT NULL +); + diff --git a/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/test-context-h2db.xml b/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/test-context-h2db.xml new file mode 100644 index 000000000..5b0004c1c --- /dev/null +++ b/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/test-context-h2db.xml @@ -0,0 +1,82 @@ +<?xml version="1.0" encoding="utf-8"?>
+<!--
+ Copyright © 2017-2018 AT&T Intellectual Property.
+
+ 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.
+-->
+
+<beans xmlns="http://www.springframework.org/schema/beans"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xmlns:jdbc="http://www.springframework.org/schema/jdbc"
+ xmlns:context="http://www.springframework.org/schema/context"
+ xsi:schemaLocation="http://www.springframework.org/schema/beans
+ http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
+ http://www.springframework.org/schema/jdbc
+ http://www.springframework.org/schema/jdbc/spring-jdbc-3.1.xsd
+ http://www.springframework.org/schema/context
+ http://www.springframework.org/schema/context/spring-context-3.1.xsd">
+
+ <context:annotation-config />
+
+ <bean id="test.dataSource"
+ class="org.springframework.jdbc.datasource.DriverManagerDataSource"
+ lazy-init="false">
+ <property name="driverClassName" value="org.h2.Driver" />
+ <property name="url"
+ value="jdbc:h2:mem:test;DB_CLOSE_DELAY=-1;MODE=MySQL" />
+ </bean>
+
+ <jdbc:initialize-database
+ data-source="test.dataSource">
+ <jdbc:script location="sql/schema.sql" />
+ </jdbc:initialize-database>
+
+ <bean id="jdbcTemplate"
+ class="org.springframework.jdbc.core.JdbcTemplate">
+ <property name="dataSource" ref="test.dataSource" />
+ </bean>
+
+ <bean id="namedParameterJdbcTemplate"
+ class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate">
+ <constructor-arg ref="test.dataSource" />
+ </bean>
+
+ <bean id="configResourceDao"
+ class="org.onap.ccsdk.config.data.adaptor.dao.ConfigResourceDaoImpl">
+ <constructor-arg ref="jdbcTemplate" />
+ </bean>
+
+ <bean id="configPropertyMapDao"
+ class="org.onap.ccsdk.config.data.adaptor.dao.ConfigPropertyMapDaoImpl">
+ <constructor-arg ref="jdbcTemplate" />
+ </bean>
+
+ <bean id="queryExecutorDao"
+ class="org.onap.ccsdk.config.data.adaptor.dao.QueryExecutorDaoImpl">
+ <constructor-arg ref="jdbcTemplate" />
+ </bean>
+
+ <bean id="namedQueryExecutorDao"
+ class="org.onap.ccsdk.config.data.adaptor.dao.NamedQueryExecutorDaoImpl">
+ <constructor-arg ref="namedParameterJdbcTemplate" />
+ </bean>
+
+ <bean id="transactionLogDao"
+ class="org.onap.ccsdk.config.data.adaptor.dao.TransactionLogDaoImpl">
+ <constructor-arg ref="jdbcTemplate" />
+ </bean>
+
+ <context:component-scan
+ base-package="org.onap.ccsdk.config.data.adaptor" />
+
+</beans>
diff --git a/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/test-context.xml b/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/test-context.xml new file mode 100644 index 000000000..0e73b40b3 --- /dev/null +++ b/blueprints-processor/adaptors/data-adaptor-provider/src/test/resources/test-context.xml @@ -0,0 +1,95 @@ +<?xml version="1.0" encoding="utf-8"?>
+<!--
+ Copyright © 2017-2018 AT&T Intellectual Property.
+
+ 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.
+-->
+
+<beans xmlns="http://www.springframework.org/schema/beans"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xmlns:jdbc="http://www.springframework.org/schema/jdbc"
+ xmlns:context="http://www.springframework.org/schema/context"
+ xsi:schemaLocation="http://www.springframework.org/schema/beans
+ http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
+ http://www.springframework.org/schema/jdbc
+ http://www.springframework.org/schema/jdbc/spring-jdbc-3.1.xsd
+ http://www.springframework.org/schema/context
+ http://www.springframework.org/schema/context/spring-context-3.1.xsd
+ ">
+
+ <context:annotation-config />
+
+ <bean id="test.dataSource"
+ class="org.springframework.jdbc.datasource.DriverManagerDataSource"
+ lazy-init="false">
+ <property name="driverClassName"
+ value="org.mariadb.jdbc.Driver" />
+ <property name="url"
+ value="jdbc:mysql://localhost:3306/sdnctl" />
+ <property name="username" value="sdnctl" />
+ <property name="password" value="sdnctl" />
+ </bean>
+
+
+ <!-- <bean id="test.dataSource" -->
+ <!-- class="org.springframework.jdbc.datasource.DriverManagerDataSource" -->
+ <!-- lazy-init="false"> -->
+ <!-- <property name="driverClassName" value="org.h2.Driver" /> -->
+ <!-- <property name="url" -->
+ <!-- value="jdbc:h2:mem:test;DB_CLOSE_DELAY=-1;MODE=MySQL" /> -->
+ <!-- </bean> -->
+ <!-- <jdbc:initialize-database data-source="test.dataSource"> -->
+ <!-- <jdbc:script location="sql/schema.sql" /> -->
+ <!-- </jdbc:initialize-database> -->
+ <!-- <bean id="dataSetup" -->
+ <!-- class="org.onap.ccsdk.config.data.adaptor.db.utils.DataSetup"> -->
+ <!-- <property name="testDb" ref="testDb" /> -->
+ <!-- </bean> -->
+ <!-- <bean id="testDb" class="org.onap.ccsdk.config.data.adaptor.db.utils.TestDb"> -->
+ <!-- <property name="jdbcTemplate" ref="jdbcTemplate" /> -->
+ <!-- </bean> -->
+
+ <bean id="jdbcTemplate"
+ class="org.springframework.jdbc.core.JdbcTemplate">
+ <property name="dataSource" ref="test.dataSource" />
+ </bean>
+
+ <bean id="namedParameterJdbcTemplate"
+ class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate">
+ <constructor-arg ref="test.dataSource" />
+ </bean>
+
+ <bean id="configResourcelDao"
+ class="org.onap.ccsdk.config.data.adaptor.dao.ConfigResourceDaoImpl">
+ <constructor-arg ref="jdbcTemplate" />
+ </bean>
+
+ <bean id="ConfigPropertyMapDao"
+ class="org.onap.ccsdk.config.data.adaptor.dao.ConfigPropertyMapDaoImpl">
+ <constructor-arg ref="jdbcTemplate" />
+ </bean>
+
+ <bean id="queryExecutorDao"
+ class="org.onap.ccsdk.config.data.adaptor.dao.QueryExecutorDaoImpl">
+ <constructor-arg ref="jdbcTemplate" />
+ </bean>
+
+ <bean id="namedQueryExecutorDao"
+ class="org.onap.ccsdk.config.data.adaptor.dao.NamedQueryExecutorDaoImpl">
+ <constructor-arg ref="namedParameterJdbcTemplate" />
+ </bean>
+
+ <context:component-scan
+ base-package="org.onap.ccsdk.config.data.adaptor" />
+
+</beans>
|