使用Mongoose向MongoDB数组执行$push操作失败问题求助

可能的原因及修复方案 #

1. 路由参数_id未正确转换为ObjectId #

MongoDB的_id是ObjectId类型，虽然Mongoose通常会自动转换字符串ID，但某些场景下（比如参数格式异常、版本兼容问题）会导致匹配失败。

修复：
手动将req.params.id转换为Mongoose内置的ObjectId：

// 导入Mongoose
import mongoose from "mongoose";
const ObjectId = mongoose.Types.ObjectId;

// 修改updateOne的查询条件
const userToUpdate = await User.updateOne(
    {_id: new ObjectId(req.params.id)},
    {
        $push: {
            dcrLocations: {
                dcrLocationId: new ObjectId(dcrLocationId)
            }
        }
    }
);

2. 确认目标用户是否存在 #

先通过ID查询用户，验证req.params.id对应的用户是否真实存在：

// 在updateOne前添加查询验证
const existingUser = await User.findById(req.params.id);
console.log(existingUser); // 输出null则说明ID无效或用户不存在

如果返回null，检查前端传入的id是否正确，或者数据库中是否有该用户文档。

3. 替换mongodb的ObjectId为Mongoose内置类型 #

你当前从mongodb包导入ObjectID，建议直接用Mongoose自带的mongoose.Types.ObjectId，避免版本兼容性问题：

// 移除mongodb的导入
// import {ObjectID as ObjectId} from "mongodb";

// 改用Mongoose内置的ObjectId
import mongoose from "mongoose";
const ObjectId = mongoose.Types.ObjectId;

4. 验证dcrLocationId的有效性 #

确保传入的dcrLocationId是合法的ObjectId字符串（长度24位，仅包含0-9和a-f字符），可在代码中添加校验：

if (!ObjectId.isValid(dcrLocationId)) {
    return res.status(400).json({error: "无效的dcrLocationId"});
}

5. 检查路由参数是否正确传递 #

确认路由定义是否正确（比如是否为/api/users/:id），同时打印参数验证是否拿到了正确值：

console.log("用户ID:", req.params.id);
console.log("dcrLocationId:", dcrLocationId);

如果req.params.id为空或错误，说明路由参数传递有问题，需检查前端请求或路由配置。

完整修复后的控制器示例 #

import mongoose from "mongoose";
import {User} from "../../path/to/model.js";

const ObjectId = mongoose.Types.ObjectId;

function functionName() {
    return {
        AssDCRLoToUsr: async (req, res) => {
            try {
                const {dcrLocationId} = req.body;
                const userId = req.params.id;

                // 校验ID有效性
                if (!ObjectId.isValid(userId) || !ObjectId.isValid(dcrLocationId)) {
                    return res.status(400).json({error: "无效的ID参数"});
                }

                // 验证用户存在
                const existingUser = await User.findById(userId);
                if (!existingUser) {
                    return res.status(404).json({error: "用户不存在"});
                }

                const userToUpdate = await User.updateOne(
                    {_id: new ObjectId(userId)},
                    {
                        $push: {
                            dcrLocations: {
                                dcrLocationId: new ObjectId(dcrLocationId)
                            }
                        }
                    }
                );

                console.log(userToUpdate);
                res.json(userToUpdate);
            } catch (error) {
                console.error(error);
                res.status(500).json({error: "服务器内部错误"});
            }
        },
    }
}

export {functionName};

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