首页 文章

Datastax Cassandra PHP驱动程序:如何知道CQL INSERT,UPDATE,DELETE是否成功

提问于
浏览
1

我正在使用Datastax php-driver在我的cassandra上运行CQL . 我使用INSERT,UPDATE,DELETE操作 .

下面是我为插入运行的示例代码

$cluster = Cassandra::cluster()
                ->withContactPoints('54.XX.XX.XX', '54.XX.XX.XX','54.XX.XX.XX')
                ->withDefaultConsistency(4)
                ->build();

        $session = $cluster->connect('Sample_Key_Space');
        $statement = new Cassandra\SimpleStatement('insert_query');
        $result = $session->execute($statement);

我的问题是,如何知道插入(或更新,删除)是成功的 . 我已经阅读了Datastax文档并知道 $session->execute 返回 Cassandra\Rows ,使用此Rows对象“ How to judge my CQL is successful or Failed? ” .

任何帮助或输入都非常感谢...

更新:

根据答案,工作代码样本

try {
$cluster = Cassandra::cluster()
            ->withContactPoints('54.XX.XX.XX')
            ->withDefaultConsistency(4)
            ->build();

    $session = $cluster->connect('school');

    $statement = new Cassandra\SimpleStatement("UPDATE1 activities SET activity_by = 'nagarajan' WHERE master_id = 12 AND activity_type='Hello' AND activity_id=10");
$result = $session->execute($statement);
return true;
} catch (Cassandra\Exception $e $e) {
    return 'failed';
}

1 回答

  • 2

    try catch 包围execute方法 . 如果查询失败,则execute方法抛出异常,您可以在应用程序中检查该异常 .

    有关详细信息,请访问Session.Execute .

相关问题