fastapi 后端项目目录结构 mysql fastapi 数据库操作

原文：fastapi 后端项目目录结构 mysql fastapi 数据库操作_mob6454cc786d85的技术博客_51CTO博客

一、安装sqlalchemy、pymysql模块

pip install sqlalchemy -i https://pypi.tuna.tsinghua.edu.cn/simple

pip install pymysql -i https://pypi.tuna.tsinghua.edu.cn/simple

注意，pymysql需要写进代码中，下面会有体现

二、创建数据库

 create database fastapi charset=utf8;

三、通过代码连接数据库并且测试

# 导入FastAPI模块
from fastapi import FastAPI
# 创建app实例
app = FastAPI()## 连接数据库# 连接mysql数据库需要导入pymysql模块
import pymysql
pymysql.install_as_MySQLdb()from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
# 配置数据库地址：数据库类型+数据库驱动名称://用户名:密码@机器地址:端口号/数据库名
engine =create_engine("mysql+pymysql://root:123@192.168.219.132:3306/fastapi",encoding='utf-8')
# 把当前的引擎绑定给这个会话；
# autocommit：是否自动提交 autoflush：是否自动刷新并加载数据库 bind：绑定数据库引擎
Session = sessionmaker(autocommit=False, autoflush=False, bind=engine)
# 实例化
session = Session()# declarative_base类维持了一个从类到表的关系，通常一个应用使用一个Base实例，所有实体类都应该继承此类对象
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()from sqlalchemy import Column, String, Integer
# 创建数据库模型（定义表结构:表名称，字段名称以及字段类型）
class User(Base):# 定义表名__tablename__ = 'tbluser'# 定义字段# primary_key=True 设置为主键userid = Column(Integer,primary_key=True)username = Column(String(255))# 构造函数def __init__(self,userid,username):self.userid = useridself.username = username# 打印形式def __str__(self):return "id:%s, name:%s" % (str(self.userid) ,self.username)# 在数据库中生成表
Base.metadata.create_all(bind=engine)

 通过uvicorn启动测试连接并且生成对象表

uvicorn app:app --port 8080 --host 127.0.0.1 --reload

 检查数据库看看是否成功

四、增删改查代码

