Flask-SQLAlchemy 组件

devtools/2024/10/24 4:52:48/

一、ORM

要了解 ORM 首先了解以下概念。

  1. 什么是持久化
    持久化 (Persistence)，即把数据（如内存中的对象）保存到可永久保存的存储设备中（如磁盘）。持久化的主要应用是将内存中的数据存储在关系型的数据库中，当然也可以存储在磁盘文件中、XML 数据文件中等等。

  2. 什么是持久层
    持久层 (Persistence Layer)，即专注于实现数据持久化应用领域的某个特定系统的一个逻辑层面，将数据使用者和数据实体相关联。

  3. 什么是 ORM
    ORM(Object Relation Mapping)，对象关系映射。主要实现模型对象到关系数据库数据的映射。

优点：

只需要面向对象编程，统一风格，不需要使用 SQL 语言。

实现数据模型和数据库的解藕，及不用关心是什么数据库，更改简单配置即可更换数据库。

缺点：

有部分性能损耗

二、SQLAlchemy

SQLAlchemy 是 Python 语言开发的 ORM 框架，是 ORM 具体实现的实例。

SQLAlchemy中文文档：https://www.osgeo.cn/sqlalchemy/

三、Flask-SQLAlchemy

Flask-SQLAlchemy 是基于 SQLAlchemy 进行高度封装、简化，适用于 Flask 矿建的 Flask 组件。

Flask-SQLAlchemy 中文文档：http://www.pythondoc.com/flask-sqlalchemy/

四、基本配置

  1. 安装 flask_sqlalchemy
    pip install flask_sqlalchemy
  2. 连接 MySQL 数据库
    SQLALCHEMY_DATABASE_URI = ‘mysql://root:g3nt00567@127.0.0.1:3306/vnet_user_dev’
    默认情况下，MySQL 使用的是 mysqlclient 驱动。当然也可以使用其他驱动，如：mysqldb、pymysql 等。

SQLALCHEMY_DATABASE_URI = ‘mysql+mysqldb://root:g3nt00567@127.0.0.1:3306/vnet_user_dev’
SQLALCHEMY_DATABASE_URI = ‘mysql+pymysql://root:g3nt00567@127.0.0.1:3306/vnet_user_dev’
3. 连接其他数据库
oracle
SQLALCHEMY_DATABASE_URI = ‘oracle://root:g3nt00567@127.0.0.1:3306/vnet_user_dev’
mssql
SQLALCHEMY_DATABASE_URI = ‘mssql://root:g3nt00567@127.0.0.1:3306/vnet_user_dev’
sqlite
SQLALCHEMY_DATABASE_URI = ‘sqlite:tmp/test.db’
redis
REDIS_URL = ‘redis://127.0.0.1:6379/1’
4. 其他配置

输出原始 SQL

SQLALCHEMY_ECHO = False

数据库连接池的大小

SQLALCHEMY_POOL_SIZE = 1000

动态追踪修改设置

SQLALCHEMY_TRACK_MODIFICATIONS = False
更多配置请参考官方链接：http://www.pythondoc.com/flask-sqlalchemy/config.html

五、模型定义

  1. 字段类型
    Integer 普通整数，一般是32位
    SmallInteger 取值范围小的整数，一般是16位
    BigInteger 不限制精度的整数
    Float 浮点数
    Numeric 普通整数，一般是32位
    String 变长字符串
    Text 变长字符串，对较长或不限长度的字符串做了优化
    JSON JSON 数据
    Unicode 变长 Unicode 字符串
    UnicodeText 变长 Unicode 字符串，对较长或不限长度的字符串做了优化
    Boolean 布尔值
    Date 日期
    Time 时间
    DateTime 日期和时间
    LargeBinary 二进制文件
  2. 类型属性
    primary_key 如果为True，代表表的主键
    unique 如果为True，代表这列不允许出现重复的值
    index 如果为True，为这列创建索引，提高查询效率
    nullable 如果为True，允许有空值，如果为 False，不允许有空值
    default 为这列定义默认值
  3. 示例代码
    demo.py
