Java, MongoDB: Jak zaktualizować każdy obiekt podczas iterowania ogromnej kolekcji?

Question

Mam kolekcję około 1 miliona rekordów z 20 polami każdego. Muszę zaktualizować pole liczby całkowitej flag w każdym rekordzie (dokumencie) przypisującym losowo 1 lub 2 do tego pola flag. Jak to zrobić podczas iteracji kursora nad całą kolekcją? To nie wydaje się być dobrym pomysłem, aby szukać raz drugi dla obiektu już znaleziona przez MongoDB, tylko żeby być w stanie zaktualizować go:

DBCursor cursor = coll.find(); 
    try { 
    while(cursor.hasNext()) { 
    BasicDBObject obj = (BasicDBObject) cursor.next(); 
    ... 
    coll.update(query,newObj) 

    } 
    } finally { 
    cursor.close(); 
    } 

Jak zaktualizować pola w każdym dokumencie ogromnej kolekcji MongoDB z różnymi wartościami wydajnie?

Answer 1

Twoje podejście jest zasadniczo poprawne. Jednak nie uważam taką kolekcję jako „ogromny” można uruchomić coś podobnego z powłoki:

coll.find({}).forEach(function (doc) { 
    doc.flag = Math.floor((Math.random()*2)+1); 
    coll.save(doc); 
}); 

zależności od wersji MongoDB, konfiguracji i obciążenia, może to wziąć coś między kilku minut do kilku godziny

Jeśli chcesz wykonać tę aktualizację w puszkach, korzystać z niektórych warunków w dokumencie zapytań, coś takiego jak coll.find({"aFiled" : {$gt : minVal}, "aFiled" : {$lt : maxVal}})

Answer 2

Moje rozwiązanie do mojego pytania, zainspirowany @orid:

public void tagAll(int min, int max) { 
    int rnd = 0; 
    DBCursor cursor = this.dataColl.find(); 
    try { 
     while (cursor.hasNext()) { 
      BasicDBObject obj = (BasicDBObject) cursor.next(); 
      rnd = min + (int) (Math.random() * ((max - min) + 1)); 
      obj.put("tag", rnd); 
      this.dataColl.save(obj); 
     } 
    } finally { 
     cursor.close(); 
    } 
}