Flask-SQLAlchemy操作数据库

2020-03-19 17:50:16 浏览数 (1)

flask默认提供模型操作，但是并没有提供ORM，所以一般开发的时候我们会采用flask-SQLAlchemy模块来实现ORM操作。 SQLAlchemy是一个关系型数据库框架，它提供了高层的 ORM 和底层的原生数据库的操作。flask-sqlalchemy 是一个简化了 SQLAlchemy 操作的flask扩展。 SQLAlchemy: https://www.sqlalchemy.org/

安装 flask-sqlalchemy

代码语言：javascript复制
pip install flask-sqlalchemy

如果连接的是 mysql 数据库，需要安装 mysqldb **驱动**

代码语言：javascript复制
pip install flask-mysqldb

创建数据库 登录mariadb并创建demo数据库

代码语言：javascript复制
$ mysql -uroot -p123456
$ create database demo charset=utf8;

连接数据库设置

在 Flask-SQLAlchemy 中，数据库使用URL指定，而且程序使用的数据库必须保存到Flask配置对象的 **SQLALCHEMY_DATABASE_URI** 键中

代码语言：javascript复制
 app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:123456@127.0.0.1:3306/demo'

其他设置：

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

常用的SQLAlchemy字段类型

类型名

python中类型

说明

Integer

int

普通整数，一般是32位

SmallInteger

int

取值范围小的整数，一般是16位

BigInteger

int或long

不限制精度的整数

Float

float

浮点数

Numeric

decimal.Decimal

普通整数，一般是32位

String

str

变长字符串

Text

str

变长字符串，对较长或不限长度的字符串做了优化

Unicode

unicode

变长Unicode字符串

UnicodeText

unicode

变长Unicode字符串，对较长或不限长度的字符串做了优化

Boolean

bool

布尔值

Date

datetime.date

时间

Time

datetime.datetime

日期和时间

LargeBinary

str

二进制文件

代码语言：javascript复制
### 常用的SQLAlchemy列选项

选项名

说明

primary_key

如果为True，代表表的主键

unique

如果为True，代表这列不允许出现重复的值

index

如果为True，为这列创建索引，提高查询效率

nullable

如果为True，允许有空值，如果为False，不允许有空值

default

为这列定义默认值

代码语言：javascript复制
### 常用的SQLAlchemy关系选项

选项名

说明

backref

在关系的另一模型中添加反向引用,用于设置外键名称,在1查多的

primary join

明确指定两个模型之间使用的联结条件

uselist

如果为False，不使用列表，而使用标量值

order_by

指定关系中记录的排序方式

secondary

指定多对多关系中关系表的名字

secondary join

在SQLAlchemy中无法自行决定时，指定多对多关系中的二级联结条件

数据库基本操作

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

常用的SQLAlchemy查询过滤器

过滤器

说明

filter()

把过滤器添加到原查询上，返回一个新查询

filter_by()

把等值过滤器添加到原查询上，返回一个新查询

limit()

使用指定的值限定原查询返回的结果

offset()

偏移原查询返回的结果，返回一个新查询

order_by()

根据指定条件对原查询结果进行排序，返回一个新查询

group_by()

根据指定条件对原查询结果进行分组，返回一个新查询

常用的SQLAlchemy查询结果的方法

方法

说明

all()

以列表形式返回查询的所有结果

first()

返回查询的第一个结果，如果未查到，返回None

first_or_404()

返回查询的第一个结果，如果未查到，返回404

get()

返回指定主键对应的行，如不存在，返回None

get_or_404()

返回指定主键对应的行，如不存在，返回404

count()

返回查询结果的数量

paginate()

返回一个Paginate对象，它包含指定范围内的结果

创建表：

db.create_all() # 注意，create_all()方法执行的时候，需要放在模型的后面### 删除表 db.drop_all()

插入一条数据

ro1 = Role(name='admin') db.session.add(ro1) db.session.commit() 再次插入一条数据 ro2 = Role(name='user') db.session.add(ro2) db.session.commit()

一次插入多条数据

us1 = User(name='wang',email='wang@163.com',password='123456',role_id=ro1.id) us2 = User(name='zhang',email='zhang@189.com',password='201512',role_id=ro2.id) us3 = User(name='chen',email='chen@126.com',password='987654',role_id=ro2.id) us4 = User(name='zhou',email='zhou@163.com',password='456789',role_id=ro1.id) us5 = User(name='tang',email='tang@163.com',password='158104',role_id=ro2.id) us6 = User(name='wu',email='wu@gmail.com',password='5623514',role_id=ro2.id) us7 = User(name='qian',email='qian@gmail.com',password='1543567',role_id=ro1.id) us8 = User(name='liu',email='liu@163.com',password='867322',role_id=ro1.id) us9 = User(name='li',email='li@163.com',password='4526342',role_id=ro2.id) us10 = User(name='sun',email='sun@163.com',password='235523',role_id=ro2.id) db.session.add_all([us1,us2,us3,us4,us5,us6,us7,us8,us9,us10]) db.session.commit() filter_by精确查询

返回名字等于wang的所有人

User.query.filter_by(name='wang').all()

first()返回查询到的第一个对象

User.query.first()

all()返回查询到的所有对象

User.query.all()

filter模糊查询，返回名字结尾字符为g的所有数据。

User.query.filter(User.name.endswith('g')).all()

get():参数为主键，如果主键不存在没有返回内容

User.query.get()

逻辑非，返回名字不等于wang的所有数据

User.query.filter(User.name!='wang').all()

not_ 相当于取反 from sqlalchemy import not_ User.query.filter(not_(User.name=='chen')).all()

逻辑与，需要导入and，返回and()条件满足的所有数据from sqlalchemy import and_ User.query.filter(and_(User.name!='wang',User.email.endswith('163.com'))).all()

逻辑或，需要导入or_ from sqlalchemy import or_ User.query.filter(or_(User.name!='wang',User.email.endswith('163.com'))).all()

查询数据后删除

user = User.query.first() db.session.delete(user) db.session.commit() User.query.all()

更新数据

user = User.query.first() user.name = 'dong' db.session.commit() User.query.first()

关联查询示例：

> 角色和用户的关系是一对多的关系，一个角色可以有多个用户，一个用户只能属于一个角色。

- 查询角色的所有用户

查询roles表id为1的角色 ro1 = Role.query.get(1) 查询该角色的所有用户 ro1.us.all()

- 查询用户所属角色

#查询users表id为3的用户 us1 = User.query.get(3) #查询用户属于什么角色 us1.role

数据库 sql sqlalchemy 编程算法 flask

0 人点赞