快捷導(dǎo)航

Django關(guān)于事務(wù)transaction.atomic()的使用方式

更新時(shí)間：2023年08月24日 09:43:17 作者：天下·第二

這篇文章主要介紹了Django關(guān)于事務(wù)transaction.atomic()的使用方式,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

Django事務(wù)transaction.atomic()使用

導(dǎo)入需要使用的包

from django.shortcuts import render
from django.http import HttpResponse
from django.views import View
from django.db import transaction   # 導(dǎo)入事務(wù)

類視圖 (整個(gè)函數(shù)使用事務(wù),@transaction.atomic裝飾器)

class MyView(View):
    @transaction.atomic
    # transaction.atomic裝飾器可以保證該函數(shù)中所有的數(shù)據(jù)庫操作都在一個(gè)事務(wù)中。
    def post(self, request):
        # 數(shù)據(jù)庫操作1。。。
        # 數(shù)據(jù)庫操作2。。。
        return HttpResponse('ok')

類視圖 (函數(shù)體事務(wù),保存點(diǎn)的使用)

class MyView2(View):
    @transaction.atomic
    def post(self, request):
        # 設(shè)置事務(wù)保存點(diǎn)
        s1 = transaction.savepoint()   # 可以設(shè)置多個(gè)保存點(diǎn)
        # 數(shù)據(jù)庫操作。。。
        # 事務(wù)回滾 (如果發(fā)生異常,就回滾事務(wù))
        transaction.savepoint_rollback(s1)  # 可以回滾到指定的保存點(diǎn)
        # 提交事務(wù) (如果沒有異常,就提交事務(wù))
        transaction.savepoint_commit(s1)
        # 返回應(yīng)答
        return HttpResponse('ok')

函數(shù)體中使用

def func(request):
    with transaction.atomic():
        sid = transaction.savepoint()
        try:
            serializer.is_valid(raise_exception=True)
            comment = serializer.save()
            handle_obj_files(comment, request)
            visitor_order.epilogue.add(comment)
            visitor_order.status = 'complete'
            visitor_order.save()
        except Exception as e:
            transaction.savepoint_rollback(sid)
            return api_bad_request(str(e))
        else:
            transaction.savepoint_commit(sid)
        data = VisitorOrderRetrieveSerializer(visitor_order).data
        return api_success(data=data)

此方法和方法二類似

為什么需要with transaction.atomic()

django的事務(wù)回滾操作

1.為什么需要事務(wù)回滾操作？

2.SQL事務(wù)是什么？

3. 數(shù)據(jù)會安全

4. django為什么需要with transaction.atomic()？

            with transaction.atomic():
                issue_field = After.objects.get(id=issue_field_id)
                issue_field.is_abandoned = True
                issue_field.save()
                # if set is_abandoned to True, set all field value with this field is_abandoned to True
                all_issue_field_value = AfterSales.objects.update().filter(field=issue_id)
                for issue= in all_issue:
                    issue.is_abandoned = True
                    issue.save()