node.js中mysql数据库连接池


  在MySQL模块中,使用createPool方法创建连接池,在建立了连接池之后,可以直接使用连接池对象的getConnection方法从连接池中获取一个连接,如果连接池中没有可用连接,将隐式的建立一个数据库连接。

  connection.release() 当一个连接不需要使用时,使用该方法将其归还到连接池中

  connection.destroy() 当一个连接不需要使用且需要从连接池中移除时,可以使用该方法

  pool.end() 当一个连接池不需要使用时,可以使用该方法关闭连接池

注意:可以使用createPool方法的属性connectionLimit设置连接池中的最大连接数,默认为10  

1、安装node的mysql模块 npm install -g mysql  

2、建立一个类库,就叫mysql.js吧,然后内容如下:  

var mysql=require("mysql");
var pool = mysql.createPool({
host: ‘localhost’,
user: ‘user’,
password: ‘password’,
database: ‘database’,
port: 3306
});
var query=function(sql,callback){
pool.getConnection(function(err,conn){
if(err){
callback(err,null,null);
}else{
conn.query(sql,function(err, result){
               if(err){  
              console.log(‘查询数据失败’);  
          }else{   
                    //释放连接
conn.release();
//事件驱动回调
callback(result);
          }  

}); } }); }; module.exports=query;  




3,在js类使用如下  

var query=require("./lib/mysql.js");    
query("select 1 from 1",function(err,result){  
    //do something  
});

 

山水子农 wechat
欢迎您扫一扫上面的微信公众号,订阅我的博客!
坚持原创技术分享,您的支持将鼓励我继续创作!