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..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) { @@ -919,8 +920,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; } @@ -1363,6 +1366,7 @@ public Collection getInitialListeners() { * @return the newly built Cluster instance. */ public Cluster build() { + System.out.println("start to build"); return Cluster.buildFrom(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 0869385e6f8..eaf29c22358 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. @@ -35,21 +32,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 (Exception e) { + e.printStackTrace(); + } finally { client.close(); } } @@ -67,11 +66,15 @@ public static void main(String[] args) { */ 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"); System.out.printf("Connected to cluster: %s%n", cluster.getMetadata().getClusterName()); + System.out.println("tes3"); session = cluster.connect(); }