【python】flask结合SQLAlchemy，在视图函数中实现对数据库的增删改查

news2024/11/24 2:02:59

在这里插入图片描述

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

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

🏆 作者简介：景天科技苑
🏆《头衔》：大厂架构师，华为云开发者社区专家博主，阿里云开发者社区专家博主，CSDN全栈领域优质创作者，掘金优秀博主，51CTO博客专家等。
🏆《博客》：Python全栈，前后端开发，人工智能，js逆向，App逆向，网络系统安全，数据分析，Django，fastapi，flask等框架，linux，shell脚本等实操经验，网站搭建，面试宝典等分享。

所属的专栏：flask框架零基础，进阶应用实战教学
景天的主页：景天科技苑

文章目录

  • flask项目中数据库连接设置
    • 数据库基本操作
    • 模型类定义
  • flask中数据表操作
    • 创建和删除表
    • 数据操作
      • 添加一条数据
      • 添加多条数据
      • 更新操作
      • 删除操作
  • 关于数据库锁
  • 总结

上一章，我们学到了在python中怎么使用SQLAlchemy来操作数据库，在工作中，我们经常结合flask来操作数据库。本章我们来一起深入探讨下！！！

flask项目中数据库连接设置

  • 在 Flask-SQLAlchemy 中，数据库的链接配置信息使用URL指定，而且程序使用的数据库必须保存到Flask的 SQLALCHEMY_DATABASE_URI 配置项中

manage.py，代码：

# SQLAlchemy的链接配置："数据库名://账户名:密码@服务器地址:端口/数据库名称?配置参数选项"
app.config["SQLALCHEMY_DATABASE_URI"] = "mysql://root:123@127.0.0.1:3306/flaskdemo?charset=utf8mb4"



# 如果不使用mysqldb改用pymysql，则需要在连接时指定pymysql
# app.config["SQLALCHEMY_DATABASE_URI"] = "mysql+pymysql://root:Jin*******7!@10.10.0.52:3306/students?charset=utf8mb4"

其他设置项：

# 动态追踪修改设置，如未设置只会提示警告
app.config["SQLALCHEMY_TRACK_MODIFICATIONS"] = True
# 查询时会显示原始SQL语句
app.config["SQLALCHEMY_ECHO"] = True

常用的SQLAlchemy字段类型与python数据类型对照
在这里插入图片描述

常用的SQLAlchemy列约束选项
在这里插入图片描述

数据库基本操作

  • 在SQLAlchemy中，添加、修改、删除操作，均由数据库会话(sessionSM)管理。
    • 会话用 db.session 表示。在准备把数据写入数据库前，要先将数据添加到会话中然后调用 db.session.commit() 方法提交会话。
  • 在SQLAlchemy 中，查询操作是通过 query 对象操作数据。
    • 最基本的查询是返回表中所有数据，也可以通过filter或filter_by过滤器进行更精确的数据库查询。

模型类定义

我们后面会把模型创建到单独的文件中，但是现在我们先把模型类写在main.py文件中。

from flask import Flask
from flask_sqlalchemy import SQLAlchemy


app = Flask(__name__)
# 连接数据库连接url
app.config["SQLALCHEMY_DATABASE_URI"] = "mysql+pymysql://root:Jinghao31357!@10.10.0.52:3306/students?charset=utf8mb4"
# 动态追踪修改设置，如未设置只会提示警告
app.config["SQLALCHEMY_TRACK_MODIFICATIONS"] = True
# 查询时会显示原始SQL语句
app.config["SQLALCHEMY_ECHO"] = True

# 把SQLAlchemy组件注册到项目中
db = SQLAlchemy()
db.init_app(app)


