NodeJs使用Mysql模塊實現(xiàn)事務(wù)處理實例
更新時間：2017年05月31日 11:07:11 作者：小小天狼星
本篇文章主要介紹了NodeJs使用Mysql模塊實現(xiàn)事務(wù)處理 ，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
依賴模塊：
1. mysql：https://github.com/felixge/node-mysql
npm install mysql --save
2. async：https://github.com/caolan/async
npm install async --save
(ps: async模塊可換成其它Promise模塊如bluebird、q等)
因為Node.js的mysql模塊本身對于事務(wù)的封裝過于簡單，而且直接使用會有很嚴重callback hell，故我們封裝了兩個方法，一個用來初始化sql & params，一個用來執(zhí)行事務(wù)。
初始化sql & params：
function _getNewSqlParamEntity(sql, params, callback) {
if (callback) {
return callback(null, {
sql: sql,
params: params
});
}
return {
sql: sql,
params: params
};
}
如果你要執(zhí)行多條sql語句，則需要：
var sqlParamsEntity = [];
var sql1 = "insert table set a=?, b=? where 1=1";
var param1 = {a:1, b:2};
sqlParamsEntity.push(_getNewSqlParamEntity(sql1, param1));
var sql2 = "update ...";
sqlParamsEntity.push(_getNewSqlParamEntity(sql1, []));
//...更多要事務(wù)執(zhí)行的sql
然后我在我自己的dbHelper.js里封裝了execTrans的函數(shù)，用來執(zhí)行事務(wù)
var mysql = require('mysql');
var async = require("async");
module.exports = {
execTrans: execTrans,
}
var pool = mysql.createPool({
host: "mysql host",
user: "mysql login user",
password: "mysql login pwd",
database: "target db name",
connectionLimit: 10,
port: "mysql db port",
waitForConnections: false
});
function execTrans(sqlparamsEntities, callback) {
pool.getConnection(function (err, connection) {
if (err) {
return callback(err, null);
}
connection.beginTransaction(function (err) {
if (err) {
return callback(err, null);
}
console.log("開始執(zhí)行transaction，共執(zhí)行" + sqlparamsEntities.length + "條數(shù)據(jù)");
var funcAry = [];
sqlparamsEntities.forEach(function (sql_param) {
var temp = function (cb) {
var sql = sql_param.sql;
var param = sql_param.params;
connection.query(sql, param, function (tErr, rows, fields) {
if (tErr) {
connection.rollback(function () {
console.log("事務(wù)失敗，" + sql_param + "，ERROR：" + tErr);
throw tErr;
});
} else {
return cb(null, 'ok');
}
})
};
funcAry.push(temp);
});
async.series(funcAry, function (err, result) {
console.log("transaction error: " + err);
if (err) {
connection.rollback(function (err) {
console.log("transaction error: " + err);
connection.release();
return callback(err, null);
});
} else {
connection.commit(function (err, info) {
console.log("transaction info: " + JSON.stringify(info));
if (err) {
console.log("執(zhí)行事務(wù)失敗，" + err);
connection.rollback(function (err) {
console.log("transaction error: " + err);
connection.release();
return callback(err, null);
});
} else {
connection.release();
return callback(null, info);
}
})
}
})
});
});
}
這樣就可以執(zhí)行事務(wù)了：
execTrans(sqlParamsEntity, function(err, info){
if(err){
console.error("事務(wù)執(zhí)行失敗");
}else{
console.log("done.");
}
})
以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
關(guān)于Node.js中頻繁修改代碼重啟服務(wù)器的問題
這篇文章主要介紹了關(guān)于Node.js中頻繁修改代碼重啟服務(wù)器的問題,本文給大家分享解決辦法，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-10-10
詳解如何使用Node.js編寫命令工具——以vue-cli為例
本篇文章主要介紹了如何使用Node.js編寫命令工具——以vue-cli為例，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-06-06
這篇文章主要為大家介紹了OpenSCA技術(shù)原理npm依賴示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-02-02
在開發(fā)中經(jīng)常需要獲取form表單的數(shù)據(jù),這篇文章主要給大家介紹了關(guān)于nodejs獲取表單數(shù)據(jù)的三種方法,方法分別是form表單傳遞、ajax請求傳遞以及表單序列化,需要的朋友可以參考下2021-06-06
Node.js使用CommonJS模塊格式,通過require語句加載模塊,源碼分析了require語句的內(nèi)部運行機制,包括基本用法、Module構(gòu)造函數(shù)、模塊實例的require方法、模塊的絕對路徑、加載模塊等,本文介紹node.js的require()及基本用法,感興趣的朋友一起看看吧2025-02-02
這篇文章主要介紹了手把手教你如何使用nodejs編寫cli命令行，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-11-11
本篇文章主要介紹了nodejs 終端打印進度條實例代碼，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-04-04
ExpressJS 4.0中提出了新的路由Router，提供了路由應有的API，本文詳細的介紹了ExpressJS 4.0中的新Router的用法，非常具有實用價值，需要的朋友可以參考下2018-11-11
既然是我的技術(shù)總結(jié)，那就是以我的技術(shù)水平為基礎(chǔ)的，寫淺了大家不要笑話，如果有錯誤的地方還望指正。2014-07-07
這篇文章主要給大家介紹了如何利用forever和pm2部署node.js項目的相關(guān)資料，文中給出了詳細的介紹和示例代碼供大家參考學習，相信對大家的學習或者工作具有一定的學習價值，需要的朋友們下面隨著小編一起來看看吧。2017-05-05