Mongoose复合键过滤实现Upsert失效问题排查与解决

一、复合键过滤查询的正确写法 #

你写的复合键过滤查询其实是对的，MongoDB支持用'_id.productId'和'_id.categoryCode'这种嵌套路径匹配复合主键，另外还有种更简洁的写法——直接匹配整个_id对象，效果完全一致：

filter: { _id: { productId: product._id.productId, categoryCode: product._id.categoryCode } }

二、upsert失效的常见原因及修复方法 #

1. Update参数用了全文档替换（不规范） #

你现在直接把product整个传给update字段，这在updateOne里属于全文档替换而非字段更新。虽然理论上能跑，但容易出问题：

• 原文档里没在传入product里的字段会被全删；
• Mongoose的Schema验证可能对这种全量替换有限制，尤其是_id字段的处理，会导致upsert逻辑异常。

正确姿势是用$set操作符只更新需要改的字段：

update: {
  $set: {
    productName: product.productName,
    category: product.category,
    quantityInStock: product.quantityInStock
    // _id是主键，过滤条件已经匹配了，不用在这里更新
  }
}

要是确实需要全量替换，就改用replaceOne，但得保证_id结构完全匹配：

replaceOne: {
  filter: { _id: product._id },
  replacement: product,
  upsert: true
}

2. Mongoose Schema没正确定义复合_id #

你只给了TypeScript接口，但Mongoose的Schema必须明确指定_id的结构，不然它会默认把_id当成ObjectId类型，完全无视你自定义的复合键。正确的Schema得这么写：

import mongoose from 'mongoose';

const ProductSchema = new mongoose.Schema({
  _id: {
    productId: { type: Number, required: true },
    categoryCode: { type: Number, required: true }
  },
  productName: { type: String, required: true },
  category: { type: String, required: true },
  quantityInStock: { type: Number, required: true }
});

// 必须禁用Mongoose自动生成的_id，不然会和你自定义的复合_id冲突
ProductSchema.set('id', false);
ProductSchema.set('_id', false);

const Product = mongoose.model('Product', ProductSchema);
export default Product;

要是Schema没这么配置，Mongoose根本不认你的复合_id，过滤条件永远匹配不到文档，upsert自然失效。

3. 数据类型不匹配 #

检查下传入的product._id.productId和product._id.categoryCode类型，是不是和Schema里定义的一致。比如Schema里是Number，但你传的是字符串，MongoDB会因为类型不匹配找不到文档，结果每次都插新的，根本不会更新。

4. 复合_id的索引有问题 #

虽然复合_id本身会自动生成主键索引，但如果是在已有集合上改的Schema，可能得手动确认索引存在。可以用这条命令查：

await Product.collection.getIndexes();

要是没看到包含_id.productId和_id.categoryCode的唯一复合索引，就手动建一个：

await Product.collection.createIndex({ '_id.productId': 1, '_id.categoryCode': 1 }, { unique: true });

三、修正后的完整代码 #

结合上面的建议，改好的bulkWrite代码如下：

async updateOrInsert(products: Product[]) {
  await Product.bulkWrite(products.map(product => ({
    updateOne: {
      filter: { _id: product._id },
      update: {
        $set: {
          productName: product.productName,
          category: product.category,
          quantityInStock: product.quantityInStock
        }
      },
      upsert: true
    }
  })));
}

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