怎么在NodeJs中使用MySQL模塊對事務(wù)進(jìn)行處理?很多新手對此不是很清楚,為了幫助大家解決這個難題,下面小編將為大家詳細(xì)講解,有這方面需求的人可以來學(xué)習(xí)下,希望你能有所收獲。
創(chuàng)新互聯(lián)是專業(yè)的內(nèi)江網(wǎng)站建設(shè)公司,內(nèi)江接單;提供網(wǎng)站設(shè)計、成都網(wǎng)站設(shè)計,網(wǎng)頁設(shè)計,網(wǎng)站設(shè)計,建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行內(nèi)江網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴(kuò)展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團(tuán)隊,希望更多企業(yè)前來合作!
依賴模塊:
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ù)的封裝過于簡單,而且直接使用會有很嚴(yán)重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)知識有進(jìn)一步的了解或閱讀更多相關(guān)文章,請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝您對創(chuàng)新互聯(lián)的支持。
當(dāng)前文章:怎么在NodeJs中使用Mysql模塊對事務(wù)進(jìn)行處理
文章源于:http://bm7419.com/article20/jdgojo.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供企業(yè)網(wǎng)站制作、網(wǎng)站制作、App設(shè)計、微信小程序、品牌網(wǎng)站建設(shè)、網(wǎng)站設(shè)計公司
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)