使用Mongoose批量增改集合文档时遇到的问题求助

你的问题根源在于误用了单文档操作来处理批量需求，以及upsert时查询条件的不合理设置：

为什么原来的代码不生效？ #

1. 单文档操作限制：findAndModify 和单个 update 都是针对单文档的操作——哪怕你用了 $in 作为查询条件，MongoDB也只会处理第一个匹配到的文档，剩下的元素完全不会被处理，这就是为什么只创建了一个新文档。
2. $in 导致upsert字段缺失：当你用 $in 作为查询条件并开启 upsert 时，MongoDB无法推断要插入的新文档应该把 field1 设置成哪个值（毕竟$in里有多个候选值），所以新创建的文档自然就缺失了field1字段。

正确的解决方案：批量操作分两步处理 #

要实现「存在则自增，不存在则插入默认值」的需求，最高效的方式是用bulkWrite一次性完成所有操作，它只需要和数据库交互一次，还能保证操作的原子性：

代码实现 #

const array_1 = ['abc','def','ghi','jkl'];
const Collection = // 替换为你的集合对象

async function processBatch() {
  // 第一步：查询array_1中已存在的field1值
  const existingField1s = await Collection.distinct('field1', { field1: { $in: array_1 } });

  // 第二步：构建批量操作数组
  const bulkOps = [];

  // 为已存在的元素添加自增操作
  existingField1s.forEach(fieldVal => {
    bulkOps.push({
      updateOne: {
        filter: { field1: fieldVal },
        update: { $inc: { field2: 1 } }
      }
    });
  });

  // 为不存在的元素添加插入操作（field2设为0）
  const missingField1s = array_1.filter(val => !existingField1s.includes(val));
  missingField1s.forEach(fieldVal => {
    bulkOps.push({
      insertOne: {
        document: { field1: fieldVal, field2: 0 }
      }
    });
  });

  // 第三步：执行批量操作
  if (bulkOps.length > 0) {
    const result = await Collection.bulkWrite(bulkOps);
    console.log(`成功更新${result.modifiedCount}个文档，插入${result.insertedCount}个新文档`);
  }
}

// 调用执行
processBatch().catch(err => console.error(err));

为什么这样可行？ #

• 先通过distinct筛选出已存在的field1值，确保我们只对存在的文档执行自增操作。
• 对缺失的元素直接生成插入操作，明确设置field1和field2的值，完全符合你的需求。
• bulkWrite会把所有操作打包成一个请求发送给数据库，比多次单独操作更高效，也能保证操作的原子性（要么全部成功，要么全部失败）。

如果你更倾向于分开执行两步操作（先更新再插入），也可以用updateMany和insertMany，逻辑是一致的：

// 第一步：批量更新已存在的文档
await Collection.updateMany(
  { field1: { $in: array_1 } },
  { $inc: { field2: 1 } }
);

// 第二步：插入缺失的文档
const existingField1s = await Collection.distinct('field1', { field1: { $in: array_1 } });
const missingElements = array_1.filter(el => !existingField1s.includes(el));
if (missingElements.length > 0) {
  await Collection.insertMany(missingElements.map(el => ({ field1: el, field2: 0 })));
}

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