Django事务 django.db.transaction

小鱼儿 2022-12-04 02:22 34阅读 0赞

Django 中可以通过django.db.transaction 模块提供的atomic来定义一个事务

\*\*

## atomic提供两种方案实现事务 ##

\*\*

**1、装饰器用法：**

from django.db import transaction
    
    @transaction.atomic
    def viewfunc(request):
      pass

装饰器用法：整个视图中所有 MySQL 数据库的操作都看做一个事务，范围太大，不够灵活。而且无法直接作用于类视图

**2、with 语句用法：**

from django.db import transaction
    
    def viewfunc(request):
      	pass
    
      with transaction.atomic():
          pass

with 语句用法：可以灵活的把某些 MySQL 数据库的操作看做一个事务。且不用关心视图的类型。

from django.db import transaction
    
    # 创建保存点
    save_id = transaction.savepoint()
    
    # 回滚到保存点
    transaction.savepoint_rollback(save_id)
    
    # 提交从保存点到当前状态的所有数据库事务操作
    transaction.savepoint_commit(save_id)

**实例：**

from django.db import transaction
    
    class BookDetailView(generics.ListCreateAPIView, generics.UpdateAPIView):
        queryset = Book.objects.all()
        pagination_class = VueTablePagination
        serializer_class = BookSerializer
    
        filter_fields = (
            'id', 'uuid', 'name','username', 'type', 'status', 'description','created_at', 'created_by', 'updated_at', 'updated_by')
        search_fields = ['name','username', 'type', 'status', 'description','created_at', 'created_by', 'updated_at', 'updated_by']
        ordering_fields = ('id',)
    
        def post(self, request):
            request_data = request.data.copy()
    		····
    		# 创建保存点
    		save_id = transaction.savepoint()
    		try：
    			······
    		except BaseException as e:
            	LOG.error("Save Book:{d} failed: {err}".format(d=data, err=str(e)))
            	# 回滚到保存点
    			transaction.savepoint_rollback(save_id)
            	return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
            
            # 提交从保存点到当前状态的所有数据库事务操作
    		transaction.savepoint_commit(save_id)
            return Response(status=status.HTTP_201_CREATED)