beccam · June 27, 2014 19:54 · iabhinay · Feb 13, 2016 · LazyCoder88 · May 16, 2016
diff --git a/GettingStarted.java b/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', '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();
 	}
 }
	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();
	}
	}
No results found