PROBLEMA
Se desea obtener la lista de autores de un libro basados en la búsqueda por _id
en la colección de autores. Los valores de _id
son parte del campo autor
en el doicumento de la colección de libros.
Entre los muchos problemas que tienes en tu implementación es que estás tratando de hacer 2 conexiones diferentes para obtener la información. Y no sólo se trta de las 2 conexiones, sino que intentas usar variables que estarán disponibles únicamente dentro de su propio ámbito, porque no estás tomando en cuenta que todo petición a base de datos es asíncrona.
SOLUCIÓN
Lo primero que debes hacer es comprender que no necesitas abrir una conexión para consultar datos que se encuentran en la misma base de datos. Puedes hacer las 2 consultas usando la misma conexión. También debes entender que los procesos son asíncronos, por lo cual el manejo que harás de los mismos debe ser el adecuado.
Tu petición podría verse de la siguiente forma:
// Dependencia requerida para hacer la conversión de string a ObjectId
const ObjectID = require('mongodb').ObjectID,
app.post('/verLibro', urlencodedParser, (req, res) => {
// Conexión a la Base de Datos
MongoClient.connect(url, function (err, db) {
if (err) {
console.error(err.message);
throw err;
}
const dbo = db.db(mydb);
const query = { isbn: req.body.libro };
dbo.collection(coleccion).findOne(query, function (err, libro) {
if (err) {
console.error(err.message);
throw err;
}
if (!libro) {
console.log(`No existen libros para isbn: ${query.isbn}`);
// podemos cerrara la conexión
return db.close(() => {
return res.status(200).json({
message: 'No se encuentran libros'
value: query.isbn
});
});
}
let { autores } = libro;
if(!autores.length) {
// el libro no tiene registrado ningún autor, no necesito consultar nada mas
// cierro la conexión y devuelvo el resultado
return db.close(() => {
return res.status(200).json({
message: 'Libro encontrado',
value: libro
});
});
}
// en este momento ya tengo la lista de autores, pero son strings
// debemos convertirlos a ObjectId
autores = autores.map(idStr => (new ObjectId(idStr));
// ahora la lista de autores contiene objetos de tipo ObjectId
// usando esta misma conexión buscamos los autores
dbo.collection(coleccionAu).find({ _id: {$in: autores} }, function (err, autores) {
if (err) {
console.error(err.message);
throw err;
}
// reemplazamos la lista de autores del libro por la obtenida de la DB
libro.autores = autores;
// podemos cerrar la conexión y enviar la respuesta
return db.close(() => {
return res.status(200).jason({
message: 'Libro encontrado',
value: libro
});
});
}); // Fin de find()
}); // Fin de findOne()
}); // Fin de connect()
}); // Fin de app.post()
Como puedes observar, se hacen las dos consultas usando la misma conexión. Además se debe convertir la lista de autores de string
a ObjectId
. También puedes ver que he cambiado la lógica de las respuestas basado en si se obtienen resultados o no. Además estoy usando como respuesta una cadena en formato JSON y dejar así que sea el cliente el que se encargue de mostrar la información como mejor le parezca.
Mejora usando async / await
Como puedes observar del código anterior, al final he usado comentarios para saber qué función callback se estaba cerrando y no hacerme un lío. El problema de usar callbacks en métodos anidados es que puede conducir a errores y hace el código muy difícil de entender, porduciéndose lo que se conoce como Callback Hell
.
Una forma de evitar esto es usando funciones tipo async
. Los métodos find
, findOne
y connect
del driver de MongoDB para NodeJS soportan el uso de await
, devolviendo una Promesa cuando no se usa una función callback como último parámetro.
El código anterior podría verse así:
// Dependencia requerida para hacer la conversión de string a ObjectId
const ObjectID = require('mongodb').ObjectID,
// la función callback que recibe el método post se declara async
app.post('/verLibro', urlencodedParser, async (req, res) => {
// Al trabajar con Promesas debemos usar try catch
try {
const db = await MongoClient.connect(url);
const dbo = db.db(mydb);
const query = { isbn: req.body.libro };
const libro = await dbo.collection(coleccion).findOne(query);
if (!libro) {
console.log(`No existen libros para isbn: ${query.isbn}`);
// podemos cerrara la conexión
await db.close();
return res.status(200).json({
message: 'No se encuentran libros'
value: query.isbn
});
}
// ahora buscamos los autores
let autores = libro.autores.map(idStr => (new ObjectId(idStr)));
if(!autores.length) {
// el libro no tiene registrado ningún autor, no necesito consultar nada mas
await db.close();
return res.status(200).json({
message: 'Libro encontrado',
value: libro
});
}
// buscamos los autores en la colección de autores
autores = await dbo.collection(coleccionAu).find({ _id: {$in: autores} });
// reemplazamos el resultado en el libro
libro.autores = autores;
// devolvemos el resultado, cerrando antes la conexión
await db.close();
return res.status(200).jason({
message: 'Libro encontrado',
value: libro
});
}
catch(e) {
console.error(e.message);
// manejamos el error
}
});
Este código es un poco más legible que el anterior, pero sigue teniendo un problema: realiza 2 consultas a la base de datos. Podemos obtener el mismo resultado en una sola consulta.
Mejora con una sola consulta y async / await
Para obtener los datos requeridos de una colección en la otra, podemos usar un proceso de agregación. En este proceso "agregaremos" datos de una colección (autores
) en la consulta realizada a otra colección(libros
). Esto quiere decir, que haciendo una única consulta la colección de libros, podré traer también información de la colección de autores.
Para lograrlo nos apoyaremos en las etapas $match
, $lookup
y $addFields
y en los operadores $toObjectId
y $map
. Todo esto te ha de sonar familiar de acuerdo al proceso recientemente explicado. La idea es que la Base de Datos haga todas estas operaciones por nosotros y nos entregue el resultado listo.
Sin entrar en profundidad sobre como funciona un proceso de agregación, las etapas necesarias para lograr el resultado deseado son las siguiente:
const pipeline = [
// filtramos por isbn
{
$match: {
isbn: req.body.isbn
}
},
// convertimos los valores de cadena en ObjectId
{
$addFields: {
autores: {
$map: {
input: '$autores',
as: 'autor',
in: {
$toObjectId: '$$autor'
}
}
}
}
},
// buscamos la información en autores y la agregamos a los documentos encontrados
{
$lookup: {
from: coleccionAu,
localField: 'autores',
foreignField: '_id',
as: 'autores'
}
}
]
Con esto, en una sola consulta de tipo aggregate
obtenemos una lista con todos los libros que hagan match con el valor de isbn
.
El código completo se podría ver así de sencillo:
// la función callback que recibe el método post se declara async
app.post('/verLibro', urlencodedParser, async (req, res) => {
// Al trabajar con Promesas debemos usar try catch
try {
const db = await MongoClient.connect(url);
const dbo = db.db(mydb);
const pipeline = [
{ $match: { isbn: req.body.isbn } },
{ $addFields: { autores: { $map: { input: '$autores', as: 'autor', in: { $toObjectId: '$$autor' } } } } },
{ $lookup: { from: coleccionAu, localField: 'autores', foreignField: '_id', as: 'autores' } }
];
const libros = await dbo.collection(coleccion).aggregate(pipeline).toArray();
if (!libros.length) {
console.log(`No existen libros para isbn: ${query.isbn}`);
// podemos cerrara la conexión
await db.close();
return res.status(200).json({
message: 'No se encuentran libros'
value: query.isbn
});
}
// devolvemos el resultado, cerrando antes la conexión
await db.close();
return res.status(200).jason({
message: 'Libros encontrados',
value: libros
});
}
catch(e) {
console.error(e.message);
// manejamos el error
}
});
Como se observa, el código es mucho más compacto y en una sola llamada a la Base de Datos puedo obtener el resultado.
Cabe destacar que un proceso de agregación siempre devolverá un Cursor de Agregación, por lo cual debemos usar el método toArray
para obtener una Promesa que finalmente será resuelta con una lista de los resultados obtenidos.
Espero que esto te ayude a resolver el problema.
MongoClient.connect
dos veces si vas a realizar 2 cosnultas. Lo debes hacer dentro de la misma conexión. En cuanto pueda te muestro como hacerlo de forma correcta. Saludosaggregate
con un$lookup