import org.openecomp.sdc.exception.ResponseFormat;
import org.springframework.beans.factory.annotation.Autowired;
-import java.io.*;
-import java.util.*;
+import java.io.BufferedWriter;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.OutputStreamWriter;
+import java.io.Writer;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.Set;
import java.util.stream.Collectors;
@org.springframework.stereotype.Component("artifactUuidFix")
return Either.left(vfModules);
}
-
- /*public boolean manualFix() {
-
- Set<String> fixedIds = new HashSet<>();
- Component component;
- String componentId = "86683566-20e8-4cc5-872d-12abca1d57f0";//"9f6a6976-18e3-488a-98a4-c1aade480739";
- Either<Resource, StorageOperationStatus> toscaElement = toscaOperationFacade.getToscaFullElement(componentId);
- if (toscaElement.isRight()) {
- log.info("Failed to fetch resources {} {}", componentId, toscaElement.right().value());
-
- }
- boolean res = generateToscaPerComponent(fixedIds, toscaElement.left().value());
- log.info("Fix component return res {} ", res);
- titanDao.commit();
-
- return res;
- }
-
-
- public boolean manualCheck() {
-
- Set<String> fixedIds = new HashSet<>();
- Component component;
- String componentId = "86d50186-7b00-4bfc-abcb-9e4c6892f338";//"9f6a6976-18e3-488a-98a4-c1aade480739";
- Either<Service, StorageOperationStatus> toscaElement = toscaOperationFacade.getToscaFullElement(componentId);
- if (toscaElement.isRight()) {
- log.info("Failed to fetch resources {} {}", componentId, toscaElement.right().value());
-
- }
- boolean res = true;
- try {
- res = isProblematicService(toscaElement.left().value(), toscaElement.left().value().getName());
- if(res){
- List<Service> services = new ArrayList<>();
- services.add(toscaElement.left().value());
- this.fix(new ArrayList<Resource>(), services, null, null, null);
-
- Either<Service, StorageOperationStatus> toscaElementNew = toscaOperationFacade.getToscaFullElement(componentId);
- if (toscaElement.isRight()) {
- log.info("Failed to fetch resources {} {}", componentId, toscaElementNew.right().value());
-
- }
- res = isProblematicService(toscaElementNew.left().value(), toscaElementNew.left().value().getName());
- }
- titanDao.commit();
-
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- log.info("Fix component return res {} ", res);
-
- return res;
-}*/
-
}
package org.openecomp.sdc.asdctool.impl;
import com.google.gson.Gson;
-import com.thinkaurelius.titan.core.*;
+import com.thinkaurelius.titan.core.TitanEdge;
+import com.thinkaurelius.titan.core.TitanFactory;
+import com.thinkaurelius.titan.core.TitanGraph;
+import com.thinkaurelius.titan.core.TitanGraphQuery;
+import com.thinkaurelius.titan.core.TitanVertex;
import org.apache.commons.configuration.BaseConfiguration;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.apache.tinkerpop.gremlin.structure.*;
import org.openecomp.sdc.be.datatypes.enums.NodeTypeEnum;
import org.openecomp.sdc.common.log.wrappers.Logger;
-import java.io.*;
-import java.util.*;
+import java.io.BufferedInputStream;
+import java.io.BufferedOutputStream;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
import java.util.Map.Entry;
public class GraphMLConverter {
return false;
} finally {
if (graph != null) {
- // graph.shutdown();
graph.close();
}
}
String result = null;
- // GraphMLWriter graphMLWriter = new GraphMLWriter(graph);
-
String outputFile = outputDirectory + File.separator + "exportGraph." + System.currentTimeMillis() + ".json";
OutputStream out = null;
try {
out = new BufferedOutputStream(new FileOutputStream(outputFile));
- // GraphSONWriter.outputGraph(graph, outputFile);
final GraphSONWriter.Builder builder = GraphSONWriter.build();
final GraphSONMapper mapper = newGraphSONMapper(graph);
builder.mapper(mapper);
final GraphSONWriter writer = builder.create();
writer.writeGraph(out, graph);
- // GraphSONWriter create = GraphSONWriter.build(). create();
- // create.writeGraph(out, graph);
-
- // graph.commit();
graph.tx().commit();
result = outputFile;
private static GraphSONMapper newGraphSONMapper(final Graph graph) {
final GraphSONMapper.Builder builder = graph.io(IoCore.graphson()).mapper();
- // Different failure with embedded type info.
- // builder.embedTypes(true);
return builder.create();
}
is = new BufferedInputStream(new FileInputStream(graphJsonFile));
System.out.println("Before importing file " + graphJsonFile);
- // GraphSONReader.inputGraph(graph, graphJsonFile);
GraphSONReader create = GraphSONReader.build().create();
create.readGraph(is, graph);
- // graph.commit();
graph.tx().commit();
result = true;
String result = null;
- // GraphMLWriter graphMLWriter = new GraphMLWriter(graph);
-
String outputFile = outputDirectory + File.separator + "exportGraph." + System.currentTimeMillis() + ".json";
OutputStream out = null;
Vertex vertexTo = null;
Edge edge = null;
- // Iterable<Edge> edges = graph.getEdges();
- // Iterable<Edge> edges = graph.query().edges();
Iterable<TitanEdge> edges = graph.query().edges();
- // Iterator<Edge> iterator = edges.iterator();
Iterator<TitanEdge> iterator = edges.iterator();
while (iterator.hasNext()) {
edge = iterator.next();
- // vertexFrom = edge.getVertex(Direction.OUT);
- // vertexTo = edge.getVertex(Direction.IN);
vertexFrom = edge.outVertex();
vertexTo = edge.inVertex();
TitanGraph openGraph = Utils.openGraph(conf);
TitanVertex addVertexFrom = openGraph.addVertex();
- // ElementHelper.setProperties(addVertexFrom,
- // ElementHelper.getProperties(vertexFrom));
Utils.setProperties(addVertexFrom, Utils.getProperties(vertexFrom));
TitanVertex addVertexTo = openGraph.addVertex();
- // ElementHelper.setProperties(addVertexTo,
- // ElementHelper.getProperties(vertexTo));
Utils.setProperties(addVertexTo, Utils.getProperties(vertexTo));
- // Edge addEdge = openGraph.addEdge(null, addVertexFrom,
- // addVertexTo, edge.getLabel());
-
- // Edge edge = tGraph.addEdge(null,
- // fromV.left().value(), toV.left().value(), type);
-
Edge addEdge = addVertexFrom.addEdge(edge.label(), addVertexTo);
- // ElementHelper.setProperties(addEdge,
- // ElementHelper.getProperties(edge));
Utils.setProperties(addEdge, Utils.getProperties(edge));
log.info("fromVertex={}", Utils.getProperties(vertexFrom));
log.info("toVertex={}", Utils.getProperties(vertexTo));
log.info("edge={} {} ",edge.label(),Utils.getProperties(edge));
- // GraphSONWriter.outputGraph(openGraph, outputFile);
GraphSONWriter create = GraphSONWriter.build().create();
create.writeGraph(out, openGraph);
- // openGraph.rollback();
openGraph.tx().rollback();
} catch (Exception e) {
}
}
- // graph.rollback();
graph.tx().rollback();
}
if (runVertexScan) {
Vertex vertex = null;
- // Iterable<Vertex> vertices = graph.getVertices();
-
- // Iterator<Vertex> iteratorVertex = vertices.iterator();
Iterator<Vertex> iteratorVertex = graph.vertices();
while (iteratorVertex.hasNext()) {
try {
vertex = iteratorVertex.next();
-
- // Iterable<Edge> edges2 =
- // vertex.getEdges(Direction.BOTH);
-
- // Iterator<Edge> iterator2 = edges2.iterator();
Iterator<Edge> iterator2 = vertex.edges(Direction.BOTH);
if (false == iterator2.hasNext()) {
}
}
- // graph.rollback();
graph.tx().rollback();
}
- // Iterable<Vertex> vertices2 =
- // graph.getVertices(GraphPropertiesDictionary.HEALTH_CHECK.getProperty(),
- // "GOOD");
Iterable<TitanVertex> vertices2 = graph.query()
.has(GraphPropertiesDictionary.HEALTH_CHECK.getProperty(), "GOOD").vertices();
;
- Vertex next = vertices2.iterator().next();
BaseConfiguration conf = new BaseConfiguration();
conf.setProperty("storage.backend", "inmemory");
- TitanGraph openGraph = Utils.openGraph(conf);
-
- // TitanVertex addVertexFrom = openGraph.addVertex();
- //
- // addVertexFrom.setProperty(GraphPropertiesDictionary.HEALTH_CHECK.getProperty(),
- // "GOOD");
- // addVertexFrom.setProperty("healthcheck",
- // next.getProperty("healthcheck"));
- //
- // //next.remove();
- //
- // next.removeProperty("healthcheck");
- // next.removeProperty("healthcheckis");
- //
- // next.remove();
-
- // GraphSONWriter.outputGraph(openGraph, outputFile);
-
for (NodeTypeEnum nodeTypeEnum : NodeTypeEnum.values()) {
removeNodesByLabel(graph, nodeTypeEnum.getName());
}
- // GraphSONWriter.outputGraph(graph, outputFile);
GraphSONWriter create = GraphSONWriter.build().create();
create.writeGraph(out, graph);
- // graph.rollback();
graph.tx().rollback();
} catch (Exception e) {
log.info("find Error In Json Graph failed - {}" , e);
- // graph.rollback();
graph.tx().rollback();
} finally {
try {
}
}
- public static void clearGraph(TitanGraph graph) {
-
- Iterable<TitanVertex> vertices = graph.query().vertices();
-
- long erased = 0;
-
- if (vertices != null) {
- Iterator<TitanVertex> iterator = vertices.iterator();
- while (iterator.hasNext()) {
- Vertex vertex = iterator.next();
- // graph.removeVertex(vertex);
- vertex.remove();
- erased++;
- }
-
- }
-
- System.out.println("After erasing " + erased + " vertices.");
- // graph.commit();
- graph.tx().commit();
- }
-
public String exportUsers(TitanGraph graph, String outputDirectory) {
List<Map<String, Object>> users = new ArrayList<>();
String result = null;
- // GraphMLWriter graphMLWriter = new GraphMLWriter(graph);
-
String outputFile = outputDirectory + File.separator + "users." + System.currentTimeMillis() + ".json";
FileWriter fileWriter = null;
return false;
} finally {
if (graph != null) {
- // graph.shutdown();
graph.close();
}
}