From 2312c06acaa4aa6a236e58f51bd4016dfa82c27c Mon Sep 17 00:00:00 2001 From: Chang Lou Date: Thu, 5 Jul 2018 21:09:44 +0000 Subject: [PATCH 1/7] modify on examples --- .../examples/basic/CreateAndPopulateKeyspace.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java b/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java index 0869385e6f8..a8d7f82da51 100644 --- a/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java +++ b/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java @@ -35,21 +35,23 @@ */ public class CreateAndPopulateKeyspace { - static String[] CONTACT_POINTS = {"127.0.0.1"}; - static int PORT = 9042; + static String[] CONTACT_POINTS = {"10.0.0.23"}; + static int PORT = 9160; public static void main(String[] args) { CreateAndPopulateKeyspace client = new CreateAndPopulateKeyspace(); + System.out.println("test"); try { - client.connect(CONTACT_POINTS, PORT); client.createSchema(); client.loadData(); client.querySchema(); - } finally { + } catch (Error e) { + e.printStackTrace(); + } finally { client.close(); } } @@ -67,11 +69,13 @@ public static void main(String[] args) { */ public void connect(String[] contactPoints, int port) { + System.out.println("tes2"); cluster = Cluster.builder() .addContactPoints(contactPoints).withPort(port) .build(); System.out.printf("Connected to cluster: %s%n", cluster.getMetadata().getClusterName()); + System.out.println("tes3"); session = cluster.connect(); } From bbd5c73ba8317e013c0a3f43a0a59d233d7a4c8b Mon Sep 17 00:00:00 2001 From: Mcfatealan Date: Thu, 5 Jul 2018 17:55:45 -0400 Subject: [PATCH 2/7] minor --- .../src/main/java/com/datastax/driver/core/Cluster.java | 2 ++ .../driver/examples/basic/CreateAndPopulateKeyspace.java | 8 ++++---- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/driver-core/src/main/java/com/datastax/driver/core/Cluster.java b/driver-core/src/main/java/com/datastax/driver/core/Cluster.java index e4bc42f4a0b..5db63224dc1 100644 --- a/driver-core/src/main/java/com/datastax/driver/core/Cluster.java +++ b/driver-core/src/main/java/com/datastax/driver/core/Cluster.java @@ -919,8 +919,10 @@ public Builder addContactPoint(String address) { * @see Builder#addContactPoint */ public Builder addContactPoints(String... addresses) { + System.out.println("start to addContactPoints"); for (String address : addresses) addContactPoint(address); + System.out.println("finish addContactPoints"); return this; } diff --git a/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java b/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java index a8d7f82da51..ab36543b6ad 100644 --- a/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java +++ b/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java @@ -42,7 +42,7 @@ public static void main(String[] args) { CreateAndPopulateKeyspace client = new CreateAndPopulateKeyspace(); - System.out.println("test"); + System.out.println("test"); try { client.connect(CONTACT_POINTS, PORT); client.createSchema(); @@ -51,7 +51,7 @@ public static void main(String[] args) { } catch (Error e) { e.printStackTrace(); - } finally { + } finally { client.close(); } } @@ -69,13 +69,13 @@ public static void main(String[] args) { */ public void connect(String[] contactPoints, int port) { - System.out.println("tes2"); + System.out.println("tes2"); cluster = Cluster.builder() .addContactPoints(contactPoints).withPort(port) .build(); System.out.printf("Connected to cluster: %s%n", cluster.getMetadata().getClusterName()); - System.out.println("tes3"); + System.out.println("tes3"); session = cluster.connect(); } From 4d08216bafd8d3980b1933f7def54f27015a0dcd Mon Sep 17 00:00:00 2001 From: Mcfatealan Date: Thu, 5 Jul 2018 18:11:29 -0400 Subject: [PATCH 3/7] minor --- driver-core/src/main/java/com/datastax/driver/core/Cluster.java | 1 + 1 file changed, 1 insertion(+) diff --git a/driver-core/src/main/java/com/datastax/driver/core/Cluster.java b/driver-core/src/main/java/com/datastax/driver/core/Cluster.java index 5db63224dc1..318a59de2ee 100644 --- a/driver-core/src/main/java/com/datastax/driver/core/Cluster.java +++ b/driver-core/src/main/java/com/datastax/driver/core/Cluster.java @@ -1365,6 +1365,7 @@ public Collection getInitialListeners() { * @return the newly built Cluster instance. */ public Cluster build() { + System.out.println("start to build"); return Cluster.buildFrom(this); } } From c16216678820afcf8712455d266ce0f369ddd670 Mon Sep 17 00:00:00 2001 From: Mcfatealan Date: Thu, 5 Jul 2018 18:14:08 -0400 Subject: [PATCH 4/7] minor --- driver-core/src/main/java/com/datastax/driver/core/Cluster.java | 1 + 1 file changed, 1 insertion(+) diff --git a/driver-core/src/main/java/com/datastax/driver/core/Cluster.java b/driver-core/src/main/java/com/datastax/driver/core/Cluster.java index 318a59de2ee..045f6ba5abc 100644 --- a/driver-core/src/main/java/com/datastax/driver/core/Cluster.java +++ b/driver-core/src/main/java/com/datastax/driver/core/Cluster.java @@ -113,6 +113,7 @@ protected Cluster(Initializer initializer) { checkNotEmpty(initializer.getContactPoints()), initializer.getConfiguration(), initializer.getInitialListeners()); + System.out.println("init finished"); } private static List checkNotEmpty(List contactPoints) { From 02a1057c3734a61d47f06ae6d35f5257b61e494b Mon Sep 17 00:00:00 2001 From: Mcfatealan Date: Thu, 5 Jul 2018 18:16:12 -0400 Subject: [PATCH 5/7] minor --- .../driver/examples/basic/CreateAndPopulateKeyspace.java | 1 + 1 file changed, 1 insertion(+) diff --git a/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java b/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java index ab36543b6ad..731d1fc3055 100644 --- a/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java +++ b/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java @@ -74,6 +74,7 @@ public void connect(String[] contactPoints, int port) { .addContactPoints(contactPoints).withPort(port) .build(); + System.out.println("tes4"); System.out.printf("Connected to cluster: %s%n", cluster.getMetadata().getClusterName()); System.out.println("tes3"); From 640cdb4826bfc8758053e48572d7d8b8384ef996 Mon Sep 17 00:00:00 2001 From: Chang Lou Date: Fri, 6 Jul 2018 18:16:37 +0000 Subject: [PATCH 6/7] sync --- .../driver/examples/basic/CreateAndPopulateKeyspace.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java b/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java index ab36543b6ad..d06adb621c5 100644 --- a/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java +++ b/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java @@ -49,7 +49,7 @@ public static void main(String[] args) { client.loadData(); client.querySchema(); - } catch (Error e) { + } catch (Exception e) { e.printStackTrace(); } finally { client.close(); From 2c238efbd99b7832afdefac8715f6e99a0a2ec4d Mon Sep 17 00:00:00 2001 From: Mcfatealan Date: Fri, 6 Jul 2018 14:23:32 -0400 Subject: [PATCH 7/7] sync --- .../driver/examples/basic/CreateAndPopulateKeyspace.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java b/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java index 731d1fc3055..296fec55cc5 100644 --- a/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java +++ b/driver-examples/src/main/java/com/datastax/driver/examples/basic/CreateAndPopulateKeyspace.java @@ -15,10 +15,7 @@ */ package com.datastax.driver.examples.basic; -import com.datastax.driver.core.Cluster; -import com.datastax.driver.core.ResultSet; -import com.datastax.driver.core.Row; -import com.datastax.driver.core.Session; +import com.datastax.driver.core.*; /** * Creates a keyspace and tables, and loads some data into them. @@ -72,6 +69,7 @@ public void connect(String[] contactPoints, int port) { System.out.println("tes2"); cluster = Cluster.builder() .addContactPoints(contactPoints).withPort(port) + .withProtocolVersion(ProtocolVersion.V2) .build(); System.out.println("tes4");