考虑这段代码，我需要在其中创建或更新特定文档。

Inbox.model.findOneAndUpdate({ number: req.phone.number }, {
    number: req.phone.number,
    country: req.phone.country,
    token: hat(),
    appInstalled: true
}, { new: true, upsert: true }).then(function(inbox){
    /*
       do something here with inbox, but only if the inbox was created (not updated)
    */
});

Mongoose 是否有能力区分文档是创建还是更新？我需要 new: true 因为我需要调用 inbox 上的函数。

最佳答案

在 .findOneAndUpdate() 的情况下或 mongoose 的任何 .findAndModify() 核心驱动程序变体，实际的回调签名具有“三个”参数:

 function(err,result,raw)

第一个是任何错误响应，然后是修改或原始文档，取决于选项，第三个是发出语句的写入结果。

第三个参数应该返回类似这样的数据:

{ lastErrorObject:
   { updatedExisting: false,
     n: 1,
     upserted: 55e12c65f6044f57c8e09a46 },
  value: { _id: 55e12c65f6044f57c8e09a46, 
           number: 55555555, 
           country: 'US', 
           token: "XXX", 
           appInstalled: true,
           __v: 0 },
  ok: 1 }

其中的一致字段为 lastErrorObject.updatedExisting 是 true/false 取决于是否发生 upsert 的结果。请注意，当此属性为 false 时，还有一个包含新文档的 _id 响应的“upserted”值，而不是当它为 true 时>.

因此，您将修改您的处理以考虑第三个条件，但这仅适用于回调而不是 promise :

Inbox.model.findOneAndUpdate(
    { "number": req.phone.number },
    { 
      "$set": {
          "country": req.phone.country,
          "token": hat(),
          "appInstalled": true
      }
    }, 
    { "new": true, "upsert": true },
    function(err,doc,raw) {

      if ( !raw.lastErrorObject.updatedExitsing ) {
         // do things with the new document created
      }
    }
);

我也强烈建议您使用 update operators而不是这里的原始对象，因为原始对象总是会覆盖整个文档，但是像 $set 这样的运算符只影响列出的字段。

还要注意，只要它们的值与未找到的完全匹配，该语句的任何匹配“查询参数”都会自动分配到新文档中。

鉴于由于某种原因使用 promise 似乎不会返回附加信息，那么除了设置 { new: false} 并且基本上当没有文件被退回然后它是一个新的。

无论如何，您都有预期要插入的所有文档数据，因此您并不需要返回这些数据。事实上，原生驱动方法是如何在核心处理这个问题的，并且仅在发生 upsert 时以“upserted”_id 值响应。

这实际上归结为本网站上讨论的另一个问题，如下:

Can promises have multiple arguments to onFulfilled?

这实际上归结为 promise 响应中多个对象的解析，这在 native 规范中不直接支持，但其中列出了一些方法。

因此，如果您实现 Bluebird promise 并在那里使用 .spread() 方法，那么一切都很好:

var async = require('async'),
    Promise = require('bluebird'),
    mongoose = require('mongoose'),
    Schema = mongoose.Schema;

mongoose.connect('mongodb://localhost/test');

var testSchema = new Schema({
  name: String
});

var Test = mongoose.model('Test',testSchema,'test');
Promise.promisifyAll(Test);
Promise.promisifyAll(Test.prototype);

async.series(
  [
    function(callback) {
      Test.remove({},callback);
    },
    function(callback) {
      var promise = Test.findOneAndUpdateAsync(
        { "name": "Bill" },
        { "$set": { "name": "Bill" } },
        { "new": true, "upsert": true }
      );

      promise.spread(function(doc,raw) {
        console.log(doc);
        console.log(raw);
        if ( !raw.lastErrorObject.updatedExisting ) {
          console.log( "new document" );
        }
        callback();
      });
    }
  ],
  function(err) {
    if (err) throw err;
    mongoose.disconnect();
  }
);

这当然会返回两个对象，然后您可以一致地访问:

{ _id: 55e14b7af6044f57c8e09a4e, name: 'Bill', __v: 0 }
{ lastErrorObject:
   { updatedExisting: false,
     n: 1,
     upserted: 55e14b7af6044f57c8e09a4e },
  value: { _id: 55e14b7af6044f57c8e09a4e, name: 'Bill', __v: 0 },
  ok: 1 }

以下是展示正常行为的完整 list :

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

mongoose.connect('mongodb://localhost/test');

var testSchema = new Schema({
  name: String
});

var Test = mongoose.model('Test',testSchema,'test');

async.series(
  [
    function(callback) {
      Test.remove({},callback);
    },
    function(callback) {
      Test.findOneAndUpdate(
        { "name": "Bill" },
        { "$set": { "name": "Bill" } },
        { "new": true, "upsert": true }
      ).then(function(doc,raw) {
        console.log(doc);
        console.log(raw);
        if ( !raw.lastErrorObject.updatedExisting ) {
          console.log( "new document" );
        }
        callback();
      });
    }
  ],
  function(err) {
    if (err) throw err;
    mongoose.disconnect();
  }
);

作为记录， native 驱动程序本身没有这个问题，因为响应对象实际上是除了任何错误之外它唯一返回的对象:

var async = require('async'),
    mongodb = require('mongodb'),
    MongoClient = mongodb.MongoClient;

MongoClient.connect('mongodb://localhost/test',function(err,db) {

  var collection = db.collection('test');

  collection.findOneAndUpdate(
    { "name": "Bill" },
    { "$set": { "name": "Bill" } },
    { "upsert": true, "returnOriginal": false }
  ).then(function(response) {
    console.log(response);
  });
});

所以总是这样:

{ lastErrorObject:
   { updatedExisting: false,
     n: 1,
     upserted: 55e13bcbf6044f57c8e09a4b },
  value: { _id: 55e13bcbf6044f57c8e09a4b, name: 'Bill' },
  ok: 1 }

关于node.js - (mongoose/promises) 你如何检查文档是否是使用 findOneAndUpdate 和 upsert 创建的，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/32281892/