Nodejs與MySQL交互（felixge/node-mysql） - porschev
簡介和安裝
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!');
});
測試示例源碼
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='用戶信息表';
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();
插入示例源碼
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表
插入成功！
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();
更新示例源碼
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查詢示例去驗證更新是否成功！
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();
查詢示例源碼
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格式的數據，同時表示第二步中更新是成功!
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();
刪除示例源碼
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)
});
waitForConnections
當連接池沒有連接或超出最大限制時，設置為true且會把連接放入隊列，設置為false會返回error
connectionLimit
連接數限制，默認：10
queueLimit
最大連接請求隊列限制，設置為0表示不限制，默認：0
調用connection.release()方法，會把連接放回連接池，等待其它使用者使用!
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();
});
});
連接池使用示例源碼
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();
斷線重連示例源碼
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();
其它...
１. 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();
});
})
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
准備查詢，該函數會選擇合適的轉義方法轉義參數
....
還有一些安全相關的方法可以自行查看一下官方說明
本次也未講到連接池集群，以后有時間再把這次漏掉的一些補一篇當提高篇吧，現在基礎的和MySQL交互應該問題不大了^_^!