cassandra-collections-example.java

import com.datastax.driver.core.*;

import java.util.Arrays;
import java.util.UUID;

// create keyspace test with replication = {'class': 'SimpleStrategy', 'replication_factor': 1};
// create table t2 (id uuid primary key, value list<text>);

public class CassandraTest {
    public static void main(String[] args)
    {

        Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();

        Session session = cluster.connect("test");

        PreparedStatement preparedStatement = session.prepare("INSERT INTO t2 (id, value) values (?, ?)");
        BoundStatement boundStatement = new BoundStatement(preparedStatement);
        UUID uuid = UUID.randomUUID();
        boundStatement.bind(uuid, Arrays.asList("1", "2"));

        session.execute(boundStatement);

        preparedStatement = session.prepare("UPDATE t2 SET VALUE = ? WHERE id = ?");
        boundStatement = new BoundStatement(preparedStatement);
        boundStatement.bind(Arrays.asList("9", "8"), uuid);
        session.execute(boundStatement);

        ResultSet resp = session.execute("SELECT * FROM t2");

        for (Row row : resp)
        {
            System.out.println(row.getUUID("id").toString() + " " + row.getList("value", String.class));
        }

        cluster.close();
    }
}