Kundera с Datastax DS-Driver жалуется, что «поле» не является полем, определенным в UDT

Question

Я использую Kundera-Cassandra с Kundera-Cassandra-ds-драйвером, как с версией 3.7. H имеет структуру вложенных объектов, которая сохраняется в Cassandra.

Объект сохраняется правильно, и find() возвращает правильный результат. Однако при запуске простого запроса он возвращает «ava.lang.IllegalArgumentException: не поле, определенное в этом UDT».

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) 

Вот запрос я бегу:

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

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

Cassandra 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-драйвером. Пожалуйста, дайте мне знать, если мне что-то не хватает.

Спасибо!

Answer 1

Я отлаживал код, и это кажется ошибкой в ​​драйвере datastax.

Ошибка: Fetching UDT колонны с case-sensitive именами

Вы можете использовать что-то вроде firstname, lastname как обходной путь на данный момент.

следующие работы:

@Embeddable 
public class Name implements Serializable { 
    @Column(
    public String firstname; 
    @Column 
    public String lastname; 
}