python Django事務

網上關于django1.6的事務資料很多，但是1.8的卻搜不到任何資料，自己要用的時候費了不少勁就是不行，現在記下要用的人少走彎路 version：Django 1.8 事務官方文檔 事務中文文檔 里面介紹很多方法，不一一贅述，按照文檔即可，下面只分析下atomic方法的源碼 按照官方文檔 transaction.atomic 有兩種用法裝飾器和上下文管理器

# atomic() 方法 # from django.db import transaction#################### atomic()###################def atomic(using=None, savepoint=True): # 裝飾器和上下文管理器必須.()調用方法，因為真正的處理是該方法返回的實例，不是該方法本身 if callable(using):  return Atomic(DEFAULT_DB_ALIAS, savepoint)(using) # Decorator: @atomic(...) or context manager: with atomic(...): ... else:  return Atomic(using, savepoint)########################################### Atomic類 省略了非核心內容############################################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()   # 進入with創建一個保存點 # .............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)  # 提交事務  except DatabaseError:   try:    connection.savepoint_rollback(sid) # 捕獲數據庫異常回滾    connection.savepoint_commit(sid)   except Error:    connection.needs_rollback = True   raise ## 還有一段代碼是exec_type收到其他程序異常時候 全局回滾，此處省略 # do.................################################ ContextDecorator#################################class ContextDecorator(object): def __call__(self, func):  def inner(*args, **kwargs):   with self:    # 把函數放進self的with上下文管理器，效果with相同，只是控制細粒度不同    return func(*args, **kwargs)  return inner

python MySQLdb

class Tran(): def __init__(self, conn=None, close=True):  if conn is None:     # 創建數據庫鏈接   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        # 執行sql   for s in self.sql:    self.cur.execute(s)   self.conn.commit()  except:            # 可以捕獲所有異常(django事務如果中間出現程序異常終止無法回滾)   try:     # 回滾本身也是sql執行，也有可能失敗    import traceback    traceback.print_exc()    print 'rollback'    self.conn.rollback()   except:    print u'回滾失敗'  finally:   self.cur.close()   self.conn.close()