Django中的事务介绍

本文介绍: 在Django中，它的默事务行为是自动提交。除非事务正在执行，每个查询将会马上自动提交到数据库，例如：如果没有手动设置事务，那么这两条代码在执行完成后就会马上提交到数据库中进行保存，Django 自动使用事务或还原点，以确保需多次查询的 ORM 操作的一致性，特别是 delete() 和 update() 操作。通过django 手动创建事务的方式一般为两种：装饰器和:装饰器：wi t h 语句：需要注意的是当事务回滚时，模型的属性需要手动恢复。例如下面的代码，的初始值是.我们设置了然后进行了保存操作

一、Django 事务 介绍

在Django中，它的默事务行为是自动提交。除非事务正在执行，每个查询将会马上自动提交到数据库，例如：

# ApiData为model
ApiData.objects.create(name='测试名字', path='/')
ApiData.objects.filter(id=1).update(name='测试名字', path='/')

如果没有手动设置事务，那么这两条代码在执行完成后就会马上提交到数据库中进行保存，Django 自动使用事务或还原点，以确保需多次查询的 ORM 操作的一致性，特别是 delete() 和 update() 操作。

二、使用Django事务

通过django手动创建事务的方式一般为两种：装饰器和with:

装饰器：

@api_view(['POST'])
@transaction.atomic
def test_views(request):
    """
    该方法会在一个事务中执行
    """
    ApiData.objects.create(name='测试名字', path='/')
    ApiData.objects.filter(id=1).update(name='测试名字', path='/')
    return Response(data={'msg': '创建成功！'})

with 语句：

@api_view(['POST'])
def test_views(request):
    try:
        with transaction.atomic(): #仅with包裹的下面的语句会在事务中执行
            ApiData.objects.create(name='测试名字', path='/')
            ApiData.objects.filter(id=1).update(name='测试名字', path='/')
    except Exception as e:
        pass
    return Response(data={'msg': '创建成功！'})

需要注意的是当事务回滚时，模型的属性需要手动恢复。

例如下面的代码，obj.active的初始值是False.我们设置了obj.active=True然后进行了保存obj.save()操作，但这个时候发生了异常导致保存失败了，那此时的obj.active的值还是为True,并不会因为保存失败而变为False：

from django.db import DatabaseError, transaction

obj = MyModel(active=False)
obj.active = True
try:
    with transaction.atomic():
        obj.save()
except DatabaseError:
    pass

if obj.active: #下面的代码
    ...

因此，针对上面的代码我们可以在抛异常处将active的值设为False来达到恢复模型属性的值的目的：

try:
    with transaction.atomic():
        obj.save()
except DatabaseError:
    obj.active=False #手动恢复active属性

三、全局事务

如果为了图省事而场景也较为通用，我们可以设置全局事务配置来让每个请求 view都使用事务：
在settings.py配置文件中的DATABASES项里增加ATOMIC_REQUESTS配置：

DATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': 'testdb', 
        'USER': 'root',  
        'PASSWORD': '123', 
        'HOST': '127.0.0.1',     
        'PORT': 3306,  
        'ATOMIC_REQUESTS': True  # 全局开启事务，和http请求的整个过程绑定在一起
    }
}