Python web框架fastapi数据库操作ORM（二）增删改查逻辑实现方法

✨✨ 欢迎大家来到景天科技苑✨✨

养成好习惯，先赞后看哦~

所属专栏：Fastapi
景天的主页：景天科技苑

上一章，我们讲到了fastapi数据库操作ORM的配置和查询操作，感兴趣的小伙伴可以回顾下：
Python web框架fastapi数据库操作ORM（一）

今天，我们一起探讨一下fastapi的增删改查逻辑实现

文章目录

• ORM数据库增删改查操作
• • 1.添加单条记录
  • • 1.添加方式一
    • 2.添加方式二
  • 2.多对多表添加记录
  • • 1.一对多查询
    • 2.多对多查询
  • 3.更新学生信息接口
  • 4.删除学生接口

ORM数据库增删改查操作

需要导入的包
from pydantic import BaseModel

from typing import Union,List

#保存数据到数据库，对用户输入数据进行校验
class StudentIn(BaseModel):
name: str
pwd: str
sno: int
clas_id: int
courses: List[int] = []

1.添加单条记录

api接口实现

1.添加方式一

@api_student.post("/",tags=["添加学生"])async def addStudent(stu: StudentIn):# 添加数据库操作# 方式1student = Student(name=stu.name, pwd=stu.pwd, sno=stu.sno, clas_id=stu.clas_id)#插入数据库动作await student.save()print(student, dir(student))return student

接口测试

查看数据库，数据已入库

2.添加方式二

# 方式2student = await Student.create(name=stu.name, pwd=stu.pwd, sno=stu.sno, clas_id=stu.clas_id)print(student, dir(student))

数据库查看，添加成功

2.多对多表添加记录

由于多对多那张表，没有对应的模型类，所以一般无法通过模型类直接添加删除
需要借助学生表的多对多字段courses来处理

# 添加多对多关系记录courses = await Course.filter(id__in=stu.courses)print("courses", courses)#添加的时候，要用*打散的方式传参await student.courses.add(*courses)print("student", student.courses)

查看数据库

可以看到id 13 对15和16，多对多插入成功

1.一对多查询

#一对多查询student = await Student.get(name="wangfang")#直接通过外键字段查询，班级名称clasname = await student.clas.values('name')print("班级名称",clasname)#查询所有学生的班级名称,通过外键__字段值students = await Student.all().values("name","clas__name")print(students)

2.多对多查询

#多对多查询，根据某个学生查询报的班名称和老师名称student = await Student.get(name="wangfang")print(await student.courses.all().values('name','teacher__name'))#查询所有学生的课程名称和老师名称students = await Student.all().values("name", "clas__name",'courses__name')print(students)

查询某一个学生的接口

#查看某个学生，基于路径参数@api_student.get("/{student_id}")async def getOneStudent(student_id:int):#注意，与数据库的操作要加awaitstudent = await Student.get(id=student_id)print(student.name)return student

3.更新学生信息接口

#更新学生信息，使用put请求@api_student.put("/student/{student_id}")async def update_student(student_id: int, student: StudentIn):#将对象转换为字典data = student.dict(exclude_unset=True)#将courses字段排除，因为student表中没有courses字段courses = data.pop("courses")print(data, courses)#更新用filter方法。因为filter查出来的对象有update方法await Student.filter(id=student_id).update(**data)#设置多对多课程courses = await Course.filter(id__in=student.courses)edit_student = await Student.get(id=student_id)#先把原来课程清空，再添加更新后的await edit_student.courses.clear()await edit_student.courses.add(*courses)return student

先看下源数据库13号学生信息

多对多表

在接口执行更新

更新后

多对多表

4.删除学生接口

导入异常包
from fastapi.exceptions import HTTPException
该异常类可以设置响应状态码，描述信息等

@api_student.delete("/student/{student_id}")async def delete_student(student_id: int):#返回删除的数量deleted_count = await Student.filter(id=student_id).delete()# 条件删除#输入的id不存在删除报错if not deleted_count:raise HTTPException(status_code=404, detail=f"Student {student_id} not found")#能正产给删除，返回空return {}

删除对应学生的时候，也会级联删除对应的多对多表中数据
我们删除13号学生

执行删除请求

