Datastax Cassandra PHP 驱动程序:如何知道 CQL INSERT、UPDATE、DELETE 是否成功
Datastax Cassandra PHP Driver : How to know CQL INSERT,UPDATE,DELETE are Successful
我在我的 cassandra 上使用 Datastax php-驱动程序到 运行 CQL。我使用 INSERT,UPDATE,DELETE 操作。
下面是示例代码 I 运行 for insert
$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 return Cassandra\Rows,使用此 Rows 对象“如何判断我的CQL成功还是失败?".
非常感谢任何帮助或意见...
更新:
基于答案,工作代码样本
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';
}
用 try catch
包围执行方法。
如果查询失败,execute 方法会抛出异常,您可以在您的应用程序中查看。
更多详情请访问
Session.Execute.
我在我的 cassandra 上使用 Datastax php-驱动程序到 运行 CQL。我使用 INSERT,UPDATE,DELETE 操作。
下面是示例代码 I 运行 for insert
$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 return Cassandra\Rows,使用此 Rows 对象“如何判断我的CQL成功还是失败?".
非常感谢任何帮助或意见...
更新:
基于答案,工作代码样本
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';
}
用 try catch
包围执行方法。
如果查询失败,execute 方法会抛出异常,您可以在您的应用程序中查看。
更多详情请访问 Session.Execute.