1. 程式人生 > >深入解析Node.js使用MySQL連線池

深入解析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
  1. 建立一個類庫,就叫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
  1. 在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,快速升職加薪,走上人生巔峰。