#创建模型类
class Student(db.Model):
    """学生信息模型"""

    #下面的字段配置相当于执行sql语句如下
    """
    CREATE TABLE tb_student2 (
        id INTEGER NOT NULL COMMENT '主键' AUTO_INCREMENT, 
        name VARCHAR(15) COMMENT '姓名', 
        age SMALLINT COMMENT '年龄', 
        sex BOOL COMMENT '性别', 
        email VARCHAR(128) COMMENT '邮箱地址', 
        money NUMERIC(10, 2) COMMENT '钱包', 
        PRIMARY KEY (id), 
        UNIQUE (email)
    )
    """

    # 声明与当前模型绑定的数据表名称
    __tablename__ = "tb_student2"
    id = db.Column(db.Integer, primary_key=True, comment="主键")
    name = db.Column(db.String(15), index=True, comment="姓名")
    age = db.Column(db.SmallInteger, comment="年龄")
    sex = db.Column(db.Boolean, default=True, comment="性别")
    email = db.Column(db.String(128), unique=True, comment="邮箱地址")
    money = db.Column(db.Numeric(10, 2), default=0.0, comment="钱包")

    def __repr__(self):  # 相当于django的__str__
        return f"{self.name}<{self.__class__.__name__}>"


class Course(db.Model):
    """课程模型"""
    """
        CREATE TABLE tb_course (
        id INTEGER NOT NULL COMMENT '主键' AUTO_INCREMENT, 
        name VARCHAR(255) COMMENT '课程', 
        price NUMERIC(8, 2) COMMENT '价格', 
        PRIMARY KEY (id), 
        UNIQUE (name)
    )

    """
    __tablename__ = "tb_course"
    id = db.Column(db.Integer, primary_key=True, comment="主键")
    name = db.Column(db.String(255), unique=True, comment="课程")
    price = db.Column(db.Numeric(8, 2), comment="价格")

    def __repr__(self):  # 相当于django的__str__
        return f"{self.name}<{self.__class__.__name__}>"


class Teacher(db.Model):
    """老师模型"""
    """
    CREATE TABLE tb_teacher (
        id INTEGER NOT NULL COMMENT '主键' AUTO_INCREMENT,
        name VARCHAR(255) COMMENT '姓名',
        `option` ENUM('讲师','助教','班主任'),
        PRIMARY KEY (id),
        UNIQUE (name)
    )
    """
    __tablename__ = "tb_teacher"
    id = db.Column(db.Integer, primary_key=True, comment="主键")
    name = db.Column(db.String(255), unique=True, comment="姓名")
    option = db.Column(db.Enum("讲师", "助教", "班主任"), default="讲师")

    def __repr__(self):
        return f"{self.name}<{self.__class__.__name__}>"



if __name__ == '__main__':
    #要想执行创建表，需要调用db.creat_all()，db要想被调用，需要放到app上下文里面
    with app.app_context():
        # 如果没有提前声明模型中的数据表，则可以采用以下代码生成数据表，
        # 如果数据库中已经声明了有数据表，则不会继续生成
        db.create_all()
    app.run(debug=True)

在这里插入图片描述

flask中数据表操作

创建和删除表

创建表

# 在视图内调用：
@app.route("/create")
def create_table():
    db.create_all() # 为项目中被识别的所有模型创建数据表
    return "ok"



# 在视图以外的地方调用：
with app.app_context():
    # create_all()方法执行的时候，需要放在模型的后面
    # 检测数据库中是否存在和模型匹配的数据表。
    # 如果没有，则根据模型转换的建表语句进行建表。
    # 如果找到，则不会进行额外处理
    db.create_all()

删除表

# 在视图内调用：
@app.route("/drop")
def drop_table():
    db.drop_all()   # 为项目中被识别的所有模型删除数据表
    return "ok"


# 在视图以外的地方调用：
    with app.app_context():
        db.drop_all()  # 慎用，很给力的！！这表示删除数据库中所有模型对应的表。

数据操作

添加一条数据

#在视图函数中实现增删改查
@app.route("/data")
def data():
    """添加数据"""
    # # 添加一条数据
    student = Student(
        name="小明",
        age=17,
        sex=True,
        email="xiaoming@qq.com",
        money=30.50
    )
    db.session.add(student)
    db.session.commit()
    return "ok"

get请求访问data路径
在这里插入图片描述

可以看到数据已被添加到表中
在这里插入图片描述

