MongoDB在一个查询中更新多行

你可以使用 bulk operation Collection.initializeUnorderedBulkOp

var bulkOp = yourCollection.initializeUnorderedBulkOp();

bulkOp.find({ _id: 1 }).updateOne({ /* update document */ });
bulkOp.find({ _id: 2 }).updateOne({ /* update document */ });
// etc

bulkOp.execute();

您可以根据需要构建它,然后让数据库一次完成所有工作。

不能使用单个请求执行所需的更改。

有少量数据的

为要执行的每个更改启动一个请求

await Promise.all(entries.map(x => model.findOneAndUpdate(...)));

有大量数据的

使用游标按包处理数据。

const cursor = await model.find({
   _id: {
      $in: idsEntries,
   },
}).cursor().exec();

await handleCursorRead(cursor);

handleCursorRead(cursor) {
   return new Promise((resolve) => {
       cursor.eachAsync((x) => {
           x.stock = ...;

           x.save();
       }, {
          // How many items do we look at same time
          parallel: 250,
       }, () => {
          // When we are done processing all items
          resolve();
       });
   });
}

更简洁的方式

要更新的数组

const array = [{
    "_id" : 1,
    "item" : "item1",
    "stock" : 80
}, {
    "_id" : 2,
    "item" : "item2",
    "stock" : 60
}, {
    "_id" : 3,
    "item" : "item3",
    "stock" : 170
}]

查询以进行批量更新

Model.bulkWrite(
  array.map((data) => 
    ({
      updateOne: {
        filter: { _id: data._id },
        update: { $set: { stock: data.stock } }
      }
    })
  )
})