Cassandraでのデータ登録

提供: LunaBiblos

Software > DataBase > KeyValueストア > Cassandraの利用方法 > Cassandraでのデータ登録

public class CassandraReadTest {
 public void run() {
   TTransport tr = new TSocket("192.168.0.1", 9160);
   TProtocol proto = new TBinaryProtocol(tr);
   Cassandra.Client client = new Cassandra.Client(proto);
   try {
     tr.open();
   } catch (TTransportException e) {
     e.printStackTrace();
     System.out.println(e.toString());
   }
   String key_user_id = "1";
   long timestamp = System.currentTimeMillis();
   // ================================================
   String tbl = "Keyspace1";
   String clm = "Standard1";
   // ================================================
   long st = System.nanoTime();
   Integer i = 0;
   try {
      client.insert(tbl, i.toString(), new ColumnPath(clm).setColumn("Name".getBytes()), ("Chris Goffinet" + l).getBytes("UTF-8"), timestamp, ConsistencyLevel.ONE);
   } catch (UnsupportedEncodingException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
   } catch (InvalidRequestException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
   } catch (UnavailableException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
   } catch (TimedOutException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
   } catch (TException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
   }
   tr.close();
  }