如何使用java中的cassandra驱动程序从UDT集合（例如：list）中读取UDT？

Question

我有表emp（id，name，list

线程“main”com中出现异常。数据税。驾驶员果心例外情况。CodeNotFoundException:找不到请求操作的编解码器：[已冻结]

String query1="select * from iotbilling.emp where id=?";
PreparedStatement preparedStatement2=this.session.prepare(query1);
BoundStatement boundStatement2=preparedStatement2.bind(4);
ResultSet rs2=this.session.execute(boundStatement2);
Row row2=rs2.one();
List<address> addresses=row2.getList("adresses",address.class);
System.out.println("Addresses retrieved");
for(address adr:addresses)
    System.out.println(adr.toString());

'

这里，如何在java代码中捕获从cassandra返回的冻结地址列表？




Answer 1

为此，您可能需要使用datastax映射器。您必须使用Datastax注释声明Java表和类型表，如下所示：

    @Table(keyspace = "corporate", name = "emp")
     public class Employee{

          @PartitionKey(0)
          @Column(name = "id")
           private Integer id;

          @Column(name = "name")
           private String name;

          @Frozen
          @Column(name = "address_list")
          private List<Address> address;

          ...(Getter and Setters)
     }

您的UDT注释如下：

     @UDT(keyspace = "corporate", name="address")
     public class Address{

          @Field(name="hno")
          private Integer hno;

          @Field(name="street")
          private String street;

          ...(Getters and Setters)
     }

如果没有，您可能希望事先将以下依赖项添加到pom.xml文件中

    <dependency>
        <groupId>com.datastax.cassandra</groupId>
        <artifactId>cassandra-driver-core</artifactId>
        <version>3.3.0</version>
    </dependency>
    <dependency>
        <groupId>com.datastax.cassandra</groupId>
        <artifactId>cassandra-driver-mapping</artifactId>
        <version>3.3.0</version>
    </dependency>

完成这些步骤后，您需要使用Mapper对象来获得结果：

    MappingManager manager = new MappingManager(this.session);
    Mapper<Employee> mapper = manager.mapper(Employee.class);

一旦你得到结果集使用映射器得到：

    Result<Employee> list = mapper.map(rs2);
    Employee emp = list.one();

现在您可以作为java对象访问emp并使用emp。获取访问列表的地址。

Answer 2

您可以从行读取值并逐行读取元数据：

UDTValue udtData = row.getUDTValue(address);

例如：

udtData.getString("name");

用列表示例更新

对于列表，它可能如下所示：

List<UDTValue> udtDataList = row.getList("adresses", UDTValue.class)

然后，您可以轻松地遍历列表并访问数据字段。

最好的