Getting Started with Apache Cassandra and Java

GettingStarted.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', '[email protected]', '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();
	}
}

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

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.