Datastax Cassandra Java驱动程序4分页问题

Question

我需要以分页的方式从cassandra数据库表中获取结果。我使用的是spring引导版本2.3.1，它反过来使用cassandra java驱动程序4。在以前的驱动程序版本中，在分页时，没有问题，驱动程序用来获取与指定页面大小相等的结果，如下所示：

Where select = QueryBuilder.select("column1", "column2", "column3")
    .from("my_table")
    .where(QueryBuilder.eq("column4", "some_value"))
    .and(QueryBuilder.eq("column5", "some_value"));

select.setFetchSize(5);

if (!page.equals("0"))
    select.setPagingState(PagingState.fromString(page));
ResultSet results = cassandraTemplate.getCqlOperations().queryForResultSet(select);
PagingState nextPage = results.getExecutionInfo().getPagingState();
int remaining = results.getAvailableWithoutFetching(); // gives 5 results as specified

在4中，该方法已从setFetchSize(int)更改为setPageSize(int)。但同样的事情在这里不起作用。即使在指定了大小之后，它也会获取所有结果：

SimpleStatement stmt = QueryBuilder.selectFrom("my_keyspace", "my_table")
    .columns(Arrays.asList("column1", "column2", "column3"))
    .where(Relation.column("column4")
             .isEqualTo(QueryBuilder.literal("some_value")),
           Relation.column("column5")
             .isEqualTo(QueryBuilder.literal("some_value))).build();

stmt.setPageSize(5);
if (!page.equals("0"))
    stmt.setPagingState(Bytes.fromHexString(page));

ResultSet results = cassandraTemplate.getCqlOperations().queryForResultSet(stmt);
ByteBuffer nextPage = results.getExecutionInfo().getPagingState();
int remaining = results.getAvailableWithoutFetching(); // gives all the results, even though size is specified as 5

我做错了什么吗？如果我不是，那么该如何解决这个问题呢？

Answer 1

驱动程序4中的语句是不可变的。您需要更改以下行：

stmt = stmt.setPageSize(5);
if (!page.equals("0"))
    stmt = stmt.setPagingState(Bytes.fromHexString(page));

IOW，每个变异方法都返回一个新实例，因此您需要通过每次重新分配stmt变量来捕获该实例。