2017-02-17 7 views
0

私はKundera-CassandraとKundera-Cassandra-ds-driverをバージョン3.7で使用しています。 HはCassandraに永続化されるネストされたオブジェクト構造を持っています。DatunderのDS-Driverを使ったKunderaは "フィールド"がUDTで定義されているフィールドではないと不平を言います

オブジェクトは正しく永続化され、find()は正しい結果を返します。 しかし、単純なクエリを実行すると、 "ava.lang.IllegalArgumentException:このUDTで定義されたフィールドではありません"が返されます。

Query query = em.createQuery("Select p from Person p", Person.class); 
    List<Person> persons = query.getResultList(); 

Person.java

@Entity 
    @Table(name = "PERSON") 
    public class Person implements Serializable { 

     @Id 
     @Column 
     public String personId; 

     @Embedded 
     public Name name; 

     @ElementCollection 
     public List<Address> addresses = new ArrayList<Address>(); 

     @Column 
     public int age; 
    } 

Name.java

@Embeddable 
    public class Name implements Serializable { 
     @Column 
     public String firstName; 
     @Column 
     public String lastName; 
    } 

Address.java

9:11:16.834 [main] INFO com.impetus.kundera.query.QueryImpl - On getResultList() executing query: Select p from Person p 
    09:11:16.834 [main] DEBUG c.i.client.cassandra.query.CassQuery - Populating entities for Cassandra query Select p from Person p. 
    Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 2.219 sec <<< FAILURE! - in com.abc.KunderaTest 
    test(com.abc.KunderaTest) Time elapsed: 2.101 sec <<< ERROR! 
    java.lang.IllegalArgumentException: lastName is not a field defined in this UDT 
      at com.datastax.driver.core.UDTValue.getAllIndexesOf(UDTValue.java:49) 
      at com.datastax.driver.core.AbstractData.getIndexOf(AbstractData.java:66) 
      at com.datastax.driver.core.AbstractGettableData.isNull(AbstractGettableData.java:55) 
      at com.impetus.kundera.client.cassandra.dsdriver.DSClientUtilities.setBasicValue(DSClientUtilities.java:459) 
      at com.impetus.kundera.client.cassandra.dsdriver.DSClientUtilities.setUDTValue(DSClientUtilities.java:431) 
      at com.impetus.kundera.client.cassandra.dsdriver.DSClientUtilities.assign(DSClientUtilities.java:393) 
      at com.impetus.kundera.client.cassandra.dsdriver.DSClient.iteratorColumns(DSClient.java:909) 
      at com.impetus.kundera.client.cassandra.dsdriver.DSClient.populateObjectFromRow(DSClient.java:803) 
      at com.impetus.kundera.client.cassandra.dsdriver.DSClient.iterateAndReturn(DSClient.java:792) 
      at com.impetus.kundera.client.cassandra.dsdriver.DSClient.executeQuery(DSClient.java:531) 
      at com.impetus.client.cassandra.query.CassQuery.populateEntities(CassQuery.java:146) 
      at com.impetus.kundera.query.QueryImpl.fetch(QueryImpl.java:1377) 
      at com.impetus.kundera.query.QueryImpl.getResultList(QueryImpl.java:200) 
      at com.impetus.kundera.query.KunderaTypedQuery.getResultList(KunderaTypedQuery.java:250) 

ここで私が実行していたクエリがあります

@Embeddable 
    public class Address implements Serializable { 
     @Column 
     public String city; 
     @Column 
     public String country; 
    } 

カサンドラCQLSH作成したテーブルの上:

CREATE TYPE mykeyspaces."Address" (
     country text, 
     city text 
    ); 

    CREATE TYPE mykeyspaces."Name" (
     "firstName" text, 
     "lastName" text 
    ); 

    CREATE TABLE mykeyspaces."PERSON" (
     "personId" text PRIMARY KEY, 
     addresses list<frozen<"Address">>, 
     age int, 
     name frozen<"Name"> 
    ) 

物事はDS-ドライバーで倹約して正常に動作しなく。 私に何かが不足している場合はお知らせください。

ありがとうございます!

答えて

0

コードをデバッグしましたが、これはdatastaxドライバのバグです。

バグ:case-sensitive

あなたは今のところ回避策としてfirstnamelastnameのようなものを使用することができるとフェッチUDT列。

@Embeddable 
public class Name implements Serializable { 
    @Column(
    public String firstname; 
    @Column 
    public String lastname; 
} 
:作品に続き

関連する問題