【python】flask操作数据库工具SQLAlchemy，详细用法和应用实战

ops/2024/9/23 2:39:04/

在这里插入图片描述

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

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

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

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

文章目录

  • ORM
    • Flask-SQLAlchemy
    • 原生SQLAlchemy连接配置操作
    • 针对数据库的增删改查操作
      • 添加数据
      • 添加多条数据
      • 查询所有数据
      • 按条件查询
      • 更新一条数据
      • 更新多条数据
      • 删除一条数据
      • 删除多条数据
      • 执行原生sql语句
    • 总结

ORM

ORM 全拼Object-Relation Mapping，中文意为 对象-关系映射。主要实现模型对象到关系数据库数据的映射。

ORM提供了一种面向对象操作数据库的方式给开发者。不需要编写原生SQL语句也能操作数据库，实现了业务代码与底层数据的解耦。

优点：

  • 只需要面向对象编程, 不需要面向数据库编写SQL。
    • 对数据库的操作都转化成对类/对象的属性和方法的操作. 表字段—>对象属性, SQL关键字-> 操作方法
    • 不用编写各种数据库的原生sql语句，当然也可以编写原生SQL语句。
  • 实现了数据模型代码与数据库数据的解耦, 屏蔽了不同数据库操作上的差异。
    • 不再需要关注当前项目使用的是哪种数据库。
    • 通过简单的配置就可以轻松更换数据库, 而不需要修改业务代码.

缺点：

  • 相比较直接使用SQL语句操作数据库,ORM需要把操作转换成SQL语句，所以有性能损失.
  • 根据对象的操作转换成SQL语句,根据查询的结果转化成模型实例对象, 在映射过程中有性能损失.
  • 不同的ORM提供的操作不一样，增加了学习成本

flask与python原生操作数据库流程对比
在这里插入图片描述

SQLAlchemy_42">Flask-SQLAlchemy

flask默认不提供数据库操作，也并没有提供ORM，所以一般开发的时候我们会采用flask-SQLAlchemy模块来实现ORM操作。

SQLAlchemy是一个python语言编写的高性能的关系型数据库ORM框架，它提供了高层的 ORM 和底层的原生数据库的操作。

我们使用sqlalchemy 不需要调用sqlalchemy 本身这个模块，而是采用flask-sqlalchemy ，这是一个简化了 SQLAlchemy 操作的flask扩展模块。（主要是简化了sqlalchemy初始化代码和分页操作等）

安装 flask-sqlalchemy

python">pip install flask-sqlalchemy

在这里插入图片描述

如果sqlalchemy连接的是 mysql /MariaDB数据库，需要安装 mysqldb 或pymysql驱动

python">pip install pymysql

SQLAlchemy_70">原生SQLAlchemy连接配置操作

db.py，代码：

python">from sqlalchemy import create_engine   # 驱动引擎
from sqlalchemy.ext.declarative import declarative_base # 数据库基类
from sqlalchemy import Column, Integer, String, Boolean, Numeric, Text # 字段、整型
from sqlalchemy.orm import sessionmaker  # 连接会话#创建数据库连接引擎
engine = create_engine(# 连接数据库的URL,url里面是数据库类型+数据库驱动url="mysql+pymysql://root:Jin*******7!@10.10.0.52:3306/students?charset=utf8mb4",  # 如果底层驱动是pymysql# url="mysql://root:123@127.0.0.1:3306/students?charset=utf8mb4",    # 如果底层驱动是MysqlDBecho=True, # 当设置为True时会将orm语句转化为sql语句打印，一般debug的时候可用pool_size=8, # 连接池的大小，默认为5个，设置为0时表示连接无限制pool_recycle=60*30 # 设置时间以限制数据库多久没连接自动断开，单位是秒
)#创建会话连接
DbSession = sessionmaker(bind=engine)
session = DbSession()# 创建数据基类
Model = declarative_base()

在这里插入图片描述

manage.py，代码：

