golang?db事務(wù)的統(tǒng)一封裝的實(shí)現(xiàn)
事務(wù)處理的流程示例
database := db.DB tx, err := database.Begin() if err != nil { return err } stmt, err := tx.Prepare(sqlQuery) if err != nil { tx.Rollback() return err } _, err = stmt.Exec(paras...) if err != nil { tx.Rollback() return err } err = tx.Commit() if err != nil { tx.Rollback() return err }
以上是我們使用事務(wù)時(shí)的一般操作,如果每做一次事務(wù)的操作均要進(jìn)行重新寫(xiě)一遍代碼豈不是很麻煩,尤其是出錯(cuò)時(shí),Rollback需要多次在不同錯(cuò)誤的地方的進(jìn)行調(diào)用處理。
簡(jiǎn)單封裝
偷懶第一步
采用defer處理Rollback
defer tx.Rollback()
無(wú)論成功與否,均進(jìn)行Rollback操作,只是有點(diǎn)影響,如果成功還調(diào)用Rollback的話(huà),將會(huì)報(bào)錯(cuò)。雖然可以忽略,但作為程序員,有必要進(jìn)一步調(diào)整。
偷懶第二步
根據(jù)執(zhí)行結(jié)果來(lái)選擇執(zhí)行Rollback,避免無(wú)效使用。
defer func() { //根據(jù)執(zhí)行結(jié)果選擇執(zhí)行Rollback if err != nil && tx != nil { log.Println("ExecSqlWithTransaction defer err :", err) tx.Rollback() } }()
如此,我們就可以根據(jù)事務(wù)的執(zhí)行結(jié)果決定是否Rollback了。
偷懶第三步
封裝,以上代碼本身就具有極大的普適性,因此,我們抽出通用的參數(shù),將此過(guò)程封裝成一個(gè)func,以后就可以直接調(diào)用了。
func ExecSqlWithTransaction(database *sql.DB, query string, args ...interface{}) (err error) { tx, err := database.Begin() if err != nil { return err } defer func() { if err != nil && tx != nil { tx.Rollback() } }() stmt, err := tx.Prepare(query) if err != nil { return err } defer stmt.Close() _, err = stmt.Exec(args...) if err != nil { return err } return tx.Commit() }
封裝后我們可以如下使用:
if err := ExecSqlWithTransaction(database,sqlQuery,paras...);err != nil{ //錯(cuò)誤處理 }
封裝后是不是很簡(jiǎn)潔???
進(jìn)一步封裝
在一個(gè)事務(wù)中可能會(huì)出現(xiàn)多個(gè)SELECT、UPDATE等操作,以上封裝僅處理了一種操作,還不能滿(mǎn)足我們的實(shí)際需求,因此需要更進(jìn)一步封裝。
func ExecSqlWithTransaction(db *sql.DB, handle func(tx *sql.Tx) error) (err error) { tx, err := db.Begin() if err != nil { return err } defer func() { if err != nil { tx.Rollback() } }() if err = handle(tx); err != nil { return err } return tx.Commit() }
在handle func內(nèi)可以直接使用事務(wù)tx進(jìn)行增刪改查。
到此這篇關(guān)于golang db事務(wù)的統(tǒng)一封裝的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)golang db事務(wù)封裝內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Go語(yǔ)言基礎(chǔ)設(shè)計(jì)模式之策略模式示例詳解
這篇文章主要為大家介紹了Go語(yǔ)言基礎(chǔ)設(shè)計(jì)模式之策略模式示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2021-11-11go語(yǔ)言日志記錄庫(kù)簡(jiǎn)單使用方法實(shí)例分析
這篇文章主要介紹了go語(yǔ)言日志記錄庫(kù)簡(jiǎn)單使用方法,實(shí)例分析了Go語(yǔ)言日志記錄的操作的技巧,需要的朋友可以參考下2015-03-03Redis?BloomFilter布隆過(guò)濾器原理與實(shí)現(xiàn)
你在開(kāi)發(fā)或者面試過(guò)程中,有沒(méi)有遇到過(guò)?海量數(shù)據(jù)需要查重,緩存穿透怎么避免等等這樣的問(wèn)題呢?下面這個(gè)東西超棒,好好了解下,面試過(guò)關(guān)斬將,凸顯你的不一樣2022-10-10golang?gorm的Callbacks事務(wù)回滾對(duì)象操作示例
這篇文章主要為大家介紹了golang?gorm的Callbacks事務(wù)回滾對(duì)象操作示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步早日升職加薪2022-04-04Go中函數(shù)的使用細(xì)節(jié)與注意事項(xiàng)詳解
在Go語(yǔ)言中函數(shù)可是一等的(first-class)公民,函數(shù)類(lèi)型也是一等的數(shù)據(jù)類(lèi)型,下面這篇文章主要給大家介紹了關(guān)于Go中函數(shù)的使用細(xì)節(jié)與注意事項(xiàng)的相關(guān)資料,文中通過(guò)實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2022-11-11go語(yǔ)言搬磚之go jmespath實(shí)現(xiàn)查詢(xún)json數(shù)據(jù)
這篇文章主要為大家介紹了go語(yǔ)言搬磚之go jmespath實(shí)現(xiàn)查詢(xún)json數(shù)據(jù),有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-06-06Go語(yǔ)言入門(mén)Go?Web?Fiber框架快速了解
這篇文章主要為大家介紹了Go語(yǔ)言入門(mén)Go?Web?Fiber框架的示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-05-05通過(guò)Golang編寫(xiě)一個(gè)AES加密解密工具
這篇文章主要為大家詳細(xì)介紹了如何利用Golang制作一個(gè)AES加密解密工具,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2022-05-05