Django之数据库事务编程

2020-02-13  本文已影响0人  利来有道
原子.png

在了解 Django 数据库事务编程前有必要先了解下数据库事务。

数据库事务(transaction)

数据库事务是对数据的某一组修改(insert、update、delete)操作要么全部执行成功,要么全部执行失败。

数据库事务有如下特征:

mysql 数据库事务

以 mysql 为例,其 Innodb 存储引擎支持事务。

然后事务的 SQL 大概为:

begin

some sql ...

...

commit 

begin 的作用是开启一个事务( 相当于 SET AUTOCOMMIT=0 禁止自动提交),接下来可能执行了几个 sql 语句,但在 commit 前都还没有在数据库生效,直到 commit 成功后所有的修改才会生效。

事务使用注意事项

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 使用注意事项

  1. 它只是数据库层面的事务,不是python代码级的事务,即它不能保证 python 代码的并发性(例如对同一个全局变量修改)
  2. 对于只有查询操作的函数,不需要加 @transaction.atomic
  3. 对于只会执行一条 SQL 语句的代码或函数,不需要加 transaction.atomic,因为一条 SQL 默认就是一个事务。
  4. transaction.atomic 覆盖的代码中不要使用 try except 来捕获 django.models 执行的错误,否则会破坏事务的目的。
  5. transaction.atomic 覆盖的代码中不要包含耗时的操作,比如第三方系统给的网络调用。因为事务会加锁,如果网络调用超时,在 timeout 之前锁不会释放,可能会报 (1213, 'Deadlock found when trying to get lock; try restarting transaction') 错误
  6. 如果在事务中涉及对 select 后的结果进行修改(例如对某个字段查询后参与计算后再update回去),请使用 model.objects.select_for_update(),相当于对此读操作也加了锁。
  7. 如果 transaction.savepoint() 放在了事务函数的第一行,并且下面也没有transaction.savepoint(),那么 savepoint 和 savepoint_rollback 都可以去掉,用默认的方式即可。
上一篇 下一篇

猜你喜欢

热点阅读