package org.onap.aai.dbmap;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
+
import org.apache.tinkerpop.gremlin.structure.io.IoCore;
import org.janusgraph.core.JanusGraph;
import org.janusgraph.core.JanusGraphFactory;
import org.janusgraph.core.schema.JanusGraphManagement;
import org.onap.aai.dbgen.GraphSONPartialIO;
import org.onap.aai.dbgen.SchemaGenerator;
+import org.onap.aai.logging.LogFormatTools;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class InMemoryGraph {
- private static final EELFLogger LOGGER = EELFManager.getInstance().getLogger(InMemoryGraph.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger(InMemoryGraph.class);
private JanusGraph graph = null;
- public InMemoryGraph(final Builder builder) throws IOException {
+ public InMemoryGraph(Builder builder) throws IOException {
/*
* Create a In-memory graph
*/
- try (final InputStream is = new FileInputStream(builder.propertyFile);) {
+ try (InputStream is = new FileInputStream(builder.propertyFile)) {
graph = JanusGraphFactory.open(builder.propertyFile);
- final Properties graphProps = new Properties();
+ Properties graphProps = new Properties();
graphProps.load(is);
- final JanusGraphManagement graphMgt = graph.openManagement();
if (builder.isSchemaEnabled) {
LOGGER.info("Schema Enabled");
- SchemaGenerator.loadSchemaIntoJanusGraph(graph, graphMgt, graphProps.getProperty("storage.backend"));
+ SchemaGenerator.loadSchemaIntoJanusGraph(graph, graphProps.getProperty("storage.backend"), false);
}
- try (final JanusGraphTransaction transaction = graph.newTransaction();) {
+ try (JanusGraphTransaction transaction = graph.newTransaction()) {
LOGGER.info("Loading snapshot");
if (builder.isPartialGraph) {
if ((builder.graphsonLocation != null) && (builder.graphsonLocation.length() > 0)) {
transaction.io(GraphSONPartialIO.build()).readGraph(builder.graphsonLocation);
} else {
transaction.io(GraphSONPartialIO.build()).reader().create().readGraph(builder.seqInputStream,
- graph);
+ graph);
}
} else {
if ((builder.graphsonLocation != null) && (builder.graphsonLocation.length() > 0)) {
}
}
transaction.commit();
- } catch (final IOException e) {
- LOGGER.error("ERROR: Could not load datasnapshot to in memory graph. \n", e);
- throw new IllegalStateException("Could not load datasnapshot to in memory graph");
}
- } catch (final IOException e) {
- LOGGER.error("ERROR: Could not load datasnapshot to in memory graph. \n", e);
+ } catch (Exception e) {
+ LOGGER.error(String.format("ERROR: Could not load datasnapshot to in memory graph. %n%s",
+ LogFormatTools.getStackTop(e)));
throw new IllegalStateException("Could not load datasnapshot to in memory graph");
+
}
+
}
public static class Builder {