MongoDB最佳实践：仅当数据不存在时执行POST插入的实现方案

嘿，这个问题我熟！在MongoDB里实现「仅当目标数据不存在才插入」的最佳实践，必须是结合唯一索引 + updateOne()的upsert特性——这比你现在直接insertOne的方式靠谱太多，还能解决高并发下的竞态问题，同时数据库层面会给你兜底防重复。

首先先拆解你现有代码的问题：

• 直接调用insertOne没有做前置检查，会导致相同hash的数据被重复插入；
• catch块里多次调用res.send()是错误的——HTTP响应只能发送一次，后面的send会触发报错。

具体实现步骤 #

1. 确保hash字段的唯一索引已生效

你提到hash是唯一检索字段且已建索引，这里再确认下索引是唯一索引（普通索引不会阻止重复插入），如果还没建，可以执行：

// 在MongoDB shell里执行，或者在你的初始化代码里添加
await db.dbConn('kw_data').createIndex({ hash: 1 }, { unique: true });

这个索引会在数据库层面阻止重复的hash值插入，错误码为11000，可以用来兜底捕获重复插入的情况。

2. 用updateOne() + upsert实现原子插入

updateOne()的upsert: true选项会让MongoDB自动做「查询-插入」的原子操作：如果匹配到hash对应的文档，就不做任何操作；如果没匹配到，就插入新文档。

修改后的路由代码如下：

router.post('/', async (req, res) => { 
  try { 
    const keywords = await db.dbConn('kw_data');
    
    // 原子执行：匹配hash不存在则插入，存在则不操作
    const updateResult = await keywords.updateOne(
      { hash: req.body.hash }, // 查询条件：找相同hash的文档
      {
        // 只有插入新文档时才会执行这个操作
        $setOnInsert: {
          result: req.body,
          added: new Date(),
          modified: new Date(),
          hash: req.body.hash
        }
      },
      { 
        upsert: true, // 开启upsert模式
        returnDocument: 'after' // 返回插入后的文档（MongoDB 4.2+支持）
      }
    );

    // 根据结果判断是插入成功还是数据已存在
    if (updateResult.upsertedId) {
      // 插入了新文档，返回201状态和文档数据
      const newDoc = await keywords.findOne({ _id: updateResult.upsertedId });
      res.status(201).send(newDoc);
    } else {
      // 文档已存在，返回409冲突状态和已有数据
      const existingDoc = await keywords.findOne({ hash: req.body.hash });
      res.status(409).send({ 
        message: '该数据已存在',
        data: existingDoc 
      });
    }
  } catch(e) { 
    // 统一处理错误，避免多次send响应
    if (e.code === 11000) {
      // 捕获唯一索引冲突错误（兜底情况）
      res.status(409).send({ 
        message: '该数据已存在',
        error: e.message 
      });
    } else {
      // 其他服务器错误
      res.status(500).send({ 
        message: '服务器处理失败',
        error: e.message 
      });
    }
  }
})

为什么这个方案是最佳选择？ #

• 原子性：updateOne的upsert操作是MongoDB底层原子执行的，不会出现「先查询无数据，插入时却发现已存在」的竞态问题（高并发场景下先查后插很容易踩这个坑）；
• 双重保障：既有代码层面的逻辑判断，又有数据库唯一索引的兜底，彻底杜绝重复数据；
• 错误处理更合理：修复了原代码多次res.send的问题，根据不同错误类型返回对应的HTTP状态码，符合REST规范。

额外提示 #

• 如果你的MongoDB版本低于4.2，returnDocument选项不支持，这时候可以在插入成功后通过upsertedId查询文档，或者改用findOneAndUpdate()；
• 如果不需要返回完整的文档数据，可以直接返回updateResult的状态，减少一次数据库查询请求。

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