Skip to content

Instantly share code, notes, and snippets.

@perchouli
Created November 21, 2012 06:45
Show Gist options
  • Save perchouli/4123427 to your computer and use it in GitHub Desktop.
Save perchouli/4123427 to your computer and use it in GitHub Desktop.
Cassandra批量操作
#!/usr/bin/php
<?php
require 'bootstrap.php';
require_once LIBRARY_PATH.'/thrift/packages/cassandra/Cassandra.php';
require_once LIBRARY_PATH.'/thrift/packages/cassandra/cassandra.Cassandra.client.php';
require_once LIBRARY_PATH.'/thrift/packages/cassandra/cassandra_types.php';
use cassandra\Compression;
$config = require 'configs/cassandra.php';
$pool = new phpcassa\Connection\ConnectionPool($config['keyspace'], $config['servers']);
$raw = $pool->get();
$result = $raw->client->execute_cql_query("SELECT * FROM gravatar_users limit 2", Compression::NONE);
// $row = cassa('DoubanUser')->execute_cql_query('SELECT count(*) from douban_users');
foreach ($result->rows as $value) {
$row = cassa('GravatarUser')->get($value->key);
var_dump($row);
};
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment