我正在关注Datastax网站上的Cassandra java对象映射器教程。
并在定义访问者时
@Query("SELECT * FROM testks.user ")
Result<User> getAll();
运行此查询给我一个
com.datastax.driver.core.exceptions.InvalidQueryException: Some partition key parts are missing: id
环顾四周似乎无法在不提供分区键的情况下查询cassandra。是这样的吗?这似乎是一个奇怪的要求。如果我想要选择所有查询,我该怎么做?
该表定义为
CREATE TABLE testks.user (
id text PRIMARY KEY,
name text
)
你没有提供很多细节。如果您按照以下步骤操作,则不应出现任何错误
您应该定义如下的用户模型
user.Java
@Table(name = "user")
public class User {
@PartitionKey
private String id;
private String name;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
@Override
public String toString() {
return "User{" + "id=" + id + ", name=" + name + '}';
}
}
和存储库如下
user access or.Java
@Accessor
public interface UserAccessor {
@Query("SELECT * FROM user")
Result<User> getAll();
}
以下是如何使用存储库的方法
main.Java
public static void main(String[] args) {
try (Cluster cluster = Cluster.builder().addContactPoints("127.0.0.1").withCredentials("cassandra", "cassandra").build(); Session session = cluster.connect("test")) {
MappingManager manager = new MappingManager(session);
UserAccessor userAccessor = manager.createAccessor(UserAccessor.class);
System.out.println(userAccessor.getAll().all());
}
}