• 主页
  • 如何使用CassandraRepository与Spring Data、Cassandra和Spring Boot一起查询Cassandra?

如何使用CassandraRepository与Spring Data、Cassandra和Spring Boot一起查询Cassandra?

我的Cassandra集群中有一个使用以下命令构建的表:

CREATE KEYSPACE IF NOT EXISTS activitylogs WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '1'}  AND durable_writes = true;

CREATE TABLE IF NOT EXISTS activitylogs.activities2 (
    activity_id timeuuid,
    actor_id text,
    app_id text,
    item_id text,
    viewer_id text,
    activity_type int,
    ts timestamp,
    PRIMARY KEY (actor_id, activity_id, app_id)
) WITH CLUSTERING ORDER BY (activity_id DESC, app_id ASC);

下面是我在Spring Project中的Repository:

public interface ActivityRepository extends CassandraRepository<Activity> {

@Query("SELECT actor_id FROM activities2 WHERE actor_id='actorA'")
Iterable<Activity> findByActor_Id(String actor_Id);
}

现在,当我访问与这个查询检索器关联的端点时,我得到以下错误:

Invalid null value in condition for column actor_id
at com.datastax.driver.core.Responses$Error.asException(Responses.java:136)

然而,当我在CQLSHell中运行等效的CQL命令时,我得到了我正在查找的确切行……

为什么会发生这种情况?

转载请注明出处:http://www.xjzlzx.com/article/20230530/1605308.html