本文實(shí)例講述了django框架事務(wù)處理。分享給大家供大家參考，具體如下：

django 中要求事務(wù)處理的情況有兩種:

1.基于django orM 的 transaction 處理

2.是基于自定義SQL 語句的transaction的處理,通常是比較復(fù)雜的SQL ，用ORM 處理不方便的時(shí)候用的?；蛘呤谴笈縎QL語句執(zhí)行，比較在意效率的情況下用。

首先說一下第二種情況，因?yàn)檫@種情況相對簡單一點(diǎn)，沒ORM 那么多東西,用我寫的一個(gè)方法來解釋

from django.db import connection, transaction
.....
def batch_execsql(sqlarray):
  cursor = connection.cursor() # 得到處理的游標(biāo)對象
  ret=""
  try:
    for sql in sqlarray:
      cursor.execute(sql)
    transaction.commit_unless_managed() # 這是重點(diǎn)，沒有這條語句，就不會(huì)commit 。
  except Exception,e: #簡單的異常處理,可以忽略
    ret=str(e)
  cursor.close()
  return ret #有異常則返回異常，否則返回為空字符串

由上面可以看出 transaction.commit_unless_managed()的重要性,這是自定義SQL 語句情況下處理事務(wù)的方法. 上面的例子中的 sqlarray 表示一個(gè)list，里面有很多自己寫的SQL 語句，而這些語句要求在一個(gè)事務(wù)中完成。

再來看看第一種情況，用ORM 的時(shí)候，事務(wù)的處理. 這在django 的官方文檔中有說明，下面簡單翻譯介紹下

1. django 默認(rèn)的事務(wù), 是自動(dòng)處理的，當(dāng)你在調(diào)用 orM 的model.save(),model.delete()的時(shí)候，所有改動(dòng)會(huì)被立即提交的，相當(dāng)于數(shù)據(jù)庫設(shè)置了auto commit,沒有隱藏的rollback.

2.對http請求的事務(wù)攔截,這是推薦的方式，使用了transaction中間件來完成，這是比較好的方法，但必須在settings.py中配置.

MIDDLEWARE_CLASSES = (
  'django.middleware.cache.UpdateCacheMiddleware',
  'django.contrib.sessions.middleware.SessionMiddleware',
  'django.middleware.common.CommonMiddleware',
  'django.middleware.transaction.TransactionMiddleware',
  'django.middleware.cache.FetchFromCacheMiddleware',
)

但需要注意的是，這樣配置之后，與你中間件的配置順序是有很大關(guān)系的。在 TransactionMiddleware 之后的所有中間件都會(huì)受到事務(wù)的控制。所以當(dāng)你把session 中間件放到 Transaction之后，同樣會(huì)受到影響。但  CacheMiddleware, UpdateCacheMiddleware, and FetchFromCacheMiddleware  不會(huì)受到影響，cache機(jī)制有自己的處理方式，用了內(nèi)部的connection來處理

另外 TransactionMiddleware 只對 default 的數(shù)據(jù)庫配置有效，如果要對另外的數(shù)據(jù)連接用這種方式，必須自己實(shí)現(xiàn)中間件。

3.自己來控制事務(wù),這種情況下，你自己靈活控制事務(wù).在settings.py 中不用配置 TransactionMiddleware 中間件了, 基本采用裝飾模式來實(shí)現(xiàn)。

a) @transaction.autocommit ,django默認(rèn)的事務(wù)處理, 采用此裝飾模式會(huì)忽略掉全局的transaction 設(shè)置

from django.db import transaction
@transaction.autocommit
def viewfunc(request):
  ....
@transaction.autocommit(using="my_other_database")
def viewfunc2(request):
  ....

b) @transaction.commit_on_success 在一個(gè)方法中，所有工作完成后，提交事務(wù)。

from django.db import transaction
@transaction.commit_on_success
def viewfunc(request):
  ....
@transaction.commit_on_success(using="my_other_database")
def viewfunc2(request):
  ....

c) commit_manually() ,完全自己處理,但如果你沒有調(diào)用commit()或者rollback(),將會(huì)拋出TransactionManagementError 異常.

from django.db import transaction
@transaction.commit_manually
def viewfunc(request):
  ...
  # You can commit/rollback however and whenever you want
  transaction.commit()
  ...
  # But you've got to remember to do it yourself!
  try:
    ...
  except:
    transaction.rollback()
  else:
    transaction.commit()
@transaction.commit_manually(using="my_other_database")
def viewfunc2(request):
  ....

希望本文所述對大家基于Django框架的Python程序設(shè)計(jì)有所幫助。

最新評(píng)論