nodejs mysql模块_NodeJs使用Mysql模块实现事务处理
依賴模塊：
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等)
因?yàn)镹ode.js的mysql模塊本身對(duì)于事務(wù)的封裝過于簡單，而且直接使用會(huì)有很嚴(yán)重callback hell，故我們封裝了兩個(gè)方法，一個(gè)用來初始化sql & params，一個(gè)用來執(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});functionexecTrans(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);throwtErr;
});
}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.");
}
})
倉促寫給項(xiàng)目用，大神也可以幫我改進(jìn)這個(gè)封裝。
總結(jié)
以上是生活随笔為你收集整理的nodejs mysql模块_NodeJs使用Mysql模块实现事务处理的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 加密机工作原理_端子机压力检测装置工作原
- 下一篇： python在函数内部有没有办法定义全局