# 导入FastAPI模块
from fastapi import FastAPI
# 创建app实例
app = FastAPI()## 连接数据库# 连接mysql数据库需要导入pymysql模块
import pymysql
pymysql.install_as_MySQLdb()from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
# 配置数据库地址：数据库类型+数据库驱动名称://用户名:密码@机器地址:端口号/数据库名
engine =create_engine("mysql+pymysql://root:123@192.168.219.132:3306/fastapi",encoding='utf-8')
# 把当前的引擎绑定给这个会话；
# autocommit：是否自动提交 autoflush：是否自动刷新并加载数据库 bind：绑定数据库引擎
Session = sessionmaker(autocommit=False, autoflush=False, bind=engine)
# 实例化
session = Session()# declarative_base类维持了一个从类到表的关系，通常一个应用使用一个Base实例，所有实体类都应该继承此类对象
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()from sqlalchemy import Column, String, Integer
# 创建数据库模型（定义表结构:表名称，字段名称以及字段类型）
class User(Base):# 定义表名__tablename__ = 'tbluser'# 定义字段# primary_key=True 设置为主键userid = Column(Integer,primary_key=True)username = Column(String(255))# 构造函数def __init__(self,userid,username):self.userid = useridself.username = username# 打印形式def __str__(self):return "id：%s, name：%s" % (str(self.userid) ,self.username)# 定义返回结果def to_dict(self):return {"userid": self.userid,"username": self.username}# 在数据库中生成表
Base.metadata.create_all(bind=engine)### 添加数据from pydantic import BaseModel
# 定义数据模型
class CreatUser(BaseModel):userid: intusername: strdef __str__(self):return "id：%s, name：%s" % (str(self.userid), self.username)## 添加单个
@app.post("/user/addUser")
async def InserUser(user: CreatUser):try:# 添加数据dataUser = User(userid=user.userid, username=user.username)session.add(dataUser)session.commit()session.close()except ArithmeticError:return {"code":"0002","message":"数据库异常"}return {"code":"0000","message":"添加成功"}from typing import List
## 添加多个
@app.post("/user/addUserList")
async def addUserList(*, user: List[CreatUser]):try:# user是一个列表，每个内部元素均为CreatUser类型for u in user:# 自定义的数据模型可以用.访问属性dataUser = User(userid=u.userid, username=u.username)session.add(dataUser)session.commit()session.close()except ArithmeticError:return {"code": "0002", "message": "数据库异常"}return {"code": "0000", "message": "添加成功"}### 查询## 按照user_id查询
@app.get("/user/{user_id}")
async def queryUserByUserId(user_id: int):# 创建Query查询，filter是where条件，调用one返回唯一行，调用all则是返回所有行try:# one与first的区别：# one：要求结果集中只有一个结果；如果数据库返回0或2个或更多结果，并且将引发异常，则为错误。# first：返回可能更大的结果集中的第一个，如果没有结果，则返回None。不会引发异常。# filter_by与filter的区别：# filter_by接收的参数形式是关键字参数，而filter接收的参数是更加灵活的SQL表达式结构# user1 = session.query(User).filter_by(userid=user_id).first()user1 = session.query(User).filter(User.userid==user_id).first()session.close()# 由于user1只有一个值，所以它直接是一个字典if user1:return {"code":"0000","message":"请求成功","data":user1}else:return {"code":"0001","message":"查询无结果"}except ArithmeticError:return {"code":"0002","message":"数据库异常"}## 查询所有
@app.get("/user/selectall/")
async def queryUserByUserId():# 创建Query查询，filter是where条件，调用one返回唯一行，调用all则是返回所有行try:user1 = session.query(User).all()session.close()# user1 是一个列表，内部元素为字典return {"code": "0000", "message": "请求成功", "data": user1}except ArithmeticError:return {"code":"0002","message":"数据库异常"}###删除# 根据user_id删除单个
@app.delete("/user/deleteUser/{user_id}")
async def deleteUser(user_id: int):try:user1 = session.query(User).filter(User.userid == user_id).first()if user1:session.delete(user1)session.commit()session.close()return {"code": "0000", "message": "删除成功"}else:return {"code": "0001", "message": "参数错误"}except ArithmeticError:return {"code": "0002", "message": "数据库错误"}from typing import List
## 删除多个
@app.delete("/user/deleteUserList")
async def deleteUser(user_ids: List[int]):try:for user_id in user_ids:user1 = session.query(User).filter(User.userid == user_id).first()if user1:session.delete(user1)session.commit()session.close()return {"code": "0000", "message": "删除成功"}except ArithmeticError:return {"code": "0002", "message": "数据库错误"}###修改## 根据user_id修改user_name
@app.put("/user/updateUser/")
# 定义查询参数user_id和user_name
async def updateUser(user_id: int, user_name: str):try:user1 = session.query(User).filter(User.userid == user_id).first()print(user1)if user1:user1.username = user_namesession.commit()session.close()return {"code": "0000", "message": "修改成功"}else:return {"code": "0001", "message": "参数错误"}except ArithmeticError:return {"code": "0002", "message": "数据库错误"}# 方式2：
class AlterUser(BaseModel):userid: intusername: str@app.put("/user/updateUser01/")
async def deleteUser(user: AlterUser):try:user1 = session.query(User).filter(User.userid == user.userid).first()if user1:user1.username = user.usernamesession.commit()session.close()return {"code": "0000", "message": "修改成功"}else:return {"code": "0001", "message": "参数错误"}except ArithmeticError:return {"code": "0002", "message": "数据库错误"}# if __name__ == '__main__':
#     import uvicorn
#     uvicorn.run(app=app, host="127.0.0.1", port=8000, debug=True)

这些代码的话可以通过 postman或者自带的api文档进行测试、

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

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

相关文章

IDE1007:当前上下文中不存在名称“xxx“

IDE1007:当前上下文中不存在名称“xxx“

这种在Halcon中直接导出的代码不能直接放程序中，应该在控件中比如一个按钮中，就不会出错了。
阅读更多...
【驱动】SPI驱动分析(五)-模拟SPI驱动

