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 ドキュメントを読み、この Rows オブジェクトを使用して$session->execute return Cassandra\Rowsを実行することを知っています。

どんな助けや情報も大歓迎です...

更新:

答えに基づいて、動作するコード サンプル

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';
}
4

1 に答える 1

2

execute メソッドを で囲みtry catchます。クエリが失敗した場合、execute メソッドは例外をスローします。この例外は、アプリケーションで確認できます。

詳細については、 Session.Executeを参照してください。

于 2016-06-17T11:00:50.330 に答える