MongoDB
 sql >> Baza danych >  >> NoSQL >> MongoDB

mongodb przenosi dokumenty z jednej kolekcji do innej kolekcji

Operacje masowe pokazane przez @markus-w-mahlberg (i udoskonalone @mark-mullin) są wydajne, ale niebezpieczne, jak napisano. Jeśli bulkInsert nie powiedzie się, bulkRemove będzie nadal kontynuowane. Aby upewnić się, że nie stracisz żadnych rekordów podczas przenoszenia, użyj zamiast tego:

Funkcja
function insertBatch(collection, documents) {
  var bulkInsert = collection.initializeUnorderedBulkOp();
  var insertedIds = [];
  var id;
  documents.forEach(function(doc) {
    id = doc._id;
    // Insert without raising an error for duplicates
    bulkInsert.find({_id: id}).upsert().replaceOne(doc);
    insertedIds.push(id);
  });
  bulkInsert.execute();
  return insertedIds;
}

function deleteBatch(collection, documents) {
  var bulkRemove = collection.initializeUnorderedBulkOp();
  documents.forEach(function(doc) {
    bulkRemove.find({_id: doc._id}).removeOne();
  });
  bulkRemove.execute();
}

function moveDocuments(sourceCollection, targetCollection, filter, batchSize) {
  print("Moving " + sourceCollection.find(filter).count() + " documents from " + sourceCollection + " to " + targetCollection);
  var count;
  while ((count = sourceCollection.find(filter).count()) > 0) {
    print(count + " documents remaining");
    sourceDocs = sourceCollection.find(filter).limit(batchSize);
    idsOfCopiedDocs = insertBatch(targetCollection, sourceDocs);

    targetDocs = targetCollection.find({_id: {$in: idsOfCopiedDocs}});
    deleteBatch(sourceCollection, targetDocs);
  }
  print("Done!")
}


  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. Mongoose posortuj zagregowany wynik

  2. Haszowanie hasła Mongoose

  3. Mongoose zagnieżdżone zapytanie w modelu według pola modelu, do którego się odwołuje

  4. Jak usunąć wszystkie dokumenty z kolekcji za pomocą Mongoose?

  5. Popraw strukturę agregacji MongoDB