MongoDB - Insert wenn nicht vorhanden, sonst überspringen

Haben Sie zwei echte Entscheidungen hier, je nachdem, wie Sie wollen, um Dinge zu handhaben:

1. Verwenden upsert Funktionalität von MongoDB im wesentlichen "lookup", wenn Sie die wichtigsten Daten vorhanden ist. Wenn nicht, dann werden Sie nur übergeben, Daten an $setOnInsert und das wird sich nicht berühren, sonst nichts.

2. Verwenden Sie "Ungeordnete" - Operationen in der Masse. Die ganze Gruppe von updates auch dann weiter, wenn ein Fehler zurückgegeben wird, aber der error report(s) sind genau das, und alles, was nicht ein Fehler comitted.

Ganze Beispiel:

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

var testSchema = new Schema({
  "_id": Number,
  "name": String
},{ "_id": false });

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

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

var data = [
  { "_id": 1, "name": "One" },
  { "_id": 1, "name": "Another" },
  { "_id": 2, "name": "Two" }
];

async.series(
  [
    //Start fresh
    function(callback) {
      Test.remove({},callback);
    },

    //Ordered will fail on error. Upserts never fail!
    function(callback) {
      var bulk = Test.collection.initializeOrderedBulkOp();
      data.forEach(function(item) {
        bulk.find({ "_id": item._id }).upsert().updateOne({
          "$setOnInsert": { "name": item.name }
        });
      });
      bulk.execute(callback);
    },

    //All as expected
    function(callback) {
      Test.find().exec(function(err,docs) {
        console.log(docs)
        callback(err);
      });
    },


    //Start again
    function(callback) {
      Test.remove({},callback);
    },

    //Unordered will just continue on error and record an error
    function(callback) {
      var bulk = Test.collection.initializeUnorderedBulkOp();
      data.forEach(function(item) {
        bulk.insert(item);
      });
      bulk.execute(function(err,result) {
        callback(); //so what! Could not care about errors
      });
    },


    //Still processed the whole batch
    function(callback) {
      Test.find().exec(function(err,docs) {
        console.log(docs)
        callback(err);
      });
    }
  ],
  function(err) {
    if (err) throw err;
    mongoose.disconnect();
  }
);

Beachten Sie, dass die "geänderten Aktion", in der aktuelle Treiber ist, dass das Ergebnis die Antwort auf .execute() wird Rückkehr ein Fehler-Objekt geworfen werden, wo frühere Versionen hatten das nicht so mit "Un-bestellt" - Operationen.

Dies macht es zwingend notwendig, dass Sie Ihren code niemals verlässt sich auf die err allein zurück kam, und Sie sollte inpspeting die zurückgegeben result stattdessen für die vollständige Klassifizierung der Fehler.

Dennoch, wenn ungeordnete dann die batch wird fortgesetzt, bis das Ende, egal, wie viele Fehler auftreten. Dinge, die nicht einen Fehler begangen werden, als normal.

Diese kommt wirklich darauf an, "ist die Reihenfolge wichtig". Wenn dem so ist, dann müssen Sie "Bestellt" operations und Sie können nur vermeiden, duplicate keys mit "upserts". Ansonsten verwenden Sie "ungeordnet", aber bewusst sein, die Fehler gibt und was Sie eigentlich bedeuten.

Auch, wenn mit .collection um die zugrunde liegende collection-Objekt aus der Basis-Treiber zu aktivieren "Bulk" - Operationen, dann immer sicher sein, dass entweder "einige" Mungo-Methode wurde immer als erste.

Ohne, dass es gibt keine garantierte Verbindung zu der Datenbank mit den nativen Treiber Verfahren, wie es gehandhabt wird, für den Mungo Methoden, so schlägt die operation fehl, da keine Verbindung.

Die Alternative zu "feuern" Mungo Methode zuerst wickeln Sie Ihre app-Logik in einen Ereignis-listener für die Verbindung:

mongoose.connection.on("open",function(err) {
    //app logic in here
})