使用datastax驱动程序，如何将非基本列读取为JSON字符串？

Question

我的cassandra表中有几个非基元列。其中一些是用户定义类型的UDT。

在通过datastax驱动程序查询它们时，我想将这些UDT转换为JSON值。更具体地说，我想为下面的value对象获取JSON字符串：

        Row row = itr.next();
        ColumnDefinitions cds = row.getColumnDefinitions();
        cds.asList().forEach((ColumnDefinitions.Definition cd) -> {
            String name = cd.getName();
            Object value = row.getObject(name);
      }

我经历过http://docs.datastax.com/en/developer/java-driver/3.1/manual/custom_codecs/

但我不想为我所有的UDT添加一个编解码器。

考虑到使用Datastax Java驱动程序以JSON形式查询行，我也尝试了以下方法：

row.getString(name)

但它给了我一个错误：Codec找不到请求的操作：[set

驱动程序能在不显式干预编解码器的情况下直接返回JSON吗？




Answer 1

使用toJson方法

从Apache Cassandra™的2.2版开始，toJson方法返回对象的json表示形式。

例子：

CREATE TYPE fullname (
    firstname text,
    lastname text
);

CREATE TABLE users (
    id uuid PRIMARY KEY,
    direct_reports set<frozen<fullname>>,
    name frozen<fullname>
);

现在，您可以选择direct_reports并将其命名为json

SELECT id,toJson(direct_reports) as direct_reports,toJson(name) as name FROM users ;

这里我将toJson（direct_reports）asdirect_reports和toJson（name）重命名为name，这样您就可以使用行了。getString（“直接报告”）和行。getString（“name”）获取直接报告json和名称json。

输出：

 id                  | 62c36092-82a1-3a00-93d1-46196ee77204
 direct_reports      | [{"firstname": "Naoko", "lastname": "Murai"}, {"firstname": "Sompom", "lastname": "Peh"}]
 name                | {"firstname": "Marie-Claude", "lastname": "Josset"}