2012-01-11 3 views
1

Pouvez-vous fournir un exemple de fonction batch_mutate() dans phpcassa?phpcassa cassandra mutation par lots

Impossible de comprendre comment travailler avec cette fonction et n'a pas trouvé suffisamment d'informations.

Je veux aussi savoir comment l'utiliser avec des compteurs

Merci à l'avance.

Répondre

3

« supprimer données provenant de plusieurs clés ":

function batch_remove($key=null, $columns=null, $super_column=null, $write_consistency_level=null) { 

    $timestamp = CassandraUtil::get_time(); 
    $deletion = new cassandra_Deletion(); 
    $deletion->timestamp = $timestamp; 

    if ($super_column !== null) $deletion->super_column = $this->pack_name($super_column, true); 
    else $deletion->super_column = null; 

    if ($columns !== null) { 
     $predicate = $this->create_slice_predicate($columns, '', '', false, self::DEFAULT_COLUMN_COUNT); 
     $deletion->predicate = $predicate; 
    } 

    $mutation = new cassandra_Mutation(); 
    $mutation->deletion = $deletion; 

    if (is_array($key) && count($key) >= 1) { 

     $mut_map = array(); 
     foreach($key as $v) { 
      $packed_key[$v] = $this->pack_key($v); 
      $mut_map[$v] = array($this->column_family => array($mutation)); 
     } 

     return $this->pool->call("batch_mutate", $mut_map, $this->wcl($write_consistency_level)); 

    } else return false; 

} 

//delete name1, name2, name3 from key1, key2 in a single call 
$column_family->batch_remove(array(key1, key2), array(name1, name2, name3)); 
+0

ne sais pas comment cela est pertinent pour la question spécifique posée? – sdolgy

2
  1. batch_mutate sur les compteurs ne sont pas encore disponible avec PHPCassa: https://github.com/thobbs/phpcassa/issues/31
  2. batch_mutate en action, selon le tutoriel: http://thobbs.github.com/phpcassa/tutorial.html

"l'insertion de données":

$row1 = array('name1' => 'val1', 'name2' => 'val2'); 
$row2 = array('foo' => 'bar'); 
$column_family->batch_insert(array('row1' => $row1, 'row2' => $row2); 
+0

batch_remove fonctionne comme batch_insert? $ column_family-> batch_remove (array ($ row1, $ row2);? – Undrooleek