带有Datastax DS-Driver的昆德拉抱怨"field"不是UDT中定义的字段



我将Kundera-Cassandra与Kundera-Cassandra-ds-Driver一起使用,均为版本3.7。H具有嵌套的对象结构,要持续到Cassandra中。

对象正确持续,并找到()返回正确的结果。但是,运行简单查询时,它会返回" ava.lang.illegalgumentException:不是此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驱动器无关。请让我知道我是否缺少任何东西。

谢谢!

我已经调试了代码,这似乎是dataStax驱动程序中的错误。

bug:case-sensitive名称获取UDT列

您现在可以将firstnamelastname之类的东西用作解决方法。

以下工作:

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

最新更新