添加多条数据

student_list = [
    Student(name="小黑", age=16, sex=True, email="xiaohei@qq.com", money=1000),
    Student(name="小红", age=15, sex=False, email="xiaohong@qq.com", money=1200),
    Student(name="小兰", age=11, sex=True, email="xiaolan@qq.com", money=600),
    Student(name="小白", age=21, sex=False, email="xiaobai@qq.com", money=2900),
]
db.session.add_all(student_list)
db.session.commit()

在这里插入图片描述

查看数据库
在这里插入图片描述

更新操作

更新一条数据


student = Student.query.get(3)
student.age = 18
db.session.commit()

更新之前，我们先看下3号的年龄
在这里插入图片描述

浏览器访问后查看
在这里插入图片描述

可见年龄被修改成18
在这里插入图片描述

更新多条数据

Student.query.filter(Student.sex == True).update({
    Student.money: Student.age * 100,
})
db.session.commit()

在这里插入图片描述

可见sex为True的money改成了年龄乘以100
在这里插入图片描述

删除操作

删除一条数据

student = Student.query.get(5)
db.session.delete(student)
db.session.commit()

在这里插入图片描述

id为5的数据被删除
在这里插入图片描述

删除多条数据

Student.query.filter(Student.sex==False).delete()
db.session.commit()

删之前先看看数据库表数据
在这里插入图片描述

浏览器访问/data
在这里插入图片描述

查看数据库，sex为False的全部被删除
在这里插入图片描述

完整代码：

from flask import Flask
from flask_sqlalchemy import SQLAlchemy


app = Flask(__name__)
# 连接数据库连接url
app.config["SQLALCHEMY_DATABASE_URI"] = "mysql+pymysql://root:Jinghao31357!@10.10.0.52:3306/students?charset=utf8mb4"
# 动态追踪修改设置，如未设置只会提示警告
app.config["SQLALCHEMY_TRACK_MODIFICATIONS"] = True
# 查询时会显示原始SQL语句
app.config["SQLALCHEMY_ECHO"] = True

# 把SQLAlchemy组件注册到项目中
db = SQLAlchemy()
db.init_app(app)


#创建模型类
class Student(db.Model):
    """学生信息模型"""

    # 声明与当前模型绑定的数据表名称
    __tablename__ = "tb_student2"
    id = db.Column(db.Integer, primary_key=True, comment="主键")
    name = db.Column(db.String(15), index=True, comment="姓名")
    age = db.Column(db.SmallInteger, comment="年龄")
    sex = db.Column(db.Boolean, default=True, comment="性别")
    email = db.Column(db.String(128), unique=True, comment="邮箱地址")
    money = db.Column(db.Numeric(10, 2), default=0.0, comment="钱包")

    def __repr__(self):  # 相当于django的__str__
        return f"{self.name}<{self.__class__.__name__}>"


class Course(db.Model):
    """课程模型"""

    __tablename__ = "tb_course"
    id = db.Column(db.Integer, primary_key=True, comment="主键")
    name = db.Column(db.String(255), unique=True, comment="课程")
    price = db.Column(db.Numeric(8, 2), comment="价格")

    def __repr__(self):  # 相当于django的__str__
        return f"{self.name}<{self.__class__.__name__}>"



class Teacher(db.Model):
    """老师模型"""
    __tablename__ = "tb_teacher"
    id = db.Column(db.Integer, primary_key=True, comment="主键")
    name = db.Column(db.String(255), unique=True, comment="姓名")
    #枚举类型
    option = db.Column(db.Enum("讲师", "助教", "班主任"), default="讲师")

    def __repr__(self):
        return f"{self.name}<{self.__class__.__name__}>"

