如何使用Mongoose的aggregate方法执行查询并修改数据库数据

• Mongoose的aggregate本质是只读查询，管道内的$set仅修改内存中的临时结果集，不会写入数据库，这是你当前修改不生效的根本原因。
• 目前没有办法直接在aggregate调用中完成数据库写入，因为聚合本身的定位就是数据查询分析工具，你可以通过以下两种方案兼顾聚合能力和数据修改需求，同时保留你需要的$project等管道操作：

方案1：使用支持聚合管道的更新方法（推荐） #

MongoDB 4.2及以上版本的所有更新方法（findOneAndUpdate、updateOne、updateMany）都支持传入聚合管道作为更新参数，既可以实现数据持久化修改，也支持$set、$project等聚合操作符，完全覆盖你的需求。
针对你的场景代码示例如下：

var filter = req.body.filter
const result = await dataModel.findOneAndUpdate(
  filter, // 对应原聚合的$match阶段
  [
    { $set: { item: "2" } }, // 此处$set会持久化写入数据库
    // 后续需要的$project管道直接加在这里即可，例如：
    { $project: { item: 1, createTime: 1, _id: 0 } }
  ],
  {
    new: true, // 返回更新后的文档
    sort: { $sample: { size: 1 } } // 对应原聚合的$sample随机取1条匹配文档
  }
)

方案2：聚合查询+更新分步执行 #

如果你有更复杂的聚合逻辑（比如多表关联、分组统计等无法直接在更新管道中实现的逻辑），可以分两步操作：

1. 先执行聚合查询拿到需要修改的文档标识
2. 再调用更新方法实现持久化修改，同时指定投影规则
   代码示例：

var filter = req.body.filter
// 第一步：聚合查询定位目标文档
const targetDocs = await dataModel.aggregate([
  { $match: filter },
  { $sample: { size: 1 } }
  // 其他你需要的聚合阶段都可以放在这里
])
if (!targetDocs.length) {
  // 无匹配文档的逻辑处理
  return
}
// 第二步：执行更新并返回投影后的结果
const result = await dataModel.findOneAndUpdate(
  { _id: targetDocs[0]._id },
  { $set: { item: "2" } },
  {
    new: true,
    // 此处指定投影规则，和聚合$project效果完全一致
    projection: { item: 1, createTime: 1, _id: 0 }
  }
)

内容的提问来源于stack exchange，提问作者Manilavie