向MongoDB已存在的product_reviews集合新增评论统计对象

我来帮你解决这个问题——要给每个product_reviews集合中的产品文档新增评论统计字段，用MongoDB 4.2及以上版本支持的updateMany配合聚合管道就能轻松实现。下面是针对你需求的完整解决方案：

完整更新命令 #

db.product_reviews.updateMany(
  {}, // 匹配所有文档，如需筛选特定产品可修改此处条件
  [
    {
      $set: {
        reviewStats: { // 将统计字段按你需要的结构包装在一个对象中
          reviewsCount: { $size: "$reviews" },
          avgReviewScore: {
            $avg: { 
              $map: { 
                input: "$reviews", 
                as: "r", 
                in: { $toDouble: "$$r.review/score" } 
              } 
            }
          },
          reviewScoreDistrib: {
            $mergeObjects: [
              // 预设默认评分分布，确保1-5分都有对应数值（无评论时显示0）
              { 1: 0, 2: 0, 3: 0, 4: 0, 5: 0 },
              {
                $arrayToObject: {
                  $reduce: {
                    input: "$reviews",
                    initialValue: [],
                    in: {
                      $let: {
                        vars: {
                          // 将字符串类型的评分转为整数作为统计键
                          scoreKey: { $toInt: "$$this.review/score" },
                          // 检查当前评分是否已在统计数组中
                          existingIndex: { $indexOfArray: ["$$value.k", "$$scoreKey"] }
                        },
                        in: {
                          $cond: [
                            { $ne: ["$$existingIndex", -1] },
                            // 若评分已存在，累加计数
                            {
                              $map: {
                                input: "$$value",
                                as: "item",
                                in: {
                                  $cond: [
                                    { $eq: ["$$item.k", "$$scoreKey"] },
                                    { k: "$$item.k", v: { $add: ["$$item.v", 1] } },
                                    "$$item"
                                  ]
                                }
                              }
                            },
                            // 若评分不存在，新增统计项
                            { $concatArrays: ["$$value", [{ k: "$$scoreKey", v: 1 }]] }
                          ]
                        }
                      }
                    }
                  }
                }
              }
            ]
          }
        }
      }
    }
  ]
)

代码核心逻辑解释 #

让我拆解一下这个聚合管道的关键部分：

• reviewsCount：用$size直接获取reviews数组的长度，快速得到该产品的评论总数。
• avgReviewScore：先用$map把每个评论中字符串类型的review/score转为数值类型（$toDouble），再用$avg计算所有评分的平均值，避免字符串导致的计算错误。
• reviewScoreDistrib：
  1. 用$reduce遍历reviews数组，逐个统计每个评分出现的次数，生成键值对数组（比如[{k:3, v:1}, {k:4, v:1}]）。
  2. 用$arrayToObject将键值对数组转为对象格式。
  3. 最后用$mergeObjects将统计结果和预设的默认分布合并，确保即使某个评分没有对应评论，也会显示0而不是缺失字段。

注意事项 #

• 该方案要求MongoDB版本在4.2及以上，因为从4.2版本开始才支持将聚合管道作为updateMany的更新操作。
• 如果不需要把统计字段包装在reviewStats对象中，直接把三个字段平级放在$set下即可，调整代码非常简单。

以你提供的示例文档为例，执行命令后会新增如下字段：

reviewStats: {
  avgReviewScore: 3.5,
  reviewsCount: 2,
  reviewScoreDistrib: {
    1: 0,
    2: 0,
    3: 1,
    4: 1,
    5: 0
  }
}

内容的提问来源于stack exchange，提问作者duje.je