flask mysql 数据库增删改查(微信报修小程序源码讲解四)
上一讲,我们学习了 flask 拦截器与session的使用 ,已经清楚了后台用户是否登录的判断及验证 url 合法性的方法 。
本文我们讲解数据库的增删改查操作 , 每一个应用系统都离不开数据的交互 , 数据库的操作是必须掌握的技能 。flask 中使用 flask-sqlalchemy 操作数据库将非常容易 ,我们一起学习一下 。
flask-sqlalchemy 是什么?他有什么特点 ?
flask-sqlalchemy 是一套 flask 的数据库操作框架 。
他的特点是:能够快速的完成数据库的增删改查操作 , 同时还具有的分页查询的功能 ,我们不需要写具体数据库 sql 语句就可完成不同的数据库操作 。
如何一步一步完成数据库增删改查操作呢 ?
1、 创建数据库配置文件,在app.py 同级目录下创建 config.py , 通常我们将数据库的配置写到单独的文件 , 方便数据库配置的修改 。这里我们使用的是 mysql ,每一行配置的作用,我均注释在代码后面,配置如下:
# encoding: utf-8
# dialect+driver://username:password@host:port/database
DIALECT = 'mysql' # 要用是什么数据库,我使用的是 mysql
DRIVER = 'pymysql' # 连接数据库驱动,pymysql 是 mysql 的驱动
USERNAME = 'root' # 用户名 ,你的数据库用户名
PASSWORD = 'Wjie2018' # 密码 ,你的数据库密码
HOST = '127.0.0.1' # 服务器 ,数据库所在服务器的ip,本地即 127.0.0.1
PORT = '3306' # 端口 ,数据库的默认端口 3306
DATABASE = 'ideamerry_repair_v3' # 数据库名 ,你需要链接的具体数据库的名字 ,这里是报修数据库的名字
SQLALCHEMY_DATABASE_URI = "{}+{}://{}:{}@{}:{}/{}?charset=utf8".format(DIALECT, DRIVER, USERNAME, PASSWORD, HOST, PORT,
DATABASE) # 拼接成数据库的 URI ,一般不需要修改
SQLALCHEMY_TRACK_MODIFICATIONS = False # 用于追踪数据库修改 , 默认为True ,设置为 True 会增加内存消耗
2、创建数据库 db对象:在app.py 同级目录下创建 exts.py文件。使用 exts.py 的目的是方便在其他文件中使用 db 对象做数据操作。
import os
from flask_sqlalchemy import SQLAlchemy
# 此时先不传入app
db = SQLAlchemy()
3、初始化数据库,我们在启动程序即:app.py 中引入exts.py 和config.py 然后执行数据库初始化操作 。
下面两行代码作用是:导入两个文件
import config
from exts import db
下面两行代码作用是:初始化数据库
app.config.from_object(config) # 加载数据库配置文件
db.init_app(app) # 绑定到我们到应用程序
注意:这两行代码比如放在有数据库操作的蓝图的上面 , 因为蓝图中要使用数据库操作,必须先初始化 ,如果将数据库操作的蓝图放在这两行的上面,就是数据库为初始化不能使用。
蓝图是什么?我们后面讲解。下面这行就是注册一个蓝图 user ,因 user 中有数据库操作,所以下面这行这行必须位于 数据库初始化代码的下面,切记!
# 注册user,使用前缀 user 作为前缀访问
app.register_blueprint(user, url_prefix='/user')
4、创建数据库表的model映射 ,以数据库中 user 表为例 。创建model.py 文件 , 遵循 MVC 思想,我们将创建models目录,然后在models目录下创建 model.py 。 model 中为了映射数据库字段 ,首先要引入数据库 ,从之前我们创建好的exts中引入 db
from exts import db
然后创建用户模型
# 用户模型
class User(db.Model):
tableName = 'user'
id = db.Column(db.INTEGER, primary_key=True, autoincrement=True)
userName = db.Column(db.String(30), nullable=False)
userPassword = db.Column(db.String(30), nullable=False)
openid = db.Column(name='openid', nullable=False)
详细解释上面代码: 第一行表示创建 class 的名字是 User ,参数是数据库model
class User(db.Model):
第二行是数据表的名字,默认情况下 User 类对应数据库中的 user表 ,即将大写字母转换为小写字母的表明。
多个大写字母的 class 类默认会映射数据的表是什么呢 ?比如 class 的名字是 RepairServiceSheet ,他默认映射的数据库表则是数据库中的 :repairservicesheet 表。
若不想使用默认的映射呢 ?我们可以覆盖默认的映射 ,使用 tablename来覆盖即可 ,如:你的 User 类要对应数据库中的 sys_user 表,则使用一下代码 :
class User(db.Model):
__tableName__ = 'sys_user'
第三行及以下是具体字段的映射
class 类的 id 映射数据库表 user 的 id 字段,并且是主键自增长 ,primary_key=True, autoincrement=True
id = db.Column(db.INTEGER, primary_key=True, autoincrement=True)
class 类的 userName 映射数据表的 userName 字段 , 名字必须一模一样,大小写一致 。
userName = db.Column(db.String(30), nullable=False)
或写为下面形式
userName = db.Column(name='userName', nullable=False)
如果你不想在 class User 里使用 userName 做为名字 ,则可写为下面形式 :
anyUserName = db.Column(name='userName', nullable=False)
5、增删改查操作,完成了以上配置 ,数据库操作就非常简单了 ,下面依次看一下。(可参照源代码的controllor/user/user.py中的代码)
增:向用户表添加一条数据
user = User(userName='admin', userPassword='123456')
db.session.add(user)
db.session.commit()
删:删除用户表中的一条数据
resultUser = User.query.filter(User.id == 1).first()
db.session.delete(resultUser)
db.session.commit()
改:修改用户表的一条数据 ,先查询出需要修改的记录再做修改提交
dbUser = User.query.filter(User.id == 1).first() # 先根据 id 查出数据库的一条数据
dbUser.userName='study2100' # 修改用户名admin 为 study2100
db.session.commit() # 提交数据库
查:分页查询用户表数据
users = User.query.paginate(1, per_page=10) # 分页查询第一页数据,本页查询10条
users = User.query.order_by(User.id.desc()).paginate(page, per_page=10) # order_by 是排序,按照 id 倒叙排列查询
总结:
flask 中数据库的操作并不复杂 , 只要我们按照这样的步骤去做 ,注意细节 ,增删改查操作就可以很快的完成 ,学会了数据库基本操作 , 无论是为小程序端提供 api 接口,还是后台管理功能就能很顺利的完成 。