MongoDB存储去重问题：db.update({upsert:true})失效及查询逻辑无效

看起来你遇到的核心问题是嵌套对象+数组的匹配逻辑不对，导致无论是先findOne再save，还是之前用update的upsert:true都没能正确识别重复数据。我来帮你拆解问题，给出可行的解决方案：

为什么你的findOne没生效？ #

MongoDB对对象和数组的匹配是严格的：

• 对于嵌套对象_links.self，只要href相同就能匹配，但如果是数组subscription，直接用整个数组匹配的话，元素顺序必须完全一致才能命中。比如两次请求里subscription的元素顺序换了，哪怕href和rel都一样，MongoDB也会认为是不同的数组，导致findOne返回null，进而重复插入。
• 另外，还要确认req.body._links的结构和数据库中存储的完全一致，有没有多余的字段或者类型差异（比如字符串和数字的区别）。

修正方案1：改进findOne的查询逻辑 #

如果还是想用先查询再插入的方式，需要把查询条件拆解开，分别匹配self.href和subscription的元素（不考虑顺序），同时确保数组长度一致：

const query = req.body._links;

// 构造精准的查询条件
const findQuery = {
  "_links.self.href": query.self.href,
  "_links.subscription": {
    // 确保subscription的所有元素都存在（不考虑顺序）
    $all: query.subscription.map(item => ({
      $elemMatch: { href: item.href, rel: item.rel }
    })),
    // 确保数组长度一致，避免部分匹配
    $size: query.subscription.length
  }
};

Note.findOne(findQuery).then(note => {
  if(note){
    console.log("This has already been saved");
    res.send({ message: "This has already been saved" });
  } else {
    const note = new Note({ _links: query });
    note.save()
      .then(data => res.send(data))
      .catch(err => {
        res.status(500).send({
          message: err.message || "Some error occurred while creating the Note."
        });
      });
  }
}).catch(err => {
  // 处理查询过程中的错误
  res.status(500).send({ message: err.message || "Error checking duplicate" });
});

修正方案2：用updateOne + upsert:true（更高效推荐） #

这种方式只需要一次数据库操作，还能避免竞态条件（比如两个请求同时检查都认为不存在，导致重复插入）。关键是修正查询条件，让MongoDB能正确识别重复文档：

const targetLinks = req.body._links;

// 构造匹配重复的查询条件
const updateQuery = {
  "_links.self.href": targetLinks.self.href,
  "_links.subscription": {
    $all: targetLinks.subscription.map(item => ({
      $elemMatch: { href: item.href, rel: item.rel }
    })),
    $size: targetLinks.subscription.length
  }
};

// 要更新/插入的数据
const updateData = { $set: { _links: targetLinks } };

Note.updateOne(updateQuery, updateData, { upsert: true })
  .then(result => {
    if (result.upsertedCount > 0) {
      console.log("New note inserted");
      res.send({ id: result.upsertedId, data: targetLinks });
    } else if (result.modifiedCount > 0) {
      console.log("Existing note updated");
      res.send({ message: "Note updated successfully" });
    } else {
      console.log("Note already exists");
      res.send({ message: "This has already been saved" });
    }
  })
  .catch(err => {
    res.status(500).send({
      message: err.message || "Failed to process request"
    });
  });

额外保障：数据库层面加唯一索引 #

为了从根源避免重复，你可以给_links.self.href添加唯一索引，这样即使代码逻辑有疏漏，MongoDB也会直接阻止重复插入：

// 在你的Note Schema定义中修改
const noteSchema = new mongoose.Schema({
  _links: {
    self: { 
      href: { 
        type: String, 
        unique: true, // 添加唯一约束
        required: true 
      } 
    },
    subscription: [ { href: String, rel: String } ]
  }
});

添加索引后，如果插入重复的self.href，MongoDB会抛出DuplicateKeyError，你可以在catch块中捕获这个错误，返回更明确的提示：

.catch(err => {
  if (err.code === 11000) { // MongoDB唯一键冲突的错误码
    res.status(409).send({ message: "This note's self.href already exists" });
  } else {
    res.status(500).send({ message: err.message || "Error processing request" });
  }
});

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