Skip to content

Instantly share code, notes, and snippets.

@beccam
Created June 27, 2014 19:54
Show Gist options
  • Star 10 You must be signed in to star a gist
  • Fork 17 You must be signed in to fork a gist
  • Save beccam/06c3283e5ee4a480a555 to your computer and use it in GitHub Desktop.
Save beccam/06c3283e5ee4a480a555 to your computer and use it in GitHub Desktop.
Getting Started with Apache Cassandra and Java
import com.datastax.driver.core.*;
public class GettingStarted {
public static void main(String[] args) {
Cluster cluster;
Session session;
// Connect to the cluster and keyspace "demo"
cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
session = cluster.connect("demo");
// Insert one record into the users table
session.execute("INSERT INTO users (lastname, age, city, email, firstname) VALUES ('Jones', 35, 'Austin', 'bob@example.com', 'Bob')");
// Use select to get the user we just entered
ResultSet results = session.execute("SELECT * FROM users WHERE lastname='Jones'");
for (Row row : results) {
System.out.format("%s %d\n", row.getString("firstname"), row.getInt("age"));
}
// Update the same user with a new age
session.execute("update users set age = 36 where lastname = 'Jones'");
// Select and show the change
results = session.execute("select * from users where lastname='Jones'");
for (Row row : results) {
System.out.format("%s %d\n", row.getString("firstname"), row.getInt("age"));
}
// Delete the user from the users table
session.execute("DELETE FROM users WHERE lastname = 'Jones'");
// Show that the user is gone
results = session.execute("SELECT * FROM users");
for (Row row : results) {
System.out.format("%s %d %s %s %s\n", row.getString("lastname"), row.getInt("age"), row.getString("city"), row.getString("email"), row.getString("firstname"));
}
// Clean up the connection by closing it
cluster.close();
}
}
@durgaswaroop
Copy link

durgaswaroop commented Oct 4, 2016

It is probably because the version of the driver being used is old. Use the recent version of the Java driver

@sreeladdu5
Copy link

Please check the version of java used for compiling the src code and jars added in classpath. It basically occurs when two versions of java are used in program.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment