пакетная мутация phpcassa cassandra - PullRequest
1 голос
/ 11 января 2012

Можете ли вы привести пример функции batch_mutate () в phpcassa?

Не могу понять, как работать с этой функцией, и не нашел достаточно информации.

Также я хочу знать, как использовать его со счетчиками

Заранее спасибо.

Ответы [ 2 ]

3 голосов
/ 02 февраля 2012

«удалить данные из нескольких ключей»:

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));
2 голосов
/ 12 января 2012
  1. batch_mutate для счетчиков пока недоступно с PHPCassa: https://github.com/thobbs/phpcassa/issues/31
  2. batch_mutate в действии, согласно учебнику: http://thobbs.github.com/phpcassa/tutorial.html

«вставка данных»:

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