Es mejor hacer esta actualización usando bulkWrite
API. Considere el siguiente ejemplo para los dos documentos anteriores:
var bulkUpdateOps = [
{
"updateOne": {
"filter": { "reference": 10 },
"update": { "$push": { "history": history1 } }
}
},
{
"updateOne": {
"filter": { "reference": 20 },
"update": { "$push": { "history": history2 } }
}
}
];
mongo.financeCollection.bulkWrite(bulkUpdateOps,
{"ordered": true, "w": 1}, function(err, result) {
// do something with result
callback(err);
}
El {"ordered": true, "w": 1}
asegura que los documentos se actualizarán en el servidor en serie, en el orden proporcionado y, por lo tanto, si ocurre un error, todas las actualizaciones restantes se cancelarán. El {"w": 1}
La opción determina el problema de escritura, siendo 1 una confirmación de solicitud de que la operación de escritura se propagó al mongod independiente o al primario en un conjunto de réplicas.
Para MongoDB >= 2.6
y <= 3.0
, use la API de operaciones masivas
de la siguiente manera:
var bulkUpdateOps = mongo.financeCollection.initializeOrderedBulkOp();
bulkUpdateOps
.find({ "reference": 10 })
.updateOne({
"$push": { "history": history1 }
});
bulkUpdateOps
.find({ "reference": 20 })
.updateOne({
"$push": { "history": history2 }
});
bulk.execute(function(err, result){
bulkUpdateOps = mongo.financeCollection.initializeOrderedBulkOp();
// do something with result
callback(err);
});