如何在 Mongoose 中更新/插入文档?

Posted

技术标签:

【中文标题】如何在 Mongoose 中更新/插入文档?【英文标题】:How do I update/upsert a document in Mongoose? 【发布时间】:2011-11-08 04:30:28 【问题描述】:

也许是时候了,也许是我淹没在稀疏的文档中,无法理解在 Mongoose 中更新的概念 :)

这是交易:

我有一个联系人架构和模型(缩短的属性):

var mongoose = require('mongoose'),
    Schema = mongoose.Schema;

var mongooseTypes = require("mongoose-types"),
    useTimestamps = mongooseTypes.useTimestamps;


var ContactSchema = new Schema(
    phone: 
        type: String,
        index: 
            unique: true,
            dropDups: true
        
    ,
    status: 
        type: String,
        lowercase: true,
        trim: true,
        default: 'on'
    
);
ContactSchema.plugin(useTimestamps);
var Contact = mongoose.model('Contact', ContactSchema);

我收到来自客户的请求,其中包含我需要的字段并因此使用我的模型:

mongoose.connect(connectionString);
var contact = new Contact(
    phone: request.phone,
    status: request.status
);

现在我们遇到了问题:

    如果我拨打contact.save(function(err)...),如果已存在具有相同电话号码的联系人(如预期 - 唯一),我将收到错误消息 我无法联系update(),因为文档中不存在该方法 如果我在模型上调用更新:Contact.update(phone:request.phone, contact, upsert: true, function(err...) 我进入了某种无限循环,因为 Mongoose 更新实现显然不希望将对象作为第二个参数。 如果我也这样做,但在第二个参数中我传递了请求属性的关联数组status: request.status, phone: request.phone ... 它可以工作 - 但是我没有参考具体的联系人,也找不到它的createdAt 和@987654329 @ 属性。

所以底线,毕竟我尝试过:给定一个文档contact,如果它存在,我该如何更新它,或者如果它不存在,我该如何添加它?

感谢您的宝贵时间。

【问题讨论】:

pre 中为save 挂钩怎么样? mongoosejs.com/docs/documents.html 【参考方案1】:

好吧,我等了足够长的时间,但没有答案。最后放弃了整个更新/更新方法并选择了:

ContactSchema.findOne(phone: request.phone, function(err, contact) 
    if(!err) 
        if(!contact) 
            contact = new ContactSchema();
            contact.phone = request.phone;
        
        contact.status = request.status;
        contact.save(function(err) 
            if(!err) 
                console.log("contact " + contact.phone + " created at " + contact.createdAt + " updated at " + contact.updatedAt);
            
            else 
                console.log("Error: could not save contact " + contact.phone);
            
        );
    
);

有效吗?是的。我对此满意吗?可能不是。 2 个数据库调用,而不是 1 个。 希望未来的 Mongoose 实现能够提供 Model.upsert 函数。

【讨论】:

此示例使用 MongoDB 2.2 中添加的接口在文档表单中指定 multi 和 upsert 选项。 .. include:: /includes/fact-upsert-multi-options.rst 文档说明了这一点,不知道从哪里开始。 虽然这应该可行,但您现在正在运行 2 个操作(查找、更新),而只需要 1 个(更新插入)。 @chrixian 展示了正确的方法。 值得注意的是,这是允许 Mongoose 的验证器启动的唯一答案。As per the docs,如果您调用 update 则不会发生验证。 @fiznool 看起来您可以在更新期间手动传入选项 runValidators: true:update docs(但是,更新验证器仅在 $set$unset 操作上运行) 如果您需要 .upsert() 在所有型号上可用,请查看我基于此的答案。 ***.com/a/50208331/1586406【参考方案2】:

你很亲密

Contact.update(phone:request.phone, contact, upsert: true, function(err)...)

但您的第二个参数应该是一个带有修改运算符的对象,例如

Contact.update(phone:request.phone, $set:  phone: request.phone , upsert: true, function(err)...)

【讨论】:

我认为您不需要这里的 $set: ... 部分作为我阅读的自动形式 是的,猫鼬说它把所有东西都变成了 $set 这在撰写本文时是有效的,我不再使用 MongoDB,所以我无法谈论最近几个月的变化:D 如果您不时使用本机驱动程序,则不使用 $set 可能是一个坏习惯。 在插入的情况下可以使用 $set 和 $setOnInsert 只设置某些字段【参考方案3】:

我刚刚花了 3 个小时来尝试解决同样的问题。具体来说,我想“替换”整个文档(如果存在),否则插入它。这是解决方案:

var contact = new Contact(
  phone: request.phone,
  status: request.status
);

// Convert the Model instance to a simple object using Model's 'toObject' function
// to prevent weirdness like infinite looping...
var upsertData = contact.toObject();

// Delete the _id property, otherwise Mongo will return a "Mod on _id not allowed" error
delete upsertData._id;

// Do the upsert, which works like this: If no Contact document exists with 
// _id = contact.id, then create a new doc using upsertData.
// Otherwise, update the existing doc with upsertData
Contact.update(_id: contact.id, upsertData, upsert: true, function(err...);

我创建了an issue on the Mongoose project page,请求将有关此的信息添加到文档中。

【讨论】:

目前文档似乎很差。 API文档中有一些(在页面上搜索“更新”。看起来像这样:MyModel.update( age: $gt: 18 , oldEnough: true , fn);MyModel.update( name: 'Tobi' , ferret: true , multi: true , fn); 对于没有找到案例文档,使用哪个_id? Mongoose 生成它还是被查询的那个?【参考方案4】:

看完上面的帖子,我决定用这个代码:

    itemModel.findOne('pid':obj.pid,function(e,r)
        if(r!=null)
        
             itemModel.update('pid':obj.pid,obj,upsert:true,cb);
        
        else
        
            var item=new itemModel(obj);
            item.save(cb);
        
    );

如果 r 为空,我们创建新项目。否则,请在更新中使用 upsert,因为更新不会创建新项目。

【讨论】:

如果是对 Mongo 的两次调用,那不是真的 upsert 是吗?【参考方案5】:

我需要将文档更新/插入到一个集合中,我所做的是创建一个新的对象字面量,如下所示:

notificationObject = 
    user_id: user.user_id,
    feed: 
        feed_id: feed.feed_id,
        channel_id: feed.channel_id,
        feed_title: ''
    
;

由我从数据库中其他地方获取的数据组成,然后在模型上调用更新

Notification.update(notificationObject, notificationObject, upsert: true, function(err, num, n)
    if(err)
        throw err;
    
    console.log(num, n);
);

这是我第一次运行脚本后得到的输出:

1  updatedExisting: false,
    upserted: 5289267a861b659b6a00c638,
    n: 1,
    connectionId: 11,
    err: null,
    ok: 1 

这是我第二次运行脚本时的输出:

1  updatedExisting: true, n: 1, connectionId: 18, err: null, ok: 1 

我使用的是 mongoose 版本 3.6.16

【讨论】:

【参考方案6】:

这个coffeescript适用于Node - 诀窍是_id get在从客户端发送和返回时剥离其ObjectID包装器,因此需要更换更新(当没有提供_id时,保存将恢复为插入并添加一个)。

app.post '/new', (req, res) ->
    # post data becomes .query
    data = req.query
    coll = db.collection 'restos'
    data._id = ObjectID(data._id) if data._id

    coll.save data, safe:true, (err, result) ->
        console.log("error: "+err) if err
        return res.send 500, err if err

        console.log(result)
        return res.send 200, JSON.stringify result

【讨论】:

【参考方案7】:

在 2.6 中引入了一个错误,对 2.7 也有影响

upsert 过去在 2.4 上可以正常工作

https://groups.google.com/forum/#!topic/mongodb-user/UcKvx4p4hnY https://jira.mongodb.org/browse/SERVER-13843

看一下,里面有一些重要信息

更新:

这并不意味着 upsert 不起作用。这是一个如何使用它的好例子:

User.findByIdAndUpdate(userId, online: true, $setOnInsert: username: username, friends: [], upsert: true)
    .populate('friends')
    .exec(function (err, user) 
        if (err) throw err;
        console.log(user);

        // Emit load event

        socket.emit('load', user);
    );

【讨论】:

【参考方案8】:

Mongoose 现在通过 findOneAndUpdate(调用 MongoDB findAndModify)本机支持此功能。

如果对象不存在,upsert = true 选项会创建该对象。 默认为 false

var query = 'username': req.user.username;
req.newData.username = req.user.username;

MyModel.findOneAndUpdate(query, req.newData, upsert: true, function(err, doc) 
    if (err) return res.send(500, error: err);
    return res.send('Succesfully saved.');
);

在旧版本中,Mongoose 不支持使用此方法的这些钩子:

默认值 二传手 验证器 中间件

【讨论】:

这应该是最新的答案。大多数其他人使用两个调用或(我相信)回退到本机 mongodb 驱动程序。 findOneAndUpdate 的问题是不会执行预保存。 听起来像是 Mongoose 或 MongoDB 中的错误? 来自文档:“...使用 findAndModify 助手时,以下内容不适用:默认值、设置器、验证器、中间件”mongoosejs.com/docs/api.html#model_Model.findOneAndUpdate @JamieHutber 这个默认没有设置,是自定义属性【参考方案9】:

对于到达这里的任何人仍在寻找具有钩子支持的“更新插入”的良好解决方案,这就是我已经测试和工作的内容。它仍然需要 2 次 DB 调用,但比我在单个调用中尝试过的任何方法都要稳定。

// Create or update a Person by unique email.
// @param person - a new or existing Person
function savePerson(person, done) 
  var fieldsToUpdate = ['name', 'phone', 'address'];

  Person.findOne(
    email: person.email
  , function(err, toUpdate) 
    if (err) 
      done(err);
    

    if (toUpdate) 
      // Mongoose object have extra properties, we can either omit those props
      // or specify which ones we want to update.  I chose to update the ones I know exist
      // to avoid breaking things if Mongoose objects change in the future.
      _.merge(toUpdate, _.pick(person, fieldsToUpdate));
     else       
      toUpdate = person;
    

    toUpdate.save(function(err, updated, numberAffected) 
      if (err) 
        done(err);
      

      done(null, updated, numberAffected);
    );
  );

【讨论】:

【参考方案10】:
//Here is my code to it... work like ninj

router.param('contractor', function(req, res, next, id) 
  var query = Contractors.findById(id);

  query.exec(function (err, contractor)
    if (err)  return next(err); 
    if (!contractor)  return next(new Error("can't find contractor")); 

    req.contractor = contractor;
    return next();
  );
);

router.get('/contractors/:contractor/save', function(req, res, next) 

    contractor = req.contractor ;
    contractor.update('_id':contractor._id,upsert: true,function(err,contractor)
       if(err) 
            res.json(err);
            return next(); 
            
    return res.json(contractor); 
  );
);


--

【讨论】:

【参考方案11】:

我创建了一个 *** 帐户只是为了回答这个问题。在无果地搜索互联网之后,我自己写了一些东西。我就是这样做的,因此它可以应用于任何猫鼬模型。导入此函数或将其直接添加到您正在进行更新的代码中。

function upsertObject (src, dest) 

  function recursiveFunc (src, dest) 
    _.forOwn(src, function (value, key) 
      if(_.isObject(value) && _.keys(value).length !== 0) 
        dest[key] = dest[key] || ;
        recursiveFunc(src[key], dest[key])
       else if (_.isArray(src) && !_.isObject(src[key])) 
          dest.set(key, value);
       else 
        dest[key] = value;
      
    );
  

  recursiveFunc(src, dest);

  return dest;

然后要更新 mongoose 文档,请执行以下操作,

YourModel.upsert = function (id, newData, callBack) 
  this.findById(id, function (err, oldData) 
    if(err) 
      callBack(err);
     else 
      upsertObject(newData, oldData).save(callBack);
    
  );
;

此解决方案可能需要 2 次 DB 调用,但您确实会从中受益,

针对您的模型进行架构验证,因为您使用的是 .save() 您可以在更新调用中插入深度嵌套的对象而无需手动枚举,因此如果您的模型发生更改,您不必担心更新代码

请记住,目标对象将始终覆盖源,即使源具有现有值

另外,对于数组,如果现有对象的数组比替换它的数组长,则旧数组末尾的值将保留。 upsert 整个数组的一种简单方法是在 upsert 之前将旧数组设置为空数组,如果这是您打算这样做的话。

更新 - 2016 年 1 月 16 日 我添加了一个额外条件,如果存在原始值数组,Mongoose 不会意识到该数组会在不使用“set”函数的情况下更新。

【讨论】:

+1 用于为此创建 acc :P 希望我可以给另一个 +1 仅用于使用 .save(),因为 findOneAndUpate() 使我们无法使用验证器和 pre、post 等东西.谢谢,我也去看看 抱歉,这里不起作用:(我的调用堆栈大小超出了 您使用的是什么版本的 lodash?我正在使用 lodash 版本 2.4.1 谢谢! 另外,你更新插入的对象有多复杂?如果它们太大,节点进程可能无法处理合并对象所需的递归调用次数。 我使用了这个,但必须在保护条件上添加if(_.isObject(value) && _.keys(value).length !== 0) 以阻止堆栈溢出。 Lodash 4+ 在这里,它似乎将非对象值转换为 keys 调用中的对象,因此递归保护总是正确的。也许有更好的方法,但它现在几乎对我有用......【参考方案12】:

如果有生成器,它会变得更加容易:

var query = 'username':this.req.user.username;
this.req.newData.username = this.req.user.username;
this.body = yield MyModel.findOneAndUpdate(query, this.req.newData).exec();

【讨论】:

【参考方案13】:
app.put('url', function(req, res) 

        // use our bear model to find the bear we want
        Bear.findById(req.params.bear_id, function(err, bear) 

            if (err)
                res.send(err);

            bear.name = req.body.name;  // update the bears info

            // save the bear
            bear.save(function(err) 
                if (err)
                    res.send(err);

                res.json( message: 'Bear updated!' );
            );

        );
    );

这里有一个更好的解决猫鼬更新方法的方法,您可以查看Scotch.io了解更多详细信息。这绝对对我有用!!!

【讨论】:

认为这与 MongoDB 的更新做同样的事情是错误的。它不是原子的。 我想备份@ValentinWaeselynck 的答案。 Scotch 的代码很干净——但您正在获取文档然后进行更新。在该过程的中间,文档可能会被更改。【参考方案14】:

使用 Promise 链可以实现非常优雅的解决方案:

app.put('url', (req, res) => 

    const modelId = req.body.model_id;
    const newName = req.body.name;

    MyModel.findById(modelId).then((model) => 
        return Object.assign(model, name: newName);
    ).then((model) => 
        return model.save();
    ).then((updatedModel) => 
        res.json(
            msg: 'model updated',
            updatedModel
        );
    ).catch((err) => 
        res.send(err);
    );
);

【讨论】:

为什么没有投票?似乎是一个很好的解决方案,而且非常优雅 出色的解决方案,实际上让我重新思考了我如何处理承诺。 更优雅的是将(model) => return model.save(); 重写为model => model.save(),并将(err) => res.send(err); 重写为err => res.send(err);)【参考方案15】:

一段时间后我才回到这个问题,并决定根据 Aaron Mast 的回答发布一个插件。

https://www.npmjs.com/package/mongoose-recursive-upsert

将其用作猫鼬插件。它设置了一个静态方法,将递归合并传入的对象。

Model.upsert(unique: 'value', updateObject);

【讨论】:

【参考方案16】:

以 Martin Kuzdowicz 上面发布的内容为基础。我使用以下内容使用猫鼬和 json 对象的深度合并进行更新。与 mongoose 中的 model.save() 函数一起,这允许 mongoose 进行完全验证,即使是依赖于 json 中其他值的验证。它确实需要 deepmerge 包https://www.npmjs.com/package/deepmerge。但这是一个重量很轻的包装。

var merge = require('deepmerge');

app.put('url', (req, res) => 

    const modelId = req.body.model_id;

    MyModel.findById(modelId).then((model) => 
        return Object.assign(model, merge(model.toObject(), req.body));
    ).then((model) => 
        return model.save();
    ).then((updatedModel) => 
        res.json(
            msg: 'model updated',
            updatedModel
        );
    ).catch((err) => 
        res.send(err);
    );
);

【讨论】:

在测试 NoSQL 注入(请参阅 owasp.org/index.php/Testing_for_NoSQL_injection)之前,请注意不要按原样使用 req.body @TravelingTechGuy 感谢您的谨慎,我还是 Node 和 Mongoose 的新手。我的带有验证器的猫鼬模型是否足以捕获注入尝试?在model.save()【参考方案17】:

这是创建/更新同时调用中间件和验证器的最简单方法。

Contact.findOne( phone: request.phone , (err, doc) => 
    const contact = (doc) ? doc.set(request) : new Contact(request);

    contact.save((saveErr, savedContact) => 
        if (saveErr) throw saveErr;
        console.log(savedContact);
    );
)

【讨论】:

【参考方案18】:
User.findByIdAndUpdate(req.param('userId'), req.body, (err, user) => 
    if(err) return res.json(err);

    res.json( success: true );
);

【讨论】:

虽然这段代码 sn-p 可以解决问题,但它没有解释为什么或如何回答这个问题。请include an explanation for your code,因为这确实有助于提高您的帖子质量。请记住,您正在为将来的读者回答问题,而这些人可能不知道您的代码建议的原因。 举报者/评论者: For code-only answers such as this one, downvote, don't delete!【参考方案19】:

没有其他解决方案适合我。我正在使用发布请求并更新数据,如果发现其他插入它,_id 也会与需要删除的请求正文一起发送。

router.post('/user/createOrUpdate', function(req,res)
    var request_data = req.body;
    var userModel = new User(request_data);
    var upsertData = userModel.toObject();
    delete upsertData._id;

    var currentUserId;
    if (request_data._id || request_data._id !== '') 
        currentUserId = new mongoose.mongo.ObjectId(request_data._id);
     else 
        currentUserId = new mongoose.mongo.ObjectId();
    

    User.update(_id: currentUserId, upsertData, upsert: true,
        function (err) 
            if (err) throw err;
        
    );
    res.redirect('/home');

);

【讨论】:

【参考方案20】:

这对我有用。

app.put('/student/:id', (req, res) => 
    Student.findByIdAndUpdate(req.params.id, req.body, (err, user) => 
        if (err) 
            return res
                .status(500)
                .send(error: "unsuccessful")
        ;
        res.send(success: "success");
    );

);

【讨论】:

谢谢。这是最终为我工作的那个! @Emmanuel 这对我来说也很好用,但是如果我们仔细观察这是在更新记录的 id,知道如何避免更新 id 吗?【参考方案21】:

根据Traveling Tech Guy 的回答,这已经很棒了,我们可以创建一个插件,并在初始化后将其附加到猫鼬,这样.upsert() 将适用于所有型号。

plugins.js

export default (schema, options) => 
  schema.statics.upsert = async function(query, data) 
    let record = await this.findOne(query)
    if (!record) 
      record = new this(data)
     else 
      Object.keys(data).forEach(k => 
        record[k] = data[k]
      )
    
    return await record.save()
  

db.js

import mongoose from 'mongoose'

import Plugins from './plugins'

mongoose.connect( ... )
mongoose.plugin(Plugins)

export default mongoose

然后您可以随时执行User.upsert( _id: 1 , foo: 'bar' )YouModel.upsert( bar: 'foo' , value: 1 ) 之类的操作。

【讨论】:

【参考方案22】:

您可以简单地用这个更新记录并获取更新的数据作为响应

router.patch('/:id', (req, res, next) => 
    const id = req.params.id;
    Product.findByIdAndUpdate(id, req.body, 
            new: true
        ,
        function(err, model) 
            if (!err) 
                res.status(201).json(
                    data: model
                );
             else 
                res.status(500).json(
                    message: "not found any relative data"
                )
            
        );
);

【讨论】:

@Awais/@Andrew 这段代码实际上也在更新我的 id,关于如何摆脱 id 更新的任何想法。【参考方案23】:

我是 Mongoose 的维护者。更新文档的更现代方式是使用Model.updateOne() function。

await Contact.updateOne(
    phone: request.phone
,  status: request.status ,  upsert: true );

如果您需要插入的文档,可以使用Model.findOneAndUpdate()

const doc = await Contact.findOneAndUpdate(
    phone: request.phone
,  status: request.status ,  upsert: true, useFindAndModify: false );

关键点是您需要将filter 参数中的唯一属性放入updateOne()findOneAndUpdate(),并将其他属性放入update 参数中。

这是upserting documents with Mongoose的教程。

【讨论】:

这不会跳过模型验证或“预”中间件吗?

以上是关于如何在 Mongoose 中更新/插入文档?的主要内容,如果未能解决你的问题,请参考以下文章

如何在 Mongoose 中更新/插入文档?

如何在 Mongoose 中更新/插入文档?

如何在 JavaScript 中使用 Mongoose 动态更新文档?

如何在 MongoDB 中查找文档、更新文档并插入新文档?

如何在 MongoDB 中查找文档、更新文档并插入新文档?

如何使用 Mongoose 将文档插入只有一个 ObjectID 的集合中?