Dear Wiki user, You have subscribed to a wiki page or wiki category on "Cassandra Wiki" for change notification.
The "ThriftExamples" page has been changed by DaveBrosius: http://wiki.apache.org/cassandra/ThriftExamples?action=diff&rev1=92&rev2=93 } tr.close(); } + } + }}} + + Same example as above but working with cassandra version 1.0.0 + + {{{#!java + package cassandra.clientest; + + import java.io.UnsupportedEncodingException; + import java.nio.ByteBuffer; + import java.util.List; + + import org.apache.cassandra.thrift.Cassandra; + import org.apache.cassandra.thrift.Column; + import org.apache.cassandra.thrift.ColumnOrSuperColumn; + import org.apache.cassandra.thrift.ColumnParent; + import org.apache.cassandra.thrift.ColumnPath; + import org.apache.cassandra.thrift.ConsistencyLevel; + import org.apache.cassandra.thrift.InvalidRequestException; + import org.apache.cassandra.thrift.NotFoundException; + import org.apache.cassandra.thrift.SlicePredicate; + import org.apache.cassandra.thrift.SliceRange; + import org.apache.cassandra.thrift.TimedOutException; + import org.apache.cassandra.thrift.UnavailableException; + import org.apache.thrift.TException; + import org.apache.thrift.protocol.TBinaryProtocol; + import org.apache.thrift.protocol.TProtocol; + import org.apache.thrift.transport.TFramedTransport; + import org.apache.thrift.transport.TSocket; + import org.apache.thrift.transport.TTransport; + + public class CClient + { + public static void main(String[] args) + throws TException, InvalidRequestException, UnavailableException, UnsupportedEncodingException, NotFoundException, TimedOutException + { + TTransport tr = new TFramedTransport(new TSocket("localhost", 9160)); + TProtocol proto = new TBinaryProtocol(tr); + Cassandra.Client client = new Cassandra.Client(proto); + tr.open(); + + String key_user_id = "1"; + + // insert data + long timestamp = System.currentTimeMillis(); + client.set_keyspace("Keyspace1"); + ColumnParent parent = new ColumnParent("Standard1"); + + Column nameColumn = new Column(toByteBuffer("name")); + nameColumn.setValue(toByteBuffer("Chris Goffinet")); + nameColumn.setTimestamp(timestamp); + client.insert(toByteBuffer(key_user_id), parent, nameColumn, ConsistencyLevel.ONE); + + Column ageColumn = new Column(toByteBuffer("age")); + ageColumn.setValue(toByteBuffer("24")); + ageColumn.setTimestamp(timestamp); + client.insert(toByteBuffer(key_user_id), parent, ageColumn, ConsistencyLevel.ONE); + + ColumnPath path = new ColumnPath("Standard1"); + + // read single column + path.setColumn(toByteBuffer("name")); + System.out.println(client.get(toByteBuffer(key_user_id), path, ConsistencyLevel.ONE)); + + // read entire row + SlicePredicate predicate = new SlicePredicate(); + SliceRange sliceRange = new SliceRange(toByteBuffer(""), toByteBuffer(""), false, 10); + predicate.setSlice_range(sliceRange); + + List<ColumnOrSuperColumn> results = client.get_slice(toByteBuffer(key_user_id), parent, predicate, ConsistencyLevel.ONE); + for (ColumnOrSuperColumn result : results) + { + Column column = result.column; + System.out.println(toString(column.name) + " -> " + toString(column.value)); + } + + tr.close(); + } + + public static ByteBuffer toByteBuffer(String value) + throws UnsupportedEncodingException + { + return ByteBuffer.wrap(value.getBytes("UTF-8")); + } + + public static String toString(ByteBuffer buffer) + throws UnsupportedEncodingException + { + byte[] bytes = new byte[buffer.remaining()]; + buffer.get(bytes); + return new String(bytes, "UTF-8"); + } } }}} == Python ==
