Node.js/ - MongoDB 异步/等待奇怪的行为？

Question

这里，productIds 具有数组中所有已订购商品的 ID，例如 ["1294382", "2913892"]

所以我试图从 MongoDB 的数据库中获取所有具有这些 ID 的项目。我正在映射它们中的每一个，并将它们存储在orderedItems 数组中。这样我就可以访问数据库中项目的价格（或任何属性）。

productRouter.post("/", async (req, res) => {
 
  const productIds = req.body.orderedItems.map((item) => item.id); 

  let orderedItems = [];

  productIds.map(async (productId) => {
    const d = await Product.findById(productId);
    orderedItems.push(d);
  });

  const unusedVariable = await Product.findById("61...da1"); //If i delete that line (or only await), orderedItems returns empty array. 

  console.log(orderedItems);
  
});

现在，预期的输出是：

[
  {
    _id: new ObjectId("614632cc8aa9513567dfbca4"),
    name: 'ürün1',
    desc: 'ürün1 açıklama',
    price: 50,
    __v: 0
  },
  {
    _id: new ObjectId("614632cc8aa9513567dfbca2"),
    name: 'kartal kupa',
    desc: 'kartal resimli kupa',
    price: 50,
    __v: 0
  }
]

我得到了那个输出，但前提是我有等待的未使用变量行。如果我删除该行，或从那里删除“等待”，我得到的输出是： [] 。所以一个空数组而不是用对象填充。

为什么？我该如何解决这个问题（把 unusuedVariable 留在那里？）？这段代码有多糟糕？

Answer 1

您遇到了并发问题。​没有什么不寻常的，你不是在等待(1) 的承诺结束。您的代码正常工作的唯一原因是您的情况下的 MongoDB 使用单个连接，因此 (2) 仅在 (1) （所有这些）完成后才排队和完成（这是您的幸运巧合）。

productRouter.post("/", async (req, res) => {
 ​const productIds = req.body.orderedItems.map((item) => item.id);
 ​let orderedItems = [];

 ​productIds.map(async (productId) => { // (1)
   ​const d = await Product.findById(productId);
   ​orderedItems.push(d);
 ​});

 ​const unusedVariable = await Product.findById("61...da1"); // (2)
 ​console.log(orderedItems);
});

如前所述，map 和 forEach 均不支持承诺（由于向后兼容性，它们可能永远不会支持）因此您应该使用Promise.all，这可能会给您一些同意，或者使用普通的@987654330 @ 与 async/await 语法兼容。

productRouter.post("/", async (req, res) => {
  const productIds = req.body.orderedItems.map((item) => item.id);
  let orderedItems = [];

  for (const productId: productIds) {
    orderedItems.push(await Product.findById(productId));
  }
  
  console.log(orderedItems);
});

或者

productRouter.post("/", async (req, res) => {
  const productIds = req.body.orderedItems.map((item) => item.id);
  
  const orderedItems = await Promise.all(
    productIds.map(productId => Product.findById(productId))
  );
  
  console.log(orderedItems);
});

题外话

如 cmets 中所述，您应该考虑使用 $in 运算符，这将大大减少针对您的数据库的查询数量：

productRouter.post("/", async (req, res) => {
  const productIds = req.body.orderedItems.map((item) => item.id);
  const orderedItems = Product.find({_id: {$in: productIds}});
  console.log(orderedItems);
});

More here