-
-
Save rbramwell/d35e86900e1a832dc2c8 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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(); | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment