Cómo reemplazar cadenas en todos los documentos en Mongo

Question

Necesito reemplazar una cadena en ciertos documentos. He buscado este código en Google, pero desafortunadamente no cambia nada. No estoy seguro acerca de la sintaxis en la línea de abajo:

pulpdb = db.getSisterDB("pulp_database"); 
var cursor = pulpdb.repos.find(); 
while (cursor.hasNext()) { 
    var x = cursor.next(); 
    x['source']['url'].replace('aaa', 'bbb'); // is this correct? 
    db.foo.update({_id : x._id}, x); 
} 

me gustaría añadir algunas impresiones de depuración para ver cuál es el valor, pero no tengo experiencias con MongoDB Shell. Sólo hay que sustituir este:

{ "source": { "url": "http://aaa/xxx/yyy" } } 

con

{ "source": { "url": "http://bbb/xxx/yyy" } } 

Answer 1

No corrige general: si tiene cadena http://aaa/xxx/aaa (yyy es igual a aaa) que va a terminar con http://bbb/xxx/bbb. Pero si está de acuerdo con esto, el código funcionará.

Para añadir información de depuración utilizar print función:

var cursor = db.test.find(); 
while (cursor.hasNext()) { 
    var x = cursor.next(); 
    print("Before: "+x['source']['url']); 
    x['source']['url'] = x['source']['url'].replace('aaa', 'bbb'); 
    print("After: "+x['source']['url']); 
    db.test.update({_id : x._id}, x); 
} 

(Y por cierto, si desea imprimir objetos, también hay printjson función)

Answer 2

MongoDB puede hacer búsqueda de cadenas/reemplazar a través de mapreduce. Sí, necesita una estructura de datos muy especial: no puede tener nada en las teclas superiores, pero necesita almacenar todo bajo un subdocumento bajo value. De esta manera:

{ 
    "_id" : ObjectId("549dafb0a0d0ca4ed723e37f"), 
    "value" : { 
      "title" : "Top 'access denied' errors", 
      "parent" : "system.admin_reports", 
      "p" : "\u0001\u001a%" 
    } 
} 

Una vez que haya esta perfectamente establecido que puede hacer:

$map = new \MongoCode("function() { 
    this.value['p'] = this.value['p'].replace('$from', '$to'); 
    emit(this._id, this.value); 
}"); 
$collection = $this->mongoCollection(); 
// This won't be called. 
$reduce = new \MongoCode("function() { }"); 
$collection_name = $collection->getName(); 
$collection->db->command([ 
    'mapreduce' => $collection_name, 
    'map' => $map, 
    'reduce' => $reduce, 
    'out' => ['merge' => $collection_name], 
    'query' => $query, 
    'sort' => ['_id' => 1], 
]); 

Answer 3

La mejor manera de hacer esto si usted está en MongoDB 2.6 o más reciente es un bucle sobre el objeto cursor utilizando la .forEach método y actualizar cada documento utilizando "bulk" operaciones para la máxima eficiencia.

var bulk = db.collection.initializeOrderedBulkOp(); 
var count = 0; 

db.collection.find().forEach(function(doc) { 
    print("Before: "+doc.source.url); 
    bulk.find({ '_id': doc._id }).update({ 
     '$set': { 'source.url': doc.source.url.replace('aaa', 'bbb') } 
    }) 
    count++; 
    if(count % 200 === 0) { 
     bulk.execute(); 
     bulk = db.collection.initializeOrderedBulkOp(); 
    } 

// Clean up queues 
if (count > 0) 
    bulk.execute(); 

---

De MongoDB 3.2 la Bulk() API y su asociado methods están en desuso que tendrá que utilizar el método db.collection.bulkWrite().

Necesitará un bucle sobre el cursor, construirá su consulta dinámicamente y $push cada operación en una matriz.

var operations = []; 
db.collection.find().forEach(function(doc) { 
    print("Before: "+doc.source.url); 
    var operation = { 
     updateOne: { 
      filter: { '_id': doc._id }, 
      update: { 
       '$set': { 'source.url': doc.source.url.replace('aaa', 'bbb') } 
      } 
     } 
    }; 
    operations.push(operation); 
}) 
operations.push({ 
    ordered: true, 
    writeConcern: { w: "majority", wtimeout: 5000 } 
}) 

db.collection.bulkWrite(operations);