#在视图函数中实现增删改查
@app.route("/data")
def data():
    """添加数据"""
    # # 添加一条数据
    # student = Student(
    #     name="小明",
    #     age=17,
    #     sex=True,
    #     email="xiaoming@qq.com",
    #     money=30.50
    # )
    # db.session.add(student)
    # db.session.commit()



    # # 添加多条数据
    # student_list = [
    #     Student(name="小黑", age=16, sex=True, email="xiaohei2@qq.com", money=1000),
    #     Student(name="小红", age=15, sex=False, email="xiaohong2@qq.com", money=1200),
    #     Student(name="小兰", age=11, sex=True, email="xiaolan2@qq.com", money=600),
    #     Student(name="小白", age=21, sex=False, email="xiaobai2@qq.com", money=2900),
    # ]
    # db.session.add_all(student_list)
    # db.session.commit()


    """更新操作"""
    # # 更新一条数据
    # student = Student.query.get(3)
    # student.age = 18
    # db.session.commit()



    # 更新多条数据
    # Student.query.filter(Student.sex == True).update({
    #     Student.money: Student.age * 100,
    # })
    # db.session.commit()


    """删除操作"""
    # # 删除一条数据
    # student = Student.query.get(5)
    # db.session.delete(student)
    # db.session.commit()


    # # 删除多条数据
    Student.query.filter(Student.sex==False).delete()
    db.session.commit()


    return "ok"



if __name__ == '__main__':
    #要想执行创建表，需要调用db.creat_all()，db要想被调用，需要放到app上下文里面
    with app.app_context():
        # 如果没有提前声明模型中的数据表，则可以采用以下代码生成数据表，
        # 如果数据库中已经声明了有数据表，则不会继续生成
        db.create_all()
    app.run(debug=True)

关于数据库锁

悲观锁，是属于数据库中的一种互斥锁机制，但是乐观锁并非真正的数据库锁。
2种锁都是数据库在应对并发操作时，防止出现资源抢夺的，基于不同人生观所实现2种解决方案。
悲观锁的基本使用：
>>> 数据库终端开始

begin;  -- 开启事务
select * from db_student where student_id = 5 for update; -- 添加一把更新锁【悲观锁】
....    -- 在事务提交之前，任何第三方连接都不能修改 student_id = 5这条数据 
update from db_student set age = 16 where student_id = 5;
commit; -- 提交事务

<<< 数据库终端开始

悲观锁的问题：

  1. 提前锁定数据，形成串行化，形成阻塞，不利于性能发挥，不适用高并发场景。
  2. 悲观锁只能保证数据的一致性，不能保证脏数据的出现

乐观锁的出现就是为了解决悲观锁的问题。
举例：双11活动，商城里面id=5的商品的库存num=10了，现在我们要基于乐观锁和悲观锁来解决下单过程中，出现的资源抢夺现象，避免出现超卖（商品数量不能为负数）。

乐观锁：
—> begin; 开启事务
—> 先查看库存，记录当前库存 original_num=10
—> 进行下单操作，买6件
—> 付款
—> 扣除库存 update goods set num=num-6 where num=original_num and id=5; # 增加更新条件，判断库存是否还是原来
如果执行成功，则表示没有人抢，购买成功
—> commit;
如果执行失败，则表示已经有人先抢购
—> rollback;

悲观锁：
—> begin; 开启事务
—> 先给id=5的数据，加锁
select * from goods where id=5 for update;
—> 进行下单操作，买6件
—> 付款
—> 扣除库存 update from goods set num=num-6 where id=5;
—> 执行成功解锁
—> commit; 提交事务

总结

本文详述了在flask项目中结合SQLAlchemy操作mysql数据库的详细用法，非常实用，感兴趣的朋友可以一键三连，flask的高阶用法持续更新中！！！

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

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

相关文章

C++11(下篇)

C++11(下篇)

文章目录 C111. 模版的可变参数1.1 模版参数包的使用 2. lambda表达式2.1 Lambda表达式语法捕获列表说明 2.2 lambda的底层 3. 包装器3.1 function包装器3.2 bind 4. 线程库4.1 thread类4.2 mutex类4.3 atomic类4.4 condition_variable类 C11 1. 模版的可变参数 C11支持模版的…
阅读更多...
初学若依笔记

初学若依笔记

