[Cassandra Wiki] Update of "ClientExamples" by JonathanEllis

[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 JonathanEllis:
http://wiki.apache.org/cassandra/ClientExamples

The comment on the change is:
create CE03

------------------------------------------------------------------------------
  The most common way to access Cassandra is via the [http://incubator.apache.org/thrift/ Thrift] interface.
+ 
+ These examples are for Cassandra trunk, which will become 0.4.
+ 
+ See ClientExamples03 for examples fitting the 03 API.
  
  == PHP ==
  Cassandra 0.4 Preview
@@ -85, +89 @@

  ?>
  }}}
  
- Cassandra <= 0.3
- 
- {{{
- 
- <?php
- $GLOBALS['THRIFT_ROOT'] = '/usr/share/php/Thrift';
- 
- require_once $GLOBALS['THRIFT_ROOT'].'/packages/cassandra/Cassandra.php';
- require_once $GLOBALS['THRIFT_ROOT'].'/transport/TSocket.php';
- require_once $GLOBALS['THRIFT_ROOT'].'/protocol/TBinaryProtocol.php';
- require_once $GLOBALS['THRIFT_ROOT'].'/transport/TFramedTransport.php';
- require_once $GLOBALS['THRIFT_ROOT'].'/transport/TBufferedTransport.php';
- 
- try {
-   $socket = new TSocket('localhost', 9160);
-   $transport = new TBufferedTransport($socket, 1024, 1024);
-   $protocol = new TBinaryProtocol($transport);
-   $client = new CassandraClient($protocol);
- 
-   $transport->open();
-   /* Insert some data into base attributes */
-   $key_user_id = "1";
-   $timestamp = time();
-   $client->insert("users",$key_user_id,"base_attributes:name", "Chris Goffinet", $timestamp, false);
-   $client->insert("users",$key_user_id,"base_attributes:age", "24", $timestamp, false);
- 
-   $start = -1;
-   $end = -1;
-   $result = $client->get_slice("users", $key_user_id,"base_attributes", $start, $end);
-   
-   print_r($result);
-   $transport->close();
- 
- } catch (TException $tx) {
-    print 'TException: '.$tx->why."\n";
- }
- 
- ?>
- 
- }}}
- 
- == Python ==
- Make sure that when you generate the gen-py folder, you move the cassandra/ folder into your Python's site-packages.
- 
- {{{
- from thrift import Thrift
- from thrift.transport import TTransport
- from thrift.transport import TSocket
- from thrift.transport import THttpClient
- from thrift.protocol import TBinaryProtocol
- from cassandra import Cassandra
- from cassandra.ttypes import *
- import time
- 
- socket = TSocket.TSocket("localhost", 9160)
- transport = TTransport.TBufferedTransport(socket)
- protocol = TBinaryProtocol.TBinaryProtocol(transport)
- client = Cassandra.Client(protocol)
- 
- try:
-     transport.open()
-     key_user_id = "1"
-     timestamp = time.time()
-     client.insert("users",key_user_id,"base_attributes:name", "Chris Goffinet", timestamp, False)
-     client.insert("users",key_user_id,"base_attributes:age", "24", timestamp, False)
-     start = -1
-     end = -1
-     result = client.get_slice("users", key_user_id,"base_attributes", start, end)
-     print result    
- except Thrift.TException, tx:
-     print 'Thrift: %s' % tx.message
- finally:
-     transport.close()
- 
- }}}
- 
- == 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 org.apache.cassandra.service.InvalidRequestException;
- import org.apache.cassandra.service.NotFoundException;
- import org.apache.cassandra.service.UnavailableException;
- import org.apache.cassandra.service.column_t;
- import org.apache.cassandra.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();
-     }
-   }
- }
- }}}
-