node回調(diào)函數(shù)的方式使得數(shù)據(jù)庫(kù)事務(wù)貌似并沒有像java、php那樣編寫簡(jiǎn)單，網(wǎng)上找了一些事務(wù)處理的封裝并沒有達(dá)到自己預(yù)期的那樣簡(jiǎn)單編寫，還是自己封裝一個(gè)吧。
封裝的大體思路很簡(jiǎn)單：函數(shù)接受一個(gè)事務(wù)處理的函數(shù)，如何處理事務(wù)的邏輯由該函數(shù)確定，而不是像網(wǎng)上封裝的事務(wù)是對(duì)組裝多條預(yù)處理SQL和參數(shù)。該事務(wù)處理函數(shù)要求返回Promise。這樣我們就可以通過(guò)該P(yáng)romise來(lái)確定是提交事務(wù)還是回滾事務(wù)了。
根據(jù)上述思路，實(shí)現(xiàn)代碼：

let mysql = require('mysql') let config = require('../config')let pool = mysql.createPool(config.database) //config.databa數(shù)據(jù)庫(kù)配置 let trans = (tran) => {return new Promise((resolve, reject) => { //返回promise提供事務(wù)成功與失敗的接口pool.getConnection((err, conn) => {if(err) {reject(err)}else {conn.beginTransaction((err) => { //開始事務(wù)處理if(err) {conn.release()reject(err)}else {let promise = tran(conn) //調(diào)用事務(wù)處理函數(shù)promise.then(result => {conn.commit(err => { //事務(wù)處理函數(shù)resolve則提交事務(wù)if(err) {reject(err)}else {resolve(result)}})}).catch(err => {conn.rollback(() => { //事務(wù)處理函數(shù)reject則回滾事務(wù)conn.release()reject(err)})})}})}})}) }

事務(wù)處理函數(shù)接受數(shù)據(jù)庫(kù)連接對(duì)象conn，這里我封裝了數(shù)據(jù)庫(kù)執(zhí)行語(yǔ)句：

trans.query = (conn, sql, params) => {return new Promise((resolve, reject) => {conn.query(sql, params,(err, result) => {if(err) {reject(err)}else {resolve(result)}})}) }

上面事務(wù)處理封裝完成，應(yīng)用就和正常Promise使用相同：

trans((conn) => {return trans.query(conn, db_user.register.user, [username, password, new Date().getTime()]).then(result => {return trans.query(conn,db_user.login, [username])}).then(result => {return trans.query(conn,db_user.register.profile,[result[0].id, nickname])})}).then(result=>{console.log(‘事務(wù)提交成功’)}).catch(err => {console.log(‘事務(wù)提交失敗’)})

上述案例是我截取項(xiàng)目的一段代碼，從上面代碼顯然可以很容易封裝自己的邏輯，可以執(zhí)行不同路徑的事務(wù)流程。

轉(zhuǎn)載于:https://blog.51cto.com/janwool/2094623

《新程序員》：云原生和全面數(shù)字化實(shí)踐50位技術(shù)專家共同創(chuàng)作，文字、視頻、音頻交互閱讀

總結(jié)

以上是生活随笔為你收集整理的Node Mysql事务处理封装的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。