sql >> Databasteknik >  >> NoSQL >> MongoDB

Mongo konverterar inbäddade dokument till array

Du måste fortfarande iterera över innehållet, men istället bör du skriva tillbaka med hjälp av massoperationer:

Antingen för MongoDB 2.6 och senare:

var bulk = db.collection.initializeUnorderedBulkOp(),
    count = 0;

db.collection.find({ 
   "$where": "return !Array.isArray(this.experience)"
}).forEach(function(doc) {
    bulk.find({ "_id": doc._id }).updateOne({
        "$set": { "experience": [doc.experience["0"]] }
    });
    count++;

    // Write once in 1000 entries
    if ( count % 1000 == 0 ) {
        bulk.execute();    
        bulk = db.collection.initializeUnorderedBulkOp();
    }
})

// Write the remaining
if ( count % 1000 != 0 )
    bulk.execute();

Eller i moderna versioner av MongoDB 3.2 och senare, bulkWrite() metod är att föredra:

var ops = [];

db.collection.find({ 
   "$where": "return !Array.isArray(this.experience)"
}).forEach(function(doc) {
   ops.push({
       "updateOne": {
           "filter": { "_id": doc._id },
           "update": { "$set": { "experience": [doc.experience["0"]] } }
       }
   });

   if ( ops.length == 1000 ) {
       db.collection.bulkWrite(ops,{ "ordered": false })
       ops = [];
   }
})

if ( ops.length > 0 )
    db.collection.bulkWrite(ops,{ "ordered": false });

Så när du skriver tillbaka till databasen över en markör, är bulkskrivoperationer med "oordnad" inställd rätt väg att gå. Det är bara ett skriv/svar per batch av 1000 förfrågningar, vilket minskar mycket overhead, och "oordnad" betyder att skrivningar kan ske parallellt snarare än i seriell ordning. Allt gör det snabbare.



  1. pymongo:MongoClient eller Connection

  2. De 10 bästa MongoDB-värdplattformarna

  3. MongoDB - Filtrera innehållet i en intern Array i en resultatuppsättning

  4. MongoDB $nin Query Operator