Cassandra Java Driverでデータのinsertとselectを行う

CassandraInsertAndSelect.groovy

@Grapes(
    @Grab(group='com.datastax.cassandra', module='cassandra-driver-core', version='2.1.5')
)
import com.datastax.driver.core.*

def cluster = Cluster.builder().addContactPoint('127.0.0.1').build()
def session = cluster.connect()
session.execute("INSERT INTO first_keyspace.first_table (name, value) VALUES ('foo', 'bar');");
session.execute("INSERT INTO first_keyspace.first_table (name, value) VALUES ('gee', 'baz');");

def resultSet = session.execute("select * from first_keyspace.first_table where name = 'gee';")
resultSet.each { 
  println it.getColumnDefinitions()
  println it
}

session.close()
cluster.close()

コンテステンシーレベルを指定する場合は、
Session#prepare(String)
PreparedStatement#setConsistencyLevel(ConsistencyLevel)
を使う感じでしょうか。

def statement = session.prepare("INSERT INTO first_keyspace.first_table (name, value) VALUES ('foo', 'bar');")
statement.setConsistencyLevel(ConsistencyLevel.QUORUM)
session.execute(statement)