初学若依 下载ruoyi(以前后端分离板为例) https://ruoyi.vip/ 部署 安装mysql安装redis将数据库和redis配置到若依 配置文件为 ruoyi-admin\src\main\resource\application-druid.yml 运行 略 开发自己的功能 创建模块 为了不影响原有功能&#xff0c;创建一个模块写自…
阅读更多...
[AI]-(第0期)：认知深度学习

[AI]-(第0期)：认知深度学习

深度学习是一种人工智能&#xff08;AI&#xff09;方法&#xff0c;用于教计算机以受人脑启发的方式处理数据。 深度学习模型可以识别图片、文本、声音和其他数据中的复杂模式&#xff0c;从而生成准确的见解和预测。 您可以使用深度学习方法自动执行通常需要人工智能完成的…
阅读更多...
深入理解大语言模型微调技术

深入理解大语言模型微调技术

一、概念解析 1、什么是微调&#xff08;Fine-tuning&#xff09;&#xff1f; 大模型微调&#xff0c;也称为Fine-tuning&#xff0c;是指在已经预训练好的大型语言模型基础上&#xff08;一般称为“基座模型”&#xff09;&#xff0c;使用特定的数据集进行进一步的训练&am…
阅读更多...
pandas基本用法

pandas基本用法

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 前言一、pandas的数据结构1、一维数组pd.Series1.1 pd.Series&#xff08;data,index,dtype&#xff09;示例1&#xff1a;不定义index示例2&#xff1a;自定义inde…
阅读更多...
【C++学习】C++IO流

【C++学习】C++IO流

这里写目录标题 &#x1f680;C语言的输入与输出&#x1f680;什么是流&#x1f680;CIO流&#x1f680;C标准IO流&#x1f680;C文件IO流 &#x1f680;C语言的输入与输出 C语言中我们用到的最频繁的输入输出方式就是scanf ()与printf()。 scanf(): 从标准输入设备(键盘)读取…
阅读更多...
14.C++常用的算法_排序算法

14.C++常用的算法_排序算法

文章目录 遍历算法1. sort()代码工程运行结果 2. random_shuffle()代码工程运行结果第一次运行结果第二次运行结果第三次运行结果 3. merge()代码工程运行结果 4. reverse()代码工程运行结果 遍历算法 1. sort() 代码工程 sort()函数默认是升序排列&#xff0c;如果想要降序…
阅读更多...
Jenkins配置windows/linux从节点

Jenkins配置windows/linux从节点

背景&#xff1a; 环境&#xff1a;jenkins环境&#xff08;Ubuntu&#xff09; 节点机器&#xff1a;Linux、Windows 前置条件&#xff1a; 节点机器&#xff1a;安装java、allure、python 1 Linux节点管理机器添加 1.1 系统管理->节点列表->New Node 1.2 节点配置…
阅读更多...
基于微信小程序投票评选系统的设计与实现(论文+源码)_kaic

基于微信小程序投票评选系统的设计与实现(论文+源码)_kaic

摘 要 社会发展日新月异&#xff0c;用计算机应用实现数据管理功能已经算是很完善的了&#xff0c;但是随着移动互联网的到来&#xff0c;处理信息不再受制于地理位置的限制&#xff0c;处理信息及时高效&#xff0c;备受人们的喜爱。所以各大互联网厂商都瞄准移动互联网这个潮…
阅读更多...
Weblogic 数据源无法解析错误的解决方法

Weblogic 数据源无法解析错误的解决方法

问题现象 javax.naming.NameNotFoundException: Unable to resolve datasource1. Resolved ; remaining name datasource1at weblogic.jndi.internal.BasicNamingNode.newNameNotFoundException(BasicNamingNode.java:1292)at weblogic.jndi.internal.BasicNamingNode.lookupH…
阅读更多...
2024.4.16 驱动开发

2024.4.16 驱动开发

思维导图
阅读更多...
leetcode-合并两个有序链表

leetcode-合并两个有序链表

