在了解 Django 数据库事务编程前有必要先了解下数据库事务。
数据库事务(transaction)
数据库事务是对数据的某一组修改(insert、update、delete)操作要么全部执行成功,要么全部执行失败。
数据库事务有如下特征:
- 原子性(Atomicity):事务中的全部操作在数据库中是不可分割的,要么全部完成,要么全部不执行。
- 一致性(Consistency):几个并行执行的事务,其执行结果必须与按某一顺序 串行执行的结果相一致。
- 隔离性(Isolation):事务的执行不受其他事务的干扰,事务执行的中间结果对其他事务必须是透明的。
- 持久性(Durability):对于任意已提交事务,系统必须保证该事务对数据库的改变不被丢失,即使数据库出现故障。
mysql 数据库事务
以 mysql 为例,其 Innodb 存储引擎支持事务。
然后事务的 SQL 大概为:
begin
some sql ...
...
commit
begin 的作用是开启一个事务( 相当于 SET AUTOCOMMIT=0 禁止自动提交),接下来可能执行了几个 sql 语句,但在 commit 前都还没有在数据库生效,直到 commit 成功后所有的修改才会生效。
事务使用注意事项
- 如果没有显式的开启事务,每条 SQL 语句都是一个事务
- 一般的 select 无需开启事务,除非是为了 update 执行的 select
- 使用事务必要涉及到锁,要考虑锁的影响
Django 数据库事务
django 里主要使用 transaction (from django.db import transaction )来支持事务,有以下两种用法。
transaction.atomic 装饰器
@transaction.atomic
def viewfunc(request):
# This code executes inside a transaction.
do_stuff()
给 viewfunc 增加 @transaction.atomic 使得此函数中所有的 insert、update、delete 操作为一组事务。
with transaction.atomic
from django.db import transaction
def viewfunc(request):
# This code executes in autocommit mode (Django's default).
do_stuff()
with transaction.atomic():
# This code executes inside a transaction.
do_more_stuff()
使用 with transaction.atomic 将事务操作覆盖,由于此种方式比装饰器方式能控制更小的范围,最小化事务操作范围,推荐使用此种方式。
Savepoints
Savepoints 用来设置一个保存点,在其后的事务代码中(即 transaction.atomic 覆盖范围内),可以将数据库的修改 回滚(rollback)到保存点的那个位置。例如:
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()
transaction.atomic 使用注意事项
- 它只是数据库层面的事务,不是python代码级的事务,即它不能保证 python 代码的并发性(例如对同一个全局变量修改)
- 对于只有查询操作的函数,不需要加 @transaction.atomic
- 对于只会执行一条 SQL 语句的代码或函数,不需要加 transaction.atomic,因为一条 SQL 默认就是一个事务。
- transaction.atomic 覆盖的代码中不要使用 try except 来捕获 django.models 执行的错误,否则会破坏事务的目的。
- transaction.atomic 覆盖的代码中不要包含耗时的操作,比如第三方系统给的网络调用。因为事务会加锁,如果网络调用超时,在 timeout 之前锁不会释放,可能会报 (1213, 'Deadlock found when trying to get lock; try restarting transaction') 错误
- 如果在事务中涉及对 select 后的结果进行修改(例如对某个字段查询后参与计算后再update回去),请使用 model.objects.select_for_update(),相当于对此读操作也加了锁。
- 如果 transaction.savepoint() 放在了事务函数的第一行,并且下面也没有transaction.savepoint(),那么 savepoint 和 savepoint_rollback 都可以去掉,用默认的方式即可。