如何使用 neo4j java driver 4.0.0 批量流式传输记录？

Question

假设我有一个对 neo4j 程序的查询，它应该返回 100 000 条记录。 我想要的是一种按 1000 批获取记录的方法。我不想等待 Neo4j 发送 100 000 条记录，我想在客户端控制我收到的记录数量。我注意到ResultCursor 中有一个CompletionStage<Record> nextAsync() 方法，它正在做我想做的事情，但只有一个记录。这不是最优的，因为它需要在客户端和 neo4j 之间进行太多的往返才能获取所有记录。有没有办法查询接下来的 N 条记录？

我在异步模式下使用 neo4j java 驱动程序 4.0.0。

Answer 1

[更新]

在neo4j 4.0+中，nextAsync()方法内部为你批量获取记录。

每当队列大小低于低水位线时，它的实现会从一个异步补充的队列中返回每条记录。

因此，nextAsync() 方法非常理想，通常应该很快从队列中获取下一条记录。