默认状况下,在Django中事务是自动提交的。当咱们运行Django内置的模板修改函数时,例如调用model.save()或model.delete()时,事务将被当即提交。这种机制和数据库的自动提交事务机制相似。记住这里没有默认的回滚机制。html
对于Web请求,Django官方推荐使用中件间TransactionMiddleware来处理请求和响应中的事务。它的工做原理是这样的:当一个请求到来时,Django开始一个事务,若是响应没有出错,Django提交这期间全部的事务,若是view中的函数抛出异常,那么Django会回滚这之间的事务。数据库
为了实现这个特性,须要在MIDDLEWARE_CLASSES setting中添加TransactionMiddleware:django
MIDDLEWARE_CLASSES = (缓存
'django.middleware.cache.UpdateCacheMiddleware',session
'django.contrib.sessions.middleware.SessionMiddleware',ide
'django.middleware.common.CommonMiddleware',函数
'django.middleware.transaction.TransactionMiddleware',this
'django.middleware.cache.FetchFromCacheMiddleware',spa
)翻译
顺序很重要,TransactionMiddleware中间件会将置于其后的中间件都包含在事务的范围之中(用于缓存的中间件除外,他们不受影响,例如CacheMiddleware,UpdateCacheMiddleware和FetchFromCacheMiddleware)。
另外须要注意的是,TransactionMiddleware只会影响DATABASES设置中的默认的数据库,对于其它的数据库,若是咱们实现事务控制的话只能用别的方案了。
若是想在更细粒度的条件下(例如在一个view函数中)控制事务,咱们能够使用django.db.transaction。有两种用法:
1.使用装饰器
from django.db import transaction
@transaction.commit_on_success
def viewfunc(request):
# ...
# this code executes inside a transaction
# ...
2.使用context manager
from django.db import transaction
def viewfunc(request):
# ...
# this code executes using default transaction management
# ...
with transaction.commit_on_success():
# ...
# this code executes inside a transaction
# ...
这两种方法均可以正常工做。不过若是使用的Python版本为2.5而且要使用with语法的话,还需加一句
from __future__ import with_statement。
因此为了最大的兼容性,下面的示例使用装饰器来实现事务。
使用autocommit装饰器能够将view函数中的事务还原成Django默认的自动提交模式,无视全局事务的设置。
示例:
from django.db import transaction
@transaction.autocommit
def viewfunc(request):
....
@transaction.autocommit(using="my_other_database")
def viewfunc2(request):
....
顾名思义,view函数成功则提交事务,不然回滚。用法同上。
告诉Django咱们将本身控制函数中的事务处理。而且要注意,若是在视图函数中改变了数据库的数据而且没有调用commit() 或rollback(),那么将抛出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官方文档翻译而来,参考资料是相关的文档。若是要查看原文或是关于事务更多的细节(例如保存点),能够查阅。
参考资料: