深刻解析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，快速升職加薪，走上人生巔峯。