查看数据库，13号学生已被删除

查看多对多表13号也被删除

完整代码：

from fastapi import Requestfrom fastapi.exceptions import HTTPException#导入模板的包from fastapi.templating import Jinja2Templates# 实例化Jinja2对象，并将文件夹路径设置为以templates命名的文件夹templates = Jinja2Templates(directory="templates")from pydantic import BaseModelfrom typing import Union,List#导入modelsfrom models import *from fastapi import APIRouterapi_student = APIRouter()#保存数据到数据库，对用户输入数据进行校验class StudentIn(BaseModel):name: strpwd: strsno: intclas_id: intcourses: List[int] = []#查看所有学生@api_student.get("/")async def getAllStudent():#注意，与数据库的操作要加await，得到的是queryset类型数据，[Student(),Student(),Student()....]# students = await Student.all()# print('students',students,type(students))## #循环打印# for stu in students:# print(stu.name, stu.sno)#过滤查询，查询指定内容filter,得到的依然是list类型数据# student = await Student.filter(name='liuxin')# print(student,type(student))# #得到具体数据# print(student[0].name)#get方法# student = await Student.get(name="wangfang")# print(student,type(student))# print(student.name,student.sno)#模糊查询,查询学号大于2001的学生# students = await Student.filter(sno__gt=2001)#查询学号是2001和2002的学生# students = await Student.filter(sno__in=[2001,2002])# print(students)#values查询，只查出指定字段数据# students = await Student.filter(sno__range=[1, 10000]).values('name','sno')# print(students)# for stu in students:# print(stu)#一对多查询# student = await Student.get(name="wangfang")## #直接通过外键字段查询，班级名称# clasname = await student.clas.values('name')# print("班级名称",clasname)## #查询所有学生的班级名称,通过外键__字段值# students = await Student.all().values("name","clas__name")# print(students)#多对多查询，根据某个学生查询报的班名称和老师名称student = await Student.get(name="wangfang")print(await student.courses.all().values('name','teacher__name'))#查询所有学生的课程名称和老师名称students = await Student.all().values("name", "clas__name",'courses__name')print(students)return students#将学生信息显示到页面@api_student.get("/index")async def show_student(request:Request):students = await Student.all()return templates.TemplateResponse('index.html', #第一个参数放模板文件{'request': request,# 注意，返回模板响应时，必须有request键值对，且值为Request请求对象'students':students}, #context上下文对象，是个字典)#查看某个学生，基于路径参数@api_student.get("/{student_id}")async def getOneStudent(student_id:int):#注意，与数据库的操作要加awaitstudent = await Student.get(id=student_id)print(student.name)return student#更新学生信息，使用put请求@api_student.put("/student/{student_id}")async def update_student(student_id: int, student: StudentIn):#将对象转换为字典data = student.dict(exclude_unset=True)#将courses字段排除，因为student表中没有courses字段courses = data.pop("courses")print(data, courses)#更新用filter方法。因为filter查出来的对象有update方法await Student.filter(id=student_id).update(**data)#设置多对多课程courses = await Course.filter(id__in=student.courses)edit_student = await Student.get(id=student_id)#先把原来课程清空，再添加更新后的await edit_student.courses.clear()await edit_student.courses.add(*courses)return student@api_student.delete("/student/{student_id}")async def delete_student(student_id: int):#返回删除的数量deleted_count = await Student.filter(id=student_id).delete()# 条件删除#输入的id不存在删除报错if not deleted_count:raise HTTPException(status_code=404, detail=f"Student {student_id} not found")#能正产给删除，返回空return {}@api_student.post("/",tags=["添加学生"])async def addStudent(stu: StudentIn):# 添加数据库操作# 方式1# student = Student(name=stu.name, pwd=stu.pwd, sno=stu.sno, clas_id=stu.clas_id)# #插入数据库动作# await student.save()# print(student, dir(student))# 方式2student = await Student.create(name=stu.name, pwd=stu.pwd, sno=stu.sno, clas_id=stu.clas_id)print(student, dir(student))# 添加多对多关系记录courses = await Course.filter(id__in=stu.courses)print("courses", courses)#添加的时候，要用*打散的方式传参await student.courses.add(*courses)print("student", student.courses)return courses