使用datastax java驱动程序无法通过cassandra检索UDT密钥

Question

我试图用cassandra将用户定义类型中的对象存储为分区键。我正在使用datastax java驱动程序进行对象映射，虽然我能够插入到数据库中，但我无法检索该对象。如果我更改分区键以使用非udt（例如文本），我可以保存并检索（即使对象上存在其他相同类型的udt）。从阅读文档看来，UDTs被允许作为键。我也一直无法找到任何迹象表明java驱动程序不支持udts作为键。它看起来像在对象映射期间失败，但只有当UDT是分区键时才失败。

这是一个不受支持的功能？使用对象映射器时，是否需要仅使用默认类型作为键？或者我只是做错了什么？

下面是我用于建立该数据库的CQL命令：

create keyspace example_keyspace; 
use example_keyspace; 
create type my_data_type (value text); 
create table my_classes (key frozen<my_data_type>, value frozen<my_data_type>, primary key (key)); 

这里是我曾经尝试插入java代码和检索：

package me.example; 

import com.datastax.driver.core.Cluster; 
import com.datastax.driver.mapping.Mapper; 
import com.datastax.driver.mapping.MappingManager; 
import com.datastax.driver.mapping.annotations.Frozen; 
import com.datastax.driver.mapping.annotations.PartitionKey; 
import com.datastax.driver.mapping.annotations.Table; 
import com.datastax.driver.mapping.annotations.UDT; 

public class Main { 

    public static void main(String[] args) { 
     try (Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1") 
       .build()) { 
      Mapper<MyClass> mapper = new MappingManager(cluster.newSession()) 
        .mapper(MyClass.class); 

      MyDataType value = new MyDataType(); 
      value.setValue("theValue"); 

      MyDataType key = new MyDataType(); 
      key.setValue("theKey"); 

      MyClass myClass = new MyClass(); 
      myClass.setKey(key); 
      myClass.setValue(value); 

      mapper.save(myClass); 

      MyClass toret = mapper.get(key); 
      System.out.println(toret.getKey()); 
      System.out.println(toret.getValue().getValue()); 
     } 
    } 

    @Table(keyspace = "example_keyspace", name = "my_classes") 
    public static class MyClass { 
     @PartitionKey 
     @Frozen 
     private MyDataType key; 

     @Frozen 
     private MyDataType value; 

     public MyDataType getKey() { 
      return key; 
     } 

     public void setKey(MyDataType key) { 
      this.key = key; 
     } 

     public MyDataType getValue() { 
      return value; 
     } 

     public void setValue(MyDataType value) { 
      this.value = value; 
     } 

    } 

    @UDT(keyspace = "example_keyspace", name = "my_data_type") 
    public static class MyDataType { 

     private String value; 

     public String getValue() { 
      return value; 
     } 

     public void setValue(String value) { 
      this.value = value; 
     } 

     @Override 
     public int hashCode() { 
      final int prime = 31; 
      int result = 1; 
      result = prime * result + ((value == null) ? 0 : value.hashCode()); 
      return result; 
     } 

     @Override 
     public boolean equals(Object obj) { 
      if (this == obj) { 
       return true; 
      } 
      if (obj == null) { 
       return false; 
      } 
      if (!(obj instanceof MyDataType)) { 
       return false; 
      } 
      MyDataType other = (MyDataType) obj; 
      if (value == null) { 
       if (other.value != null) { 
        return false; 
       } 
      } else if (!value.equals(other.value)) { 
       return false; 
      } 
      return true; 
     } 
    } 

} 

甲选择显示对象是插入成功：

select * from my_classes; 

收益率：

 key    | value 
-------------------+--------------------- 
{value: 'theKey'} | {value: 'theValue'} 

但我的日食控制台输出错误：

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder". 
SLF4J: Defaulting to no-operation (NOP) logger implementation 
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details. 
Exception in thread "main" com.datastax.driver.core.exceptions.InvalidTypeException: Invalid value for CQL type frozen<example_keyspace.my_data_type>, expecting class com.datastax.driver.core.UDTValue but class me.example.Main$MyDataType provided 
    at com.datastax.driver.core.DataType.serialize(DataType.java:619) 
    at com.datastax.driver.mapping.Mapper.getQuery(Mapper.java:320) 
    at com.datastax.driver.mapping.Mapper.get(Mapper.java:342) 
    at me.example.Main.main(Main.java:31) 

我也使用UDTValue对象为重点，以检索对象试过，但我仍然得到同样的错误。

我在OS X 10.10.4上运行cassandra 2.1.7。 Java版本是1.8.0_45。 Datastax Java驱动程序核心和映射器是2.1.6版本。

谢谢！

Answer 1

这是驱动程序中的错误。我们在问题跟踪器中创建了JAVA-831。

在此期间，您可以使用以下解决方法：

MappingManager manager = new MappingManager(cluster.newSession()); 
UDTMapper<MyDataType> myDataTypeMapper = manager.udtMapper(MyDataType.class); 

UDTValue keyAsUDTValue = myDataTypeMapper.toUDT(key); 
MyClass toret = mapper.get(keyAsUDTValue);