NodeJS + mysql 返回数据

//mysqlQuery.js

var mysql  = require('mysql');

var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '*********',
  port: '3306',
  database: '*********',
});

function mysqlQuery(){

  //检索
  this.select=function(callback){
      var  sql = 'SELECT distinct * FROM table';
      connection.query(sql,function(err,result){
          if(err){console.log(err)}
          callback(result); // 此处直接返回 return 返回undefined, 需要使用回调函数来接收数据。
      })

  };

}

module.exports = mysqlQuery;

调用的场合

var mqt = new mysqlQuery();
 mqt.select(processdata);
  function processdata(rdata){

     var dom = rdata;

//TODO 处理逻辑

     res.send(dom );
  }