Tatikoma\React\Cassandra
Performant pure-PHP CQL v4 (Cassandra) async (ReactPHP) library., (*1)
Library is not ready for production and much of functional is not implemented yet., (*2)
Installation, (*3)
php composer.phar require tatikoma/react-cassandra:dev-master
Example usage (async mode):, (*4)
require_once 'vendor/autoload.php';
$loop = React\EventLoop\Factory::create();
$cluster = new \Tatikoma\React\Cassandra\Async\Cluster($loop, [
['host' => '127.0.0.1'],
['host' => '127.0.0.2'],
['host' => '127.0.0.3'],
['host' => '127.0.0.4'],
]);
$cluster->connect('test')->then(function() use($cluster){
print "Connected to cluster keyspace test\n";
$uuid = '00000000-0000-0000-0000-000000000000';
return $cluster->query('
SELECT *
FROM example
WHERE id = :id
',[
'id' => new \Tatikoma\React\Cassandra\Type\UUID($uuid),
]);
})->then(function($response){
print "Query successfull, got " . count($response->results) . " rows:\n";
foreach($response as $row){
var_dump($row);
}
}, function(\Tatikoma\React\Cassandra\Protocol\ErrorFrame $reason){
print "Query failed: " . $reason->errorString . "\n";
});
$loop->run();
Example usage (sync mode):, (*5)
require_once 'vendor/autoload.php';
$cluster = new \Tatikoma\React\Cassandra\Cluster([
['host' => '127.0.0.1'],
['host' => '127.0.0.2'],
['host' => '127.0.0.3'],
['host' => '127.0.0.4'],
]);
$cluster->connect('test');
$uuid = '00000000-0000-0000-0000-000000000000';
$response = $cluster->query('
SELECT *
FROM example
WHERE id = :id
',[
'id' => new \Tatikoma\React\Cassandra\Type\UUID($uuid),
]);
print "got " . count($response->results) . " rows:\n";
foreach($response as $row){
var_dump($row);
}
Wallogit.com
Tatikoma