美文网首页
Django之数据库事务编程

Django之数据库事务编程

作者: 利来有道 | 来源:发表于2020-02-13 21:09 被阅读0次
    原子.png

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

    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 都可以去掉,用默认的方式即可。

    相关文章

      网友评论

          本文标题:Django之数据库事务编程

          本文链接:https://www.haomeiwen.com/subject/actrfhtx.html