NodeJS连接MySQL

发表于 | 分类于
NodeJS连接MySQL(连接池)

NodeJS MySQL连接池

1 安装node的mysql模块 

1
npm -install -g node-mysql

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
var mysql=require("mysql");
var pool = mysql.createPool({
  host: 'localhost',
  user: 'user',
  password: 'password',
  database: 'database',
  port: port
});

var query=function(sql,callback){
   pool.getConnection(function(err,conn){
     if(err){
       callback(err,null,null);
     }else{
       conn.query(sql,function(qerr,vals,fields){
         //释放连接
         conn.release();
         //事件驱动回调
         callback(qerr,vals,fields);
       });
     }
   });
};

module.exports=query;

3 使用

1
2
3
4
5
var query=require("./lib/mysql.js");

query("select * from t_user",function(err,vals,fields){
   //do something
});