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

news/2024/9/24 5:21:24/

在这里插入图片描述

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

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

🏆 作者简介:景天科技苑
🏆《头衔》:大厂架构师,华为云开发者社区专家博主,阿里云开发者社区专家博主,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提供的操作不一样,增加了学习成本

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

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/news/1426037.html

相关文章

InnoDB架构:内存篇

InnoDB架构&#xff1a;内存篇 InnoDB是MySQL数据库中默认的存储引擎&#xff0c;它为数据库提供了事务安全型&#xff08;ACID兼容&#xff09;、行级锁定和外键支持等功能。InnoDB的架构设计优化了对于读取密集和写入密集型应用的性能表现&#xff0c;是一个高度优化的存储系…

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

文章目录 前言一、什么是索引&#xff1f;二、不同索引结构对比2.1 二叉树2.2 平衡二叉树2.3 B-树2.4 B树 三、mysql 的索引3.1 聚簇索引3.2 非聚簇索引 前言 很多人看过mysql索引的介绍&#xff1a;hash表、B-树、B树、聚簇索引、主键索引、唯一索引、辅助索引、二级索引、联…

浏览器内置JS对象 / 事件 / 请求

浏览器内置JS对象&事件&请求 BOM - 【Browser】浏览器对象功能区域的相关操作 location - 跳转 / 读取路由数据 location.href > https://www.baidu.com/search?classbrowser#comments location.protocol > https; location.host > www.baidu.com; locati…

SpringCloud本地多网卡,服务注册地址处理

问题 Spring Cloud指定服务注册地址Dubbo指定服务注册地址 Spring Cloud指定服务注册地址 在bootstrap.yaml中写入如下内容&#xff0c;192.168.xxx.xxx是需要注册到注册中心的服务ip&#xff0c;也可以写成网段192.168.10.xxx spring:cloud:inetutils:preferred-networks: &…

Edge 浏览器的使用心得与深度探索

前言 Edge 浏览器是微软推出的一款现代化网络浏览器&#xff0c;旨在提供更快、更安全、更智能的网络浏览体验。作为一名前端开发者和网页浏览者&#xff0c;我在长期使用 Edge 浏览器的过程中积累了一些使用心得和对其功能的深度探索。在本文中&#xff0c;我将分享我对 Edge…

element-ui form表单自定义label的样式、内容

element-ui form表单自定义label的样式、内容 效果截图 代码 <el-form size"small" :inline"true" label-width"120px"><el-form-item prop"name"><div slot"label"><i style"color: red;"…

最小生成树算法的实现c++

最小生成树算法的实现c 题目链接&#xff1a;1584. 连接所有点的最小费用 - 力扣&#xff08;LeetCode&#xff09; 主要思路&#xff1a;使用krusal算法&#xff0c;将边的权值进行排序&#xff08;从小到大排序&#xff09;&#xff0c;每次将权值最小且未加入到连通分量中…

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

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