Skip to content

Commit

Permalink
use batch_mutate instead of batch_insert which is deprecated
Browse files Browse the repository at this point in the history
  • Loading branch information
hoan committed Jul 11, 2010
1 parent 490098b commit 2396fb9
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 3 deletions.
3 changes: 2 additions & 1 deletion README
Expand Up @@ -78,4 +78,5 @@ AUTHORS:
* Zach Buller (zachbuller@gmail.com) * Zach Buller (zachbuller@gmail.com)
* Timandes * Timandes
* Todd Zusman * Todd Zusman

* Yancho Georgiev (yancho@inspirestudio.net)
* Pieter Maes (maescool@gmail.com)
15 changes: 13 additions & 2 deletions phpcassa.php
Expand Up @@ -216,10 +216,10 @@ public function insert($key, $columns) {
$timestamp = CassandraUtil::get_time(); $timestamp = CassandraUtil::get_time();


$cfmap = array(); $cfmap = array();
$cfmap[$this->column_family] = $this->array_to_supercolumns_or_columns($columns, $timestamp); $cfmap[$key][$this->column_family] = $this->array_to_mutation($columns, $timestamp);


$client = CassandraConn::get_client(); $client = CassandraConn::get_client();
$resp = $client->batch_insert($this->keyspace, $key, $cfmap, $this->write_consistency_level); $resp = $client->batch_mutate($this->keyspace, $cfmap, $this->write_consistency_level);


return $resp; return $resp;
} }
Expand Down Expand Up @@ -318,6 +318,17 @@ public function columns_to_array($array_of_c) {
} }


// Helpers for turning PHP arrays into Cassandra's thrift objects // Helpers for turning PHP arrays into Cassandra's thrift objects
public function array_to_mutation($array, $timestamp=null) {
$c_or_sc = $this->array_to_supercolumns_or_columns($array, $timestamp);
$ret = null;
foreach($c_or_sc as $row) {
$mutation = new cassandra_Mutation();
$mutation->column_or_supercolumn = $row;
$ret[] = $mutation;
}
return $ret;
}

public function array_to_supercolumns_or_columns($array, $timestamp=null) { public function array_to_supercolumns_or_columns($array, $timestamp=null) {
if(empty($timestamp)) $timestamp = CassandraUtil::get_time(); if(empty($timestamp)) $timestamp = CassandraUtil::get_time();


Expand Down

0 comments on commit 2396fb9

Please sign in to comment.