增删改查（原生）

Django 3.2

  1. # -*- encoding: utf-8 -*-
  2. """
  3. @Author:暗香彻骨.沐之杰 (Addis)
  4. @Contact : qyx01@qq.com 
  5. @Time: 2022/6/26 17:05
  6. @Software： PyCharm
  7. @File: views_dj.py
  8. @Description:
  9. """
  10. import json
  11. import datetime
  12. from django.views import View
  13. from .models import DbStudent
  14. from django.http import HttpResponse, JsonResponse
  15. from addis_utils.api_utils import api_result
  16. from django.views.decorators.csrf import csrf_exempt
  18. """
  19. GET 查询所有 http://127.0.0.1:8081/demo/student
  20. POST 新增 http://127.0.0.1:8081/demo/student/
  21. GET 查询id http://127.0.0.1:8081/demo/student/107/
  22. PUT  更新  http://127.0.0.1:8081/demo/student/107/
  23. DELETE  删除(逻辑或物理)  http://127.0.0.1:8081/demo/student/10003322/
  24. """
  27. class BookListView(View):
  28.     """列表视图"""
  30.     def get(self, request):
  31.         """查询所有"""
  32.         # 1、查询出所有记录的模型
  33.         list_student = DbStudent.objects.all()
  34.         # 执行原生SQL
  35.         # list_student = DbStudent.objects.raw(
  36.         #     "SELECT * FROM db_student"
  37.         # )
  38.         # 2、遍历查询集，把模型对象转成字典
  39.         list_stu = []
  40.         for stu in list_student:
  41.             dict_student = {
  42.                 'id': stu.id,
  43.                 'name': stu.name,
  44.                 'age': stu.age,
  45.                 'sex': stu.sex,
  46.                 'class_name': stu.class_name,
  47.                 'description': stu.description if stu.description else '',
  48.                 'create_time': stu.create_time,
  49.                 'updated_time': stu.updated_time
  50.             }
  51.             list_stu.append(dict_student)
  53.         api_result["code"] = 200
  54.         api_result["msg"] = "success"
  55.         api_result["count"] = len(list_stu)
  56.         api_result["data"] = list_stu
  57.         #  3、响应
  58.         return JsonResponse(api_result, json_dumps_params={'ensure_ascii': False},
  59.                             content_type="application/json; charset=utf-8",
  60.                             status=200, safe=False)
  62.     def post(self, request):
  63.         """新增
  64.         """
  65.         dt = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
  66.         print(dt)
  67.         # 获取前端传入的请示体数据（json） request.body
  68.         json_str_bytes = request.body
  69.         # 把bytes类型的json字符串转换成json_str
  70.         json_str = json_str_bytes.decode()
  71.         # 利用json.loads将json字符串转换成json字典/列表
  72.         stu_dict = json.loads(json_str)
  73.         # 创建模型对象并保存
  74.         stu = DbStudent(
  75.             name=stu_dict['name'],
  76.             age=stu_dict['age'],
  77.             sex=stu_dict['sex'],
  78.             class_name=stu_dict['class_name'],
  79.             description=stu_dict['description'],
  80.             create_time=datetime.datetime.now(),
  81.             updated_time=stu_dict['updated_time']
  82.         )
  83.         stu.save()
  84.         # 把修改后的模型再转换成字典
  85.         json_stu = {
  86.             'id': stu.id,
  87.             'name': stu.name,
  88.             'age': stu.age,
  89.             'sex': stu.sex,
  90.             'class_name': stu.class_name,
  91.             'description': stu.description if stu.description else '',
  92.             'create_time': stu.create_time,
  93.             'updated_time': stu.updated_time
  94.         }
  95.         # 响应
  96.         return JsonResponse(json_stu,safe=False)
  99. class BookDetailView(View):
  100.     """详情视图"""
  102.     def get(self, request, pk):
  103.         """查询指定"""
  104.         # 1、获取id
  105.         # print(pk)
  106.         try:
  107.             # Django 方法
  108.             list_student = DbStudent.objects.filter(id=pk)
  109.             # 执行原生SQL
  110.             # list_student = DbStudent.objects.raw(
  111.             #     "SELECT * FROM db_student WHERE id = '{_pk}'".format(_pk=pk)
  112.             # )
  113.         except DbStudent.DoesNotExist:
  114.             return HttpResponse({"message": "经查询无记录"}, status=404)
  115.         # print(list_student)
  116.         # 2、模型对象转字典
  117.         list_stu = []
  118.         for stu in list_student:
  119.             dict_student = {
  120.                 'id': stu.id,
  121.                 'name': stu.name,
  122.                 'age': stu.age,
  123.                 'sex': stu.sex,
  124.                 'class_name': stu.class_name,
  125.                 'description': stu.description if stu.description else '',
  126.                 'create_time': stu.create_time,
  127.                 'updated_time': stu.updated_time
  128.             }
  129.             list_stu.append(dict_student)
  130.         api_result["code"] = 200
  131.         api_result["msg"] = "success"
  132.         api_result["count"] = len(list_stu)
  133.         api_result["data"] = list_stu
  134.         #  3、响应
  135.         return JsonResponse(api_result, json_dumps_params={'ensure_ascii': False},
  136.                             content_type="application/json; charset=utf-8",
  137.                             status=200, safe=False)
  139.     @csrf_exempt
  140.     def put(self, request, pk):
  141.         """修改指定"""
  142.         # 先查询要修改的模型对象
  143.         try:
  144.             stu = DbStudent.objects.get(id=pk)
  145.         except DbStudent.DoesNotExist:
  146.             return HttpResponse({"message": "要修改的数据不存在"}, status=404)
  148.         # 获取前端传入的数据（把数据转换成字典）
  149.         json_str_bytes = request.body
  150.         json_str = json_str_bytes.decode()
  151.         stu_dict = json.loads(json_str)
  152.         # stu_dict = json.loads(request.body.decode())
  153.         # 重新给模型指定的属性赋值
  154.         stu.name = stu_dict["name"]
  155.         stu.age = stu_dict["age"]
  156.         stu.sex = stu_dict["sex"]
  157.         stu.class_name = stu_dict["class_name"]
  158.         stu.description = stu_dict["description"]
  159.         stu.create_time = stu_dict["create_time"]
  160.         stu.updated_time = stu_dict["updated_time"]
  161.         # 用save方法保存修改操作
  162.         stu.save()
  163.         # 把修改后的模型再转换成字典
  164.         json_stu = {
  165.             'id': stu.id,
  166.             'name': stu.name,
  167.             'age': stu.age,
  168.             'sex': stu.sex,
  169.             'class_name': stu.class_name,
  170.             'description': stu.description if stu.description else '',
  171.             'create_time': stu.create_time,
  172.             'updated_time': stu.updated_time
  173.         }
  174.         # 响应
  175.         return JsonResponse(json_stu)
  176.         # pass
  178.     def delete_physics(self, request, pk):
  179.         """物理删除指定 """
  180.         try:
  181.             # Django 方法
  182.             list_student = DbStudent.objects.get(id=pk)
  183.             # 执行原生SQL
  184.             # list_student = DbStudent.objects.raw(
  185.             #     "SELECT * FROM db_student WHERE id = '{_pk}'".format(_pk=pk)
  186.             # )
  187.         except DbStudent.DoesNotExist:
  188.             return HttpResponse({"message": "经查询无记录"}, status=404)
  189.         # 物理删除
  190.         list_student.delete()
  191.         # # 逻辑删除
  192.         # list_student.is_deleted = 1
  193.         # list_student.save()
  194.         return HttpResponse(status=204)
  196.     def delete(self, request, pk):
  197.         """逻辑删除指定 _logic"""
  198.         try:
  199.             # Django 方法
  200.             list_student = DbStudent.objects.get(id=pk)
  201.             # 执行原生SQL
  202.             # list_student = DbStudent.objects.raw(
  203.             #     "SELECT * FROM db_student WHERE id = '{_pk}'".format(_pk=pk)
  204.             # )
  205.         except DbStudent.DoesNotExist:
  206.             return HttpResponse({"message": "经查询无记录"}, status=404)
  207.         # 物理删除
  208.         # list_student.delete()
  209.         # 逻辑删除
  210.         list_student.is_deleted = 1
  211.         list_student.save()
  212.         return HttpResponse(status=204)