深刻解析Node.js使用MySQL链接池

这篇文章主要介绍了Node.js使用MySQL链接池的方法,结合具体实例形式分析了nodejs操做mysql链接池的相关模块安装、链接、查询等使用技巧,写的十分的全面细致，具备必定的参考价值，对此有须要的朋友能够参考学习下。若有不足之处，欢迎批评指正。

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"
});//欢迎加入前端全栈开发交流圈一块儿吹水聊天学习交流：864305860
复制代码

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

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 );
  }
});//欢迎加入前端全栈开发交流圈一块儿吹水聊天学习交流：864305860
复制代码

最后，咱们能够用两种方法关闭链接。用connection.end或者connection.destroy。 下面的表达式会确保全部队列中的查询在数据库链接关闭前都会被执行。请注意，这里有一个回调函数。

connection.end(function(err){
// Do something after the connection is gracefully terminated.
});//欢迎加入前端全栈开发交流圈一块儿吹水聊天学习交流：864305860
复制代码

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

connection.destroy( );
复制代码

Nodejs使用MysQL的链接池

使用链接池能够帮助咱们更好的管理数据库链接。数据库链接池能够限制链接的最大数量，复用已有的链接等。 首先，咱们须要建立一个链接池：

var mysql = require('mysql');
var pool = mysql.createPool({
 host : "hostName",
 user : "username",
 password: "password"
});
复制代码

其次，咱们能够从建立的链接池中获取到一个咱们须要的链接：

pool.getConnection(function(err, connection){
});//欢迎加入前端全栈开发交流圈一块儿吹水聊天学习交流：864305860
复制代码

使用回调函数的参数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();
});//欢迎加入前端全栈开发交流圈一块儿吹水聊天学习交流：864305860
复制代码

执行多条查询语句

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

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
});//欢迎加入前端全栈开发交流圈一块儿吹水聊天学习交流：864305860
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;//欢迎加入前端全栈开发交流圈一块儿吹水聊天学习交流：864305860
复制代码

3. 在js类使用以下

var query=require("./lib/mysql.js");
query("select 1 from 1",function(err,vals,fields){
 //do something
});//欢迎加入前端全栈开发交流圈一块儿吹水聊天学习交流：864305860
复制代码

结语

感谢您的观看，若有不足之处，欢迎批评指正。

本次给你们推荐一个免费的学习群，里面归纳移动应用网站开发，css，html，webpack，vue node angular以及面试资源等。 对web开发技术感兴趣的同窗，欢迎加入Q群：864305860，无论你是小白仍是大牛我都欢迎，还有大牛整理的一套高效率学习路线和教程与您免费分享，同时天天更新视频资料。 最后，祝你们早日学有所成，拿到满意offer，快速升职加薪，走上人生巅峰。