Как получить составной столбец из таблицы Кассандры в PHP

Question

У меня есть CassandraHandler, который получает запросы в строках

class CassandraHandler
{
    private $keyspace = 'blabla'; //default is oyvent
    private $cluster = NULL;
    private $session = NULL;

    function __construct(){
        $this->cluster   =   \Cassandra::cluster()
            ->build();       // connects to localhost by default
        $this->session   = $this->cluster->connect($this->keyspace);
    }

    /**
     * @return  Rows
     */
    public function execute($query){
        $statement = new \Cassandra\SimpleStatement($query);
        $result    = $this->session->execute($statement);  
        return $result;
    }
}

Когда я использую для обычных столбцов, это нормально, но я не могу получить мою колонку фотографий в php

Я создал столбец, как это

photos frozen<set<map<text,text>>>

мой пример JSON

{{"urllarge": "1.jpg", "urlmedium": "2.jpg"},
 {"urllarge": "3.jpg", "urlmedium": "4.jpg"}}

А вот как я могу использовать PHP для извлечения составных столбцов?

$cassandraHandler = new CassandraHandlerClass(); 
 $rows = $cassandraHandler->fetchLatestPosts($placeids, $limit);

      foreach ($rows as $row) {
          $tmp = array();
          $tmp["userid"] = doubleval($row["userid"]);
          $tmp["fullname"] = $row["fullname"];
          $tmp["photos"] = $row["photos"]  //????????
       }

Я знаю, что есть эта документация драйвера PHP https://github.com/datastax/php-driver

Но я немного запутался.. Мне просто нужно получить значение json, как я получаю в cqlsh

Answer 1

У вас есть два варианта для преобразования композитов в пригодный для использования JSON:

1. Создайте функцию для преобразования десериализованных / немаршаллированных объектов в JSON.
2. Получите значения из Кассандры как JSON.

Вот пример, который демонстрирует оба варианта:

<?php

$KEYSPACE_NAME = "stackru";
$TABLE_NAME = "retrieve_composites";

function print_rows_as_json($rows) {
    foreach ($rows as $row) {
        $set_count = 0;
        echo "{\"photos\": [";
        foreach ($photos = $row["photos"] as $photo) {
            $map_count = 0;
            echo "{";
            foreach ($photo as $key => $value) {
                echo "\"{$key}\": \"{$value}\"";
                if (++$map_count < count($photo)) {
                    echo ", ";
                }
            }
            echo "}";
            if (++$set_count < count($photos)) {
                echo ", ";
            }
        }
        echo "]}" . PHP_EOL;
    }
}

// Override default localhost contact point
$contact_points = "127.0.0.1";
if (php_sapi_name() == "cli") {
    if (count($_SERVER['argv']) > 1) {
        $contact_points = $_SERVER['argv'][1];
    }
}

// Connect to the cluster
$cluster = Cassandra::cluster()
    ->withContactPoints($contact_points)
    ->build();
$session = $cluster->connect();

// Create the keypspace (drop if exists) and table
$session->execute("DROP KEYSPACE IF EXISTS {$KEYSPACE_NAME}");
$session->execute("CREATE KEYSPACE {$KEYSPACE_NAME} WITH replication = "
    . "{ 'class': 'SimpleStrategy', 'replication_factor': 1 }"
);
$session->execute("CREATE TABLE ${KEYSPACE_NAME}.{$TABLE_NAME} ( "
    . "id int PRIMARY KEY, "
    . "photos frozen<set<map<text, text>>> )"
);

// Create a multiple rows to retrieve
$session->execute("INSERT INTO ${KEYSPACE_NAME}.{$TABLE_NAME} (id, photos) VALUES ( "
    . "1, "
    . "{{'urllage': '1.jpg', 'urlmedium': '2.jpg'}, "
    . "{'urllage': '3.jpg', 'urlmedium': '4.jpg'}}"
    . ")");
$session->execute("INSERT INTO ${KEYSPACE_NAME}.{$TABLE_NAME} (id, photos) VALUES ( "
    . "2, "
    . "{{'urllage': '21.jpg', 'urlmedium': '22.jpg'}, "
    . "{'urllage': '23.jpg', 'urlmedium': '24.jpg'}}"
    . ")");

// Select and print the unmarshalled data as JSON
$rows = $session->execute("SELECT photos FROM ${KEYSPACE_NAME}.{$TABLE_NAME}");
print_rows_as_json($rows);

// Select the data as JSON and print the string
$rows = $session->execute("SELECT JSON photos FROM ${KEYSPACE_NAME}.{$TABLE_NAME}");
foreach ($rows as $row) {
    echo $row["[json]"] . PHP_EOL;
}

Из приведенного выше примера вы можете видеть, что выбор данных в виде JSON требует меньше кода для вашего приложения, а также переносит обработку на сервер. Это, вероятно, предпочтительный выбор для ваших потребностей приложения.

ПРИМЕЧАНИЕ. В этом примере используется v1.3.0 PHP-драйвера DataStax, который добавил поддержку для передачи строк запроса напрямую Session::execute() а также Session::executeAsync(), Если вы используете более раннюю версию, вам нужно будет преобразовать все строки запроса в Cassandra\Statement объекты, прежде чем перейти к $session->execute(...),