python">import db
#声明的数据库类要继承我们创建的数据库基类
class Student(db.Model):#声明表名__tablename__ = "flask_student"#设置表中的字段，字段类型，约束等id = db.Column(db.Integer, primary_key=True)name = db.Column(db.String(255))sex  = db.Column(db.Boolean)age  = db.Column(db.Integer)#如果表中有的字段是python中的关键字，则不能直接定义，需要用到别名转换class_name = db.Column("class", db.String(255),)description = db.Column(db.Text)is_delete = db.Column(db.Boolean, nullable=True, default=False)if __name__ == '__main__':# 如果没有提前声明模型中的数据表，则可以采用以下代码生成数据表，# 如果数据库中已经声明了有数据表，则不会继续生成db.Model.metadata.create_all(db.engine)

执行，可以看到执行的sql语句
在这里插入图片描述

查看数据库，有创建我们指定的表
在这里插入图片描述

看下表结构
在这里插入图片描述

针对数据库的增删改查操作

添加数据

python"># 添加一条数据
student = Student(name="zhangsan",class_name="301",sex=True,age=18,description="张三爱发明",is_delete = True
)
db.session.add(student)
db.session.commit()

在这里插入图片描述

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

添加多条数据

python">student_list = [Student(name="xiaohei", class_name="305", sex=False, age=18, description="美美的..",),Student(name="xiaobai", class_name="304", sex=True, age=18, description="美美的..",),Student(name="xiaohui", class_name="303", sex=False, age=18, description="美美的..",),
]db.session.add_all(student_list)
db.session.commit()

在这里插入图片描述

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

查询所有数据

python">data_list = db.session.query(Student).all()
print(data_list)
for data in data_list:print(data.name)

在这里插入图片描述

默认我们打印出来查询的是类对象，我们可以在模型类中通过__repr__方法，将类对象转化为我们自定义的格式化字符串

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

在这里插入图片描述

在这里插入图片描述

根据ID查询一条数据，query里面的参数是我们创建的表类名，查询不到返回为None

python">ret = db.session.query(Student).get(1)
print(ret)
print(ret.name)
print(ret.class_name)

在这里插入图片描述

查询不存在的id，返回为None
在这里插入图片描述

所以，查询之前要做个判断
在这里插入图片描述

按条件查询

python">data_list = db.session.query(Student).filter(Student.sex==True, Student.class_name=='301').all()
print(data_list)
for data in data_list:print(data.sex, data.name)

在这里插入图片描述

更新一条数据

python">student = db.session.query(Student).get(35)
student.name = "小会"
db.session.commit()

在这里插入图片描述

查看数据库，可见id为3的记录名字已被修改
在这里插入图片描述

更新多条数据

python">db.session.query(Student).filter(Student.class_name=="305").update({Student.age:Student.age+1})
db.session.commit()

先看下更新之前，班级为305的学生的年龄都是18岁
在这里插入图片描述

执行之后
在这里插入图片描述

年龄被修改
在这里插入图片描述

删除一条数据

python">student = db.session.query(Student).get(3)
db.session.delete(student)
db.session.commit()

在这里插入图片描述

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

删除多条数据

python">db.session.query(Student).filter(Student.class_name == "304").delete()
db.session.commit()

删除之前，我们先添加些数据
在这里插入图片描述

执行删除
在这里插入图片描述

可见班级为304的数据已被删除
在这里插入图片描述

执行原生sql语句

python"># 原生SQL语句
# 读
cursor = db.session.execute('select * from flask_student;')
#一条
data = cursor.fetchone()
print(data)

此时，会报如下错误
在这里插入图片描述

出错原因：是因为因为安装的python包依赖sqlalchmy版本不一致造成的

我的代码原来是这样的db.session.execute(“select * from flask_student”)把他改成

db.session.execute(text(“select * from flask_student”))这样，然后记得导入from sqlalchemy.sql import text。就可以了。

最新用法

python"># 原生SQL语句
from sqlalchemy.sql import text
# 读
cursor = db.session.execute(text('select * from flask_student'))
#一条
data = cursor.fetchone()
print(data)

在这里插入图片描述

#获取多条

python">data_list = cursor.fetchall()
print(data_list)

在这里插入图片描述

写[添加、删除、修改]

python">sql ='insert into flask_student(name, class, age, sex, description,is_delete) values(:name, :class, :age, :sex, :description, :is_delete)'
cursor = db.session.execute(text(sql),params={"name": "jintian","class": "307","age": 19,"sex": 0,"description": ".....","is_delete":False})
db.session.commit()
print(cursor.lastrowid)  # 获取最后添加的主键ID

