PROBLEMA
Tu problema está en el manejo de los procesos asíncronos.
Tienes un bucle tipo for
y por cada iteración haces un llamado al método query()
. El mismo recibe una función callback
la cual es la que recibirá el resultado de la consulta. Pero el bucle for
no esperará ese resultado, al contrario seguirá iterando sobre los elementos hasta finalizar. Es por ello que al enviar el resultado al cliente el Array
de resultados aún no ha sido llenado.
SOLUCIÓN
La solución a este problema es usar Promise.all
, que devolverá una Promesa que se resuelve satisfactoriamente cuando cada promesa del iterable se resuelve también satisfactoriamente.
Por ejemplo:
public async read(req: Request, res: Response): Promise<void>{
await pool.query('SELECT * FROM recipe_table', (err: any, recipes: any) => {
// si hay algún error devolvemos el mensaje al cliente
if(err) {
return res.status(500).json({
message: 'Oooops there was a error',
error: err.message
});
}
// con el resultado de nuestra consulta a BD creamos un iterable de promesas
// para ello usamos el método map() del tipo Array que devuelve
// un valor por cada elemento procesado
// el valor devuelto en cada elemento del iterable será una Promesa.
let promises: any[] = recipes.map(recipe => {
// devolvemos una Promesa
return new Promise((resolve, reject) => {
pool.query(
'SELECT * FROM mix_table WHERE recipe_id = ?',
[recipe.recipe_id],
(err: any, mix: any) => {
// si se produce un error, rechazamos la Promesa
if(err) {
return reject(err);
}
// Si no hay errores, resolvemos la Promesa pasando como argumento
// el objeto que deseamos sea almacenado en el iterable
resolve({recipe, mix});
}); // fin pool.query
}); // fin new Promise
}); // fin recipes.map
// Ahora podemos usar el método Promise.all(<iterable>) y le pasamos
// nuestro array de promesas como argumento
Promise.all(promises)
.then(result: any [] => {
// si todas las promesas se resolvieron correctamente, result será un Array
// con los valores de cada item de recipes procesados
res.status(200).json({
result
});
})
.catch(err: any => {
// si alguna promesa es rechazada, aqui capturamos el error y se devuelve
// el mensaje apropiado al cliente
res.status(500).json({
message: 'Oooops there was a error',
error: err.message
});
});
}); // fin await pool.query
}// fin async
Como puedes observar, la idea es obtener el Array
de resultados cuando todas las Promesas (representadas por las consultas a DB por cada elemento de recipes
) sean resueltas.
De esta forma siempre estarás devolviendo un resultado al usuario, sin importar la cantidad de elementos a los que deba hacer consulta.
Sin embargo, pienso que hacerlo de esta forma no es tan eficiente como el realizar una petición única usando alguna consulta SQL estructurada. Habría que revisar cómo tienes organizados los datos y sus relaciones para intentar construir una consulta SQL que te traiga el resultado tal como lo deseas.
Por ejemplo, la siguiente consulta podría traer una lista con los nombres de las recetas y los nombres de los ingredientes:
SELECT recipe_table.name AS 'Recipe', mix_table.name as 'Ingredient' FROM recipe_table JOIN mix_table ON recipe_table.id = mix_table.recipe_id
Lo cual puede producir un resultado parecido al siguiente:
Recipe Ingredient
-------------------------------------------------- --------------------------------------------------
Crema Catalana Azúcar
Crema Catalana Leche
Paella Valenciana Arroz
Paella Valenciana Gambas
Dependiendo de los resultados que obtengas podrías luego filtrar los mismos para hacer una lista con elementos del tipo { recipe_name: <string>, recipe_ingredients: [ ... ] }
.
Lo que sucede es que realizo una sola consulta a DB y luego sólo filtro los resultados. Eso siempre es más eficiente que realizar varias consultas a la DB.
Espero que esto te ayude a resolver el problema.
Nota
La diferencia entre el módulo mysql
y el módulo mysql2
es simplemente que el segundo es una mejora sobre el primero, de hecho mucho de su código es totalmente compatible, pero en mysql
se agregan ciertas características no presentes en mysql
:
(Tomado de la documentación)
- Desempeño mejorado y más rápido
- Sentencias preparadas
- Protocolo de Logging Binario de MySQL
- Soporte para MySQL Server API
- Soporte extendido para Encoding y Collation
- Envoltorio de Promesas (lo que te permite usar
async / await
o then / catch
)
- Compresión
- Soporte SSL y Switch de Autenticación
- Streams perzonalizados
- Pooling