Node.js + MongoDB не делает upsert, почему?

Question

Я не вижу изменений, отправленных на веб-сервер, почему?

• сервер работает
• я могу видеть в консоли, перед save правильный JSON: { "_id" : "abcd", "key1" : "value1" }

Это тело мое сообщение POST:

["Memorise", [["Diagram", {"_id" : "ab3sdscd", "key2" : "value1"}]]] 

---

var http = require('http'); 
var MongoClient = require('mongodb').MongoClient; 

var myServer = http.createServer(function(request, response) 
{ 
    if (request.method == 'POST') { 

    var data = ''; 

    request.on('data', function (chunk){ 
     data += chunk; 
    }); 

    request.on('end',function(){ 

     var obj = JSON.parse(data); 
     var databaseName = obj['db'] 

     MongoClient.connect("mongodb://localhost:27017/" + databaseName, function(err, db) { 

      if(!err) { 

       if (obj.length == 2) { 

        var recordsToUpsert = obj[1] 
        for (var i = 0; i < recordsToUpsert.length; i++) { 

         var recordToUpsertAndCollection = recordsToUpsert[i] 
         var collectionName = recordToUpsertAndCollection[0]; 
         var recordToUpsert = recordToUpsertAndCollection[1]; 
         var collection = db.collection(collectionName); 

         //console.log(collection) 
         console.log(recordToUpsert) 
         collection.save(recordToUpsert, {w:1}, { 

          //console.log("record upserted"); 
         }); 
        }; 

        response.writeHead(200) 
        response.end() 
       } 
      } 
     }); 
    }); 
    } 
}); 
myServer.listen(3000) 

Answer 1

Это ваша полезная нагрузка разбираемый в obj:

["Memorise", [["Diagram", {"_id" : "ab3sdscd", "key2" : "value1"}]]] 

Вот проблема:

var databaseName = obj['db'] 

Смотрите, что вы просите «ключ» под названием «дб». Он не существует, поэтому databaseName - undefined.

Поскольку JavaScript «stringifies», то строка подключения выходит так:

"mongodb://localhost:27017/undefined" 

То есть, где все ваши данные собираются.

Fix его это простого изменение:

var databaseName = obj[0] 

Answer 2

Почему бы вам не использовать:

collection.update (критерии, обновление [[, опцию], обратный вызов]);

для upsert скорее сохранить?

Попробуйте это:

collection.update ({_ ID: recordToUpsert._id}, recordToUpsert {upsert: истинно}, yourCallbackMethod);

Смотрите эту ссылку: upsert