在 cassandra 中处理分页结果

Question

我正在查看 this 。但无法弄清楚它是如何工作的。我的期望是当我会做session_execute 它会给我10 行fetch_size=10。

query = "SELECT * FROM users where region_code=1"
statement = SimpleStatement(query, fetch_size=10)
for user_row in session.execute(statement):
    print(user_row)
    print('*'*100)

它只给我单行。我在这里缺少什么。我想让它成为paginated api

Answer 1

如果您使用SELECT * FROM users where region_code=1 LIMIT 10，它将获取 10 条记录。如果你使用SELECT * FROM users where region_code=1 获取大小为 10，它将通过一次抓取 10 的所有匹配行进行分页。在您的 for 循环消耗 10 行后，它将进行另一个阻塞查询以自动获取下一个 10。