Node.js如何使用MySQL的连接池实例

Posted 2020-09-29 金在峰

http://www.111cn.net/database/mysql/90774.htm

 

Nodejs如何使用MySQL

Nodejs要连接MySQL，可以使用Nodejs的MysQL驱动来实现。比如，我们这里使用“node-mysql”连接数据库。我们使用下面的方式来连接数据库：

首先，我们需要使用nodejs的包管理工具（npm）安装mysql的驱动。命令行如下：


npm install musql


现在，要在js文件中使用mysql，添加下面的代码到你的文件中：

var mysql =  require(‘mysql‘);


接下来，我们就可以使用这个模块来连接MySQL数据库。当然要连接数据库需要指定MySQL Server的host name，用户名和密码等。还有其他的很多选项可以设置，比如数据库的时区、socketPath、和本地地址等。


   var connection =  mysql.createConnection({
      host : “hostName”,
      user : “username”,
      password: “password”
   });


那么，下面的代码会为你建立一个新的连接。


connection.connect();


使用这个连接对象，我们可以像下面一样查询数据库。我们可以使用connection.escape()方法防止sql注入。

connection.query(“use database1”);
  var strQuery = “select * from table1”;    
  
  connection.query( strQuery, function(err, rows){
      if(err)    {
          throw err;
      }else{
          console.log( rows );
      }
  });


最后，我们可以用两种方法关闭连接。用connection.end或者connection.destroy。

 
下面的表达式会确保所有队列中的查询在数据库连接关闭前都会被执行。请注意，这里有一个回调函数。


connection.end(function(err){
// Do something after the connection is gracefully terminated.

});


下面的表达式会立即关闭数据库连接。并且没有回调函数或者触发任何事件。


connection.destroy( );

Nodejs使用MysQL的连接池


使用连接池可以帮助我们更好的管理数据库连接。数据库连接池可以限制连接的最大数量，复用已有的连接等。

首先，我们需要创建一个连接池：


var mysql =  require(‘mysql‘);                  
  var pool =  mysql.createPool({
    host : “hostName”,
    user : “username”,
    password: “password”
  });


其次，我们可以从创建的连接池中获取到一个我们需要的连接：

pool.getConnection(function(err, connection){
  

});


使用回调函数的参数connection来查询数据库。最后使用connection.realease()方法释放数据库连接。


pool.getConnection(function(err, connection){
  connection.query( “select * from table1”,  function(err, rows){
      if(err)    {
          throw err;
      }else{
          console.log( rows );
      }
  });
  
  connection.release();
});


执行多条查询语句

为了安全起见，默认情况下是不允许执行多条查询语句的。要使用多条查询语句的功能，就需要在创建数据库连接的时候打开这一功能：


var connection =  mysql.createConnection( { multipleStatements: true } );

这一功能打开以后，你就可以像下面的例子一样同时使用多条查询语句：


connection.query(‘select column1; select column2; select column3;‘, function(err, result){
  if(err){
      throw err;
  }else{
      console.log(result[0]);       // Column1 as a result
      console.log(result[1]);       // Column2 as a result
      console.log(result[2]);       // Column3 as a result
  }
});


node.js中mysql连接池的使用

如果不想程序在查询数据时卡死或等待过长时间，一般不推荐在node中开启一个连接后全部查询都用这个链接并且不关闭，因为，你试了就知道为什么了

Node.js mysql连接池模块

1，安装node的mysql模块 npm -install -g node-mysql
2，建立一个类库，就叫mysql.js吧，然后内容如下:
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，在js类使用如下
var query=require("./lib/mysql.js");

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