Package org.neo4j.cypher.javacompat

Examples of org.neo4j.cypher.javacompat.ExecutionEngine.execute()

286
287
288
289
290
291
292
293
294
295
296
            assertEquals("POINT(44.44 33.33)", row.getProperty("wkt"));

            //update the node
            robin.setProperty("wkt", "POINT(55.55 33.33)");
            index.add(robin, "dummy", "value");
            assertFalse(engine.execute("start n=node:layer3('withinDistance:[33.32, 44.44, 5.0]') return n").columnAs("n").hasNext());
            assertTrue(engine.execute("start n=node:layer3('withinDistance:[33.32, 55.55, 5.0]') return n").columnAs("n").hasNext());
            tx.success();
        }

    }
View Full Code Here
287
288
289
290
291
292
293
294
295
296
297
            //update the node
            robin.setProperty("wkt", "POINT(55.55 33.33)");
            index.add(robin, "dummy", "value");
            assertFalse(engine.execute("start n=node:layer3('withinDistance:[33.32, 44.44, 5.0]') return n").columnAs("n").hasNext());
            assertTrue(engine.execute("start n=node:layer3('withinDistance:[33.32, 55.55, 5.0]') return n").columnAs("n").hasNext());
            tx.success();
        }

    }
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
    @Test
    public void totalFriendshipStrengthShouldBeCountedUsingCypher() {
        ExecutionEngine executionEngine = new ExecutionEngine(database);

        executionEngine.execute("CREATE " +
                "(p1:Person), (p2:Person), (p3:Person)," +
                "(p1)-[:FRIEND_OF {strength:3}]->(p2)," +
                "(p2)-[:FRIEND_OF {strength:1}]->(p1)," +
                "(p1)-[:FRIEND_OF {strength:2}]->(p3)");
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
                "(p2)-[:FRIEND_OF {strength:1}]->(p1)," +
                "(p1)-[:FRIEND_OF {strength:2}]->(p3)");

        String query = "MATCH (c:FriendshipCounter) RETURN c.totalFriendshipStrength as result";

        for (Map<String, Object> result : executionEngine.execute(query)) {
            assertEquals(6L, result.get("result"));
        }

        executionEngine.execute("MATCH (p1:Person)-[f:FRIEND_OF {strength:3}]->(p2) DELETE f");
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
        for (Map<String, Object> result : executionEngine.execute(query)) {
            assertEquals(6L, result.get("result"));
        }

        executionEngine.execute("MATCH (p1:Person)-[f:FRIEND_OF {strength:3}]->(p2) DELETE f");

        for (Map<String, Object> result : executionEngine.execute(query)) {
            assertEquals(3L, result.get("result"));
        }
    }
View Full Code Here
106
107
108
109
110
111
112
113
114
115
            assertEquals(6L, result.get("result"));
        }

        executionEngine.execute("MATCH (p1:Person)-[f:FRIEND_OF {strength:3}]->(p2) DELETE f");

        for (Map<String, Object> result : executionEngine.execute(query)) {
            assertEquals(3L, result.get("result"));
        }
    }
}
View Full Code Here
123
124
125
126
127
128
129
130
131
132
133
  }
  public Result query(final GraphDatabaseService graphDb, final String query, final Map<String, Object> params) {
    ArrayList<Object[]> results = new ArrayList<>();
    ArrayList<String> columnNames = new ArrayList<>();
    ExecutionEngine engine = new ExecutionEngine(graphDb);
    ExecutionResult result = engine.execute(query, params);

    Boolean firstRow = true;
    for(Map<String, Object> row : result) {
      ArrayList<Object> rowResult = new ArrayList<>();
      for(Map.Entry<String, Object> column : row.entrySet()) {
View Full Code Here
511
512
513
514
515
516
517
518
519
520
521
                List<String> columns = new ArrayList<String>();
                //
                if ( currentAlias.getConnectionMode() != ConnectionMode.REMOTE )
                {
                    ExecutionEngine engine = new ExecutionEngine( graphDb );
                    ExecutionResult result = engine.execute( cypherQuery );
                    // message = result.toString().substring( result.toString().lastIndexOf( "+" ) + 1 ).trim();
                    columns = result.columns();
                    iterator = result.iterator();
                }
                else if ( currentAlias.getConnectionMode() == ConnectionMode.REMOTE )
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
        long time = System.currentTimeMillis();
        Map<String, Object> params = map("i", null);
        Map.Entry<String, Object> entry = params.entrySet().iterator().next();
        for (int i=1;i<1_000_000;i++) {
            entry.setValue(i);
            engine.execute("return {i}",params);
            if (i % 50_000 == 0) {
                System.out.println("commit " + i + " " + (System.currentTimeMillis() - time) + " ms since start");
            }
        }
        time = System.currentTimeMillis() - time;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.