Kundera 和 Cassandra 单元问题 - 字符串作为主键

Question

我有一个 kundera 模型实体，它以 String 作为 Id。它是这样定义的。

@Id
private String id;

我有一个方法可以像这样执行本机查询。

/**
     * @param requestId
     * @return
     */
    public static ProcessRequest getRequest(Serializable requestId) {
        List<ProcessRequest> requests = execute("SELECT * from
            process_requests where id = '" + requestId + "';");
        return requests.isEmpty() ? null : requests.get(0);
    }

当运行像这样进行单元测试时，我收到以下异常。

17:50:38.716 [main] ERROR c.i.c.cassandra.CassandraClientBase - Error during executing query SELECT * from process_requests where id = '5b4468e0-6146-4fbc-81cf-571371834446';, Caused by: {} .
com.impetus.kundera.KunderaException: InvalidRequestException(why:Undefined name id in where clause ('id EQ '5b4468e0-6146-4fbc-81cf-571371834446''))
    at com.impetus.client.cassandra.CassandraClientBase.execute(CassandraClientBase.java:2101) [kundera-cassandra-2.14.jar:na]
    at com.impetus.client.cassandra.CassandraClientBase.executeCQLQuery(CassandraClientBase.java:1708) [kundera-cassandra-2.14.jar:na]
    at com.impetus.client.cassandra.CassandraClientBase$CQLClient.executeQuery(CassandraClientBase.java:1851) [kundera-cassandra-2.14.jar:na]
    at com.impetus.client.cassandra.CassandraClientBase.executeSelectQuery(CassandraClientBase.java:761) [kundera-cassandra-2.14.jar:na]
    at com.impetus.client.cassandra.thrift.ThriftClient.executeQuery(ThriftClient.java:860) [kundera-cassandra-2.14.jar:na]
    at com.impetus.client.cassandra.query.CassQuery.populateEntities(CassQuery.java:143) [kundera-cassandra-2.14.jar:na]
    at com.impetus.kundera.query.QueryImpl.fetch(QueryImpl.java:1013) [kundera-core-2.14.jar:na]
    at com.impetus.kundera.query.QueryImpl.getResultList(QueryImpl.java:164) [kundera-core-2.14.jar:na]

即使有id定义的column，也报这个异常，求助无果，无法解决。你能帮忙解决这个问题吗？

更新：

CREATE TABLE docyard.process_requests (
id text PRIMARY KEY,
content_type text,
created_at timestamp,
document_id text,
lock bigint,
lock_expiration timestamp,
namespace text,
process_input text,
process_output text,
processed text,
updated_at timestamp,
version_id text
) WITH bloom_filter_fp_chance = 0.01
AND caching = '{"keys":"ALL", "rows_per_partition":"NONE"}'
AND comment = ''
AND compaction = {'min_threshold': '4', 'class':           'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy',       'max_threshold': '32'}
AND compression = {'sstable_compression': 'org.apache.cassandra.io.compress.LZ4Compressor'}
AND dclocal_read_repair_chance = 0.1
AND default_time_to_live = 0
AND gc_grace_seconds = 864000
AND max_index_interval = 2048
AND memtable_flush_period_in_ms = 0
AND min_index_interval = 128
AND read_repair_chance = 0.0
AND speculative_retry = '99.0PERCENTILE';
CREATE INDEX process_requests_lock_idx ON docyard.process_requests  (lock);
CREATE INDEX process_requests_processed_idx ON docyard.process_requests (processed);

Answer 1

如果您使用 CQL2 创建您的架构，将创建具有任何名称的主键列，名称为 'key'。

如果您使用 createQuery 或 findById，这将由 Kundera 处理。由于您正在使用 native query 将 where id = ... 更改为 where key = ...

PS：与昆德拉一起工作时，首选CQL3。您可以参考 this 了解有关 CQL3 的更多信息。

Kundera 和 Cassandra 单元问题 - 字符串作为主键

Kundera and Cassandra unit issue - String as primary key

cassandra

kundera