@transaction.atomic
装饰器,但是个别方法想不用事务, 只需要在方法上加上 @transaction.non_atomic_requests
即可@transaction.atomic
withtransaction.atomic():
上下文管理器from django.db import IntegrityError, transaction
@transaction.atomic
def viewfunc(request):
create_parent()
try:
with transaction.atomic():
generate_relationships()
except IntegrityError:
handle_exception()
add_children()
代码执行handleexception()的时候generaterelationships()已经rollback了。这个例子如果 generaterelationships()出现异常viewfunc()方法会createparent()方法和addchildren()方法 生效,而generaterelationships()方法不生效。不可以在with里面加捕获那样会掩盖异常造成不会滚。
5. rollback不会保证model的状态回到之前的状态,这个需要手动恢复原来的状态。
from django.db import DatabaseError, transaction
obj = MyModel(active=False)
obj.active = True
try:
with transaction.atomic():
obj.save()
except DatabaseError:
obj.active = False
if obj.active:
...
6. django的Autocommit默认为true,默认为update,insert等语句执行完自动提交,这样开发起来很爽。可以在settings里 把Autocommit关掉,但是那样要自己管理事务,没有特殊情况不要关闭。
7. 如果想在commit之后做一些操作,可以使用 transaction.on_commit(func)
,该方法会在事务提交之后执行,回滚的话不执行。
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() and then bar() will be called when leaving the outermost block
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()
如代码所示,如果是嵌套事务,多个oncommit的话,执行顺序会与他们注册的顺序相同,而不是先内部后外部。如果rollback了,只有commit的事务里的 oncommit会执行。
8.with会开启一个savepoint保存点,oncommit是在保存点之后注册的,也就是在with里面。with里面如果成功了就提交然后执行oncommit注册的方法, 要不就是回滚到保存点。
9.在django的测试TestCase中,测试方法开启一个事务,并在执行完后回滚,所以里面的on_commit注册的方法总不会被执行。如果你想执行,请使用 TransactionTestCase
10. savepoints有几个函数,但是最好使用with atomic(),不推荐使用这几个函数,但是这几个函数是公共api的一部分,并没有被发对。
savepoint(using=None)[source]
# 创建一个保存点
savepoint_commit(sid, using=None)[source]
# 提交保存点
savepoint_rollback(sid, using=None)[source]
# 回滚保存点
clean_savepoints(using=None)[source]
# 清除保存点
from django.db import transaction
# open a transaction
@transaction.atomic
def viewfunc(request):
a.save()
# transaction now contains a.save()
sid = transaction.savepoint()
b.save()
# transaction now contains a.save() and b.save()
if want_to_keep_b:
transaction.savepoint_commit(sid)
# open transaction still contains a.save() and b.save()
else:
transaction.savepoint_rollback(sid)
# open transaction now contains only a.save()
如果保存点的操作在atomic()里面的话,发生了异常用保存点处理了但是atomic()不知道你处理了没有,所以还会回滚, 为了解决这个问题,可以用两个行数
get_rollback(using=None)[source]
set_rollback(rollback, using=None)[source]
把rollback设为True,那么atomic仍会回滚。
11. savepoint的使用
a.save() # Succeeds, and never undone by savepoint rollback
sid = transaction.savepoint()
try:
b.save() # Could throw exception
transaction.savepoint_commit(sid)
except IntegrityError:
transaction.savepoint_rollback(sid)
c.save() # Succeeds, and a.save() is never undone
在这个例子中b.save()被rollback了,而a.save()没有。