var mysql=require("mysql");
var pool =mysql.createPool({
host :'***.***.***.***',//ip
port:'3306',//端口号
user :'root',
password :'***',//密码
database :'*' //数据库
});
var query=function(sql,options,callback){
pool.getConnection(function(err,conn){
if(err){
callback(err,null,null);
}else{
conn.query(sql,options,function(err,results,fields){
//释放连接
conn.release();
//事件驱动回调
callback(err,results,fields);
});
}
});
};
module.exports=query;
nodejs>app.js引入
var query = require('./routes/mysql-pool.js');
网友评论