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

news2024/12/19 22:03:17

在这里插入图片描述

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

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

所属专栏：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

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

【Matlab深度学习】详解matlab深度学习进行时间序列预测

【Matlab深度学习】详解matlab深度学习进行时间序列预测

🔗 运行环境：Matlab 🚩 撰写作者：左手の明天 🥇 精选专栏：《python》 🔥 推荐专栏：《算法研究》 🔐#### 防伪水印——左手の明天 ####🔐 💗 大家…
阅读更多...
框架漏洞--＞Struts2 Docker_Vulnhub搭建

框架漏洞--＞Struts2 Docker_Vulnhub搭建

来浅浅的讲一下Struts2漏洞 目录 1.Docker_Vulnhub搭建 2.Struts2 3.Struts2的框架特征 4.S2-029-->Remote Code Execution 5.漏洞复现 1.RCE 2.Getshell 1.Docker_Vulnhub搭建 因为我用的是Linux，所以我选择直接搭个docker，这里我建议先换个…
阅读更多...
Jmeter接口测试---随机数、加密、cookie鉴权、断言、CSV参数化

Jmeter接口测试---随机数、加密、cookie鉴权、断言、CSV参数化

随机数 第一步：选择工具-函数助手对话框 第二步：选择random，设置最大值最小值，复制函数字符串到指定位置 加密接口 类型：AES、DES、Base64、RSA（可以解密） | MD5、SHA、HmacSHA（不…
阅读更多...
振弦式埋入应变计：工程安全的精准守护者

振弦式埋入应变计：工程安全的精准守护者

振弦式埋入应变计是一种先进的工程监测设备，以其卓越的性能和稳定的可靠性，广泛应用于水工建筑物及其他混凝土结构物的长期安全监测中。峟思振弦埋入式应变计的核心部件采用进口钢弦制成，保证了其使用寿命的长久性。同时，主要构件…
阅读更多...
【C++练级之路】【Lv.10】【STL】priority_queue类和反向迭代器的模拟实现

【C++练级之路】【Lv.10】【STL】priority_queue类和反向迭代器的模拟实现

快乐的流畅：个人主页 个人专栏：《C语言》《数据结构世界》《进击的C》 远方有一堆篝火，在为久候之人燃烧！ 文章目录 一、仿函数1.1 仿函数的介绍1.2 仿函数的优势 二、priority_queue2.1 push2.2 pop2.3 top2.4 size2.5 empty 三、…
阅读更多...
延迟任务基于DeyalQueue

延迟任务基于DeyalQueue

一，延迟任务应用场景？ 一般用于处理订单，将redis中的数据延迟存入数据库，实现异步存储减少DB的压力 DelayQueue是基于内存的延迟队列 二， 延迟任务的实现方案有很多 DelayQueue Redisson MQ 时间轮 原理 JDK自带延…
阅读更多...
基于Keil的RTE(run time environment)配置GD32开发环境，移植FreeRTOS

基于Keil的RTE(run time environment)配置GD32开发环境，移植FreeRTOS

前言： 10多年前就用STM32了，最近从STM32转到GD32，感觉国产的芯片发展是真的快，不但更便宜，还更快更好用了（是在是受不了STM32 I2C BUSY的那个BUG）。 先说下，实际上STM32的程序可以…
阅读更多...
5 分钟配置好 Electron 应用的图标

5 分钟配置好 Electron 应用的图标

最近在开发博客本地客户端 HexoPress，应用做好后，需要打包，如果不希望打包出来 App 的图标用的是 Electron 默认的星球环绕的图标，那么需要自己制作图标。 制作图标 首先，你需要给各种操作系统制作一个满足要求的图标…
阅读更多...
Python+OpenGL三维模型显示鼠标缩放旋转平移

Python+OpenGL三维模型显示鼠标缩放旋转平移

程序示例精选 PythonOpenGL三维模型显示鼠标缩放旋转平移 如需安装运行环境或远程调试，见文章底部个人QQ名片，由专业技术人员远程协助！ 前言 这篇博客针对《PythonOpenGL三维模型显示鼠标缩放旋转平移》编写代码，代码整洁&#…
阅读更多...
「MySQL」基本操作类型

「MySQL」基本操作类型

🎇个人主页：Ice_Sugar_7 🎇所属专栏：数据库 🎇欢迎点赞收藏加关注哦！ 数据库的操作 创建、显示数据库 使用 create 创建一个数据库 create database goods;然后可以用 show databases 来查看已经创建的数…
阅读更多...
mac电脑使用pyinstaller打包python脚本

mac电脑使用pyinstaller打包python脚本

pyinstaller -F template.py 出现报错"AssertionError: Executable contains code signature!" 移除签名 codesign --remove-signature /Users/f7692281/PycharmProjects/TPtestlist/transmit_v6.0.py 打包命令 pyinstaller --windowed transmit_v6.0.py pyinst…
阅读更多...
【MATLAB】语音信号识别与处理：T1小波滤波算法去噪及谱相减算法呈现频谱

【MATLAB】语音信号识别与处理：T1小波滤波算法去噪及谱相减算法呈现频谱

1 基本定义 T1小波滤波算法是一种基于小波变换的信号去噪算法。它可以有效地去除信号中的噪声，并保留信号的主要特征。该算法的主要思想是将信号分解为多个不同尺度的小波系数，然后通过对小波系数进行阈值处理来去除噪声。 具体来说，T1小波滤…
阅读更多...
企业CRM系统选型指南 | 掌握必备功能，提升工作效率

企业CRM系统选型指南 | 掌握必备功能，提升工作效率

大家好我是卡林，今天分享CRM系统的十大功能，企业CRM系统选型指南。说起CRM的功能，大家会联想到什么？数据库、商机管理或者销售漏斗，这些是大部分人都会联想到的功能，但不太全面。如线索管理、联系人管理、客…
阅读更多...
开发苹果iOS应用后如何提交到App Store

开发苹果iOS应用后如何提交到App Store

文章目录 摘要引言正文一、选择IPA文件和通道二、设置专用密码三、上传IPA文件提交上传界面说明 总结 摘要 本文将介绍使用AppUploader工具提交iOS应用到App Store的详细步骤。通过选择IPA文件和通道、设置专用密码以及进行上传，开发者可以顺利完成应用的提交上传过…
阅读更多...
【牛客面试必刷TOP101】Day25.BM38 在二叉树中找到两个节点的最近公共祖先和BM40 重建二叉树

【牛客面试必刷TOP101】Day25.BM38 在二叉树中找到两个节点的最近公共祖先和BM40 重建二叉树

作者简介：大家好，我是未央； 博客首页：未央.303 系列专栏：牛客面试必刷TOP101 每日一句：人的一生，可以有所作为的时机只有一次，那就是现在！！！&…
阅读更多...
LeetCode 刷题 [C++] 第279题.完全平方数

LeetCode 刷题 [C++] 第279题.完全平方数

题目描述 给你一个整数 n ，返回 和为 n 的完全平方数的最少数量 。 完全平方数是一个整数，其值等于另一个整数的平方；换句话说，其值等于一个整数自乘的积。例如，1、4、9 和 16 都是完全平方数，而 3 和 11…
阅读更多...
设计模式（十五）状态模式

设计模式（十五）状态模式

请直接看原文:设计模式系列 ------------------------------------------------------------------------------------------------------------------------------- 前言 建议在阅读本文前先阅读设计模式（十一）策略模式这篇文章，虽说状态…
阅读更多...
Python 获取beckhoff数据-OPCUA

Python 获取beckhoff数据-OPCUA

1. 背景介绍 OPC UA（Unified Architecture，统一架构）是下一代的OPC 标准，它是一种工业通讯协议，通过提供一个完整的，安全和可靠的跨平台的架构，以获取实时和历史数据和时间。OPC UA的诞生是因为…
阅读更多...
DSP，QX320F28337，数据手册，使用手册

DSP，QX320F28337，数据手册，使用手册

自研32位双核CPU 主频400MHz 单精度浮点运算FPU 三角函数运算TMU flash 1MB，sram 1MB 3个12位ADC，采样率3MSPS 3个14位ADC，采样率2.67MSPS 24个ePWM通道，16个HRPWM（150PS）
阅读更多...
爬虫实战——麻省理工学院新闻

爬虫实战——麻省理工学院新闻

文章目录 发现宝藏一、 目标二、 浅析三、获取所有模块四、请求处理模块、版面、文章1. 分析切换页面的参数传递2. 获取共有多少页标签并遍历版面3.解析版面并保存版面信息4. 解析文章列表和文章5. 清洗文章6. 保存文章图片 五、完整代码六、效果展示 发现宝藏 前些天发现了一…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023