diff options
Diffstat (limited to 'catalog-dao/src/test/java/org/openecomp/sdc/be/resources/ArtifactDaoTest.java')
| -rw-r--r-- | catalog-dao/src/test/java/org/openecomp/sdc/be/resources/ArtifactDaoTest.java | 577 |
1 files changed, 577 insertions, 0 deletions
diff --git a/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/ArtifactDaoTest.java b/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/ArtifactDaoTest.java new file mode 100644 index 0000000000..aa9d30cb12 --- /dev/null +++ b/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/ArtifactDaoTest.java @@ -0,0 +1,577 @@ +/*- + * ============LICENSE_START======================================================= + * SDC + * ================================================================================ + * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.openecomp.sdc.be.resources; + +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertNotNull; +import static org.junit.Assert.assertTrue; + +import javax.annotation.Resource; + +import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest; +import org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse; +import org.junit.Before; +import org.junit.BeforeClass; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.openecomp.sdc.be.config.ConfigurationManager; +import org.openecomp.sdc.be.dao.api.IGenericSearchDAO; +import org.openecomp.sdc.be.dao.api.ResourceUploadStatus; +import org.openecomp.sdc.be.dao.es.ElasticSearchClient; +import org.openecomp.sdc.be.resources.api.IResourceUploader; +import org.openecomp.sdc.be.resources.data.ESArtifactData; +import org.openecomp.sdc.common.api.ConfigurationSource; +import org.openecomp.sdc.common.impl.ExternalConfiguration; +import org.openecomp.sdc.common.impl.FSConfigurationSource; +import org.springframework.test.context.ContextConfiguration; +import org.springframework.test.context.TestExecutionListeners; +import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; +import org.springframework.test.context.support.DependencyInjectionTestExecutionListener; +import org.springframework.test.context.support.DirtiesContextTestExecutionListener; +import org.springframework.test.context.transaction.TransactionalTestExecutionListener; + +import fj.data.Either; + +@RunWith(SpringJUnit4ClassRunner.class) +@ContextConfiguration("classpath:application-context-test.xml") +@TestExecutionListeners(listeners = { DependencyInjectionTestExecutionListener.class, + DirtiesContextTestExecutionListener.class, TransactionalTestExecutionListener.class }) // , + // CassandraUnitTestExecutionListener.class}) +// @EmbeddedCassandra(host ="localhost", port=9042) +public class ArtifactDaoTest { + private static final String TEST_IMAGES_DIRECTORY = "src/test/resources/images"; + + @Resource + ElasticSearchClient esclient; + + /* + * @Resource(name = "artifact-dao") private IArtifactDAO artifactDAO; + */ + + @Resource(name = "resource-upload") + private IResourceUploader daoUploader; + ESArtifactData arData; + + @Resource(name = "resource-dao") + private IGenericSearchDAO resourceDAO; + + private String nodeType = "NodeType1"; + private String nodeTypeVersion = "1.0.0"; + + private String nodeType2 = "NodeType2"; + private String nodeTypeVersion2 = "1.0.1"; + + private String nodeType3 = "NodeType3"; + private String nodeNypeVersion3 = "1.1.1"; + + private String topologyId = "topology"; + private String topologyTemplateName = "topologyTemplate"; + private String topologyTemplateVersion = "1.1.1"; + + private String nodeTypeTemplate1 = "NodeTypeTemplate1"; + private String nodeTypeTemplate2 = "NodeTypeTemplate2"; + private String nodeTypeTemplate3 = "NodeTypeTemplate3"; + + private static ConfigurationManager configurationManager; + + @Before + public void before() { + // try { + // clearIndex(ICatalogDAO.RESOURCES_INDEX, ArtifactData.class); + // clearIndex(ICatalogDAO.RESOURCES_INDEX, ServiceArtifactData.class); + // } catch (InterruptedException e) { + // TODO Auto-generated catch block + // e.printStackTrace(); + // } + + } + + @BeforeClass + public static void setupBeforeClass() { + ExternalConfiguration.setAppName("catalog-dao"); + String appConfigDir = "src/test/resources/config/catalog-dao"; + ConfigurationSource configurationSource = new FSConfigurationSource(ExternalConfiguration.getChangeListener(), + appConfigDir); + configurationManager = new ConfigurationManager(configurationSource); + } + + // @Before + // public void createSchema(){ + // SdcSchemaBuilder.createSchema(); + // } + // + + @Test + public void testSaveNewArtifact() { + // daoUploader = new ArtifactUploader(artifactDAO); + if (daoUploader == null) { + assertTrue(false); + } + String strData = "qweqwqweqw34e4wrwer"; + + String myNodeType = "MyNewNodeType"; + + ESArtifactData arData = new ESArtifactData("artifactNewMarina11", strData.getBytes()); + + ResourceUploadStatus status = daoUploader.saveArtifact(arData, true); + + assertEquals(status, ResourceUploadStatus.OK); + + daoUploader.deleteArtifact(arData.getId()); + + } + + /* + * @Test public void testSaveNewImage(){ + * + * Path iconPath = Paths.get(TEST_IMAGES_DIRECTORY, "apache.png"); + * + * ImageData imageData = new ImageData(); try { + * imageData.setData(Files.readAllBytes(iconPath)); + * imageData.setComponentName("ComponentMarina"); + * imageData.setComponentVersion("v.1.0"); + * imageData.setArtifactName("apache.png"); + * imageData.setResourceCreator("Marina"); + * imageData.setResourceLastUpdater("Marina"); ResourceUploadStatus status = + * daoUploader.saveImage(imageData, true); assertEquals(status, + * ResourceUploadStatus.OK); } catch (IOException e) { // TODO + * Auto-generated catch block e.printStackTrace(); } + * + * + * } + */ + + // @Test + // public void testGetArtifactsList() { + // //daoUploader = new ArtifactUploader(artifactDAO); + // if(daoUploader==null){ + // assertTrue(false); + // } + // String myNodeType = "MyListNodeType"; + // + // + // + // //resourceDAO.save(indexedNodeType); + // + // String strData = "qweqwqweqw34e4wrwer"; + // ESArtifactData arData1 = new ESArtifactData("artifactNewMarina_1", + // strData.getBytes()); + // + // + // ResourceUploadStatus status = daoUploader.saveArtifact(arData1, true); + // assertEquals(status, ResourceUploadStatus.OK); + // + // ESArtifactData arData2 = new ESArtifactData("artifactNewMarina_2", + // strData.getBytes()); + // + // + // status = daoUploader.saveArtifact(arData2, true); + // assertEquals(status, ResourceUploadStatus.OK); + // + // ESArtifactData arData3 = new ESArtifactData("artifactNewMarina_3", + // strData.getBytes()); + // + // + // status = daoUploader.saveArtifact(arData3, true); + // assertEquals(status, ResourceUploadStatus.OK); + // + // + // + // Either<List<ESArtifactData>, ResourceUploadStatus> arrArray = + // daoUploader.getArtifacts(myNodeType, nodeTypeVersion); + // assertTrue(arrArray.isLeft()); + // + // assertEquals(3, arrArray.left().value().size()); + // + // daoUploader.deleteArtifact(arData1.getId()); + // daoUploader.deleteArtifact(arData2.getId()); + // daoUploader.deleteArtifact(arData3.getId()); + // + // //resourceDAO.delete(IndexedNodeType.class, indexedNodeType.getId()); + // + // } + // + + /* + * @Test public void testGetSeviceArtifactsList() { + * + * if(daoUploader==null){ assertTrue(false); } String strData = + * "qweqwqweqw34e4wrwer"; + * + * ServiceArtifactData serviceArData = new + * ServiceArtifactData("serviceArData", topologyTemplateName, + * topologyTemplateVersion, nodeTypeTemplate1, nodeType, nodeTypeVersion, + * "YANG", strData.getBytes(), strData.getBytes(), "Marina", null); + * //serviceArData.setRefArtifactId(arData.getId()); ResourceUploadStatus + * status = daoUploader.saveServiceArtifact(serviceArData, true); + * + * ServiceArtifactData serviceArData1 = new + * ServiceArtifactData("serviceArData1", topologyTemplateName, + * topologyTemplateVersion, nodeTypeTemplate2, nodeType2, nodeTypeVersion2, + * "YANG", strData.getBytes(), strData.getBytes(), "Marina", null); + * //serviceArData1.setRefArtifactId(arData4.getId()); status = + * daoUploader.saveServiceArtifact(serviceArData1, true); + * ServiceArtifactData getServiceData = + * daoUploader.getServiceArtifact(serviceArData.getId()).left().value(); + * + * List<ServiceArtifactData> arrArray = + * daoUploader.getServiceArtifacts(topologyTemplateName, + * topologyTemplateVersion).left().value(); + * + * assertEquals(2, arrArray.size()); + * + * daoUploader.deleteArtifact(serviceArData.getId()); + * daoUploader.deleteArtifact(serviceArData1.getId()); + * + * + * } + */ + + @Test + public void testGetArtifact() { + + String myNodeType = "MyNodeType"; + + // resourceDAO.save(indexedNodeType); + ESArtifactData arData = getArtifactData(myNodeType, nodeTypeVersion); + + ESArtifactData getData = null; + Either<ESArtifactData, ResourceUploadStatus> getArtifactStatus = daoUploader + .getArtifact(myNodeType + "- dassasd" + ":" + nodeTypeVersion + ":updatedArtifact"); + if (getArtifactStatus.isRight()) { + daoUploader.saveArtifact(arData, true); + getArtifactStatus = daoUploader.getArtifact(arData.getId()); + } + assertNotNull(getArtifactStatus.left().value()); + + } + + /* + * @Test public void testGetSeviceArtifact() { + * + * ServiceArtifactData servArData = getServiceArtifactData(); + * + * Either<ServiceArtifactData, ResourceUploadStatus> + * getServiceArtifactStatus = + * daoUploader.getServiceArtifact("MyService:v.1.1:updatedServiceArtifact"); + * if (!getServiceArtifactStatus.isLeft()){ + * daoUploader.saveServiceArtifact(servArData, true); + * getServiceArtifactStatus = + * daoUploader.getServiceArtifact(servArData.getId()); } + * + * assertNotNull(getServiceArtifactStatus.left().value()); + * + * daoUploader.deleteArtifact(getServiceArtifactStatus.left().value().getId( + * )); + * + * + * } + */ + + /* + * @Test public void testGetSeviceArtifactsCollection() { + * + * prepareTopolgyService(); prepareTestTopolgyService(); + * Either<ServiceArtifactsDataCollection, ResourceUploadStatus> + * getServiceArtifactsCollectionStatus = + * daoUploader.getServiceArtifactsCollection(topologyTemplateName, + * topologyTemplateVersion); ServiceArtifactsDataCollection serviceAtrifacts + * = getServiceArtifactsCollectionStatus.left().value(); + * + * Map<String, List<ArtifactData>> map = + * serviceAtrifacts.getServiceArtifactDataMap(); + * + * List<ArtifactData> list = map.get(nodeType); assertNotNull(list); + * assertEquals(2, list.size()); + * + * + * list = map.get(nodeTypeTemplate1 ); assertNotNull(list); assertEquals(1, + * list.size()); + * + * list = map.get(nodeTypeTemplate2 ); assertNotNull(list); assertEquals(1, + * list.size()); + * + * + * } + */ + + @Test + public void testUpdateArtifact() { + // daoUploader = new ArtifactUploader(artifactDAO); + if (daoUploader == null) { + assertTrue(false); + } + ResourceUploadStatus status = ResourceUploadStatus.OK; + + String myNodeType = "MyUpdatedNodeType"; + + // resourceDAO.save(indexedNodeType); + + ESArtifactData arData = getArtifactData(myNodeType, nodeTypeVersion); + Either<ESArtifactData, ResourceUploadStatus> getArtifactStatus = daoUploader.getArtifact(arData.getId()); + + if (!getArtifactStatus.isLeft()) + status = daoUploader.saveArtifact(arData, false); + + String payload1 = "new payloadjfdsgh"; + arData.setDataAsArray(payload1.getBytes()); + + status = daoUploader.updateArtifact(arData); + + assertEquals(status, ResourceUploadStatus.OK); + // resourceDAO.delete(IndexedNodeType.class, indexedNodeType.getId()); + + } + + private ESArtifactData getArtifactData(String componentName, String componentVersion) { + String strData = "qweqwqweqw34e4wrwer"; + ESArtifactData arData = new ESArtifactData("updatedArtifact", strData.getBytes()); + + return arData; + } + + /* + * private ServiceArtifactData getServiceArtifactData(){ String strData = + * "qweqwqweqw34e4wrwer"; ServiceArtifactData arData = new + * ServiceArtifactData("updatedServiceArtifact", "MyService", "v.1.1", + * "MyComponentTemplate", "MyComponent", "v.1.1", "YANG", + * strData.getBytes(), strData.getBytes(), "Marina", null); + * + * return arData; } + */ + + /* + * private void prepareTopolgyService(){ + * + * List<String> listCap = new ArrayList<String>(); listCap.add("very_evil"); + * List<String> listCap1 = new ArrayList<String>(); listCap.add("evil"); + * try{ // Initialize test data IndexedNodeType indexedNodeType = new + * IndexedNodeType(); CSARDependency dep = new CSARDependency(); + * dep.setName(nodeType); dep.setVersion(nodeTypeVersion); + * indexedNodeType.setElementId(nodeType); + * indexedNodeType.setArchiveName(nodeType); + * indexedNodeType.setArchiveVersion(nodeTypeVersion); + * indexedNodeType.setCreationDate(new Date()); + * indexedNodeType.setLastUpdateDate(new Date()); + * indexedNodeType.setDefaultCapabilities(listCap); + * resourceDAO.save(indexedNodeType); + * + * + * IndexedNodeType indexedNodeType1 = new IndexedNodeType(); + * indexedNodeType1.setElementId(nodeType2); + * indexedNodeType1.setArchiveName(nodeType2); + * indexedNodeType1.setArchiveVersion(nodeTypeVersion2); CSARDependency dep1 + * = new CSARDependency(); dep1.setName(nodeType2); + * dep1.setVersion(nodeTypeVersion2); indexedNodeType1.setCreationDate(new + * Date()); indexedNodeType1.setLastUpdateDate(new Date()); + * indexedNodeType1.setDefaultCapabilities(listCap1); + * resourceDAO.save(indexedNodeType1); + * + * + * indexedNodeType.setElementId(nodeType3); + * indexedNodeType.setArchiveName(nodeType3); + * indexedNodeType.setArchiveVersion(nodeNypeVersion3); CSARDependency dep2 + * = new CSARDependency(); dep2.setName(nodeType3); + * dep2.setVersion(nodeNypeVersion3); indexedNodeType.setCreationDate(new + * Date()); indexedNodeType.setLastUpdateDate(new Date()); + * indexedNodeType.setDefaultCapabilities(null); + * resourceDAO.save(indexedNodeType); String osgiliath100Id = + * indexedNodeType.getId(); + * + * Topology topology = new Topology(); topology.setId(topologyId); + * Set<CSARDependency> dependencies = new HashSet<CSARDependency>(); + * dependencies.add(dep); dependencies.add(dep2); dependencies.add(dep1); + * topology.setDependencies(dependencies); Map<String, NodeTemplate> + * nodeTemplates = new HashMap <String, NodeTemplate>(); + * + * NodeTemplate template1 = new NodeTemplate(nodeType, null, null, null, + * null, null, null); template1.setName(nodeTypeTemplate1); + * nodeTemplates.put(nodeTypeTemplate1, template1 ); + * + * NodeTemplate template2 = new NodeTemplate(nodeType2, null, null, null, + * null, null, null); template2.setName(nodeTypeTemplate2 ); + * nodeTemplates.put(nodeTypeTemplate2, template2 ); + * + * NodeTemplate template3 = new NodeTemplate(nodeType, null, null, null, + * null, null, null); template3.setName(nodeTypeTemplate3 ); + * nodeTemplates.put(nodeTypeTemplate3, template3); + * + * topology.setNodeTemplates(nodeTemplates); resourceDAO.save(topology); + * + * TopologyTemplate topologyTemplate = new TopologyTemplate(); + * topologyTemplate.setId(topologyTemplateName); + * topologyTemplate.setName(topologyTemplateName); + * topologyTemplate.setTopologyId(topology.getId()); + * topologyTemplate.setDescription("my topology template"); + * resourceDAO.save(topologyTemplate); + * + * String strData = "qweqwqweqw34e4wrwer"; ArtifactData arData = new + * ArtifactData("artifact1", nodeType, nodeTypeVersion, "YANG", + * strData.getBytes(), strData.getBytes(), "Marina"); ArtifactData arData1 = + * new ArtifactData("artifact2", nodeType, nodeTypeVersion, "YANG", + * strData.getBytes(), strData.getBytes(), "Marina"); ResourceUploadStatus + * status = daoUploader.saveArtifact(arData, true); status = + * daoUploader.saveArtifact(arData1, true); + * + * ArtifactData arData3 = new ArtifactData("artifact1", nodeType2, + * nodeTypeVersion2, "YANG", strData.getBytes(), strData.getBytes(), + * "Marina"); status = daoUploader.saveArtifact(arData3, true); + * + * ArtifactData arData4 = new ArtifactData("artifact2", nodeType2, + * nodeTypeVersion2, "YANG", strData.getBytes(), strData.getBytes(), + * "Marina"); status = daoUploader.saveArtifact(arData4, true); + * + * ServiceArtifactData serviceArData = new + * ServiceArtifactData("serviceArData", topologyTemplateName, + * topologyTemplateVersion, nodeTypeTemplate1, nodeType, nodeTypeVersion, + * "YANG", strData.getBytes(), strData.getBytes(), "Marina", + * arData.getId()); + * + * status = daoUploader.saveServiceArtifact(serviceArData, true); + * + * ServiceArtifactData serviceArData1 = new + * ServiceArtifactData("serviceArData1", topologyTemplateName, + * topologyTemplateVersion, nodeTypeTemplate2, nodeType2, nodeTypeVersion2, + * "YANG", strData.getBytes(), strData.getBytes(), "Marina", + * arData4.getId()); + * + * status = daoUploader.saveServiceArtifact(serviceArData1, true); + * + * + * } catch (Exception e) { // TODO Auto-generated catch block + * e.printStackTrace(); } + * + * } + * + * private void prepareTestTopolgyService(){ + * + * List<String> listCap = new ArrayList<String>(); + * listCap.add("very_evil test"); List<String> listCap1 = new + * ArrayList<String>(); listCap.add("evil test"); try{ // Initialize test + * data IndexedNodeType indexedNodeType = new IndexedNodeType(); + * CSARDependency dep = new CSARDependency(); dep.setName(nodeType + + * " test"); dep.setVersion(nodeTypeVersion); + * indexedNodeType.setElementId(nodeType + " test"); + * indexedNodeType.setArchiveName(nodeType + " test"); + * indexedNodeType.setArchiveVersion(nodeTypeVersion); + * indexedNodeType.setCreationDate(new Date()); + * indexedNodeType.setLastUpdateDate(new Date()); + * indexedNodeType.setDefaultCapabilities(listCap); + * resourceDAO.save(indexedNodeType); + * + * + * IndexedNodeType indexedNodeType1 = new IndexedNodeType(); + * indexedNodeType1.setElementId(nodeType2 + " test"); + * indexedNodeType1.setArchiveName(nodeType2 + " test"); + * indexedNodeType1.setArchiveVersion(nodeTypeVersion2); CSARDependency dep1 + * = new CSARDependency(); dep1.setName(nodeType2 + " test"); + * dep1.setVersion(nodeTypeVersion2); indexedNodeType1.setCreationDate(new + * Date()); indexedNodeType1.setLastUpdateDate(new Date()); + * indexedNodeType1.setDefaultCapabilities(listCap1); + * resourceDAO.save(indexedNodeType1); + * + * + * indexedNodeType.setElementId(nodeType3 + " test"); + * indexedNodeType.setArchiveName(nodeType3 + " test"); + * indexedNodeType.setArchiveVersion(nodeNypeVersion3); CSARDependency dep2 + * = new CSARDependency(); dep2.setName(nodeType3 + " test"); + * dep2.setVersion(nodeNypeVersion3); indexedNodeType.setCreationDate(new + * Date()); indexedNodeType.setLastUpdateDate(new Date()); + * indexedNodeType.setDefaultCapabilities(null); + * resourceDAO.save(indexedNodeType); String osgiliath100Id = + * indexedNodeType.getId(); + * + * Topology topology = new Topology(); topology.setId(topologyId + " test"); + * Set<CSARDependency> dependencies = new HashSet<CSARDependency>(); + * dependencies.add(dep); dependencies.add(dep2); dependencies.add(dep1); + * topology.setDependencies(dependencies); Map<String, NodeTemplate> + * nodeTemplates = new HashMap <String, NodeTemplate>(); + * + * NodeTemplate template1 = new NodeTemplate(nodeType + " test", null, null, + * null, null, null, null); template1.setName(nodeTypeTemplate1 + " test"); + * nodeTemplates.put(nodeTypeTemplate1 + " test", template1 ); + * + * NodeTemplate template2 = new NodeTemplate(nodeType2 + " test", null, + * null, null, null, null, null); template2.setName(nodeTypeTemplate2 + + * " test" ); nodeTemplates.put(nodeTypeTemplate2 + " test", template2 ); + * + * NodeTemplate template3 = new NodeTemplate(nodeType, null, null, null, + * null, null, null); template3.setName(nodeTypeTemplate3 + " test" ); + * nodeTemplates.put(nodeTypeTemplate3 + " test", template3); + * + * topology.setNodeTemplates(nodeTemplates); resourceDAO.save(topology); + * + * TopologyTemplate topologyTemplate = new TopologyTemplate(); + * topologyTemplate.setId(topologyTemplateName + " test"); + * topologyTemplate.setName(topologyTemplateName + " test"); + * topologyTemplate.setTopologyId(topology.getId()); + * topologyTemplate.setDescription("my topology template"); + * resourceDAO.save(topologyTemplate); + * + * String strData = "qweqwqweqw34e4wrwer"; ArtifactData arData = new + * ArtifactData("artifact1 test", nodeType + " test", nodeTypeVersion, + * "YANG", strData.getBytes(), strData.getBytes(), "Marina"); ArtifactData + * arData1 = new ArtifactData("artifact2 test", nodeType + " test", + * nodeTypeVersion, "YANG", strData.getBytes(), strData.getBytes(), + * "Marina"); ResourceUploadStatus status = daoUploader.saveArtifact(arData, + * true); status = daoUploader.saveArtifact(arData1, true); + * + * ArtifactData arData3 = new ArtifactData("artifact1 test", nodeType2 + + * " test", nodeTypeVersion2, "YANG", strData.getBytes(), + * strData.getBytes(), "Marina"); status = daoUploader.saveArtifact(arData3, + * true); + * + * ArtifactData arData4 = new ArtifactData("artifact2 test", nodeType2 + + * " test", nodeTypeVersion2, "YANG", strData.getBytes(), + * strData.getBytes(), "Marina"); status = daoUploader.saveArtifact(arData4, + * true); + * + * ServiceArtifactData serviceArData = new + * ServiceArtifactData("serviceArData test" , topologyTemplateName + + * " test", topologyTemplateVersion, nodeTypeTemplate1 + " test", nodeType + + * " test", nodeTypeVersion, "YANG", strData.getBytes(), strData.getBytes(), + * "Marina", arData.getId()); + * + * status = daoUploader.saveServiceArtifact(serviceArData, true); + * + * ServiceArtifactData serviceArData1 = new + * ServiceArtifactData("serviceArData1 test", topologyTemplateName + + * " test", topologyTemplateVersion, nodeTypeTemplate2 + " test", nodeType2 + * + " test", nodeTypeVersion2, "YANG", strData.getBytes(), + * strData.getBytes(), "Marina", arData4.getId()); + * + * status = daoUploader.saveServiceArtifact(serviceArData1, true); + * + * + * } catch (Exception e) { // TODO Auto-generated catch block + * e.printStackTrace(); } + * + * } + */ + + private void clearIndex(String indexName, Class<?> clazz) throws InterruptedException { + + DeleteIndexResponse actionGet = esclient.getClient().admin().indices().delete(new DeleteIndexRequest(indexName)) + .actionGet(); + assertTrue(actionGet.isAcknowledged()); + } + +} |