package me.prettyprint.cassandra.service;

import org.apache.cassandra.thrift.Column;
import org.apache.cassandra.thrift.ColumnPath;

import static me.prettyprint.cassandra.utils.StringUtils.bytes;
import static me.prettyprint.cassandra.utils.StringUtils.string;

/**
 * Example client that uses the cassandra hector client.
 *
 * @author Ran Tavory (rantav@gmail.com)
 *
 */
public class ExampleClient {

  public static void main(String[] args) throws IllegalStateException, PoolExhaustedException,
      Exception {
    CassandraClientPool pool = CassandraClientPoolFactory.INSTANCE.get();
    CassandraClient client = pool.borrowClient("tush", 9160);
    // A load balanced version would look like this:
    // CassandraClient client = pool.borrowClient(new String[] {"cas1:9160", "cas2:9160", "cas3:9160"});

    try {
      Keyspace keyspace = client.getKeyspace("Keyspace1");
      ColumnPath columnPath = new ColumnPath("Standard1");
      columnPath.setColumn(bytes("column-name"));

      // insert
      keyspace.insert("key", columnPath, bytes("value"));

      // read
      Column col = keyspace.getColumn("key", columnPath);

      System.out.println("Read from cassandra: " + string(col.getValue()));

    } finally {
      // return client to pool. do it in a finally block to make sure it's executed
      pool.releaseClient(client);
    }
  }
}

@@ -1207,24 +1207,213 @@
 Value()));%0A%0A
+      // This line makes sure that even if the client had failures and recovered, a correct%0A      // releaseClient is called, on the up to date client.%0A      client = keyspace.getClient();%0A
     %7D finall

Fix ExampleClient to release the correct client even when there's possible errors and failover (cherry picked from commit 184b6460812c21e7fde77821245848f9ed2f3e6e)