龙岗网站建设_公司推广,wordpress 如何登陆地址,wordpress结构化数据,wordpress忘记账号一、ORM
要了解 ORM 首先了解以下概念。 什么是持久化 持久化 (Persistence)#xff0c;即把数据#xff08;如内存中的对象#xff09;保存到可永久保存的存储设备中#xff08;如磁盘#xff09;。持久化的主要应用是将内存中的数据存储在关系型的数据库中#xff0c;…一、ORM
要了解 ORM 首先了解以下概念。 什么是持久化 持久化 (Persistence)即把数据如内存中的对象保存到可永久保存的存储设备中如磁盘。持久化的主要应用是将内存中的数据存储在关系型的数据库中当然也可以存储在磁盘文件中、XML 数据文件中等等。 什么是持久层 持久层 (Persistence Layer)即专注于实现数据持久化应用领域的某个特定系统的一个逻辑层面将数据使用者和数据实体相关联。 什么是 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/
四、基本配置
安装 flask_sqlalchemy pip install flask_sqlalchemy连接 MySQL 数据库 SQLALCHEMY_DATABASE_URI ‘mysql://root:g3nt00567127.0.0.1:3306/vnet_user_dev’ 默认情况下MySQL 使用的是 mysqlclient 驱动。当然也可以使用其他驱动如mysqldb、pymysql 等。
SQLALCHEMY_DATABASE_URI ‘mysqlmysqldb://root:g3nt00567127.0.0.1:3306/vnet_user_dev’ SQLALCHEMY_DATABASE_URI ‘mysqlpymysql://root:g3nt00567127.0.0.1:3306/vnet_user_dev’ 3. 连接其他数据库 oracle SQLALCHEMY_DATABASE_URI ‘oracle://root:g3nt00567127.0.0.1:3306/vnet_user_dev’ mssql SQLALCHEMY_DATABASE_URI ‘mssql://root:g3nt00567127.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
五、模型定义
字段类型 Integer 普通整数一般是32位 SmallInteger 取值范围小的整数一般是16位 BigInteger 不限制精度的整数 Float 浮点数 Numeric 普通整数一般是32位 String 变长字符串 Text 变长字符串对较长或不限长度的字符串做了优化 JSON JSON 数据 Unicode 变长 Unicode 字符串 UnicodeText 变长 Unicode 字符串对较长或不限长度的字符串做了优化 Boolean 布尔值 Date 日期 Time 时间 DateTime 日期和时间 LargeBinary 二进制文件类型属性 primary_key 如果为True代表表的主键 unique 如果为True代表这列不允许出现重复的值 index 如果为True为这列创建索引提高查询效率 nullable 如果为True允许有空值如果为 False不允许有空值 default 为这列定义默认值示例代码 demo.py
#!/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_keyTrue, autoincrementTrue)# 电话phone db.Column(db.String(11), uniqueTrue, indexTrue)# 邮箱mail db.Column(db.String(64), nullableTrue, defaultNone)# 用户username db.Column(db.String(128), nullableTrue, defaultNone)# 密码password db.Column(db.String(128), nullableFalse)# tokentoken db.Column(db.String(256), uniqueTrue)# 盐值salt db.Column(db.String(32), nullableFalse)# 用户状态status db.Column(db.Integer, nullableFalse, defaultTrue)# 创建时间create_time db.Column(db.DateTime, defaultdt.datetime_orm)# 修改时间update_time db.Column(db.DateTime, defaultdt.datetime_orm, onupdatedt.datetime_orm)# 乐观锁version db.Column(db.BigInteger, nullableFalse)__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(usernameusername, passwordpassword) 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(id1).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(*)
