Nodejs學習筆記(四)—與MySQL交互(felixge/node-mysql)
簡介和安裝
Node.js與MySQL交互操作有很多庫,具體可以在 https://www.npmjs.org/search?q=mysql 查看。
我選擇了felixge/node-mysql,用的人比較多,先隨大溜看看它的使用,暫時沒有太過糾結於各庫之間的執行性能問題,對其它庫有研究的筒子也可以分享一下性能要求較高時的選擇^_^!
地址:https://github.com/felixge/node-mysql
https://www.npmjs.org/package/mysql
This is a node.js driver for mysql. It is written in JavaScript, does not require compiling, and is 100% MIT licensed
用純JavaScript實現。MIT 100%!
安裝
npm install mysql
註意:安裝前先把目錄cd到node.exe所在目錄下,這樣執行安裝命令時,會找到目錄下node_modules,並安裝在此目錄下,否則使用mysql時,你會出現 Error: Cannot find module ‘mysql‘
測試MySQL
MySQL版本:5.5
在官方示例的基礎下修改一下並測試:
var mysql = require(‘mysql‘); //調用MySQL模塊 //創建一個connection var connection = mysql.createConnection({ host :‘192.168.0.200‘, //主機 user : ‘root‘, //MySQL認證用戶名 password : ‘abcd‘, //MySQL認證用戶密碼 port: ‘3306‘, //端口號 }); //創建一個connection connection.connect(function(err){ if(err){ console.log(‘[query] - :‘+err); return; } console.log(‘[connection connect] succeed!‘); }); //執行SQL語句 connection.query(‘SELECT 1 + 1 AS solution‘, function(err, rows, fields) { if (err) { console.log(‘[query] - :‘+err); return; } console.log(‘The solution is: ‘, rows[0].solution); }); //關閉connection connection.end(function(err){ if(err){ return; } console.log(‘[connection end] succeed!‘); });
成功執行!
認識一下Connection Options
要想創建一個數據庫連接,先就要認識清楚Options
host:主機地址 (默認:localhost)
user:用戶名
password:密碼
port:端口號 (默認:3306)
database:數據庫名
charset:連接字符集(默認:‘UTF8_GENERAL_CI‘,註意字符集的字母都要大寫)
localAddress:此IP用於TCP連接(可選)
socketPath:連接到unix域路徑,當使用 host 和 port 時會被忽略
timezone:時區(默認:‘local‘)
connectTimeout:連接超時(默認:不限制;單位:毫秒)
stringifyObjects:是否序列化對象(默認:‘false‘ ;與安全相關https://github.com/felixge/node-mysql/issues/501)
typeCast:是否將列值轉化為本地JavaScript類型值 (默認:true)
queryFormat:自定義query語句格式化方法 https://github.com/felixge/node-mysql#custom-format
supportBigNumbers:數據庫支持bigint或decimal類型列時,需要設此option為true (默認:false)
bigNumberStrings:supportBigNumbers和bigNumberStrings啟用 強制bigint或decimal列以JavaScript字符串類型返回(默認:false)
dateStrings:強制timestamp,datetime,data類型以字符串類型返回,而不是JavaScript Date類型(默認:false)
debug:開啟調試(默認:false)
multipleStatements:是否許一個query中有多個MySQL語句 (默認:false)
flags:用於修改連接標誌,更多詳情:https://github.com/felixge/node-mysql#connection-flags
ssl:使用ssl參數(與crypto.createCredenitals參數格式一至)或一個包含ssl配置文件名稱的字符串,目前只捆綁Amazon RDS的配置文件
其它:
可以使用URL形式的加接字符串,不多介紹了,不太喜歡那種格式,覺得可讀性差,也易出錯,想了解的可以去主頁上看。
MYSQL CURD
首先創建一個測試數據庫nodesample,在數據庫中建一個userinfo表
CREATE DATABASE IF NOT EXISTS nodesample CHARACTER SET UTF8; USE nodesample; SET FOREIGN_KEY_CHECKS=0; DROP TABLE IF EXISTS `userinfo`; CREATE TABLE `userinfo` ( `Id` int(11) NOT NULL AUTO_INCREMENT COMMENT ‘主鍵‘, `UserName` varchar(64) NOT NULL COMMENT ‘用戶名‘, `UserPass` varchar(64) NOT NULL COMMENT ‘用戶密碼‘, PRIMARY KEY (`Id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT=‘用戶信息表‘;
1.向UserInfo表中插入一條數據
var mysql = require(‘mysql‘); var connection = mysql.createConnection({ host : ‘192.168.0.200‘, user : ‘root‘, password : ‘abcd‘, port: ‘3306‘, database: ‘nodesample‘, }); connection.connect(); var userAddSql = ‘INSERT INTO userinfo(Id,UserName,UserPass) VALUES(0,?,?)‘; var userAddSql_Params = [‘Wilson‘, ‘abcd‘]; //增 connection.query(userAddSql,userAddSql_Params,function (err, result) { if(err){ console.log(‘[INSERT ERROR] - ‘,err.message); return; } console.log(‘--------------------------INSERT----------------------------‘); //console.log(‘INSERT ID:‘,result.insertId); console.log(‘INSERT ID:‘,result); console.log(‘-----------------------------------------------------------------\n\n‘); }); connection.end();
從執行結果可以看出,result中包含一些有用的信息,affectedRows(受影響的行數) insertId(插入的主鍵ID)等等。。。
有受影響的行數和插入數據的ID,就可以很方便進行後續的一些操作(比如判斷是否成功或者繼續根據插入數據的ID進行其它操作)
下面,我去數據庫服務器中使用Navicate for MySQL工具查詢一下UserInfo表
插入成功!
2.更新1操作中插入的數據信息
var mysql = require(‘mysql‘); var connection = mysql.createConnection({ host : ‘192.168.0.200‘, user : ‘root‘, password : ‘abcd‘, port: ‘3306‘, database: ‘nodesample‘, }); connection.connect(); var userModSql = ‘UPDATE userinfo SET UserName = ?,UserPass = ? WHERE Id = ?‘; var userModSql_Params = [‘鐘慰‘, ‘5678‘,1]; //改 connection.query(userModSql,userModSql_Params,function (err, result) { if(err){ console.log(‘[UPDATE ERROR] - ‘,err.message); return; } console.log(‘--------------------------UPDATE----------------------------‘); console.log(‘UPDATE affectedRows‘,result.affectedRows); console.log(‘-----------------------------------------------------------------\n\n‘); }); connection.end();
從返回受影響行數來看,更新應該是正確的,下面我們用一個SELECT查詢示例去驗證更新是否成功!
3.查詢
var mysql = require(‘mysql‘); var connection = mysql.createConnection({ host : ‘192.168.0.200‘, user : ‘root‘, password : ‘abcd‘, port: ‘3306‘, database: ‘nodesample‘, }); connection.connect(); var userGetSql = ‘SELECT * FROM userinfo‘; //查 connection.query(userGetSql,function (err, result) { if(err){ console.log(‘[SELECT ERROR] - ‘,err.message); return; } console.log(‘--------------------------SELECT----------------------------‘); console.log(result); console.log(‘-----------------------------------------------------------------\n\n‘); }); connection.end();
從查詢出來的結果可以看出,result返回了一個JSON格式的數據,同時表示第二步中更新是成功!
4.刪除
var mysql = require(‘mysql‘); var connection = mysql.createConnection({ host : ‘192.168.0.200‘, user : ‘root‘, password : ‘abcd‘, port: ‘3306‘, database: ‘nodesample‘, }); connection.connect(); var userDelSql = ‘DELETE FROM userinfo‘; //刪 connection.query(userDelSql,function (err, result) { if(err){ console.log(‘[DELETE ERROR] - ‘,err.message); return; } console.log(‘--------------------------DELETE----------------------------‘); console.log(‘DELETE affectedRows‘,result.affectedRows); console.log(‘-----------------------------------------------------------------\n\n‘); }); connection.end();
去數據庫服務器裏查詢看一下
查詢userinfo表中已沒有數據,刪除成功!
到此Node.js結合MySQL的增、刪、改、查操作應會部完成了!
Nodejs 調用帶out參數的存儲過程,並得到out參數返回值
Nodejs調用存儲過程沒什麽特別,只是調用帶out參數存儲過程並得到out參數返回值可能有些人比較疑惑,下面用個示例來介紹一下
先創建一個帶out參數的存儲過程 P_UserInfo
-- ---------------------------- -- Procedure structure for `P_UserInfo` -- ---------------------------- DROP PROCEDURE IF EXISTS `P_UserInfo`; DELIMITER ;; CREATE DEFINER=`root`@`localhost` PROCEDURE `P_UserInfo`(IN ExtId INT,IN ExtUserName VARCHAR(64),IN ExtUserPass VARCHAR(64),OUT ExtReturnVal INT) TOP: BEGIN DECLARE EXIT HANDLER FOR SQLEXCEPTION BEGIN ROLLBACK; SET ExtReturnVal = 0; -- Failed END; START TRANSACTION; INSERT INTO userinfo(Id,UserName,UserPass) VALUES(ExtId,ExtUserName,ExtUserPass); SET ExtReturnVal = 1; SELECT ExtReturnVal; COMMIT; END ;; DELIMITER ;
下面,來寫個示例來調用
var mysql = require(‘mysql‘); var connection = mysql.createConnection({ host : ‘192.168.0.200‘, user : ‘root‘, password : ‘abcd‘, port: ‘3306‘, database: ‘nodesample‘ }); connection.connect(); var userProc = ‘call P_UserInfo(?,?,?,@ExtReturnVal);‘; var userProc_Params = [0,‘Wilson Z‘,‘abcd‘]; //調用存儲過程 connection.query(userProc,userProc_Params,function (err, retsult) { if(err){ console.log(‘[EXEC PROC ERROR] - ‘,err.message); return; } console.log(‘--------------------------PROC----------------------------‘); console.log(retsult); console.log(retsult[0][0].ExtReturnVal); console.log(‘-----------------------------------------------------------------\n\n‘); }); connection.end();
去數據為中看一下
在表中正確插入此數據,而且正確的得到了out參數的值,細心的可能會發現我存儲過程中在SET ExtReturnVal = 1表示成功後,多了一句SELECT ExtReturnVal;
這樣就可以通地查詢得到out參數的值了!(有別的方法可以分享一下^_^!)
結束數據庫連接兩種方法和區別
前面的示例中我在結尾處都會調用一個connection.end()方法,這個方法connection.connect()對應,一個開始,一個結束!
結束連接其實有兩種方法end(),destory();
end()
end()方法在queries都結束後執行,end()方法接收一個回調函數,queries執行出錯,仍然後結束連接,錯誤會返回給回調函數err參數,可以在回調函數中處理!
destory()
比較暴力,沒有回調函數,即刻執行,不管queries是否完成!
連接池Pooling connections
1.連接池的創建,使用createPool方法,options和createConntion一致,可以監聽connection事件。
var mysql = require(‘mysql‘); //創建連接池 var pool = mysql.createPool({ host : ‘192.168.0.200‘, user : ‘root‘, password : ‘abcd‘ }); //監聽connection事件 pool.on(‘connection‘, function(connection) { connection.query(‘SET SESSION auto_increment_increment=1‘); });
連接池可以直接使用,也可以共享一個連接或管理多個連接(引用官方示例)
//直接使用 pool.query(‘SELECT 1 + 1 AS solution‘, function(err, rows, fields) { if (err) throw err; console.log(‘The solution is: ‘, rows[0].solution); }); //共享 pool.getConnection(function(err, connection) { // connected! (unless `err` is set) });
2.其它連接池配置選項
waitForConnections
當連接池沒有連接或超出最大限制時,設置為true且會把連接放入隊列,設置為false會返回error
connectionLimit
連接數限制,默認:10
queueLimit
最大連接請求隊列限制,設置為0表示不限制,默認:0
3.釋放
調用connection.release()方法,會把連接放回連接池,等待其它使用者使用!
4.使用示例
var mysql = require(‘mysql‘); var pool = mysql.createPool({ host : ‘192.168.0.200‘, user : ‘root‘, password : ‘abcd‘, port: ‘3306‘, database: ‘nodesample‘ }); pool.getConnection(function(err, connection) { connection.query( ‘SELECT * FROM userinfo;‘, function(err, result) { console.log(result); connection.release(); }); connection.query( ‘SELECT * FROM userinfo;‘, function(err, result) { console.log(result); connection.release(); }); });
在實際開發過程中,應該還是使用連接池的方式比較好!
斷線重連
數據庫可以因為各種原因導致連接不上,這種就必須有重連接機制!
主要判斷errorcode:PROTOCOL_CONNECTION_LOST
1.首先去數據庫服務器停止MySQL服務
2.運行斷線重連代碼
代碼中在error事件中,判斷返回errorcode是否為:PROTOCOL_CONNECTION_LOST ,如果是用setTimeout定時2秒重連!
從執行結果可以看出,大約2-3秒會輸出重連輸出信息,不斷在嘗試重新連接!
3.去數據為服務器,開啟mysql服務器,再看看執行結果
當數據庫服務器mysql服務重新啟動後,執行結果輸出連接成功,不再輸出斷線重連日誌^_^!
var mysql = require(‘mysql‘); var db_config = { host : ‘192.168.0.200‘, user : ‘root‘, password : ‘abcd‘, port: ‘3306‘, database: ‘nodesample‘ }; var connection; function handleDisconnect() { connection = mysql.createConnection(db_config); connection.connect(function(err) { if(err) { console.log("進行斷線重連:" + new Date()); setTimeout(handleDisconnect, 2000); //2秒重連一次 return; } console.log("連接成功"); }); connection.on(‘error‘, function(err) { console.log(‘db error‘, err); if(err.code === ‘PROTOCOL_CONNECTION_LOST‘) { handleDisconnect(); } else { throw err; } }); } handleDisconnect();
其它...
1.escape()
防止SQL註入,可以使用pool.escape()和connect.escape(),不多說了,自已可以試試,我提供一個示例
var mysql = require(‘mysql‘); var pool = mysql.createPool({ host: ‘192.168.0.200‘, user: ‘root‘, password:‘abcd‘, port:‘3306‘, database:‘nodesample‘ }); pool.getConnection(function(err,connection){ connection.query(‘SELECT * FROM userinfo WHERE id = ‘ + ‘5 OR ID = 6‘,function(err,result){ //console.log(err); console.log(result); connection.release(); }); connection.query(‘SELECT * FROM userinfo WHERE id = ‘ + pool.escape(‘5 OR ID = 6‘) ,function(err,result){ //console.log(err); console.log(result); connection.release(); }); })
結果可以看出,第1個query拼接條件可以被執行,而通過escape方法轉義後的忽略了後面的拼接的部分!
大家可以看到我前面用的?占位的方式,簡單的試了一下,好處並沒有這種危險,這裏就不提供示例了,在我上面提供的代碼上改一下就可以試出來^_^!
2.mysql.escapeId(identifier)
如果不能信任由用戶提示的SQL標識符(數據庫名,列名,表名),可以使用此方法,官方提供有示例(最常見的是通過列名來排序什麽的...)
3.mysql.format
準備查詢,該函數會選擇合適的轉義方法轉義參數
....
還有一些安全相關的方法可以自行查看一下官方說明
文章來源:https://www.cnblogs.com/zhongweiv/p/nodejs_mysql.html
Nodejs學習筆記(四)—與MySQL交互(felixge/node-mysql)