[Cassandra Wiki] Update of "ClientExamples" by NicolasBonvin

[Apache Wiki <wi...@apache.org>]

Dear Wiki user,

You have subscribed to a wiki page or wiki category on "Cassandra Wiki" for change notification.

The following page has been changed by NicolasBonvin:
http://wiki.apache.org/cassandra/ClientExamples

The comment on the change is:
Added an example using Java

------------------------------------------------------------------------------
  
  }}}
  
+ == Java ==
+ {{{
+ 
+ 
+ import java.io.UnsupportedEncodingException;
+ import java.util.List;
+ 
+ import org.apache.thrift.TException;
+ import org.apache.thrift.protocol.TBinaryProtocol;
+ import org.apache.thrift.protocol.TProtocol;
+ import org.apache.thrift.transport.TSocket;
+ import org.apache.thrift.transport.TTransport;
+ import org.apache.thrift.transport.TTransportException;
+ 
+ import com.facebook.infrastructure.service.InvalidRequestException;
+ import com.facebook.infrastructure.service.NotFoundException;
+ import com.facebook.infrastructure.service.UnavailableException;
+ import com.facebook.infrastructure.service.column_t;
+ import com.facebook.infrastructure.service.Cassandra.Client;
+ 
+ public class CClient {
+ 
+   public static void main(String[] args) {
+ 
+     TTransport tr = new TSocket("localhost", 9160);
+     TProtocol proto = new TBinaryProtocol(tr);
+     try {
+       
+       Client client = new Client(proto);
+       tr.open();
+       String key_user_id = "1";
+       long timestamp = System.currentTimeMillis();
+       client.insert("users", key_user_id, "base_attributes:name", 
+                     "Chris Goffinet".getBytes("UTF-8"), timestamp, false);
+       client.insert("users", key_user_id, "base_attributes:age", 
+                     "24".getBytes("UTF-8"), timestamp, false);
+       int start = -1;
+       int end = -1;
+       List<column_t> results =  client.get_slice("users", key_user_id,
+                                                  "base_attributes", start, end);
+       
+       for (column_t col : results) {
+         System.out.println(col.getColumnName() + " -> " + 
+                            new String(col.getValue(),"UTF-8"));
+       }
+       
+     } catch (TTransportException e) {
+       e.printStackTrace();
+     } catch (UnsupportedEncodingException e) {
+       e.printStackTrace();
+     } catch (InvalidRequestException e) {
+       e.printStackTrace();
+     } catch (UnavailableException e) {
+       e.printStackTrace();
+     } catch (TException e) {
+       e.printStackTrace();
+     } catch (NotFoundException e) {
+       e.printStackTrace();
+     } finally {
+       tr.close();
+     }
+   }
+ }
+ }}}
+