Skip to content

Instantly share code, notes, and snippets.

@beccam
Last active May 21, 2019
Embed
What would you like to do?
package com.datastax.quickstart;
import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.cql.*;
import java.net.InetSocketAddress;
public class GettingStarted {
public static void main(String[] args) {
// TO DO: Fill in your own host, port, and data center
try (CqlSession session = CqlSession.builder()
.addContactPoint(new InetSocketAddress("127.0.0.1", 9042))
.withKeyspace("demo")
.withLocalDatacenter("datacenter1")
.build()) {
setUser(session, "Jones", 35, "Austin", "bob@example.com", "Bob");
getUser(session, "Jones");
updateUser(session, 36, "Jones");
getUser(session, "Jones");
deleteUser(session, "Jones");
}
}
private static void setUser(CqlSession session, String lastname, int age, String city, String email, String firstname) {
//TO DO: execute SimpleStatement that inserts one user into the table
session.execute(
SimpleStatement.builder( "INSERT INTO users (lastname, age, city, email, firstname) VALUES (?,?,?,?,?)")
.addPositionalValues(lastname, age, city, email, firstname)
.build());
}
private static void getUser(CqlSession session, String lastname) {
//TO DO: execute SimpleStatement that retrieves one user from the table
//TO DO: print firstname and age of user
ResultSet rs = session.execute(
SimpleStatement.builder("SELECT * FROM users WHERE lastname=?")
.addPositionalValue(lastname)
.build());
Row row = rs.one();
System.out.format("%s %d\n", row.getString("firstname"), row.getInt("age"));
}
private static void updateUser(CqlSession session, int age, String lastname) {
//TO DO: execute SimpleStatement that updates the age of one user
session.execute(
SimpleStatement.builder("UPDATE users SET age =? WHERE lastname =? ")
.addPositionalValues(age, lastname)
.build());
}
private static void deleteUser(CqlSession session, String lastname) {
//TO DO: execute SimpleStatement that deletes one user from the table
session.execute(
SimpleStatement.builder("DELETE FROM users WHERE lastname=?")
.addPositionalValue(lastname)
.build());
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment