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):
    # 添加数据库操作
    # 方式1
    student = 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.添加方式二

# 方式2
student = 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):
    #注意，与数据库的操作要加await
    student = 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 Request

from fastapi.exceptions import HTTPException

#导入模板的包
from fastapi.templating import Jinja2Templates

# 实例化Jinja2对象，并将文件夹路径设置为以templates命名的文件夹
templates = Jinja2Templates(directory="templates")


from pydantic import BaseModel

from typing import Union,List


#导入models
from models import *


from fastapi import APIRouter

api_student = APIRouter()


#保存数据到数据库，对用户输入数据进行校验
class StudentIn(BaseModel):
    name: str
    pwd: str
    sno: int
    clas_id: int
    courses: 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):
    #注意，与数据库的操作要加await
    student = 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))


    # 方式2
    student = 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

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/427511.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

关于数据提交上传服务端的数据类型以及项目打包上线的流程

关于数据提交上传服务端的数据类型以及项目打包上线的流程

1 请求头的类型： content-type； 01: application/json 数据以json格式请求：{"key":"value"} 02: application/x-www.form-urlencoded from表单的数据格式 name"zs"&age12 03 mutipart/form-data…
阅读更多...
Linux安装JumpServer并结合内网穿透实现公网访问本地服务

Linux安装JumpServer并结合内网穿透实现公网访问本地服务

💝💝💝欢迎来到我的博客，很高兴能够在这里和您见面！希望您在这里可以感受到一份轻松愉快的氛围，不仅可以获得有趣的内容和知识，也可以畅所欲言、分享您的想法和见解。 推荐:kwan 的首页,持续学…
阅读更多...
云计算 2月28号 （linux的磁盘分区）

云计算 2月28号 （linux的磁盘分区）

一 存储管理 主要知识点: 基本分区、逻辑卷LVM、EXT3/4/XFS文件系统、RAID 初识硬盘 机械 HDD 固态 SSD SSD的优势 SSD采用电子存储介质进行数据存储和读取的一种技术，拥有极高的存储性能，被认为是存储技术发展的未来新星。 与传统硬盘相比&#xff0c…
阅读更多...
（已解决）emoji及其特殊符号在vue中的使用

（已解决）emoji及其特殊符号在vue中的使用

问题叙述 使用问题&#xff1a;在表情库中点击后无法展示对应的emoji表情&#xff0c;仅仅显示Unicode代码编号&#xff0c;按照vue eslint规则更改添加分号后&#xff0c;没有报错但是依旧无法正确渲染。 问题源码&#xff1a; <template><div><!-- 被点击的…
阅读更多...
Window系统部署Splunk Enterprise并结合内网穿透实现远程访问本地服务

Window系统部署Splunk Enterprise并结合内网穿透实现远程访问本地服务

文章目录 前言1. 搭建Splunk Enterprise2. windows 安装 cpolar3. 创建Splunk Enterprise公网访问地址4. 远程访问Splunk Enterprise服务5. 固定远程地址 前言 本文主要介绍如何简单几步&#xff0c;结合cpolar内网穿透工具实现随时随地在任意浏览器&#xff0c;远程访问在本地…
阅读更多...
Windows上构建一个和Linux类似的Terminal

Windows上构建一个和Linux类似的Terminal

感谢大佬批评指正&#xff0c;现已更新 preview Target&#xff1a;致力打造最赏心悦目Window下的终端&#xff0c;同时能够很接近Linux的使用习惯 key word&#xff1a;windows终端美化 windows terminal windows powershell 类似Linux下的Window终端 Window也能用ll windows…
阅读更多...
105.从前序与中序遍历序列构造二叉树

105.从前序与中序遍历序列构造二叉树

// 定义一个名为 Solution 的类 class Solution {// 创建一个哈希映射&#xff08;Map&#xff09;对象&#xff0c;用于根据数值查找对应的索引位置Map<Integer, Integer> map;// 公共方法 buildTree&#xff0c;接收两个整数数组&#xff08;前序遍历序列 preorder 和 …
阅读更多...
px、rem、vh、vw

px、rem、vh、vw

一、基础概念 屏幕分辨率&#xff1a;纵横向上的像素点数&#xff0c;单位是px。 物理分辨率&#xff1a;出厂设置&#xff0c;硬件分辨率&#xff0c;1920*1080 逻辑分辨率&#xff1a;软件/驱动设置&#xff0c;缩放调解的分辨率&#xff0c;1920/150% 制作网页参考逻辑分…
阅读更多...
Vue开发实例（八）Vuex状态管理store

Vue开发实例（八）Vuex状态管理store

Vuex状态管理store 一、Vuex的安装与配置二、store使用方法1、基础使用2、提交变更3、getters使用4、在其他页面&#xff08;组件&#xff09;中显示5、modules多模块 做vue项目的时候&#xff0c; store状态管理器可以帮助我们完成一些数据的存储和管理&#xff0c;通俗理解是…
阅读更多...
2024-03-03 c++

2024-03-03 c++