目录 题目 图解 方法一 方法二 代码(解析在注释中) 方法一 ​编辑方法二 题目 将两个升序链表合并为一个新的 升序 链表并返回。新链表是通过拼接给定的两个链表的所有节点组成的。 示例 1&#xff1a; 输入&#xff1a;l1 [1,2,4], l2 [1,3,4] 输出&#xff1a;[1,1…
阅读更多...
电机控制器电路板布局布线参考指导（五）

电机控制器电路板布局布线参考指导（五）

电机控制器电路板布局布线参考指导&#xff08;五&#xff09;大容量电容和旁路电容的放置 1.大容量电容的放置2.电荷泵电容器3.旁路电容/去耦电容的放置3.1 靠近电源3.2 靠近功率器件3.3 靠近开关电流源3.4 靠近电流感测放大器3.5 靠近稳压器 tips&#xff1a;资料主要来自网络…
阅读更多...
Spring Boot 多环境配置：YML 文件的三种高效方法

Spring Boot 多环境配置：YML 文件的三种高效方法

&#x1f31f; 前言 欢迎来到我的技术小宇宙&#xff01;&#x1f30c; 这里不仅是我记录技术点滴的后花园&#xff0c;也是我分享学习心得和项目经验的乐园。&#x1f4da; 无论你是技术小白还是资深大牛&#xff0c;这里总有一些内容能触动你的好奇心。&#x1f50d; &#x…
阅读更多...
【Redis 神秘大陆】006 灾备方案

【Redis 神秘大陆】006 灾备方案

六、Redis 灾备方案 6.1 存储方案 6.1.1 基础对比 RDB持久化AOF持久化原理周期性fork子进程生成持久化文件每次写入记录命令日志文件类型二进制dump快照文件文本appendonly日志文件触发条件默认超过300s间隔且有1s内超过1kb数据变更永久性每秒fsync一次文件位置配置文件中指…
阅读更多...
基于Qt的二维码生成与识别

基于Qt的二维码生成与识别

基于Qt的二维码生成与识别 一、获取QZxing开源库 1.通过封装的QZxing开源库生成和识别二维码&#xff0c;下载地址&#xff1a;GitCode - 开发者的代码家园https://gitcode.com/mirrors/ftylitak/qzxing/tree/master。 2.下载解压后&#xff0c;使用Qt Creator xx&#xff0…
阅读更多...
如何采集opc服务器数据上传云端

如何采集opc服务器数据上传云端

为了进一步提高生产效率&#xff0c;生产制造的不断朝着智能化发展和升级&#xff0c;传统的自动化生产系统已经不能满足需求。传统的SCADA系统一般是用于现场的数据采集与控制&#xff0c;但是本地控制已经无法满足整个工厂系统智能化数字化的需求&#xff0c;智能化数字化是需…
阅读更多...
NTC热敏电阻采集温度-单片机通用模板

NTC热敏电阻采集温度-单片机通用模板

NTC热敏电阻采集温度-单片机通用模板 一、NTC热敏电阻转换温度的原理二、AT104Tem.c的实现三、AT104Tem.h的实现 一、NTC热敏电阻转换温度的原理 ①NTC热敏电阻会随着温度的升高&#xff0c;电阻值R逐渐降低&#xff1b;②硬件搭建电阻分压电路采集ADC逆推热敏电阻当前的阻值&…
阅读更多...
线上频繁fullgc问题-SpringActuator的坑

线上频繁fullgc问题-SpringActuator的坑

整体复盘 一个不算普通的周五中午&#xff0c;同事收到了大量了cpu异常的报警。根据报警表现和通过arthas查看&#xff0c;很明显的问题就是内存不足&#xff0c;疯狂无效gc。而且结合arthas和gc日志查看&#xff0c;老年代打满了&#xff0c;gc不了一点。既然问题是内存问题&…
阅读更多...
[html]一个动态js倒计时小组件

[html]一个动态js倒计时小组件

先看效果 代码 <style>.alert-sec-circle {stroke-dasharray: 735;transition: stroke-dashoffset 1s linear;} </style><div style"width: 110px; height: 110px; float: left;"><svg style"width:110px;height:110px;"><cir…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023