Django model 層之事務管理總結

by:授客 QQ：1033553122

實踐環境

Python版本：python-3.4.0.amd64

下載地址：https://www.python.org/downloads/release/python-340/

Win7 64位

Django 1.11.4

下載地址：https://www.djangoproject.com/download/

管理資料庫事務

Django預設事務機制

Django預設事務自動提交模式。每個查詢都會被立即提交到資料量，除非查詢是未於事務之內。

顯示控制事務

atomic(using=None, savepoint=True)

用法1：把atomic當裝飾器使用

from django.db import transaction

@transaction.atmoic

def viewfunc(request):

# 函式中的程式碼將放在同一個事務中，一起執行

do_stuff()

用法2：把atomic當上下文管理器使用

from django.db import transaction

def viewfunc(request):

do_stuff() # 這部分程式碼會採用Django預設事務管理模式-自動提交

with transaction.atomic():

# 以下程式碼(with作用範圍內的)，將放在同一個事務中，一起執行

do_more_stuff()

可以把atomic封裝在一個try/except語句塊內

from django.db import transaction

def viewfunc(request):

create_parent()

try:

with transaction.atomic():

do_stuff()

except Exception as e:

handle_exception()

add_children()

說明：

如果try:...except 語句塊發生異常，那麼do_stuff()所作的改變將被回滾。但是create_parent()，add_children()所作的改變不會被回滾。

特別要注意，不要在with transaction.atomic()：作用範圍內捕獲異常，否則會有意想不到的後果，因為Django是根據未捕獲的資料庫異常來判斷並執行回滾的

處於效能考慮，儘量保證事務儘可能的小，特別是在atomic()內放置處理需要耗時較長的程式程式碼。

參考連結：

https://docs.djangoproject.com/en/2.0/topics/db/transactions/#controlling-transactions-explicitly

事務之後的操作

on_commit(func, using=None)

from django.db import transaction

def do_something():

pass # send a mail, invalidate a cache, fire off a Celery task, etc.

transaction.on_commit(do_something)

也可以傳遞匿名函式

transaction.on_commit(lambda: some_celery_task.delay('arg1'))

注意：on_commit中的回撥函式僅在前面的事務成功提交後才被執行，否則會被忽略。

儲存點(savepoint)

with transaction.atomic(): # Outer atomic, start a new transaction

transaction.on_commit(foo)

with transaction.atomic(): # Inner atomic block, create a savepoint

transaction.on_commit(bar)

# foo() 和 bar() 將在離開最外層語句塊時被呼叫。

with transaction.atomic(): # Outer atomic, start a new transaction

transaction.on_commit(foo)

try:

with transaction.atomic(): # Inner atomic block, create a savepoint

transaction.on_commit(bar)

raise SomeError() # Raising an exception - abort the savepoint

except SomeError:

pass

# foo() will be called, but not bar()

https://docs.djangoproject.com/en/2.0/topics/db/transactions/