我的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