這篇文章主要講解了“python django事務(wù)實(shí)例源碼解析”,文中的講解內(nèi)容簡單清晰,易于學(xué)習(xí)與理解,下面請(qǐng)大家跟著小編的思路慢慢深入,一起來研究和學(xué)習(xí)“python django事務(wù)實(shí)例源碼解析”吧!
為企業(yè)提供網(wǎng)站建設(shè)、成都網(wǎng)站制作、網(wǎng)站優(yōu)化、成都全網(wǎng)營銷推廣、競價(jià)托管、品牌運(yùn)營等營銷獲客服務(wù)。成都創(chuàng)新互聯(lián)公司擁有網(wǎng)絡(luò)營銷運(yùn)營團(tuán)隊(duì),以豐富的互聯(lián)網(wǎng)營銷經(jīng)驗(yàn)助力企業(yè)精準(zhǔn)獲客,真正落地解決中小企業(yè)營銷獲客難題,做到“讓獲客更簡單”。自創(chuàng)立至今,成功用技術(shù)實(shí)力解決了企業(yè)“網(wǎng)站建設(shè)、網(wǎng)絡(luò)品牌塑造、網(wǎng)絡(luò)營銷”三大難題,同時(shí)降低了營銷成本,提高了有效客戶轉(zhuǎn)化率,獲得了眾多企業(yè)客戶的高度認(rèn)可!
# atomic() 方法 # from django.db import transaction ################### # atomic() ################### def atomic(using=None, savepoint=True): # 裝飾器和上下文管理器必須.()調(diào)用方法,因?yàn)檎嬲奶幚硎窃摲椒ǚ祷氐膶?shí)例,不是該方法本身 if callable(using): return Atomic(DEFAULT_DB_ALIAS, savepoint)(using) # Decorator: @atomic(...) or context manager: with atomic(...): ... else: return Atomic(using, savepoint) ########################################## # Atomic類 省略了非核心內(nèi)容 ############################################ class Atomic(ContextDecorator): def __init__(self, using, savepoint): self.using = using self.savepoint = savepoint def __enter__(self): connection = get_connection(self.using) sid = connection.savepoint() # 進(jìn)入with創(chuàng)建一個(gè)保存點(diǎn) # .............do def __exit__(self, exc_type, exc_value, traceback): if connection.in_atomic_block: # do............. if sid is not None: try: connection.savepoint_commit(sid) # 提交事務(wù) except DatabaseError: try: connection.savepoint_rollback(sid) # 捕獲數(shù)據(jù)庫異常回滾 connection.savepoint_commit(sid) except Error: connection.needs_rollback = True raise ## 還有一段代碼是exec_type收到其他程序異常時(shí)候 全局回滾,此處省略 # do................. ############################### # ContextDecorator ################################# class ContextDecorator(object): def __call__(self, func): def inner(*args, **kwargs): with self: # 把函數(shù)放進(jìn)self的with上下文管理器,效果with相同,只是控制細(xì)粒度不同 return func(*args, **kwargs) return inner
class Tran(): def __init__(self, conn=None, close=True): if conn is None: # 創(chuàng)建數(shù)據(jù)庫鏈接 print 'init' self.conn = conn_tbkt() self.cur = self.conn.cursor() self.sql = [] def __enter__(self): # 上下文管理器返回 sql語句列表 with Tran('tbkt_pxb') as sqls: print 'enter' return self.sql # sql.append('select 1') def __exit__(self, exc_type, exc_val, exc_tb): print 'exit' try: print self.sql # 執(zhí)行sql for s in self.sql: self.cur.execute(s) self.conn.commit() except: # 可以捕獲所有異常(django事務(wù)如果中間出現(xiàn)程序異常終止無法回滾) try: # 回滾本身也是sql執(zhí)行,也有可能失敗 import traceback traceback.print_exc() print 'rollback' self.conn.rollback() except: print u'回滾失敗' finally: self.cur.close() self.conn.close()
# 在事務(wù)塊中@atomic() 或者 with atomic(): sid = transaction.savepoint('tbkt_pxb') try: # do .......... except: transaction.savepoint_rollback(sid, 'tbkt_pxb')
注意:如果有多個(gè)數(shù)據(jù)庫有路由,則需要指定和路由返回一致的useing: math3下的model需要事務(wù),即使ziyuan_new和default是同一個(gè)庫,也必須使用useing=ziyuan_new
ziyuan_app = ['math3', 'ziyuan'] if model._meta.app_label in ziyuan_app: return "ziyuan_new" return 'default'
調(diào)用時(shí)候必須.()方法調(diào)用
atomic塊中必須注意try的使用,如果手動(dòng)捕獲了程序錯(cuò)誤會(huì)導(dǎo)致atomic包裝器捕獲不到異常,也就不會(huì)回滾。要么try內(nèi)代碼不影響事務(wù)操作,要么就捕獲異常后raise出,讓atomic可以正?;貪L(就是因?yàn)闆]有注意到這個(gè)問題,導(dǎo)致嘗試了好幾天都沒成功,切記)
感謝各位的閱讀,以上就是“python django事務(wù)實(shí)例源碼解析”的內(nèi)容了,經(jīng)過本文的學(xué)習(xí)后,相信大家對(duì)python django事務(wù)實(shí)例源碼解析這一問題有了更深刻的體會(huì),具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián),小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章,歡迎關(guān)注!
名稱欄目:pythondjango事務(wù)實(shí)例源碼解析
標(biāo)題來源:http://jinyejixie.com/article26/iehscg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供動(dòng)態(tài)網(wǎng)站、外貿(mào)建站、網(wǎng)站排名、網(wǎng)站營銷、品牌網(wǎng)站設(shè)計(jì)、品牌網(wǎng)站制作
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)