Django_事务

 

介绍

函数说明

from django.db import transaction

transaction.atomic  # 原子性操做，把一系列操做当作一个总体，错了则集体回退
transaction.on_commit(func，using = None)  # 在整个事件完成后，执行func函数

使用方法

from django.db import transaction

# atomic
@transaction.atomic
def index(request):
    ...

def index(request):
    with transation.atomic():
        ....
    ....


# on_commit
@transaction.atomic
def index(request):
    do_something...
    transation.oncommit(func)

 

示例

from django.db import models

class Account(models.Model):
    nid = models.IntegerField(primary_key=True)
    money = models.IntegerField(verbose_name="余额")

models.py

from django.contrib import admin
from django.urls import path,re_path,include
from app01 import views

urlpatterns = [
    re_path("index.html",views.index)
]

urls.py

 

 一、正常状况，转帐成功

from django.shortcuts import render,HttpResponse
from app01 import models
from django.db.models import F

def index(request):
    models.Account.objects.filter(nid=1).update(money=F("money")-1)  # 帐号1给帐号2转帐1元钱
    # raise IndexError
    models.Account.objects.filter(nid=2).update(money=F("money")+1)
    return HttpResponse("OK")

views.py

二、转帐到一半出现错误

from django.shortcuts import render,HttpResponse
from app01 import models
from django.db.models import F

def index(request):
    models.Account.objects.filter(nid=1).update(money=F("money")-1)
    raise IndexError
    models.Account.objects.filter(nid=2).update(money=F("money")+1)
    return HttpResponse("OK")

views.py

三、还原全部money到1000，配置事务

from django.shortcuts import render,HttpResponse
from app01 import models
from django.db import transaction
from django.db.models import F


def index(request):
    with transaction.atomic():
        models.Account.objects.filter(nid=1).update(money=F("money")-1)
        raise IndexError
        models.Account.objects.filter(nid=2).update(money=F("money")+1)
    return HttpResponse("OK")

# 能够使用装饰器
# @transaction.atomic
# def index(request):
#     models.Account.objects.filter(nid=1).update(money=F("money")-1)
#     raise ValueError("出错")
#     models.Account.objects.filter(nid=2).update(money=F("money")+1)
#     return HttpResponse("OK")

views.py

 四、验证on_commit

说明：若是原子性操做出错，则整个on_commit都不会执行，不管on_commit放在什么位置。这与直接在该位置执行func是不同的。

from django.shortcuts import render,HttpResponse
from app01 import models
from django.db import transaction
from django.db.models import F


def before():
    print("before")
    # 能够作一些特定工做，如发邮件、记录log

def after():
    print("after")


@transaction.atomic
def index(request):
    transaction.on_commit(before)
    models.Account.objects.filter(nid=1).update(money=F("money")-1)
    # raise ValueError("出错")
    models.Account.objects.filter(nid=2).update(money=F("money")+1)
    transaction.on_commit(after)
    return HttpResponse("OK")

views.py

from django.shortcuts import render,HttpResponse
from app01 import models
from django.db import transaction
from django.db.models import F


def before():
    print("before")
    # 能够作一些特定工做，如发邮件、记录log

def after():
    print("after")


@transaction.atomic
def index(request):
    transaction.on_commit(before)
    models.Account.objects.filter(nid=1).update(money=F("money")-1)
    raise ValueError("出错")
    models.Account.objects.filter(nid=2).update(money=F("money")+1)
    transaction.on_commit(after)
    return HttpResponse("OK")

触发错误，raise ValueError，未出现func的东西