You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by ok...@apache.org on 2015/10/30 00:29:27 UTC
[06/50] incubator-tinkerpop git commit: TINKERPOP3-903 Add a test to
validate that results of all sizes stream properly.
TINKERPOP3-903 Add a test to validate that results of all sizes stream properly.
This is an amendment to TINKERPOP-903 which was already merged and closed.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/173228e7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/173228e7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/173228e7
Branch: refs/heads/TINKERPOP3-925
Commit: 173228e776ea88b5856d0f02cd4c2070e8f5463c
Parents: b2ef5a3
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Sat Oct 24 06:38:35 2015 -0400
Committer: Stephen Mallette <sp...@genoprime.com>
Committed: Sat Oct 24 06:38:35 2015 -0400
----------------------------------------------------------------------
.../server/GremlinDriverIntegrateTest.java | 44 +++++++++++++++++++-
1 file changed, 43 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/173228e7/gremlin-server/src/test/java/org/apache/tinkerpop/gremlin/server/GremlinDriverIntegrateTest.java
----------------------------------------------------------------------
diff --git a/gremlin-server/src/test/java/org/apache/tinkerpop/gremlin/server/GremlinDriverIntegrateTest.java b/gremlin-server/src/test/java/org/apache/tinkerpop/gremlin/server/GremlinDriverIntegrateTest.java
index 575f96e..769f216 100644
--- a/gremlin-server/src/test/java/org/apache/tinkerpop/gremlin/server/GremlinDriverIntegrateTest.java
+++ b/gremlin-server/src/test/java/org/apache/tinkerpop/gremlin/server/GremlinDriverIntegrateTest.java
@@ -20,8 +20,11 @@ package org.apache.tinkerpop.gremlin.server;
import org.apache.commons.lang.exception.ExceptionUtils;
import org.apache.tinkerpop.gremlin.TestHelper;
-import org.apache.tinkerpop.gremlin.driver.*;
import org.apache.tinkerpop.gremlin.driver.Channelizer;
+import org.apache.tinkerpop.gremlin.driver.Client;
+import org.apache.tinkerpop.gremlin.driver.Cluster;
+import org.apache.tinkerpop.gremlin.driver.Result;
+import org.apache.tinkerpop.gremlin.driver.ResultSet;
import org.apache.tinkerpop.gremlin.driver.exception.ConnectionException;
import org.apache.tinkerpop.gremlin.driver.exception.ResponseException;
import org.apache.tinkerpop.gremlin.driver.message.ResponseStatusCode;
@@ -108,6 +111,45 @@ public class GremlinDriverIntegrateTest extends AbstractGremlinServerIntegration
}
@Test
+ public void shouldHandleResultsOfAllSizes() throws Exception {
+ final Cluster cluster = Cluster.open();
+ final Client client = cluster.connect();
+
+ final String script = "g.V().drop().iterate();\n" +
+ "\n" +
+ "List ids = new ArrayList();\n" +
+ "\n" +
+ "int ii = 0;\n" +
+ "Vertex v = graph.addVertex();\n" +
+ "v.property(\"ii\", ii);\n" +
+ "v.property(\"sin\", Math.sin(ii));\n" +
+ "ids.add(v.id());\n" +
+ "\n" +
+ "Random rand = new Random();\n" +
+ "for (; ii < size; ii++) {\n" +
+ " v = graph.addVertex();\n" +
+ " v.property(\"ii\", ii);\n" +
+ " v.property(\"sin\", Math.sin(ii/5.0));\n" +
+ " Vertex u = g.V(ids.get(rand.nextInt(ids.size()))).next();\n" +
+ " v.addEdge(\"linked\", u);\n" +
+ " ids.add(u.id());\n" +
+ " ids.add(v.id());\n" +
+ "}\n" +
+ "g.V()";
+
+ final List<Integer> sizes = Arrays.asList(1, 10, 20, 50, 75, 100, 250, 500, 750, 1000, 5000, 10000);
+ for (Integer size : sizes) {
+ final Map<String, Object> params = new HashMap<>();
+ params.put("size", size - 1);
+ final ResultSet results = client.submit(script, params);
+
+ assertEquals(size.intValue(), results.all().get().size());
+ }
+
+ cluster.close();
+ }
+
+ @Test
public void shouldFailWithBadClientSideSerialization() throws Exception {
final Cluster cluster = Cluster.open();
final Client client = cluster.connect();