GraphDatabase.java

package pl.edu.agh.ki.bd2;

import java.io.File;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

import org.neo4j.driver.v1.*;

import static org.neo4j.driver.v1.Values.parameters;

public final class GraphDatabase {
    public static GraphDatabase createDatabase() {
        return new GraphDatabase();
    }
    Driver driver;
    private GraphDatabase() {
        driver = org.neo4j.driver.v1.GraphDatabase.driver("bolt://localhost:7687", AuthTokens.basic("neo4j", "alek"));
        registerShutdownHook();
    }



    private void registerShutdownHook() {
        // Registers a shutdown hook for the Neo4j instance so that it
        // shuts down nicely when the VM exits (even if you "Ctrl-C" the
        // running application).
        Runtime.getRuntime().addShutdownHook(new Thread(() -> driver.close()));
    }

    public String runCypher(final String cypher) {
        try (Session session = driver.session()) {
            String txres = session.writeTransaction(tx -> {
                StatementResult result = tx.run(cypher);
                List<String> records = new ArrayList<>();
                result.forEachRemaining(x -> records.add(x.values().stream().map(y ->y.asNode().asMap().toString()).collect(Collectors.joining())));
return records.toString();
            });
            return txres;
        } catch (Exception e) {
            return e.toString();
        }
    }
}