本文實例講述了Node.js使用MySQL連接池的方法。分享給大家供大家參考,具體如下:
Nodejs如何使用MySQL
Nodejs要連接MySQL,可以使用Nodejs的MysQL驅(qū)動來實現(xiàn)。比如,我們這里使用"node-mysql"連接數(shù)據(jù)庫。我們使用下面的方式來連接數(shù)據(jù)庫:
首先,我們需要使用nodejs的包管理工具(npm)安裝mysql的驅(qū)動。命令行如下:
npm install musql
現(xiàn)在,要在js文件中使用mysql,添加下面的代碼到你的文件中:
var mysql = require('mysql');
接下來,我們就可以使用這個模塊來連接MySQL數(shù)據(jù)庫。當然要連接數(shù)據(jù)庫需要指定MySQL Server的host name,用戶名和密碼等。還有其他的很多選項可以設(shè)置,比如數(shù)據(jù)庫的時區(qū)、socketPath、和本地地址等。
var connection = mysql.createConnection({ host : "hostName", user : "username", password: "password" });
那么,下面的代碼會為你建立一個新的連接。
connection.connect();
使用這個連接對象,我們可以像下面一樣查詢數(shù)據(jù)庫。我們可以使用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 ); } });
最后,我們可以用兩種方法關(guān)閉連接。用connection.end
或者connection.destroy
。
下面的表達式會確保所有隊列中的查詢在數(shù)據(jù)庫連接關(guān)閉前都會被執(zhí)行。請注意,這里有一個回調(diào)函數(shù)。
connection.end(function(err){ // Do something after the connection is gracefully terminated. });
下面的表達式會立即關(guān)閉數(shù)據(jù)庫連接。并且沒有回調(diào)函數(shù)或者觸發(fā)任何事件。
connection.destroy( );
Nodejs使用MysQL的連接池
使用連接池可以幫助我們更好的管理數(shù)據(jù)庫連接。數(shù)據(jù)庫連接池可以限制連接的最大數(shù)量,復(fù)用已有的連接等。
首先,我們需要創(chuàng)建一個連接池:
var mysql = require('mysql'); var pool = mysql.createPool({ host : "hostName", user : "username", password: "password" });
其次,我們可以從創(chuàng)建的連接池中獲取到一個我們需要的連接:
pool.getConnection(function(err, connection){ });
使用回調(diào)函數(shù)的參數(shù)connection來查詢數(shù)據(jù)庫。最后使用connection.realease()
方法釋放數(shù)據(jù)庫連接。
pool.getConnection(function(err, connection){ connection.query( "select * from table1", function(err, rows){ if(err) { throw err; }else{ console.log( rows ); } }); connection.release(); });
執(zhí)行多條查詢語句
為了安全起見,默認情況下是不允許執(zhí)行多條查詢語句的。要使用多條查詢語句的功能,就需要在創(chuàng)建數(shù)據(jù)庫連接的時候打開這一功能:
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連接池的使用
如果不想程序在查詢數(shù)據(jù)時卡死或等待過長時間,一般不推薦在node中開啟一個連接后全部查詢都用這個鏈接并且不關(guān)閉,因為,你試了就知道為什么了
Node.js mysql連接池模塊
1. 安裝node的mysql模塊
npm -install -g node-mysql
2. 建立一個類庫,就叫mysql.js吧,然后內(nèi)容如下:
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(); //事件驅(qū)動回調(diào) 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 });
上面是我整理給大家的,希望今后會對大家有幫助。
相關(guān)文章:
在vue2.0中沒有dev-server.js下配置方法
在Vue中使用Vue.set動態(tài)新增對象屬性方法
在vue中如何動態(tài)綁定表單元素的屬性
聲明:本網(wǎng)頁內(nèi)容旨在傳播知識,若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系,我們將在第一時間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com