Cassandra .setFetchSize() on 语句不被接受

Question

我想在UI上实现分页，所以我这样设置fetchSize：

boundStatement.setFetchSize(20)

但是 setFetchSize() 不被接受。我的 table 截至目前有 400 行，并且检索了所有 400 行。当我使用

检索下一组行时

rs.getExecutionInfo().getPagingState();

然后检索接下来的 380 行。因此分页状态已正确设置和检索，但为什么驱动程序从 table 检索所有 400 行，我如何避免这种情况或使其仅检索 400

部分代码：

....
....

// "SELECT * FROM abc.sometable"
BoundStatement boundStatement = pStmt.bind();
boundStatement.setFetchSize(20);

if (pagingState != null) {
  boundStatement.setPagingState(PagingState.fromString(pagingState));
}
ResultSet rs = session.execute(boundStatement);
PagingState nextPage = rs.getExecutionInfo().getPagingState();
int remaining = rs.getAvailableWithoutFetching();
List<?> list = new ArrayList<>();
for (Row row : rs) {
  list.add(getValidObjectFromRow(row));
}
 ....

Cassandra 版本 - 3.7 和 cassandra 驱动程序版本 - 3.1.0

谢谢！

Answer 1

setFetchSize 控制页面大小，但不控制 ResultSet.

中返回的最大行数

for (Row row : rs) {
    list.add(getValidObjectFromRow(row));
}

在您的示例代码的上述代码中，它将遍历前 20 行，当它到达当前结果的末尾时，它将获取更多行，直到没有更多行匹配查询。

如果您想限制返回的行数，您有几个选择。

将 LIMIT X（其中 x 是您想要的行数）添加到查询的末尾。
只迭代直到没有更多的行，即：

while(rs.getAvailableWithoutFetching() > 0) {
    list.add(getValidObjectFromRow(rs.one()));
}

这将从 ResultSet 开始读取，直到页面中不再有行，此时它将停止迭代。

Cassandra .setFetchSize() on 语句不被接受

Cassandra .setFetchSize() on statement is not honoured

java

cassandra

datastax-java-driver