Mongoose如何单查询更新两个集合 实现销售变动自动更新商品计数

MongoDB 原生不支持单条语句跨集合执行更新操作，Mongoose 也没有对应封装能力，不存在严格意义上「单条查询更新两个集合」的实现。要满足销售操作触发时同步更新商品库存的需求，核心是保证「写入销售记录」和「更新商品库存」两个操作的一致性，避免出现数据错乱，具体实现方案如下。

先修正现有模型的笔误 #

你贴的代码里有两处会直接导致运行报错的问题：

• products 模型中required属性拼写错误为trud，schema 变量命名和模型语义不匹配
• sales 模型中关联商品的productId字段缺少必填约束，可能生成无对应商品的无效销售数据
  修正后的模型代码：

products（商品）模型 #

const mongoose = require("mongoose");
const productSchema = new mongoose.Schema({
    productname:{
        type:String,
        required:true,
        unique:true
    },
    productCount:{
        type:Number,
        required:true
    }
});
module.exports = mongoose.model("products", productSchema);

sales（销售）模型 #

const mongoose = require("mongoose");
const salesSchema = new mongoose.Schema({
    productId:{
        type:mongoose.Schema.Types.ObjectId,
        ref:"products",
        required:true
    },
    salesCount:{
        type:Number,
        required:true
    }
});
module.exports = mongoose.model("sales", salesSchema);

生产环境推荐方案：多文档事务 #

使用 MongoDB 多文档事务可以保证两个操作要么同时成功，要么出错时全部回滚，完全避免数据不一致问题。注意该功能需要 MongoDB 以副本集或分片集群模式部署，本地开发可直接使用 Mongoose 内置的内存副本集测试。
销售操作的实现示例：

async function handleSale(productId, saleQuantity) {
    const session = await mongoose.startSession();
    session.startTransaction();
    try {
        // 校验商品存在且库存充足
        const targetProduct = await Products.findById(productId).session(session);
        if (!targetProduct) throw new Error("对应商品不存在");
        if (targetProduct.productCount < saleQuantity) throw new Error("商品库存不足");

        // 写入销售记录
        await Sales.create([{
            productId,
            salesCount: saleQuantity
        }], { session });

        // 扣减对应商品库存
        await Products.updateOne(
            { _id: productId },
            { $inc: { productCount: -saleQuantity } },
            { session }
        );

        // 所有操作执行完成后提交事务
        await session.commitTransaction();
        return { success: true, message: "销售记录生成成功，库存已同步更新" };
    } catch (err) {
        // 任意步骤出错则回滚所有已执行的操作
        await session.abortTransaction();
        throw err;
    } finally {
        // 释放会话资源
        await session.endSession();
    }
}

低版本MongoDB兼容方案（不推荐生产使用） #

如果你使用的 MongoDB 版本低于4.0不支持事务，可以在 sales 模型上挂载 Mongoose 中间件（钩子），在销售记录写入、更新、删除时自动触发对应商品的库存调整：

// sales模型中新增钩子，写入销售记录后扣减库存
salesSchema.post('save', async function(doc) {
    await Products.updateOne(
        { _id: doc.productId },
        { $inc: { productCount: -doc.salesCount } }
    )
})

该方案的缺陷是没有回滚能力，如果钩子执行过程中出现服务宕机、网络错误，会出现销售记录和库存数据不匹配的问题。

注意：不要尝试用聚合管道的$lookup实现跨集合更新，聚合更新仅能修改当前集合的字段，无法直接修改关联集合的数据。

内容的提问来源于stack exchange，提问作者Sayeed Mahdi Mousavi