【驱动】SPI驱动分析(五)-模拟SPI驱动

简介 模拟SPI驱动是一种软件实现的SPI总线驱动。在没有硬件SPI控制器的系统中，通过软件模拟实现SPI总线的功能。它允许在不修改硬件的情况下，通过GPIO（通用输入/输出）引脚模拟SPI总线的通信，从而与SPI设备进行数据交换…
阅读更多...
单片机学习12——电容

单片机学习12——电容

电容的作用： 1）降压作用： 容抗： Xc 1/2fc 串联分压原理。2100Ω的容量，50Hz的频率，可以得到1.5uF。断电之后，需要串联一个1MΩ的电阻放电。 那是不是可以使用2100欧姆的电阻来代替电容呢&am…
阅读更多...
Redis基础系列-安装Redis

Redis基础系列-安装Redis

Redis基础系列-安装Redis 文章目录 Redis基础系列-安装Redis1. 环境要求2. 下载redis3. 安装4. 配置5 参考与感谢 1. 环境要求 （安装C语言编译环境）redis是用C语言开发的，所以需要安装C语言编译环境,中途可能会出现询问你是否需要可以安装&a…
阅读更多...
useDispatch和store.dispatch

useDispatch和store.dispatch

在 React 中，useDispatch 是 React Redux 提供的一个 hook，而 store.dispatch 是 Redux 中的一个方法。它们的作用是触发 Redux 中的 action，从而更新状态。下面是它们之间的主要区别： 使用场景： useDispatch: 这是 Re…
阅读更多...
DS八大排序之直接选择排序和堆排序

DS八大排序之直接选择排序和堆排序

前言 上一期我们已经介绍了，排序、为什么要有排序以及排序在实际生活中的应用。并且介绍并实现了直接插入排序和它的优化即希尔排序~！本期我们再来学习一组排序 ---- "选择排序"即直接选择排序和堆排序~！ 本期内容介绍 直接选择排…
阅读更多...
【机器视觉技术栈】- 机器视觉基础

【机器视觉技术栈】- 机器视觉基础

1.1 为什么采用机器视觉 人眼与机器视觉对比 人眼机器视觉精确性差，64灰度级，不能分辨小于100微米的目标强，256灰度级，可检测微米级目标速度慢，无法看清间隔小于40毫秒的运动目标快，快门时间可达10微秒适…
阅读更多...
操作系统背景知识

操作系统背景知识

一、程序分类 程序按其运行环境分为： 裸机程序：直接运行在对应硬件上的程序 应用程序：只能运行在对应操作系统上的程序 二、计算机系统的层次结构 计算机系统两种层次结构： 2.1 无操作系统的简单的两层结构 2.2 有操作系统的…
阅读更多...
企业软件的分类有哪些|app小程序定制开发

企业软件的分类有哪些|app小程序定制开发

企业软件的分类有哪些|app小程序定制开发 企业软件是指为了满足企业运营和管理需求而开发的软件系统。根据不同的功能和应用领域，企业软件可以分为以下几个分类： 1. 企业资源计划（Enterprise Resource Planning，ERP）软…
阅读更多...
Vue2升级到Vue3到底是不是一个正确的选择？

Vue2升级到Vue3到底是不是一个正确的选择？

Vue2升级到Vue3是否是一个正确的选择，这取决于您的项目需求和团队的技术栈。以下是一些关于Vue2升级到Vue3的优缺点，供您参考： 优点： 1. 性能提升：Vue3在性能方面进行了优化，包括渲染速度、内存占用等方面…
阅读更多...
云计算生成式 -给你不一样的音乐推荐新体验

云计算生成式 -给你不一样的音乐推荐新体验

目录 摘要： 正文： 一、亚马逊云与生成式 AI 结合的展望/总结 二、我用亚马逊云科技生成式 AI 产品打造了什么，解决了什么问题 三、未来云端技术发展趋势的见解 四、云端技术未来需要解决的问题 1、如何保护数据安全和隐私？ …
阅读更多...
空间连通区域@曲面积分为零问题@通量和散度@高斯公式物理意义

空间连通区域@曲面积分为零问题@通量和散度@高斯公式物理意义

