如何使用 AsynCluster 在 Couchbase 中进行批量（使用选择更新）处理，而不在 couchbase SDK 3.x 中使用反应式？

Question

我有一个要求，我想更新 Couchbase 中的 1000 条记录并获取更新记录的 id。我不想使用couchbase SDK 3.x官方文档中提到的Reactive（项目反应器）。

还有另一种方法，我们可以在服务端使用 CompletableFuture 并调用 AsynCluster.query(queryStatment) ，它也返回 CompletableFuture;后退。

有没有办法执行 1000 更新（准确地说是选择“UPDATE bucketName SET docType = 'abc'”WHERE caseId = 123 RETURNING caseId as caseId ;”更新）操作并返回 caseID 并异步执行此任务。

我尝试过下面的代码，但不确定它

    List <CompletableFuture<QueryResult>> completableFutureList = new ArrayList<>();
    for(JsonObject j : jsonObjectList) {
        completableFutureList.add(asyncCluster.query(queryStatement, 
        QueryOptions.queryOptions().parameters(j)));}
  CompletableFuture.allOf(completableFutureList.toArray(new CompletableFuture[0]))
            .exceptionally(ex-> null).join();

应该异步工作并返回成功更新的 caseId 列表，并处理执行更新操作和捕获时发生的任何异常。分别那个。