RedisGraph Java client
<dependencies> <dependency> <groupId>com.redislabs</groupId> <artifactId>jredisgraph</artifactId> <version>2.2.0</version> </dependency> </dependencies> <repositories> <repository> <id>snapshots-repo</id> <url>https://oss.sonatype.org/content/repositories/snapshots</url> </repository> </repositories>and
<dependencies> <dependency> <groupId>com.redislabs</groupId> <artifactId>jredisgraph</artifactId> <version>2.3.0-SNAPSHOT</version> </dependency> </dependencies>package com.redislabs.redisgraph; import com.redislabs.redisgraph.graph_entities.Edge; import com.redislabs.redisgraph.graph_entities.Node; import com.redislabs.redisgraph.graph_entities.Path; import com.redislabs.redisgraph.impl.api.RedisGraph; import java.util.List; public class RedisGraphExample { public static void main(String[] args) { // general context api. Not bound to graph key or connection RedisGraph graph = new RedisGraph(); Map<String, Object> params = new HashMap<>(); params.put("age", 30); params.put("name", "amit"); // send queries to a specific graph called "social" graph.query("social","CREATE (:person{name:'roi',age:32})"); graph.query("social","CREATE (:person{name:$name,age:$age})", params); graph.query("social","MATCH (a:person), (b:person) WHERE (a.name = 'roi' AND b.name='amit') CREATE (a)-[:knows]->(b)"); ResultSet resultSet = graph.query("social", "MATCH (a:person)-[r:knows]->(b:person) RETURN a, r, b"); while(resultSet.hasNext()) { Record record = resultSet.next(); // get values Node a = record.getValue("a"); Edge r = record.getValue("r"); //print record System.out.println(record.toString()); } resultSet = graph.query("social", "MATCH p = (:person)-[:knows]->(:person) RETURN p"); while(resultSet.hasNext()) { Record record = resultSet.next(); Path p = record.getValue("p"); // More path API at Javadoc. System.out.println(p.nodeCount()); } // delete graph graph.deleteGraph("social"); // get connection context - closable object try(RedisGraphContext context = graph.getContext()) { context.query("contextSocial","CREATE (:person{name:'roi',age:32})"); context.query("social","CREATE (:person{name:$name,age:$age})", params); context.query("contextSocial", "MATCH (a:person), (b:person) WHERE (a.name = 'roi' AND b.name='amit') CREATE (a)-[:knows]->(b)"); // WATCH/MULTI/EXEC context.watch("contextSocial"); RedisGraphTransaction t = context.multi(); t.query("contextSocial", "MATCH (a:person)-[r:knows]->(b:person{name:$name,age:$age}) RETURN a, r, b", params); // support for Redis/Jedis native commands in transaction t.set("x", "1"); t.get("x"); // get multi/exec results List<Object> execResults = t.exec(); System.out.println(execResults.toString()); context.deleteGraph("contextSocial"); } } }