Estoy tratando de escribir un script en Node.js que actualice mediante updates una colección en MongoDB. Tengo N pacientes (sus IDs en un array) y para cada uno quiero actualizar los datos en la colección con un objeto. Los documentos pueden no existir previamente.
Ahora mismo estoy haciendo
MongoClient.connect(url, function (err, db) {
...
var collection = db.collection('datasample_second');
for(var i=0;i<PatientIDs.length; i++){
collection.update({'timestamp' : epoch_sec, 'patientID' : PatientIDs[i] },
updateObj,
{ upsert: true }
);
}
setTimeout(function() {
db.close()
}, 2000);
}); //MongoClient.conect
y me he visto obligado a poner ese último timeout ahí para que el bucle pueda disparar los updates a base de datos y darles tiempo a ejecutarse antes de cerrar la conexión. A priori en lugar del timeout tenía simplemente db.close() y claro, sólo me entraba el primer update y para los otros recibía un mensaje tipo "socket closed".
Este apaño funciona mientras sigo con otras cosas, pero no me gusta. He estado intentando encontrar algo mejor con la documentación del driver de Node.js para MongoDB, pero no he encontrado nada.
Sé que a update le puedo pasar como cuarto parámetro una función de callback, en la que podría cerrar la conexión. Mi problema es, de nuevo, que no puede hacer el close tras el primer update, si tras mandarlos todos.
Quizá sería más fácil también hacer un único update, pero como digo los documentos no siempre existen (de ahí el {upsert : true}) y con cada update quiero insertar/actualizar tantos documentos como pacientes tengo en el array PatientIDs.
Intenté usar un $in
para la query, pero al no encontrar ningún documento preexistente mongo hace un único update sin el campo patientID en el objeto.
Hay alguna manera de detectar que los updates se han realizado para después hacer el close?