Django Rest Framework如何实现单请求批量PUT、删除或批量更新操作
DRF 批量更新实现方案
以下两种方案可满足你的需求,可根据业务场景选择:
方案1:重写update方法支持PUT批量更新
该方案复用标准REST的PUT接口,当传入JSON数组时自动走批量更新逻辑,要求每个更新对象必须携带主键id用于匹配需要修改的实例,代码如下:
def update(self, request, *args, **kwargs): # 校验是否为批量更新 if isinstance(request.data, list): # 提取所有需要更新的实例id ids = [item.get('id') for item in request.data if item.get('id')] # 批量查询实例,并且按照传入id的顺序排序,避免更新错位 instances = ListForm.objects.filter(id__in=ids).order_by('id') # 序列化器传入实例和请求数据,开启多实例模式 serializer = self.get_serializer(instance=instances, data=request.data, many=True) serializer.is_valid(raise_exception=True) # 执行更新 serializer.save() # 返回更新后的数据,可根据你的需求调整返回逻辑,比如保留你的分页逻辑 return Response(serializer.data, status=status.HTTP_200_OK) # 单条更新走默认逻辑 return super().update(request, *args, **kwargs)
如果需要支持部分字段更新(不需要传所有必填字段,仅传修改的字段),可以在序列化器初始化时添加partial=True参数。
方案2:新增POST类型的批量更新接口
如果你不想修改标准PUT方法的逻辑,可以新增独立的批量更新接口,代码如下:
from rest_framework.decorators import action class ListFormViewSet(viewsets.ModelViewSet): # 你原有代码保持不变 ... @action(methods=['post'], detail=False, url_path='bulk_update') def bulk_update(self, request): ids = [item.get('id') for item in request.data if item.get('id')] instances = ListForm.objects.filter(id__in=ids).order_by('id') # 同样可以加partial=True支持部分更新 serializer = self.get_serializer(instance=instances, data=request.data, many=True) serializer.is_valid(raise_exception=True) serializer.save() return Response(serializer.data, status=status.HTTP_200_OK)
接口调用地址为POST /{你的接口前缀}/listform/bulk_update/,请求体传入JSON数组即可。
修正后完整的views.py代码
你原有代码中的create方法存在缩进错误,部分返回逻辑永远不会执行,已同步修正:
from django.shortcuts import render from .models import ListForm from rest_framework import viewsets from .serializers import ListFormSerializer from rest_framework import filters import django_filters.rest_framework from rest_framework.response import Response from rest_framework import status, viewsets from rest_framework.decorators import action class ListFormViewSet(viewsets.ModelViewSet): """ API endpoint that allows users to be viewed or edited. """ queryset = ListForm.objects.all().order_by('group') serializer_class = ListFormSerializer filter_backends = (django_filters.rest_framework.DjangoFilterBackend, filters.SearchFilter, filters.OrderingFilter,) filterset_fields = ['group','key_description'] search_fields = ['group'] def create(self, request, *args, **kwargs): serializer = self.get_serializer(data=request.data, many=isinstance(request.data,list)) serializer.is_valid(raise_exception=True) self.perform_create(serializer) headers = self.get_success_headers(serializer.data) queryset = self.filter_queryset(self.get_queryset()) page = self.paginate_queryset(queryset) if page is not None: serializer = self.get_serializer(page, many=True) return self.get_paginated_response(serializer.data) # 修正缩进错误 serializer = self.get_serializer(queryset, many=True) return Response(serializer.data, status=status.HTTP_201_CREATED, headers=headers) def update(self, request, *args, **kwargs): # 校验是否为批量更新 if isinstance(request.data, list): # 提取所有需要更新的实例id ids = [item.get('id') for item in request.data if item.get('id')] # 批量查询实例,并且按照传入id的顺序排序,避免更新错位 instances = ListForm.objects.filter(id__in=ids).order_by('id') # 序列化器传入实例和请求数据,开启多实例模式 serializer = self.get_serializer(instance=instances, data=request.data, many=True) serializer.is_valid(raise_exception=True) # 执行更新 serializer.save() # 返回更新后的数据,可根据你的需求调整返回逻辑,比如保留你的分页逻辑 return Response(serializer.data, status=status.HTTP_200_OK) # 单条更新走默认逻辑 return super().update(request, *args, **kwargs) @action(methods=['post'], detail=False, url_path='bulk_update') def bulk_update(self, request): ids = [item.get('id') for item in request.data if item.get('id')] instances = ListForm.objects.filter(id__in=ids).order_by('id') # 同样可以加partial=True支持部分更新 serializer = self.get_serializer(instance=instances, data=request.data, many=True) serializer.is_valid(raise_exception=True) serializer.save() return Response(serializer.data, status=status.HTTP_200_OK)
内容的提问来源于stack exchange,提问作者Desmond meng
相关产品推荐
相关产品推荐

