Client 객체는 기본적으로, Cassandra.Client 생성을 클래스 예제 코드를 같이 사용하고 있습니다.
가장 기초적인 1개의 Column에 데이타 insert/get 하는 예제입니다..
가장 기초적인 1개의 Column에 데이타 insert/get 하는 예제입니다..
package net.sjava.cassandra.test;
import org.apache.cassandra.thrift.Column;
import org.apache.cassandra.thrift.ColumnPath;
import org.apache.cassandra.thrift.ConsistencyLevel;
public class CassandraTest {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
CassandraClientFactory factory = CassandraClientFactory.getInstance();
String keyspace = "Keyspace1";
String columnFamily = "Standard2";
String key = "key1";
long timestamp = System.currentTimeMillis();
String value ="aaaaaaaaaaaaaaaaaaa_bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb";
try {
ColumnPath cPath = new ColumnPath(columnFamily);
cPath.setColumn("name".getBytes("utf-8"));
factory.getClient().insert(keyspace, key, cPath, value.getBytes("utf-8"), timestamp, ConsistencyLevel.ONE);
Column col = factory.getClient().get(keyspace, key, cPath, ConsistencyLevel.ONE).getColumn();
System.out.println("Column name: " + new String(col.name, "utf-8"));
System.out.println("Column value: " + new String(col.value, "utf-8"));
value ="aaaaaaaaaa";
long time2 = System.currentTimeMillis();
factory.getClient().insert(keyspace, key, cPath, value.getBytes("utf-8"), time2, ConsistencyLevel.ONE);
Column col2 = factory.getClient().get(keyspace, key, cPath, ConsistencyLevel.ONE).getColumn();
System.out.println("Column2 name: " + new String(col2.name, "utf-8"));
System.out.println("Column2 value: " + new String(col2.value, "utf-8"));
} catch(Exception e) {
e.printStackTrace();
}
}
}
import org.apache.cassandra.thrift.Column;
import org.apache.cassandra.thrift.ColumnPath;
import org.apache.cassandra.thrift.ConsistencyLevel;
public class CassandraTest {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
CassandraClientFactory factory = CassandraClientFactory.getInstance();
String keyspace = "Keyspace1";
String columnFamily = "Standard2";
String key = "key1";
long timestamp = System.currentTimeMillis();
String value ="aaaaaaaaaaaaaaaaaaa_bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb";
try {
ColumnPath cPath = new ColumnPath(columnFamily);
cPath.setColumn("name".getBytes("utf-8"));
factory.getClient().insert(keyspace, key, cPath, value.getBytes("utf-8"), timestamp, ConsistencyLevel.ONE);
Column col = factory.getClient().get(keyspace, key, cPath, ConsistencyLevel.ONE).getColumn();
System.out.println("Column name: " + new String(col.name, "utf-8"));
System.out.println("Column value: " + new String(col.value, "utf-8"));
value ="aaaaaaaaaa";
long time2 = System.currentTimeMillis();
factory.getClient().insert(keyspace, key, cPath, value.getBytes("utf-8"), time2, ConsistencyLevel.ONE);
Column col2 = factory.getClient().get(keyspace, key, cPath, ConsistencyLevel.ONE).getColumn();
System.out.println("Column2 name: " + new String(col2.name, "utf-8"));
System.out.println("Column2 value: " + new String(col2.value, "utf-8"));
} catch(Exception e) {
e.printStackTrace();
}
}
}
'Apache Project > Cassandra' 카테고리의 다른 글
| org.apache.cassandra.db.marshal.MarshalException: cannot parse 'xxx' as hex bytes 에러시.. (0) | 2011/06/29 |
|---|---|
| Cassandra.Client 풀링하기.. (2) | 2010/12/01 |
| Cassandra simple insert/get 하기.. (2) | 2010/11/28 |
| Cassandra에 대한 좋은 설명과 예제들.. (0) | 2010/10/14 |
| Cassandra 발표 자료 (0) | 2010/07/06 |
Cassandra.pdf
