cassandra — драйвер CQL PHP: недопустимый тип значения в подготовленном операторе с хорошими значениями

Я новичок в Кассандре. Я использую драйвер Cassandra PHP от Datastax. Я пытаюсь создать пакетную инструкцию с несколькими вставками. Учитывая модель стола:

CREATE TABLE real_time_log (
du_id int,
tag_id int,
status int,
time_stamp bigint,
value float,
PRIMARY KEY ((du_id, tag_id), status, time_stamp)
)

Я пытаюсь вставить следующие значения двумя способами:

$batch = new Cassandra\BatchStatement();
$stmt = $this->cassandraDb->prepare('insert into real_time_log'
. ' (du_id, tag_id, status, time_stamp, value) '
. 'VALUES (?, ?, ?, ?, ?)');
foreach ($curData as $cData) {
$values = explode(',', $cData);
$stmtValues = array(
'du_id' => 11111,
'tag_id' => 22222,
'status' => (int) $values[2],
'time_stamp' => new Cassandra\Bigint($values[0]),
'value' => (double) $values[1]
);
$batch->add($stmt, $stmtValues);
}
$this->cassandraDb->executeAsync($batch);

Это приводит к ошибке:

PHP Fatal error:  Uncaught exception 'Cassandra\Exception\InvalidArgumentException' with message 'Invalid value type'

Между тем я попробовал более прямой подход без готовых заявлений:

$batch = new Cassandra\BatchStatement();
foreach ($curData as $cData) {
$values = explode(',', $cData);
$stmtValues = array(
11111,
22222,
(int) $values[2],
new Cassandra\Bigint($values[0]),
(double) $values[1]
);
$batch->add(new Cassandra\SimpleStatement('insert into real_time_log'
. ' (du_id, tag_id, status, time_stamp, value) '
. 'VALUES (' . implode(',', $stmtValues) . ')'));
}
$this->cassandraDb->executeAsync($batch);

Таким образом, все работает, но это будет намного медленнее.
Может быть, кто-то может объяснить, что не так с готовым подходом заявления, который я делаю?

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

0

Решение

На первый взгляд похоже, что он должен работать — вы пытались явно передать его float ( менять (double) $values[1] в new Cassandra\Float($values[1]) )?

1

Другие решения

Я выполнил это для вставки одной строки, и она работает нормально:

$glid = 12345;
$modid = 'mobile';
$sysdate = date("YmdHis");

$sql = "insert into user (USR_ID,modid,membersince) values (?,?,?)";
$par = array(new Cassandra\Bigint($glid),$modid,new Cassandra\Bigint($sysdate));

$statement = $db->prepare($sql);
$db->execute($statement, array(
'arguments' => $par
));
0