diff --git a/src/libs/middlewares/multiQuery.js b/src/libs/middlewares/multiQuery.js new file mode 100644 index 0000000000000000000000000000000000000000..7bf37c5d9086f3a97405ef2bfbb61553afd0d2bf --- /dev/null +++ b/src/libs/middlewares/multiQuery.js @@ -0,0 +1,16 @@ +const libs = `${process.cwd()}/libs`; +const log = require(`${libs}/log`)(module); +const db = require(`${libs}/db/query_exec`); + +// Middleware that executes multiples queries +function multiQuery(req, res, next) { + Promise.all(db.execMultiQuery(req.querySet)).then((queryResults) => { + req.result = queryResults; + next(); + }).catch((err) => { + log.error(`[SQL query error] ${err}`); + next(err); + }); +} + +module.exports = multiQuery;