CQL 中语句的 PagingState

Question

我试图了解 PagingState 如何与 Cassandra 中的 Statement 一起使用。我尝试使用将几 1000 条记录插入数据库的示例，并尝试从数据库中读取相同的数据，并将获取大小设置为 10 并使用分页状态。这工作得很好。这是我的示例junit代码：

@Before
public void setup() {
    cassandraTemplate.executeQuery("create table if not exists pagesample(a int, b int, c int, primary key(a,b))");
    String insertQuery = "insert into pagesample(a,b,c) values(?,?,?)";
    PreparedStatement insertStmt = cassandraTemplate.getConnection().prepareStatement(insertQuery);
    for(int i=0; i < 5; i++){
        for(int j=100; j<1000; j++){
            cassandraTemplate.executeQuery(insertStmt, new Object[]{i, j, RandomUtils.nextInt()});
        }
    }
}

@Test
public void testPagination() {
    String selectQuery = "select * from pagesample where a=?";
    String pagingStateStr = null;
    for(int run=0; run<90; run++){
        ResultSet resultSet = selectRows(selectQuery, 10, pagingStateStr, 1);
        int fetchedCount = resultSet.getAvailableWithoutFetching();
        System.out.println(run+". Fetched size: "+fetchedCount);
        for(Row row : resultSet){
            System.out.print(row.getInt("b")+", ");
            if(--fetchedCount == 0){
                break;
            }
        }
        System.out.println();

        PagingState pagingState = resultSet.getExecutionInfo().getPagingState();
        pagingStateStr =  pagingState.toString();
    }
}

public ResultSet selectRows(String cql, int fetchSize, String pagingState, Object... bindings){
    SimpleStatement simpleStatement = new SimpleStatement(cql, bindings);
    statement.setFetchSize(fetchSize);
    if(StringUtils.isNotEmpty(pagingState)){
        statement.setPagingState(PagingState.fromString(pagingState));
    }
    return getSession().execute(simpleStatement);
}

当我执行这个程序时，我看到 testPagination 中的每次迭代都准确地打印了 10 条记录。但这是文档所说的：

• 请注意，设置获取大小并不意味着 Cassandra 将 总是返回确切的行数，有可能它 返回或多或少的结果。

我不太明白为什么 Cassandra 返回的行数与 fetch size 中指定的行数不完全相同。当查询中没有提供 where 子句时，是否会出现这种情况？当查询受限于分区键时，它会返回确切数量的记录吗？请澄清。

Answer 1

来自CQL protocol specification：

客户也不应该断言没有结果会超过result_page_size 结果。虽然当前实现始终尊重 result_page_size 的确切值，我们保留在未来出于性能原因返回稍微更小或更大的页面的权利

因此，最好始终依赖 getAvailableWithoutFetching 而不是页面大小，以防 Cassandra 将来更改其实现。