diff options
Diffstat (limited to 'catalog-dao')
9 files changed, 15 insertions, 568 deletions
diff --git a/catalog-dao/src/main/java/org/openecomp/sdc/be/dao/titan/TitanGraphClient.java b/catalog-dao/src/main/java/org/openecomp/sdc/be/dao/titan/TitanGraphClient.java index e13b0ee9c5..e50c5e6278 100644 --- a/catalog-dao/src/main/java/org/openecomp/sdc/be/dao/titan/TitanGraphClient.java +++ b/catalog-dao/src/main/java/org/openecomp/sdc/be/dao/titan/TitanGraphClient.java @@ -37,7 +37,8 @@ import org.openecomp.sdc.be.config.ConfigurationManager; import org.openecomp.sdc.be.dao.DAOTitanStrategy; import org.openecomp.sdc.be.dao.TitanClientStrategy; import org.openecomp.sdc.be.dao.neo4j.GraphPropertiesDictionary; -import org.openecomp.sdc.common.log.wrappers.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; import javax.annotation.PostConstruct; @@ -48,9 +49,8 @@ import java.util.concurrent.*; @Component("titan-client") public class TitanGraphClient { - - private static Logger logger = Logger.getLogger(TitanGraphClient.class.getName()); - private static Logger healthLogger = Logger.getLogger("titan.healthcheck"); + private static Logger logger = LoggerFactory.getLogger(TitanGraphClient.class.getName()); + private static Logger healthLogger = LoggerFactory.getLogger("titan.healthcheck"); private static final String HEALTH_CHECK = GraphPropertiesDictionary.HEALTH_CHECK.getProperty(); private static final String OK = "GOOD"; @@ -67,12 +67,6 @@ public class TitanGraphClient { healthLogger.trace("Health Check Node Found...{}", v.property(HEALTH_CHECK)); graph.tx().commit(); - // Vertex v = graph.getVertices(HEALTH_CHECK, OK).iterator().next(); - // v.setProperty("healthcheck", OK + "_" + - // System.currentTimeMillis()); - // graph.commit(); - // healthLogger.trace("Health Check Node - // Found..."+v.getProperty(HEALTH_CHECK) ); return v; } } @@ -397,19 +391,10 @@ public class TitanGraphClient { if (!graphMgt.containsGraphIndex(prop.getProperty())) { if (prop.isUnique()) { index = graphMgt.buildIndex(prop.getProperty(), Vertex.class).addKey(propKey).unique().buildCompositeIndex(); - - graphMgt.setConsistency(propKey, ConsistencyModifier.LOCK); // Ensures - // only - // one - // name - // per - // vertex - graphMgt.setConsistency(index, ConsistencyModifier.LOCK); // Ensures - // name - // uniqueness - // in - // the - // graph + // Ensures only one name per vertex + graphMgt.setConsistency(propKey, ConsistencyModifier.LOCK); + // Ensures name uniqueness in the graph + graphMgt.setConsistency(index, ConsistencyModifier.LOCK); } else { graphMgt.buildIndex(prop.getProperty(), Vertex.class).addKey(propKey).buildCompositeIndex(); diff --git a/catalog-dao/src/main/java/org/openecomp/sdc/be/resources/data/CategoryData.java b/catalog-dao/src/main/java/org/openecomp/sdc/be/resources/data/CategoryData.java index 5576f0db9f..f5ec18ac61 100644 --- a/catalog-dao/src/main/java/org/openecomp/sdc/be/resources/data/CategoryData.java +++ b/catalog-dao/src/main/java/org/openecomp/sdc/be/resources/data/CategoryData.java @@ -86,21 +86,6 @@ public abstract class CategoryData extends GraphNode { return "CategoryData [name=" + name + ", normalizedName=" + normalizedName + "uniqueId=" + uniqueId + "]"; } - /* - * @Override public int hashCode() { final int prime = 31; int result = 1; - * result = prime * result + ((name == null) ? 0 : name.hashCode()); result - * = prime * result + ((uniqueId == null) ? 0 : uniqueId.hashCode()); return - * result; } - * - * @Override public boolean equals(Object obj) { if (this == obj) return - * true; if (obj == null) return false; if (getClass() != obj.getClass()) - * return false; CategoryData other = (CategoryData) obj; if (name == null) - * { if (other.name != null) return false; } else if - * (!name.equals(other.name)) return false; if (uniqueId == null) { if - * (other.uniqueId != null) return false; } else if - * (!uniqueId.equals(other.uniqueId)) return false; return true; } - */ - @Override public String getUniqueIdKey() { return GraphPropertiesDictionary.UNIQUE_ID.getProperty(); diff --git a/catalog-dao/src/main/java/org/openecomp/sdc/be/resources/impl/ResourceUploader.java b/catalog-dao/src/main/java/org/openecomp/sdc/be/resources/impl/ResourceUploader.java index 8b5dee4e8b..5b9f548b46 100644 --- a/catalog-dao/src/main/java/org/openecomp/sdc/be/resources/impl/ResourceUploader.java +++ b/catalog-dao/src/main/java/org/openecomp/sdc/be/resources/impl/ResourceUploader.java @@ -124,26 +124,6 @@ public class ResourceUploader implements IResourceUploader { return status; } - /* - * @Override public ResourceUploadStatus - * updateServiceArtifact(ServiceArtifactData artifactUpdateData) { - * ResourceUploadStatus status = ResourceUploadStatus.OK; if(resourceDAO == - * null) return ResourceUploadStatus.ERROR; Either<ServiceArtifactData, - * ResourceUploadStatus> getServiceArtifactStatus = - * getServiceArtifact(artifactUpdateData.getId()); - * - * if(getServiceArtifactStatus.isRight()){ - * log.debug("ResourceUploadStatus:updateArtifactt artifact with id " + - * artifactUpdateData.getId() + " not exist."); status = - * getServiceArtifactStatus.right().value(); } - * if(getServiceArtifactStatus.isLeft()){ status = - * updateServiceArtifact(artifactUpdateData, - * getServiceArtifactStatus.left().value()); } - * - * return status; } - * - */ - @Override public Either<ESArtifactData, ResourceUploadStatus> getArtifact(String id) { if (resourceDAO == null) @@ -152,13 +132,6 @@ public class ResourceUploader implements IResourceUploader { return resourceDAO.getArtifact(id); } - /* - * @Override public Either<ServiceArtifactData, ResourceUploadStatus> - * getServiceArtifact(String id) { if(resourceDAO == null) return - * Either.right(ResourceUploadStatus.ERROR); - * - * return resourceDAO.getServiceArtifact(id); } - */ @Override public void deleteArtifact(String id) { if (resourceDAO != null) { diff --git a/catalog-dao/src/test/java/org/openecomp/sdc/be/dao/cassandra/schema/SdcSchemaBuilderTest.java b/catalog-dao/src/test/java/org/openecomp/sdc/be/dao/cassandra/schema/SdcSchemaBuilderTest.java index 14eda51a03..f902f8f603 100644 --- a/catalog-dao/src/test/java/org/openecomp/sdc/be/dao/cassandra/schema/SdcSchemaBuilderTest.java +++ b/catalog-dao/src/test/java/org/openecomp/sdc/be/dao/cassandra/schema/SdcSchemaBuilderTest.java @@ -44,24 +44,6 @@ public class SdcSchemaBuilderTest extends DAOConfDependentTest{ result = SdcSchemaBuilder.deleteSchema(); } - /*@Test - public void testParseKeyspaceMetadata() throws Exception { - List<KeyspaceMetadata> keyspacesMetadata = new LinkedList<>(); - Map<String, Map<String, List<String>>> result; - - // default test - result = Deencapsulation.invoke(SdcSchemaBuilder.class, "parseKeyspaceMetadata", keyspacesMetadata); - }*/ - - /*@Test - public void testGetMetadataTablesStructure() throws Exception { - List<KeyspaceMetadata> keyspacesMetadata = new LinkedList<>(); - Map<String, Map<String, List<String>>> result; - - // default test - result = Deencapsulation.invoke(SdcSchemaBuilder.class, "getMetadataTablesStructure", keyspacesMetadata); - }*/ - @Test public void testCreateIndexName() throws Exception { String table = ""; @@ -72,19 +54,6 @@ public class SdcSchemaBuilderTest extends DAOConfDependentTest{ result = Deencapsulation.invoke(SdcSchemaBuilder.class, "createIndexName", table, column); } - /*@Test - public void testAlterTable() throws Exception { - Session session = null; - Map<String, List<String>> existingTablesMetadata = null; - ITableDescription tableDescription = null; - String tableName = ""; - Map<String, ImmutablePair<DataType, Boolean>> columnDescription = null; - - // default test - Deencapsulation.invoke(SdcSchemaBuilder.class, "alterTable", - new Object[] { Session.class, Map.class, ITableDescription.class, tableName, Map.class }); - }*/ - @Test public void testCreateKeyspace() throws Exception { String keyspace = "mock"; diff --git a/catalog-dao/src/test/java/org/openecomp/sdc/be/dao/graph/GraphElementFactoryTest.java b/catalog-dao/src/test/java/org/openecomp/sdc/be/dao/graph/GraphElementFactoryTest.java index 47dccd3bea..7a66f85d3f 100644 --- a/catalog-dao/src/test/java/org/openecomp/sdc/be/dao/graph/GraphElementFactoryTest.java +++ b/catalog-dao/src/test/java/org/openecomp/sdc/be/dao/graph/GraphElementFactoryTest.java @@ -62,8 +62,6 @@ public class GraphElementFactoryTest { properties); result = Deencapsulation.invoke(GraphElementFactory.class, "createNode", NodeTypeEnum.Service.getName(), properties); - // result = Deencapsulation.invoke(GraphElementFactory.class, "createNode", - // NodeTypeEnum.Resource.getName(), properties); result = Deencapsulation.invoke(GraphElementFactory.class, "createNode", NodeTypeEnum.Property.getName(), properties); result = Deencapsulation.invoke(GraphElementFactory.class, "createNode", NodeTypeEnum.HeatParameter.getName(), 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 index fe31e39199..dc65d5d236 100644 --- 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 @@ -21,9 +21,6 @@ package org.openecomp.sdc.be.resources; import fj.data.Either; -import static org.junit.Assert.fail; -import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest; -import org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse; import org.junit.Test; import org.junit.runner.RunWith; import org.openecomp.sdc.be.config.ConfigurationManager; @@ -70,7 +67,7 @@ public class ArtifactDaoTest extends DAOConfDependentTest { public void testSaveNewArtifact() { // daoUploader = new ArtifactUploader(artifactDAO); if (daoUploader == null) { - fail(); + assertTrue(false); } String strData = "qweqwqweqw34e4wrwer"; @@ -86,111 +83,6 @@ public class ArtifactDaoTest extends DAOConfDependentTest { } - /* - * @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) { 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() { @@ -210,67 +102,16 @@ public class ArtifactDaoTest extends DAOConfDependentTest { } - /* - * @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) { - fail(); + fail(); } ResourceUploadStatus status = ResourceUploadStatus.OK; String myNodeType = "MyUpdatedNodeType"; - // resourceDAO.save(indexedNodeType); - ESArtifactData arData = getArtifactData(myNodeType, nodeTypeVersion); Either<ESArtifactData, ResourceUploadStatus> getArtifactStatus = daoUploader.getArtifact(arData.getId()); @@ -283,8 +124,6 @@ public class ArtifactDaoTest extends DAOConfDependentTest { status = daoUploader.updateArtifact(arData); assertEquals(status, ResourceUploadStatus.OK); - // resourceDAO.delete(IndexedNodeType.class, indexedNodeType.getId()); - } private ESArtifactData getArtifactData(String componentName, String componentVersion) { @@ -292,231 +131,4 @@ public class ArtifactDaoTest extends DAOConfDependentTest { return new ESArtifactData("updatedArtifact", strData.getBytes()); } - - /* - * 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) { - * 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) { - * 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()); - } - } diff --git a/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/AuditingDaoTest.java b/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/AuditingDaoTest.java index 5639228233..919c69fce4 100644 --- a/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/AuditingDaoTest.java +++ b/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/AuditingDaoTest.java @@ -386,22 +386,6 @@ public class AuditingDaoTest extends DAOConfDependentTest{ assertTrue(!esclient.getClient().admin().indices().prepareExists(expectedIndexName).execute().actionGet() .isExists()); - // Client client = esclient.getClient(); - // final CreateIndexRequestBuilder createIndexRequestBuilder = - // client.admin().indices().prepareCreate(expectedIndexName); - // final XContentBuilder mappingBuilder = - // jsonBuilder().startObject().startObject("resourceadminevent") - // .startObject("_ttl").field("enabled", "true").field("default", - // "1s").endObject().endObject() - // .endObject(); - // System.out.println(mappingBuilder.string()); - // createIndexRequestBuilder.addMapping(documentType, mappingBuilder); - // - // // MAPPING DONE - // createIndexRequestBuilder.execute().actionGet(); - // - // - Map<AuditingFieldsKey, Object> params = getResourceAdminEventParams(timestamp, "DRequest"); params.put(AuditingFieldsKey.AUDIT_DISTRIBUTION_ID, distributionId); testCreationPeriodScenario(params, creationPeriod, expectedIndexName, ResourceAdminEvent.class); diff --git a/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/CassandraTest.java b/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/CassandraTest.java index 195232aaf5..e18a4528b1 100644 --- a/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/CassandraTest.java +++ b/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/CassandraTest.java @@ -52,8 +52,6 @@ public class CassandraTest { Mapper<Account> mapper = new MappingManager(session).mapper(Account.class); Account account = new Account("John Doe", "jd@example.com"); - // Class<? extends Account> class1 = account.getClass(); - // Class class2 = Account.class; mapper.save(account); Account whose = mapper.get("jd@example.com"); diff --git a/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/TitanGenericDaoTest.java b/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/TitanGenericDaoTest.java index d420f630e4..e8c6b3cdd1 100644 --- a/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/TitanGenericDaoTest.java +++ b/catalog-dao/src/test/java/org/openecomp/sdc/be/resources/TitanGenericDaoTest.java @@ -21,7 +21,11 @@ package org.openecomp.sdc.be.resources; import com.google.gson.Gson; -import com.thinkaurelius.titan.core.*; +import com.thinkaurelius.titan.core.PropertyKey; +import com.thinkaurelius.titan.core.TitanEdge; +import com.thinkaurelius.titan.core.TitanFactory; +import com.thinkaurelius.titan.core.TitanGraph; +import com.thinkaurelius.titan.core.TitanVertex; import com.thinkaurelius.titan.core.attribute.Text; import com.thinkaurelius.titan.core.schema.TitanManagement; import fj.data.Either; @@ -414,70 +418,9 @@ public class TitanGenericDaoTest { propKey = graphMgt.makePropertyKey("string2").dataType(String.class).make(); - // graphMgt.buildIndex("string2", Vertex.class).addKey(propKey, - // Mapping.TEXT.getParameter()).buildMixedIndex("search"); graphMgt.buildIndex("string2", Vertex.class).addKey(propKey).unique().buildCompositeIndex(); graphMgt.commit(); - // TitanVertex v = graph.addVertex(); - // v.addProperty("string1", "My new String 1"); - // v.addProperty("string2", "String11"); - // graph.commit(); - // - // v = graph.addVertex(); - // v.addProperty("string1", "my new string 1"); - // v.addProperty("string2", "string11"); - // graph.commit(); - // - // System.out.println("First index search - case"); - // - // Iterable<Vertex> vertices = graph.getVertices("string1", "My new - // String 1"); - // Iterator<Vertex> iter = vertices.iterator(); - // while ( iter.hasNext() ){ - // Vertex ver = iter.next(); - // System.out.println(com.tinkerpop.blueprints.util.ElementHelper.getProperties(ver)); - // } - // System.out.println("First index search non case"); - // - // vertices = graph.getVertices("string1", "my new string 1"); - // iter = vertices.iterator(); - // while ( iter.hasNext() ){ - // Vertex ver = iter.next(); - // System.out.println(com.tinkerpop.blueprints.util.ElementHelper.getProperties(ver)); - // } - // System.out.println("Second index search case"); - // - // vertices = graph.getVertices("string2", "String11"); - // iter = vertices.iterator(); - // while ( iter.hasNext() ){ - // Vertex ver = iter.next(); - // System.out.println(com.tinkerpop.blueprints.util.ElementHelper.getProperties(ver)); - // } - // System.out.println("second index search non case"); - // - // vertices = graph.getVertices("string2", "string11"); - // iter = vertices.iterator(); - // while ( iter.hasNext() ){ - // Vertex ver = iter.next(); - // System.out.println(com.tinkerpop.blueprints.util.ElementHelper.getProperties(ver)); - // } - // System.out.println("Query index search case"); - // vertices = graph.query().has("string1", "My new String - // 1").vertices(); - // iter = vertices.iterator(); - // while ( iter.hasNext() ){ - // Vertex ver = iter.next(); - // System.out.println(com.tinkerpop.blueprints.util.ElementHelper.getProperties(ver)); - // } - // System.out.println("Query index search non case"); - // vertices = graph.query().has("string1", "my new string - // 1").vertices(); - // iter = vertices.iterator(); - // while ( iter.hasNext() ){ - // Vertex ver = iter.next(); - // System.out.println(com.tinkerpop.blueprints.util.ElementHelper.getProperties(ver)); - // } log.debug("**** predicat index search non case"); Iterable<TitanVertex> vertices = graph.query().has("string1", Text.REGEX, "my new string 1").vertices(); |