Python 测开27期 - julia - 学习笔记 - 测试平台ORM

学习笔记
,
1

什么是 ORM

  • Object Relational Mapping 对象关系映射
  • 作用是在关系型数据库和对象之间做一个映射，这样在具体操作数据库的时候，就不需要再去和复杂的 SQL 语句打交道，只要像平时操作对象一样操作就可以了

ORM 与 SQL 的对比

# 使用sql语句查询数据
sql = "SELECT
username, email, gender
FROM User  WHERE id = 1"

# 执行sql 代码
res = db.execSql(sql);

# 取出数据
name = res[0]

# 使用orm 查询数据，定义ORM对象，get 值 ，
res = db.session.query(\
    User.username, User.email, User.gender).\
    filter(User.id==1).first()
name = res.username

ORM 映射

image

ORM 优缺点

  • 优势：
    • 隐藏了数据访问细节
    • ORM 使我们构造固化数据结构变得非常简单
  • 缺点：
    • 性能下降 ，添加了关联操作，性能不可避免的会下降一些
    • 无法解决特别复杂的数据库操作

Flask-SQLAlchemy 插件配置

Flask-SQLAlchemy 的安装

  • SQLAlchemy 是 python 中最有名的 ORM 框架；在 Flask 中一般使用 Flask-SQLAlchemy 来操作数据库
  • Flask-SQLAlchemy 的安装命令： pip install flask-sqlalchemy

Flask-SQLAlchemy 的实例化

# 导入Flask的类
from flask import Flask
# 导入 flask_sqlalchemy 中的 SQLAlchemy 模块
from flask_sqlalchemy import SQLAlchemy

# 实例化 Flask
app = Flask(__name__)

# 将 app 与 Flask-SQLAlchemy 进行绑定，实例化一个 db 对象
db = SQLAlchemy(app)

Flask-SQLAlchemy 配置

Flask-SQLAlchemy 常用配置

常用的配置 说明
SQLALCHEMY_DATABASE_URI 连接数据库的 URL 配置
SQLALCHEMY_TRACK_MODIFICATIONS 追踪对象的修改
SQLALCHEMY_BINDS 用于多数据库连接的配置
SQLALCHEMY_POOL_SIZE 连接池的配置 默认为 5

SQLALCHEMY_DATABASE_URI 的配置说明

  • SQLALCHEMY_DATABASE_URI 连接串格式：dialect+driver://username:password@host:port/database
  • 比如常用的 sqlite 与 mysql:
    • sqlite：sqlite:///数据库db文件所在的路径
    • mysql：mysql+pymysql://username:password@host:port/database

Flask-SQLAlchemy 示例

# 导入Flask的类
from flask import Flask
# 实例化 Flask的类，并且绑定module
from flask_sqlalchemy import SQLAlchemy

# 实例化 Flask
app = Flask(__name__)

# mysql 数据库用户名
username = "root"
# mysql 数据库密码
pwd = "123456"
# mysql 数据库的 host 地址
ip = "127.0.0.1"
# mysql 数据库端口
port = "3306"
# 代码使用的数据库名
database = "demo"

# 设置mysql 链接方法是
app.config['SQLALCHEMY_DATABASE_URI'] = f'mysql+pymysql://{username}:{pwd}@{ip}:{port}/{database}?charset=utf8'

# 定义应用使用数据库的配置
# 设置SQLALCHEMY_TRACK_MODIFICATIONS参数 不设置该配置的时候会抛出警告
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True

# 将 app 与 Flask-SQLAlchemy 的 db 进行绑定
db = SQLAlchemy(app)

Flask-SQLAlchemy 对象与数据模型

数据模型

数据模型（Data Model）是数据特征的抽象，它从抽象层次上描述了系统的静态特征、动态行为和约束条件，为数据库系统的信息表示与操作提供一个抽象的框架。
image

Flask-SQLAlchemy 的属性字段定义

参数类型 含义
Integer 整型字段定义
String(20) 字符串字段定义，括号为字符串的最大长度
JSON json 字符串字段
DateTime 时间格式字段

Flask-SQLAlchemy 字段常用关键字参数

参数类型 含义
primary_key 是否主键
autoincrement 是否自增
nullable 是否允许为空
unique 是否允许重复
default 默认值

数据 CRUD

单条数据添加

  1. 实例化类，创建表数据
  2. 将实例添加到 session（add）
  3. 提交更新 (commit)
  4. 关闭 session
# 新增表数据，需要导入 User 类，进行实例化
user1 = User(id=1, username="张三", email="123@123.com")
# 将数据提交到session
db.session.add(user1)
# 将数据提交到commit
db.session.commit()
# 关闭 session
db.session.close()

批量数据添加

  1. 多次实例化类，创建多条表数据
  2. 将多个实例依次添加到 session 中（add）或者一次性添加到 session 中（add_all）
  3. 提交更新 (commit)
  4. 关闭 session
# 批量添加数据操作
user2 = User(id=2, username="张四", email="124@123.com")
user3 = User(id=3, username="张五", email="125@123.com")
# 第一种依次添加，将数据提交到session
db.session.add(user2)
db.session.add(user3)
# 第二种批量添加
db.session.add_all([user2, user3])
# 将数据提交到commit
db.session.commit()
# 端口session
db.session.close()

查询表中全部数据

  • 格式：类.query.all() 
# 读取全部数据
res = User.query.all()
# 遍历数据，得到想要的字段
for rs in res:
    print(rs.username, rs.email)

条件查询

  • 格式：类.query.filter_by(条件).单条或多条

单条件查询

  • 查询单条数据：类.query.filter_by(条件).first()
  • 查询多条数据：类.query.filter_by(条件).all() 
# 单条数据查询
res = User.query.filter_by(gender="男").first()
print(res)
# 多条数据查询
res = User.query.filter_by(gender="男").all()

多条件查询

  • 查询单条数据：类.query.filter_by(条件).filter_by(条件)...first()
  • 查询多条数据：类.query.filter_by(条件).filter_by(条件)...all() 
# 单条数据查询
res = User.query.filter_by(gender = "男").\
filter_by(username='马力').filter_by(email="aaa").\
first()
# 多条数据查询
res = User.query.filter_by(gender = "男").\
filter_by(username='马力').filter_by(email="aaa").\
all()

修改数据

  • 方式一：
    • 首先查询出来需要的数据
    • 对查询出来的数据对象进行属性的修改
    • 提交 session
  • 方式二：
    • 给定查询条件进行查询后，直接进行 update 操作
    • 提交 session
# 数据的修改
# 第一种方式，更新某个字段
res = User.query.filter_by(id=2).first()
res.gender = "女"
# 提交
db.session.commit()
# 关闭session
db.session.close()

# 第二种方式，直接调用update方法更新行数据
res = User.query.filter_by(id=2).update({"gender": "男"})
# 提交
db.session.commit()
# 关闭session
db.session.close()

删除数据

  • 方式一：
    • 查询数据
    • 对查询出来的数据对象进行删除操作
    • 提交 session
  • 方式二：
    • 给定查询条件进行查询后，直接进行 delete 操作
    • 提交 session
# 方式一：
# 查询数据
user = User.query.filter_by(id=1).first()
# 删除操作
db.session.delete(user)
# 提交
db.session.commit()
# 关闭session
db.session.close()

# 方式二：
# 查询结果直接删除操作
User.query.filter_by(id=1).delete()
# 提交
db.session.commit()
# 关闭session
db.session.close()