网站域名备案注册证书,html5手机app网站模板免费下载,教育网站模块建设,黄金网站ORM flask 通过Model操作数据库#xff0c;不管你的数据库是MySQL还是Sqlite#xff0c;flask自动帮你生成相应数据库类型的sql语句#xff0c;所以不需要关注sql语句和类型#xff0c;对数据的操作flask帮我们自动完成#xff0c;只需要会写Model就可以了 flask使用对象关…ORM flask 通过Model操作数据库不管你的数据库是MySQL还是Sqliteflask自动帮你生成相应数据库类型的sql语句所以不需要关注sql语句和类型对数据的操作flask帮我们自动完成只需要会写Model就可以了 flask使用对象关系映射简称为ORM框架去操控数据库 ORM对象关系映射是一种程序技术用于实现面向对象变成语言里不同类型系统的数据之间的转换将对对象的操作转换为原生的SQL语句。简单易用可以有效减少重复的SQL性能损耗少设计灵活可以轻松实现复杂查询可移植性好 数据库连接
Flask使用Python自带的ORMSQLAlchemy。针对于Flask的支持需要安装相应的插件
pip install flask-sqlalchemy为什么使用sqlite而不是mysql
SQLite和MySQL是两种常见的数据库管理系统它们之间有一些重要的区别。 数据库类型SQLite是一种嵌入式数据库它将整个数据库作为一个文件存储在磁盘上。而MySQL是一种客户端/服务器数据库它以独立的服务器进程运行并通过网络接口来处理客户端请求。 部署和配置由于SQLite是一个嵌入式数据库它非常容易部署和配置。你只需要在应用程序中包含SQLite的库文件即可。MySQL需要单独安装和配置数据库服务器并通过网络连接来访问。 性能和扩展性SQLite适用于小型应用程序和个人项目因为它在处理大量数据和高并发访问时可能性能较低。相比之下MySQL被设计用于处理大型数据集和高负载的应用程序它具有更好的性能和扩展性。 功能和支持MySQL是一个成熟的数据库管理系统提供了广泛的功能和丰富的工具。它支持复杂的查询语言如SQL事务处理和高级安全特性。相比之下SQLite是一个轻量级的数据库功能相对较少。 并发处理MySQL支持多个并发连接可以同时处理多个客户端请求。SQLite在写操作时会锁定整个数据库文件因此在高并发访问情况下可能会出现性能问题。
综上所述SQLite适用于小型应用程序和个人项目而MySQL适用于中大型应用程序和高负载环境。选择哪种数据库取决于你的具体需求和项目规模。
连接配置 直接看老师讲的视频好了容易理解。千峰教育 Flask2入门 数据库连接
数据迁移
当数据库和表配置好后需要进行数据迁移这样会在项目中生成真正的数据库和表。 基本步骤如下
使用cmd打开项目目录app.py所在的目录依次输入下面的命令 flask db init 创建迁移文件夹migrates只调用一次flask db migrate 生成迁移文件flask db upgrade 执行迁移文件中的升级flask db downgrade 执行迁移文件中的降级
初始化 执行完会在项目根目录下生成对应的文件夹instance和migrations 生成迁移文件 会生成数据库db文件 并且会生成一个操作记录的py文件 生成表 实际上就是执行的上一次生成文件里的upgrade函数执行完成后我们可以使用类似dberver的工具来进行查看 修改表结构 在修改表结构时比如新添加一列。必须要先修改对应的模型然后在重新进行生成迁移文件、执行迁移文件中的升级。
数据库的常见操作
新增数据
baseBlue.route(/add-user/)
def addUser():# 创建一个对象user BaseModel()user.name 张三user.email 2345163.comuser.password 123user.create_time datetime.now()# 将对象添加进session中db.session.add(user)# 将数据提交到数据库db.session.commit()data {code: 0, data: , msg: 添加成功}return jsonify(data)如果添加多条数据时可以使用add_all例如 users []for i in range(10):user BaseModel()user.name 张三 str(i)user.email 2345163.comuser.password 123user.create_time datetime.now()users.append(user)db.session.add_all(users)db.session.commit()同时可以添加异常处理
def addUser():# 创建一个对象user BaseModel()user.name 张三user.email 2345163.comuser.password 123user.create_time datetime.now()try:# 将对象添加进session中db.session.add(user)# 将数据提交到数据库db.session.commit()data {code: 0, data: , msg: 添加成功}except Exception as e:data {code: 1, data: , msg: 添加失败}db.session.rollback() # 回滚db.session.flush() # 清空sessionprint(addUser errorstr(e))return jsonify(data)删除数据
def delUser(id):try:user BaseModel.query.get(id)db.session.delete(user)db.session.commit()data {code: 0, data: , msg: 删除成功}except Exception as e:data {code: 1, data: , msg: 删除失败}db.session.rollback() # 回滚db.session.flush() # 清空sessionprint(delUser errorstr(e))return jsonify(data)修改数据
def updateUser(id):try:user BaseModel.query.get(id)user.name李四db.session.commit()data {code: 0, data: , msg: 修改成功}except Exception as e:data {code: 1, data: , msg: 修改失败}db.session.rollback() # 回滚db.session.flush() # 清空sessionprint(updateUser errorstr(e))return jsonify(data)查询数据
过滤器
filter() 把过滤器添加到原查询上返回一个新的查询limit() 使用指定的值限制原查询返回的结果数量返回一个新的查询offset() 偏移原查询返回的结果返回一个新的查询order_by() 根据指定条件对原查询结果进行排序返回一个新查询group_by() 根据指定条件对原查询结果进行分组返回一个新的查询
常用查询
all() 以列表形式返回查询的所有结果返回列表first() 返回查询的第一个结果如果没有结果返回Noneget() 返回指定主键对应的行如果没有对应的行则返回Nonecount() 返回查询结果的数量paginate() 返回一个Paginate对象它包含指定范围内的结果
逻辑运算
and_ 逻辑与filter()默认为逻辑与多个条件时用逗号分隔or_ 逻辑或not_ 逻辑非
查询属性
contains() contains(3) 模糊查找类似于sql中的likein_() in_([1,2,3]) 其中之一startswith() 和 endswidth() 以什么开始和以什么结束
根据用户名模糊查询
def queryUser(name):try:users BaseModel.query.filter(BaseModel.name.like(%name%)).all()res [user.to_dict() for user in users]data {code: 0, data: res, msg: 查询成功}except Exception as e:data {code: 1, data: , msg: 查询失败}print(queryUser errorstr(e))return jsonify(data)注意查询返回的结果是模型对象因此需要将模型对象转换为字典
class BaseModel(db.Model):# 表的名字__tablename__ base_user# 表的结构id db.Column(db.Integer, primary_keyTrue, autoincrementTrue) # 主键name db.Column(db.String(20), uniqueFalse, nullableFalse) # 用户名email db.Column(db.String(20), uniqueTrue, nullableFalse) # 邮箱password db.Column(db.String(20), nullableFalse) # 密码rank db.Column(db.String(20), nullableFalse,defaultuser) # 用户等级admin为管理员user为普通用户create_time db.Column(db.DateTime, nullableFalse) # 创建时间# 将模型对象转换为字典def to_dict(self):return {c.name: getattr(self, c.name) for c in self.__table__.columns}query.filter就相当于sql中的where查询如果存在多个查询条件时可以如下操作
from sqlalchemy import and_, or_# 示例查询条件
condition1 BaseModel.column1 value1
condition2 BaseModel.column2 value2
condition3 BaseModel.column3.like(% value3 %)# 使用 and_ 方法将多个条件组合为与关系
query BaseModel.query.filter(and_(condition1, condition2, condition3))# 或者使用 or_ 方法将多个条件组合为或关系
query BaseModel.query.filter(or_(condition1, condition2, condition3))# 执行查询
results query.all()或者
from sqlalchemy import or_conditions [User.username user1,User.id 5,# ...
]query User.query
query query.filter(or_(*conditions))users query.all()分页查询
SQLAlchemy内部提供了paginate方法来实现分页的功能。
# 分页查询
baseBlue.route(/get-all-user, methods[POST])
def getAllUser():# 获取前端传递过来的参数page int(request.form.get(page))page_size int(request.form.get(pageSize))p BaseModel.query.paginate(pagepage, per_pagepage_size, error_outFalse)# 将模型对象转换为字典data [item.to_dict() for item in p.items]res {code: 0,data: {total: p.total,page: p.page,pageSize: p.per_page,list: data},msg: 查询成功}return jsonify(res)paginate对象的属性
items返回当前页的内容列表has_next是否还有下一页has_prev是否还有上一页next(error_outFalse)返回下一页的Pagination对象prev(error_outFalse)返回上一页的Pagination对象page当前的页码从1开始pages总页数pre_page每页显示的数量prev_num上一页页码数next_num下一页页码数total查询返回的记录总数 多表操作
一对多
学生、班级表
class Grade(db.Model):# 表名__tablename__ grade# 表结构id db.Column(db.Integer, primary_keyTrue, autoincrementTrue, doc主键)name db.Column(db.String(10), uniqueTrue, nullableFalse, doc班级名称)# 建立联系# 参数1表名类的名称这里要用字符串# 参数2反向引用的名称grade对象让student去反过来得到grade对象的名称# 这样Student表可以直接使用Grade中的字段而不是使用班级id再去表里查询# 参数3懒加载# 这里的students不是表字段是一个类属性students db.relationship(Student, backrefgrade, lazydynamic)# 学生表
class Student(db.Model):__tablename__ student# 字段id db.Column(db.Integer, primary_keyTrue, autoincrementTrue, doc主键)name db.Column(db.String(10), uniqueTrue, nullableFalse, doc学生姓名)grade_id db.Column(db.Integer, db.ForeignKey(grade.id), nullableFalse, doc班级id)lazy属性
lazy属性懒加载可以延迟在使用关联属性的时候才建立关联
lazydynamic会返回一个query对象查询集可以继续使用其他的查询方法比如all()lazyselect首次访问到属性的时候就会全部加载该属性的数据lazyjoined在对关联的两个表进行join操作是从而获取到所有相关的对象lazyTrue返回一个可用的列表对象同select
增加数据
def addGradeStudent():student Student()student.name 张三student.grade_id 1try:db.session.add(student)db.session.commit()data {code: 0, data: , msg: 添加成功}except Exception as e:data {code: 1, data: , msg: 添加失败}db.session.rollback() # 回滚db.session.flush() # 清空session修改、删除操作基本上也与单表操作一致。需要注意的是比如在删除班级时这个班级里有学生。删除后学习表里的学生不会被删除但是学习对应的班级id会变为null
查询
# 查询学生所在班级的班级名称
def getGradeName():try:student Student.query.get(1)# 这里使用了反向引用这样就不许要再查询班级表gradeName student.grade.nameres {code: 0, data: gradeName, msg: 查询成功}data {code: 0, data: res, msg: 查询成功}except Exception as e:data {code: 1, data: , msg: 查询失败}print(getGradeName errorstr(e))# 查询班级下的所有学生grade Grade.query.get(1)students grade.students多对多
多对多需要创建一个中间表比如用户收藏电影需要有用户表、收藏表、电影表收藏表就是这个中间表。
用户表、电影表、收藏表
# 用户表
class User(db.Model):__tablename__ userid db.Column(db.Integer, primary_keyTrue, autoincrementTrue, doc主键)username db.Column(db.String(10), uniqueTrue, nullableFalse, doc用户名)# 类属性不是表字段。collections db.relationship(Collection, back_populatesuser)# 电影表
class movie(db.Model):__tablename__ movieid db.Column(db.Integer, primary_keyTrue, autoincrementTrue, doc主键)name db.Column(db.String(10), uniqueTrue, nullableFalse, doc电影名称)score db.Column(db.Float, nullableFalse, doc评分)collections db.relationship(Collection, back_populatesmovie)# 收藏表
class Collection(db.Model):id db.Column(db.Integer, primary_keyTrue,doc主键)user_id db.Column(db.Integer, db.ForeignKey(user.id),doc用户id)movie_id db.Column(db.Integer, db.ForeignKey(movie.id),doc电影id)user db.relationship(User, back_populatescollections)movie db.relationship(Movie, back_populatescollections)back_populates 是 SQLAlchemy 关系的一个参数用于指定两个模型之间的双向关联关系。当在一个模型类中定义了一个关系并指定了另一个模型类时back_populates 参数允许你在另一个模型类中定义一个相反方向的关系。
与 backref 不同back_populates 必须在双方都明确声明而 backref 只需要在一方声明即可自动创建另一方的反向引用。back_populates 更适合于复杂的关系映射和控制反向引用的名称。