python">#!/usr/bin/env python3
# -*- coding: UTF-8 -*-from app import db
from app.lib.datetimeLib import dt# 用户表
class Users(db.Model):__tablename__ = 'users'# idid = db.Column(db.BigInteger, primary_key=True, autoincrement=True)# 电话phone = db.Column(db.String(11), unique=True, index=True)# 邮箱mail = db.Column(db.String(64), nullable=True, default=None)# 用户username = db.Column(db.String(128), nullable=True, default=None)# 密码password = db.Column(db.String(128), nullable=False)# tokentoken = db.Column(db.String(256), unique=True)# 盐值salt = db.Column(db.String(32), nullable=False)# 用户状态status = db.Column(db.Integer, nullable=False, default=True)# 创建时间create_time = db.Column(db.DateTime, default=dt.datetime_orm)# 修改时间update_time = db.Column(db.DateTime, default=dt.datetime_orm, onupdate=dt.datetime_orm)# 乐观锁version = db.Column(db.BigInteger, nullable=False)__mapper_args__ = {"version_id_col": version}def __repr__(self):return "<User (%s)>" % self.id

六、模型操作

1. 过滤器

filter() 把过滤器添加到原查询上，返回一个新查询
filter_by() 把等值过滤器添加到原查询上，返回一个新查询
limit() 使用指定的值限定原查询返回的结果
offset() 偏移原查询返回的结果，返回一个新查询
order_by() 根据指定条件对原查询结果进行排序，返回一个新查询
group_by() 根据指定条件对原查询结果进行分组，返回一个新查询

2. 执行器

all() 以列表形式返回查询的所有结果
first() 返回查询的第一个结果，如果未查到，返回 None
get() 返回指定主键对应的行，如不存在，返回 None
count() 返回查询结果的数量
paginate() 返回一个 Paginate 对象，它包含指定范围内的结果

3. 新增

user = Users(username=username, password=password)
db.session.add(user)
db.session.commit()
先将对象添加到数据库的会话中，然后在提交到数据库，具体细节请参考对应的数据库。

如果，我们想立即返回刚刚新建数据的 id 该如何实现呢？其实也有简单的方法，通过 flush 即可。

db.session.add(user)
db.session.flush()
user_id = user.id
db.session.commit()
在提交之前，预先将任何剩余的状态刷新到数据库，这样数据库是不可见的，但是数据已经存在了，等拿到 id 之后再提交。

4. 删除

删除记录是十分类似的，使用 delete() 实现删除功能。

db.session.delete(user)
db.session.commit()

5. 修改

user = Users.query.get(1)
user.username = ‘new user’
db.session.commit()

6. 查询

查询所有用户数据

Users.query.all()
查询有多少个用户

Users.query.count()
查询第一个用户

Users.query.first()
查询 id 为 1 的用户

Users.query.get(1)
Users.query.filter(Users.id == 1).first()
Users.query.filter_by(id=1).first()
查询名字结尾字符为 vnet 的所有数据

Users.query.filter(Users.name.endswith(‘vnet’)).all()
查询名字开始字符为 vnet 的所有数据

Users.query.filter(Users.name.startswith(‘vnet’)).all()
查询名字包含字符为 vnet 的所有数据

Users.query.filter(Users.name.contains(‘vnet’)).all()
查询名字不等于 vnet 的所有数据

Users.query.filter(not_(Users.name == ‘vnet’)).all()
Users.query.filter(Users.name != ‘vnet’).all()
查询名字和邮箱都以 vnet 开头的所有数据

Users.query.filter(and_(Users.name.startswith(‘vnet’), Users.email.startswith(“li”))).all() Users.query.filter(Users.name.startswith(‘vnet’), Users.email.startswith(‘vnet’)).all()
查询 id 为 [1, 3, 5, 7, 9] 的用户列表

Users.query.filter(Users.id.in_([1, 3, 5, 7, 9])).all()
查询所有用户数据，并以邮箱正序排序

Users.query.order_by(Users.email).all()
查询所有用户数据，并以邮箱倒序排序

Users.query.order_by(Users.email.desc()).all()
查询指定每页 3 条，属于第 2 页的数据

Users.query.paginate(2, 3, False).items
主键查询

Users.query.get(1)
精确查询

Users.query.filter_by(name=‘vnet’).all()
模糊查询

Users.query.filter(Users.name.contains(‘vnet’)).all()
返回查询到第一个对象

Users.query.filter_by(name=‘vnet’).first()
返回查询到所有的对象

Users.query.filter_by(name=‘vnet’).all()
逻辑非查询

Users.query.filter(Users.name!=‘vnet’).all()
逻辑与查询

from sqlalchemy import and_

Users.query.filter(and_(Users.name!=‘vnet’, Users.email.endswith(‘163.com’))).all()
逻辑或查询

