利用Mongo DB异步驱动程序将文档列表转化为Java列表

Question

我是MongoDB的新手。有人建议使用MongoDB异步Java驱动程序API，而不是Spring-Data/Mongo DB驱动程序API，因为异步API支持对DB的回调和非阻塞调用。当我通过下面的链接时，我注意到了一些不同之处。

// find documents
collection.find().into(new ArrayList<Document>(), 
    new SingleResultCallback<List<Document>>() {
        @Override
        public void onResult(final List<Document> result, final Throwable t) {
            System.out.println("Found Documents: #" + result.size());
        }
    });

// find documents
List<BasicDBObject> foundDocument = collection.find().into(new ArrayList<BasicDBObject>());

向你问好，钱德拉。

Answer 1

我最终使用Java8的CompletableFuture实现了它，如下所示：

  public CompletableFuture<List<Document>> getMongoDocuments() throws InterruptedException, ExecutionException {
    CompletableFuture<List<Document>> future = new CompletableFuture<>();
    List<Document> list = new ArrayList<>();

    collection.find().forEach((document) -> {
      try {
        list.add(document);
      } catch (Exception e) {
        LOGGER.error("Error while parsing document::" + document.toString(), e);
      }

    }, (final Void result, final Throwable t) -> {
      future.complete(list);
    });

    List<Document> resultList = future.get(); //Just for testing if everything is as planned
    LOGGER.info("getHighResDocumentsByDriveSessionVinAndLogDate:: Count::" + resultList.size());
    return future;
  }

向你问好，钱德拉。