私は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-ドライバーで倹約して正常に動作しなく。 私に何かが不足している場合はお知らせください。
ありがとうございます!