&#x1f338; MFC进度条控件 | Progress Control 1。新建MFC项目&#xff08;基于对话框、静态库&#xff09; 2。添加控件&#xff0c;删除初始的3个多余控件 加1个progress control&#xff0c;修改其marquee为true&#xff0c;添加变量&#xff1a;变量名为test_progress。…
阅读更多...
mysql8.0安装(zip版本)最详细

mysql8.0安装(zip版本)最详细

下载 https://dev.mysql.com/downloads/mysql/ 解压 [mysqld] # 设置3306端口 port3306 # 设置mysql的安装目录 basedirD:\Atools\mysql-8.0.30-winx64 # 切记此处一定要用双斜杠\\&#xff0c;单斜杠我这里会出错&#xff0c;不过看别人的教程&#xff0c;有的是单斜杠。自己…
阅读更多...
探索数字未来：DApp钱包Defi引领新纪元

探索数字未来：DApp钱包Defi引领新纪元

​小编介绍&#xff1a;10年专注商业模式设计及软件开发&#xff0c;擅长企业生态商业模式&#xff0c;商业零售会员增长裂变模式策划、商业闭环模式设计及方案落地&#xff1b;扶持10余个电商平台做到营收过千万&#xff0c;数百个平台达到百万会员&#xff0c;欢迎咨询。 随…
阅读更多...
AI 视频、图片修复 CodeFormer 安装 使用

AI 视频、图片修复 CodeFormer 安装 使用

一 CodeFormer 优秀的开源修复图片与视频的项目 1 下载 开源地址&#xff1a;https://github.com/sczhou/CodeFormer 下载成功&#xff1a; 2 安装 解压进入目录 安装依赖 pip install -r requirements.txt 安装完成&#xff0c;测试运行&#xff0c;报了个错误如下&#xff…
阅读更多...
白话transformer（一）：注意力机制

白话transformer（一）：注意力机制

前面我们分篇讲述了transformer的原理&#xff0c;但是对于很多刚接触transformer的人来说可能会有一点懵&#xff0c;所以我们接下来会分三篇文章用白话的形式在将transformer 讲一遍。 前文链接 Bert基础(一)–自注意力机制 Bert基础(二)–多头注意力 Bert基础(三)–位置编…
阅读更多...
独立游戏《星尘异变》UE5 C++程序开发日志1——项目与代码管理

独立游戏《星尘异变》UE5 C++程序开发日志1——项目与代码管理

写在前面&#xff1a;本日志系列将会向大家介绍在《星尘异变》这款模拟经营游戏&#xff0c;在开发时用到的与C相关的泛用代码与算法&#xff0c;主要记录UE5C与原生C的用法区别&#xff0c;以及遇到的问题和解决办法&#xff0c;因为这是我本人从ACM退役以后第一个从头开始的项…
阅读更多...
类加载器分类

类加载器分类

类加载器&#xff08;Class Loader&#xff09;是Java虚拟机&#xff08;JVM&#xff09;的一个重要组件&#xff0c;负责加载Java类到内存中并使其可以被JVM执行。类加载器是Java程序的核心机制之一。 主要有一下四种类加载器&#xff1a; &#xff08;1&#xff09;启动类加…
阅读更多...
01tire算法

01tire算法

01tire算法 #include<bits/stdc.h> using namespace std; #define maxn 210000 int a[maxn], ch[maxn][2], val[maxn], n, ans, tot; void insert(int x) {int now 0;for (int j 31; j > 0; j -- ){int pos ((x >> i) & 1);if (!ch[now][pos])ch[now][po…
阅读更多...
【贪心算法】专题练习二

【贪心算法】专题练习二

欢迎来到Cefler的博客&#x1f601; &#x1f54c;博客主页&#xff1a;折纸花满衣 &#x1f3e0;个人专栏&#xff1a;题目解析 &#x1f30e;推荐文章&#xff1a;【LeetCode】winter vacation training 目录 &#x1f449;&#x1f3fb;买卖股票的最佳时机&#x1f449;&…
阅读更多...
Android Stdio Execution failed for task ‘:app:compileDebugKotlin‘ 报错解决

Android Stdio Execution failed for task ‘:app:compileDebugKotlin‘ 报错解决

具体报错信息如下&#xff1a; compileDebugJavaWithJavac task (current target is 1.8) and compileDebugKotlin task (current target is 17)jvm target compatibility should be set to the same Java version.很显然&#xff0c;这是一个版本冲突问题&#xff0c;compile…
阅读更多...
深入理解C语言：开发属于你的三子棋小游戏

深入理解C语言：开发属于你的三子棋小游戏

三子棋 1. 前言2. 准备工作3. 使用二维数组存储下棋的数据4. 初始化棋盘为全空格5. 打印棋盘6. 玩家下棋7. 电脑下棋8. 判断输赢9. 效果展示10. 完整代码 1. 前言 大家好&#xff0c;我是努力学习游泳的鱼&#xff0c;今天我们会用C语言实现三子棋。所谓三子棋&#xff0c;就是…
阅读更多...
最新文章

Copyright @ 2022~2023