我将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列
您现在可以将firstname
,lastname
之类的东西用作解决方法。
以下工作:
@Embeddable
public class Name implements Serializable {
@Column(
public String firstname;
@Column
public String lastname;
}