from sqlalchemy import or_

Users.query.filter(or_(Users.name!=‘vnet’, Users.email.endswith(‘163.com’))).all()
取反查询

from sqlalchemy import not_

Users.query.filter(not_(Users.name==‘vnet’)).all()
原生 SQL

data = list(db.session.execute(sql))
函数

from sqlalchemy import func

users = Users.query.filter(func.find_in_set(id, id_set).all()
排序

from sqlalchemy import desc, asc

users = Users.query.order_by(desc(‘id’)).filter(*)


http://www.ppmy.cn/devtools/128363.html

相关文章

Android 开发 TabLayout 自定义指示器长度

Android 开发 TabLayout 自定义指示器长度

前言 原生 TabLayout 的指示器长度是充满整个屏幕的&#xff0c;但在实际开发中 UI 会设计成 指示器的长度等于或者小于标题字体长度&#xff0c;如图 如果设置成跟字体长度一样即使用 API: mTabLayout.setTabIndicatorFullWidth(false);或者在 xml 布局文件中的TabLayout标签…
阅读更多...
无人机封闭空间建图检测系统技术详解

无人机封闭空间建图检测系统技术详解

无人机封闭空间建图检测系统技术是一种集成了多种传感器、智能算法与控制系统的高级技术&#xff0c;旨在实现无人机在复杂封闭环境下的自主导航、精确建图与高效检测。以下是对该技术的详细解析&#xff1a; 一、技术概述 无人机封闭空间建图检测系统通过集成激光雷达(LiDAR…
阅读更多...
【设计模式-迪米特法则】

【设计模式-迪米特法则】

迪米特法则&#xff08;Law of Demeter&#xff0c;LoD&#xff09;&#xff0c;也称为最少知识原则&#xff08;Principle of Least Knowledge&#xff09;&#xff0c;是一种面向对象编程中的设计原则。它的核心思想是&#xff1a;一个对象应当尽可能少地了解其他对象&#x…
阅读更多...
基于STM32的水温控制系统设计

基于STM32的水温控制系统设计

引言 水温控制系统在家庭、工业和农业等多个领域具有重要应用&#xff0c;尤其在加热设备、热水器和地暖系统中&#xff0c;通过实时监测和调节水温可以提高能源利用效率&#xff0c;保证使用的舒适性和安全性。本文基于STM32设计了一个智能水温控制系统&#xff0c;集成温度传…
阅读更多...
调查显示软件供应链攻击增加

调查显示软件供应链攻击增加

OpenText 发布了《2024 年全球勒索软件调查》&#xff0c;强调了网络攻击的重要趋势&#xff0c;特别是在软件供应链中&#xff0c;以及生成式人工智能在网络钓鱼诈骗中的使用日益增多。 尽管各国政府努力加强网络安全措施&#xff0c;但调查显示&#xff0c;仍有相当一部分企…
阅读更多...
scrapy案例——豆瓣电影Top250的爬取

scrapy案例——豆瓣电影Top250的爬取

项目&#xff1a;豆瓣电影Top250的爬取 案例需求&#xff1a; 1.使用scrapy爬虫技术爬取豆瓣电影Top250的电影数据&#xff08;包括排名、电影名称、导演、演员、url、评分&#xff09; 2.实现分页爬取&#xff0c;共十页 3.将爬取下来的数据保存在数据库中 案例分析&…
阅读更多...
初学者怎么入门大语言模型（LLM）？

初学者怎么入门大语言模型（LLM）？

如果你真心想要入门大型语言模型&#xff08;LLM&#xff09;&#xff0c;只看这一个文章应该是可以入门的。但是修行下去&#xff0c;还是要靠自己的了&#xff01; 如果你把大语言模型/LLM 当成一门技术来看&#xff0c;那就要看一下这门技术需要什么。 基本要求&#xff1…
阅读更多...
给哔哩哔哩bilibili电脑版做个手机遥控器

给哔哩哔哩bilibili电脑版做个手机遥控器

前言 bilibili电脑版可以在电脑屏幕上观看bilibili视频。然而&#xff0c;电脑版的bilibili不能通过手机控制视频翻页和调节音量&#xff0c;这意味着观看视频时需要一直坐在电脑旁边。那么&#xff0c;有没有办法制作一个手机遥控器来控制bilibili电脑版呢&#xff1f; 首先…
阅读更多...
最新文章

Copyright @ 2022~2023