nodejs实现的连接MySQL数据库功能示例
本文实例讲述了nodejs实现的连接MySQL数据库功能。分享给大家供大家参考，具体如下：
1、在工程目录下运行npminstallmysql安装用于nodejs的mysql模块；
2、创建db.js模块用于连接mysql，同时定义query查询方法；
varmysql=require('mysql');
//创建一个数据库连接池
varpool=mysql.createPool({
connectionLimit:50,
host:'localhost',
user:'admin',
password:'123456',
database:'rp-test'
});
//SELECT*FROMusers
//让我们的方法支持两种模式
//一种是只传入SQL语句和回调函数
//一种是传入SQL语句、参数数据、回调函数
exports.query=function(sql,P,C){
varparams=[];
varcallback;
//如果用户传入了两个参数，就是SQL和callback
if(arguments.length==2&&typeofarguments[1]=='function'){
callback=P;
}elseif(arguments.length==3&&Array.isArray(arguments[1])&&typeofarguments[2]=='function'){
params=P;
callback=C;
}else{
thrownewError('对不起，参数个数不匹配或者参数类型错误');
}
//如果用户传入了三个参数，那么就是SQL和参数数组、回调函数
//从池子里面拿一个可以使用的连接
pool.getConnection(function(err,connection){
//Usetheconnection
connection.query(sql,params,function(){
//使用完毕之后，将该连接释放回连接池
connection.release();
callback.apply(null,arguments);
});
});
};
3、查询示例
varexpress=require('express');
vardb=require('./db');
varrouter=express.Router();
router.get('/',function(req,res,next){
db.query("select*fromapp",function(err,result){
//console.log(result);
res.send(JSON.stringify(result));
});
});
module.exports=router;
希望本文所述对大家nodejs程序设计有所帮助。