文章目录 沿任意闭曲面的曲面积分为0的条件空间连通区域概念小结例 充要条件定理证明 通量和散度流量(通量)例 散度和高斯公式的物理意义借助速度场讨论一般向量场的散度小结例 高斯公式的向量场的通量和散度向量形式 沿任意闭曲面的曲面积分为0的条件 与讨论曲线积分中闭曲线…
阅读更多...
一个菜单两个二级路由的搭建

一个菜单两个二级路由的搭建

效果如下，而且这是最上方的菜单，需要进入以后重定向。 {path: /,name: HOME,component: ConsoleLayout, //这里也有router-viewmeta: {menu: false},redirect: {name: ManagerList},children: [{path: /rightsManage,name: RightsManage,component: () &…
阅读更多...
【FMC140】 基于VITA57.4标准的双通道5.2GSPS（或单通道10.4GSPS）射频采样FMC+子卡模块

【FMC140】 基于VITA57.4标准的双通道5.2GSPS（或单通道10.4GSPS）射频采样FMC+子卡模块

板卡概述 FMC140是一款具有缓冲模拟输入的低功耗、12位、双通道（5.2GSPS/通道）、单通道10.4GSPS、射频采样ADC模块，该板卡为FMC标准，符合VITA57.1规范，该模块可以作为一个理想的IO单元耦合至FPGA前端，8通道…
阅读更多...
第三届大湾区跨境物流商交会 深航协华南会14周年庆盛大召开

第三届大湾区跨境物流商交会 深航协华南会14周年庆盛大召开

2023年11月28日，华南物流商会年度盛典:第三届大湾区跨境物流商交会 暨 深航协华南会十四周年庆在深圳市龙华希尔顿逸林酒店隆重举行。长沙市驻深办事处刘永红主任、深圳市商务局鲁云帆处长、深圳市航空业协会朱庆峰会长、深圳市物流行业协会王利强会长、深圳市跨境电…
阅读更多...
ComfiUI API调用随记

ComfiUI API调用随记

来进行知识接力了： 首先了解下ComfiUI的APIstable diffusion comfyui的api使用教程-CSDN博客 对于ComfiUI，接口比较简单。查询接口比较容易看明白。 对于发起prompt的请求，如果需要图片的，则需预先上传图片给ComfiUI&#xff0c…
阅读更多...
基于深度学习的驾驶员状态监测预警系统（正文）

基于深度学习的驾驶员状态监测预警系统（正文）

摘 要 近年来驾驶员因疲劳驾驶而造成的交通事故逐年增多，驾驶员的驾驶状态对道路和人身安全产生重大影响，因此做好驾驶员驾驶状态的管理及预警是非常有必要的。 随着深度学习在目标检测算法应用的不断深入，YOLOv5等目标检测算法也相继具有了广…
阅读更多...
11.30固定成本，完全竞争市场，无差异曲线，帕累托最优

11.30固定成本，完全竞争市场，无差异曲线，帕累托最优

固定成本 固定成本是指不随生产量变化而变化的成本，它是企业在生产过程中无论产量高低都必须支付的成本。计算固定成本的方法如下： 确定固定成本的项目：首先需要确定固定成本的项目，例如租金、折旧费、固定人工费用等。 收集相关…
阅读更多...
暗物质：揭秘宇宙的隐形奥秘

暗物质：揭秘宇宙的隐形奥秘

暗物质：揭秘宇宙的隐形奥秘 一、引言 在浩瀚的宇宙中，有一种神秘的存在，它虽然看不见、摸不着，但却对宇宙的结构和演化起着至关重要的作用。这种存在就是暗物质。暗物质的研究是天文学和物理学领域的热点之一，科学家们正在利用各种手段来揭示它的奥秘。在本文中，我们将一…
阅读更多...
学习k8s的介绍（一）

学习k8s的介绍（一）

一、kubernetes及Docker相关介绍 1、kubernetes是什么 1-1、简称为k8s或kube，是一个可移植、可扩展的开源平台，用于管理容器化的工作负载和服务，可促进声明式配置和自动化。 声明式配置语法： kubectl create/apply/delete -f xx…
阅读更多...
最新文章

Copyright @ 2022~2023