无法将子文档属性作为筛选条件的MongoDB更新问题排查

现有MongoDB文档 #

{
    "items": [
        {
            "_id": "63a48f12a9731cfd8a64b0b1",
            "item_name": "adidas shoes",
            "__v": 0,
            "rating": [
                {
                    "_id": "63a48fd51fb70775d216eb87",
                    "rate": 1,
                    "user_id": "6398a1a157d6146413b23b43"
                }
            ]
        }
    ]
}

需求 #

当rating数组中已存在指定user_id的评分时，更新该评分的rate值；若不存在，则向数组中新增一条评分记录。

现有接口代码 #

const addRating = async (req, res) => {
    const { rate, user_id, item_id } = req.body;
    const ratingInfo = new RatingDB.Rating({
        rate: rate, // 7
        user_id: user_id, // 63a48fd51fb70775d216eb87
        item_id: item_id, // 63a48f12a9731cfd8a64b0b1
    });

    try {
        const result = await itemDB.item.updateOne(
            { _id: item_id, rating: { user_id: user_id } },
            {
                $push: {
                    rating: { _id: ratingInfo._id, rate: rate, user_id: user_id },
                },
            },
            { upsert: true}
        );

        console.log(result);
        res.json({ message: "success" });
    } catch (err) {
        res.json({ message: err });
    }
};

遇到的问题 #

1. 使用初始筛选条件{ _id: item_id, rating: { user_id: user_id } }时，控制台无输出，返回错误：

{
    "message": {
        "index": 0,
        "code": 2
    }
}

2. 尝试其他筛选方式：
   • { _id: item_id, rating.user_id: user_id }或{ _id: item_id, rating[user_id]: user_id }：出现unexpected token语法错误
   • { _id: item_id, "rating.user_id": user_id }：返回上述相同的code:2错误响应

Items集合的Mongoose Schema #

const ItemSchema = mongoose.Schema({
  item_name: {
    type: String,
    required: true,
  },
  rating: {
    type:Array,
    required: false,
  },
});

解决方案 #

核心问题分析 #

• 初始查询条件rating: { user_id: user_id }是精确匹配整个数组元素，要求该元素仅包含user_id字段且值完全匹配，但实际rating元素还有_id和rate字段，因此无法匹配到目标文档。
• code:2是MongoDB的InvalidBSON错误，通常因查询条件格式错误或类型不匹配导致（比如字符串类型的item_id未转换为ObjectId）。
• 直接使用$push无法实现"存在则更新"的逻辑，需要分情况处理更新和新增操作。

修正后的代码实现 #

const addRating = async (req, res) => {
  const { rate, user_id, item_id } = req.body;
  // 确保ID类型与数据库一致（转换为ObjectId）
  const objectItemId = mongoose.Types.ObjectId(item_id);
  const objectUserId = mongoose.Types.ObjectId(user_id);

  try {
    // 第一步：尝试更新已存在的用户评分
    let updateResult = await itemDB.item.updateOne(
      { 
        _id: objectItemId, 
        "rating.user_id": objectUserId 
      },
      { $set: { "rating.$.rate": rate } }
    );

    // 如果没有匹配到文档，说明需要新增评分
    if (updateResult.matchedCount === 0) {
      updateResult = await itemDB.item.updateOne(
        { _id: objectItemId },
        { 
          $push: { 
            rating: { 
              _id: new mongoose.Types.ObjectId(), 
              rate, 
              user_id: objectUserId 
            } 
          } 
        }
      );
    }

    console.log(updateResult);
    res.json({ message: "success" });
  } catch (err) {
    res.json({ message: err.message || err });
  }
};

优化Schema定义 #

为了避免类型不匹配问题，建议明确rating数组的子文档结构：

const ItemSchema = mongoose.Schema({
  item_name: {
    type: String,
    required: true,
  },
  rating: [{
    _id: mongoose.Types.ObjectId,
    rate: {
      type: Number,
      required: true
    },
    user_id: {
      type: mongoose.Types.ObjectId,
      required: true
    }
  }],
});

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