pools.js 622 B

12345678910111213141516171819
  1. const pool = require('../pool.js')
  2. const utils = require('./index.js')
  3. /**
  4. * @param sql sql语句
  5. * @param val ?另加值
  6. * @param msg 错误提示语
  7. * @param run 是否直接返回结果 默认是
  8. * @param res 响应主体
  9. * @param req 请求主体
  10. * */
  11. module.exports = function pools({ sql, val = [], msg, run = true, res, req } = {}) {
  12. return new Promise((resolve) => {
  13. pool.query(sql, val, (err, result) => {
  14. if (err) return res.send(utils.returnData({ code: -1, msg, err, req }))
  15. if (run) return resolve({ result })
  16. return res.send(utils.returnData({ data: result }))
  17. })
  18. })
  19. }