MongoDB复合唯一索引失效求助：不同用户加同影片仍报重复

可能的原因及排查步骤 #

1. 数据库存在冲突的旧索引 #

最常见的问题是watchlist集合中已存在单独的content_id唯一索引，或者复合索引未正确创建。这会导致不同用户添加同一影片时触发唯一键冲突。

检查数据库索引：

• 登录MongoDB Shell，执行命令查看watchlist集合的所有索引：

  db.watchlist.getIndexes()
  

• 核对输出结果：
  • 如果存在{ "content_id": 1 }且unique: true的索引，这就是冲突根源，需要删除该索引。
  • 确认是否存在{ "profile_id": 1, "content_id": 1 }且unique: true的复合索引。

2. Mongoose未同步Schema定义的索引 #

默认情况下，Mongoose在生产环境不会自动创建/更新索引（autoIndex默认为false）。如果是修改Schema后新增的复合索引，数据库可能未同步更新。

解决方法：

• 开发环境可在MongoDB连接时开启自动索引（生产环境不推荐）：

  mongoose.connect(uri, {
    autoIndex: true // 仅开发环境使用
  });
  

• 或者在应用启动时手动同步索引：

  // 在Model导出后或应用初始化阶段执行
  WatchListModel.syncIndexes().then(() => {
    console.log("索引同步完成");
  }).catch(err => {
    console.error("索引同步失败:", err);
  });
  

3. 数据类型不匹配 #

复合索引对字段类型严格敏感，如果profile_id或content_id的实际存储类型与Schema定义不符，会导致索引判断错误：

• 确认user._id是ObjectId类型，且profile_id字段存储的是ObjectId而非字符串。
• 确认list_id（对应content_id）是数字类型，若前端传递的是字符串格式的数字，可手动转换：

  content_id: parseInt(list_id, 10)
  

4. 现有数据违反复合索引约束 #

如果数据库中已存在不同用户但同一profile_id + content_id的重复数据，也会导致新插入失败。可清理冲突数据：

# 查找重复数据
db.watchlist.aggregate([
  { $group: { _id: { profile_id: "$profile_id", content_id: "$content_id" }, count: { $sum: 1 } } },
  { $match: { count: { $gt: 1 } } }
])
# 删除重复数据（保留第一条）
db.watchlist.deleteMany({
  _id: { $nin: db.watchlist.distinct("_id", {
    $group: { _id: { profile_id: "$profile_id", content_id: "$content_id" }, firstId: { $first: "$_id" } },
    $project: { _id: "$firstId" }
  }) }
})

优化后的代码示例 #

修正后的创建逻辑（简化并确保类型正确） #

WatchlistRouter.post('/list', async(req, res) => {
  const { list_id, media_type, name, ActiveUser } = req.body;
  try {
    const user = await UserModel.findOne({ email: ActiveUser });
    if (!user) {
      return res.status(400).send('You are not logged in to access this feature');
    }

    // 确保content_id为数字类型
    const contentId = parseInt(list_id, 10);
    if (isNaN(contentId)) {
      return res.status(400).send('Invalid content ID');
    }

    // 直接用create方法传入对象，无需提前实例化
    await WatchListModel.create({
      profile_id: user._id,
      content_id: contentId,
      mediaType: media_type,
      title: name
    });

    res.status(200).send('Added to Watchlist successfully');
  } catch (error) {
    if (error.code === 11000) {
      res.status(400).send(`This item is already in the watchlist for ${ActiveUser}.`);
    } else {
      res.status(500).send(`An error occurred: ${error.message}`);
    }
  }
});

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