MongoDB使用Node驱动Upsert时忽略查询条件的技术问询

我完全理解你的困扰——默认的upsert行为确实会按照查询条件生成基础文档，这就导致当你用指定的_id查询但不存在时，新文档会直接用这个查询的_id，而不是MongoDB自动生成的常规ObjectId。下面给你两种可行的解决方案：

方案一：分步查询+更新/插入（简单直接） #

这种方法先检查目标_id是否存在，再决定是更新现有文档还是插入新文档（不指定_id让MongoDB自动生成）。代码示例如下：

const { MongoClient, ObjectId } = require('mongodb');

// 假设这是你要查询的目标_id
const targetId = new ObjectId('60d21b4667d0d8992e610c85');
const mongoUri = 'mongodb://localhost:27017';
const dbName = 'your_database';
const collName = 'your_collection';

async function customUpsert() {
  let client;
  try {
    client = await MongoClient.connect(mongoUri);
    const collection = client.db(dbName).collection(collName);

    // 第一步：检查目标文档是否存在
    const existingDoc = await collection.findOne({ _id: targetId });

    if (existingDoc) {
      // 存在则执行更新操作
      const updateResult = await collection.updateOne(
        { _id: targetId },
        { $set: { /* 这里写你要更新的字段，比如: username: "updated_user" */ } }
      );
      console.log(`已更新 ${updateResult.modifiedCount} 条文档`);
    } else {
      // 不存在则插入新文档，不指定_id，MongoDB会自动生成常规ObjectId
      const insertResult = await collection.insertOne({
        /* 这里写新文档的字段，比如: username: "new_user", createTime: new Date() */
      });
      console.log(`已创建新文档，自动生成的_id: ${insertResult.insertedId}`);
    }
  } catch (err) {
    console.error('操作失败:', err);
  } finally {
    if (client) await client.close();
  }
}

customUpsert();

注意点： #

• 这种方法在低并发场景下完全够用，但高并发时可能存在竞态条件：比如在findOne和insertOne之间，有其他进程插入了目标_id的文档。如果你的业务需要严格避免这种情况，可以用下面的事务方案。

方案二：用事务保证原子性（高并发场景） #

如果你的MongoDB部署是副本集或分片集群，就可以用事务来把查询和更新/插入操作变成原子性操作，彻底避免竞态问题：

async function upsertWithTransaction() {
  let client;
  try {
    client = await MongoClient.connect(mongoUri);
    const session = client.startSession();
    session.startTransaction();

    try {
      const collection = client.db(dbName).collection(collName);
      const existingDoc = await collection.findOne({ _id: targetId }, { session });

      if (existingDoc) {
        await collection.updateOne(
          { _id: targetId },
          { $set: { username: "updated_via_transaction" } },
          { session }
        );
      } else {
        await collection.insertOne(
          { username: "new_via_transaction", createTime: new Date() },
          { session }
        );
      }

      // 提交事务
      await session.commitTransaction();
      console.log('事务执行成功');
    } catch (err) {
      // 事务失败则回滚
      await session.abortTransaction();
      console.error('事务执行失败，已回滚:', err);
      throw err;
    } finally {
      session.endSession();
    }
  } catch (err) {
    console.error('整体操作失败:', err);
  } finally {
    if (client) await client.close();
  }
}

upsertWithTransaction();

为什么默认upsert不行？ #

再帮你回顾下原因：MongoDB的upsert机制是先从查询条件的相等匹配字段生成一个基础文档，再把更新表达式应用上去。所以当你用{ _id: targetId }作为查询条件时，upsert触发后会直接创建一个_id为targetId的文档，这和你想要自动生成ObjectId的需求不符，所以必须用分步或事务的方式绕开这个机制。

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