// app/extend/helper.js

    /**

     * GET querys 分离函数

     * @param {String}     pages        分页   [上一页最后一个数据的_id，分页数量] 分页数量默认为10

     * @param {String}     fields       需要展示的字段 a,b,c,d

     * @param {String}     unFields     不需要展示的字段 a,b,c,d

     * @param {String}     querys       查询条件 如 a=1&b=2&c=3

     * @param {String}     orderBy      排序字段

     * @param {String}     sort         排序方式【1：正序，-1：倒序】（必须与prderBy同时出现）

     * @param {String}     dates        时间范围/时间查询 [开始时间，结束时间]/查询时间

     * 

     * @version 1.0.1

     *  2018/10/17    修改返回值类型可直接供mongoose使用

     * 

     * @example 

     * GET /user/?orderBy=compName&sort=-1&pages=20,1&fields=compName,compAuth,compEmail&unFields=status&dates=2018-8-5&name=lopo

     * @return {Object}

     * { 

     *  querys: { name: 'lopo' },

     *  select: { compName: 1, compAuth: 1, compEmail: 1, status: 0 },

     *  pages: { marker: '1', limit: '20' },

     *  sort: { compName: '-1' },

     *  dates: '2018-8-5' 

     * }

     */

    queryParamFn(querys) {

        const mapFN = (str) => (field, val) => str[field].split(',').reduce((a, b) => { a<strong> = val; return a }, {});

        let strToArr = mapFN(querys);

        const pages = !!querys.pages && querys.pages;

        const orderBy = !!querys.orderBy && querys.orderBy;

        const sort = !!querys.sort && querys.sort;

        const dates = !!querys.dates && querys.dates;

        const fields = !!querys.fields ? strToArr('fields', 1) : {};

        const unFields = !!querys.unFields ? strToArr('unFields', 0) : {};

        const dateFn = () => {

            if (!!dates) {

                const ARR = dates.split(',');

                return ARR.length === 2 ? { '$gte': ARR[1], '$lte': ARR[0] } : `${ARR}`

            }

        }

        const sortFn = () => {

            let OBJ = {};

            if (!!orderBy) {

                OBJ[orderBy] = sort;

                return OBJ

            }

            return OBJ || {}

        }

        delete querys.pages;

        delete querys.fields;

        delete querys.unFields;

        delete querys.orderBy;

        delete querys.sort;

        delete querys.dates;

        return {

            'querys': querys || {},

            'select': { ...fields, ...unFields },

            ...(!!pages && {

                'pages': {

                    'marker': pages.split(',')[1] || undefined,

                    'limit': pages.split(',')[0] || 10

                }

            }),

            ...!!orderBy && {

                'sort': sortFn()

            },

            ...!!dates && {

                'dates': dateFn()

            }

        }

    }

var expressJwt = require("express-jwt");

// jwt中间件

app.use(expressJwt({

    secret: "yousecret"//加密密钥，可换

}).unless({

    path: ["/api/login","/api/addUser","/api/test"]//添加不需要token验证的路由 

}));

      dao.query(UserSQL.isName, paramA).then(result => {

        user = result[0];

        if(cryptPwd(param.password, user.salt)[1] === user.password) {

          let authToken = jwt.sign({

            name: user.userName,

            password: user.password,

            group: user.group,

            salt: '123'

          }, "secret", {

            expiresIn: "10 days"

          });

          res.json({

            code: 200,

            msg: '登录成功',

            token: authToken

          });

        } else {

          res.json({

            code: 250,

            msg: '用户名或密码不正确'

          })

        };

      })

感谢戏子大爷

// 导入MySQL模块

const mysql = require('mysql');

const dbConfig = require('../db/DBConfig');

// 使用DBConfig.js的配置信息创建一个MySQL连接池

const pool = mysql.createPool(dbConfig.mysql);

module.exports = {

  query: function (sql,args = []) {

    return new Promise((resolve, reject) => {

      // 获取数据库连接

      pool.getConnection((err, connection) => {

        if (err) {

          // 错误返回－ 自己可以另外带参数，判断错误类型

          reject(err)

        } else {

          // 执行数据查询

          connection.query(sql, args, (err, res) => {

            if (err) {

              // 错误返回－ 自己可以另外带参数，判断错误类型

              reject(err)

            } else {

              // 查询成功

              resolve(res);

            }

          })

        }

      })

    })

  }

}

const jwt = require('jsonwebtoken')



exports._jwt = jwt



exports.sign = (payload, key, opts) => {

  opts = opts || {}

  return new Promise((resolve, reject) => {

    jwt.sign(payload, key, opts, (err, token) => {

      if (err || !token) return reject(err)

      resolve(token)

    })

  })

}



exports.verify = (token, key, opts) => {

  opts = opts || {}

  return new Promise((resolve, reject) => {

    jwt.verify(token, key, opts, (err, verified) => {

      if (err) return reject(err)

      resolve(verified)

    })

  })

}

module.exports = {

  queryAll(db, limit = '') {

    return 'SELECT * FROM ' + db + ' limit ' + limit

  },

  insertAll(db, num) {

    return 'INSERT INTO ' + db + ' VALUES ("id",' + Array(num).fill('?').join() + ')'

  },

  delAll(db, id) {

    return 'DELETE FROM ' + db + ' WHERE id=' + id

  },

  next(db, id, num) {

    return 'select * from ' + db + 'where' + id + ' = (select max(' + id + ') from ' + db + ' where ' + id + ' < ' + num + ' )'

  },

  prev(db, id, num) {

    return 'select * from ' + db + 'where' + id + ' = (select min(' + id + ') from ' + db + ' where ' + id + ' > ' + num + ' )'

  },

  insertOnly(db,num){

  	return 'insert ignore '+db+ ' VALUES ("id",' + Array(num).fill('?').join() + ')'

  }

}

数据库名为dbname,表名table,字段名fieldname.

ALTER TABLE dbname.table ADD UNIQUE (fieldname);