在这里插入图片描述

数据库查看

在这里插入图片描述

总结

本文详述了python中的SQLAlchemy操作mysql数据库的详细用法，后续在我们在flask中操作数据库就借助这个工具，非常实用，感兴趣的朋友可以一键三连，flask的高阶用法持续更新中！！！


http://www.ppmy.cn/ops/3681.html

相关文章

前端开发攻略---在输入框中输入中文但是还没选中的时候，搜索事件依然存在；中文输入法导致的高频事件。

前端开发攻略---在输入框中输入中文但是还没选中的时候，搜索事件依然存在；中文输入法导致的高频事件。

1、演示 解决前 解决后 2、输入框事件介绍 compositionstart事件在用户开始使用输入法输入时触发。这意味着用户正在进行组合输入&#xff0c;比如在中文输入法中&#xff0c;用户可能正在输入一个多个字符的词语。在这个阶段&#xff0c;输入框的内容可能还没有完全确定&#…
阅读更多...
Elasticsearch(2)

Elasticsearch(2)

目录 121.ES查询中match和term的区别？ 122.Es查询中should和must的区别？ 123.ES查询中match,match_phrase和match_phase_prefix有什么区别？ 124.ES查询中什么是复合查询？有哪些复合查询方式？
阅读更多...
深入刨析 mysql 底层索引结构B+树

深入刨析 mysql 底层索引结构B+树

文章目录 前言一、什么是索引&#xff1f;二、不同索引结构对比2.1 二叉树2.2 平衡二叉树2.3 B-树2.4 B树 三、mysql 的索引3.1 聚簇索引3.2 非聚簇索引 前言 很多人看过mysql索引的介绍&#xff1a;hash表、B-树、B树、聚簇索引、主键索引、唯一索引、辅助索引、二级索引、联…
阅读更多...
【Web】陇原战“疫“2021网络安全大赛 题解

【Web】陇原战“疫“2021网络安全大赛 题解

目录 CheckIN eaaasyphp EasyJaba CheckIN 拿到附件&#xff0c;贴出关键代码 func getController(c *gin.Context) {cmd : exec.Command("/bin/wget", c.QueryArray("argv")[1:]...)err : cmd.Run()if err ! nil {fmt.Println("error: ", …
阅读更多...
桥接模式【结构型模式C++】

桥接模式【结构型模式C++】

1.概述 桥接模式是一种结构型设计模式&#xff0c;是用于把抽象化与实现化解耦&#xff0c;使得二者可以独立变化。这种类型的设计模式属于结构型模式&#xff0c;它通过提供抽象化和实现化之间的桥接结构&#xff0c;来实现二者的解耦。 这种模式涉及到一个作为桥接的接口&am…
阅读更多...
语言模型的发展

语言模型的发展

文章目录 语言模型的发展历程大语言模型的能力特点大语言模型关键技术概览大语言模型对科技发展的影响 语言模型的发展历程 一般来说&#xff0c;语言模型旨在对于人类语言的内在规律进行建模&#xff0c;从而准确预测词序列中未来&#xff08;或缺失&#xff09;词或词元&…
阅读更多...
【无标题】PHP-parse_str变量覆盖

【无标题】PHP-parse_str变量覆盖

[题目信息]&#xff1a; 题目名称题目难度PHP-parse_str变量覆盖1 [题目考点]&#xff1a; 变量覆盖指的是用我们自定义的参数值替换程序原有的变量值&#xff0c;一般变量覆盖漏洞需要结合程序的其它功能来实现完整的攻击。 经常导致变量覆盖漏洞场景有&#xff1a;$$&…
阅读更多...
JWT原理

JWT原理

为什么会有JWT的出现&#xff1f; 首先不得不提到一个知识叫做跨域身份验证&#xff0c;JWT的出现就是为了更好的解决这个问题&#xff0c;但是在没有JWT的时候&#xff0c;我们一般怎么做呢&#xff1f;一般使用Cookie和Session&#xff0c;流程大体如下所示&#xff1a; 用…
阅读更多...
最新文章

Copyright @ 2022~2023