在 MongoDB 中等待查询

Question

我有这个用 Typescript 编写的异步方法来查询，使用 nodejs 驱动程序，一个 MongoDB；编译器指出“myConnectedClient”之前的“await”对这个表达式的类型没有影响；我很困惑：对聚合（）的调用是异步的吗？所以，我必须等待吗？
谢谢。

async findQuery<T>(
    collection: string,
    findParams: Query<T>,
    sort: Sort<T>,
    myConnectedClient: MongoClient
  ) {
    const firstResult = await myConnectedClient // the compiler indicates await is useless
      .db("ZZZ_TEST_ALL")
      .collection("my_collection_01")
      .aggregate<string>([{ $project: { _id: 0, name: 1 } }]);
    firstResult.forEach((field) => {
      console.log(`Field: ${field}`);
    });
  }

更新：我必须在 .aggregate() 调用之后添加 .toArray()；但为什么？任何人都可以解释我的机制吗？聚合（）没有回调并且不返回承诺？ .toArray() 有替代品吗？谢谢。

// now await it's ok
const firstResult = await myConnectedClient
      .db("ZZZ_TEST_ALL")
      .collection("my_collection_01")
      .aggregate<string>([{ $project: { _id: 0, name: 1 } }]).toArray();

Answer 1

Aggregate 是同步的并返回一个AggregationCursor。

游标有许多异步方法来检索实际数据：toArray、forEach 或简单的iterator

在第一个sn -p firstResult中是游标，所以不需要等待。 您使用 firstResult.forEach 来记录结果。它确实返回了承诺，但你忽略了它，这会咬你 - findQuery 返回的承诺将立即解决，而 forEach 将并行迭代结果。为了保持承诺链，你应该这样做

const firstResult = myConnectedClient.......; 
return firstResult.forEach(......);

所以从findQuery 返回的承诺只有在 forEach 被解析时才会被解析，例如你完成了对结果的迭代。

在第二个“update”sn-p中，firstResult是数据，所以需要await从toArray()中获取。显式游标的等价物是：

const cursor = myConnectedClient.......; 
const firstResult = await cursor.toArray();