Flask中一般使用flask-sqlalchemy来操作数据库。

一、SQLAlchemy与flask-sqlalchemy关系

1. SQLALchemy 实际上是对数据库的抽象，让开发者不用直接和 SQL 语句打交道，而是通过 Python
   对象来操作数据库，在舍弃一些性能开销的同时，换来的是开发效率的较大提升。
2. SQLAlchemy是一个关系型数据库框架，支持多种数据库后台。它提供了高层的 ORM 和底层的原生数据库的操作。
3. flask-sqlalchemy是一个简化了 SQLAlchemy 操作的flask扩展。

备注：ORM 全拼Object-Relation Mapping. 称为对象-关系映射，主要实现模型对象到关系数据库数据的映射

二、flask-sqlalchemy安装

1. 安装flask-sqlalchemy : pip install flask-sqlalchemy
2. 如果连接的是 mysql 数据库，需要安装 flask-mysqldb或者pymysql 驱动。说明：pymysql 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库，Python2中则使mysqldb。

pip install flask-mysqldb  #如果flask-mysqldb安装不上,安装pymysql
pip install pymysql

3. 数据库连接设置

格式:mysql://<用户名>:<密码>@:<端口>/数据库名

如果安装pymysql ，需要这样连接数据库

mysql+pymysql://<用户名>:<密码>@:<端口>/数据库名

例如：

# 数据库链接地址
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:mysql@127.0.0.1:3306/test'

三、SQLAlchemy常用配置

1、sqlalchemy配置信息

2、SQLAlchemy字段类型及对应python中类型

备注：如果使用的是mysql数据库，则数据库中字段类型和python中数据类型对应关系如下：

3、常用的SQLAlchemy列选项

4、常用的SQLAlchemy关系选项

四、数据库基本操作

在Flask-SQLAlchemy中，增删改查操作，均由数据库会话管理。
会话用 db.session 表示。在准备把数据写入数据库前，要先将数据添加到会话中然后调用 db.session.commit() 方法提交会话。提交操作把会话对象全部写入数据库。

流程操作如下：

db.session.add(role)    添加到数据库的session中
db.session.add_all([user1, user2]) 添加多个信息到session中
db.session.commit()     提交修改(包括增/删/改)到数据库
db.session.rollback()   数据库的回滚操作
db.session.delete(user) 删除数据库(需跟上commit)

在 Flask-SQLAlchemy 中，查询操作是通过 query 对象操作数据。
最基本的查询是返回表中所有数据，可以通过过滤器进行更精确的数据库查询。

1、查询过滤器

2、查询执行器方法

3、filter过滤条件

4、逻辑运算

5、DB操作

五.、完整流程举例

from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)

#设置连接数据库的URL
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:mysql@127.0.0.1:3306/Flask_test'
#查询时会显示原始SQL语句，便于调试
app.config['SQLALCHEMY_ECHO'] = True

db = SQLAlchemy(app)

class Role(db.Model):
    # 定义表名
    __tablename__ = 'roles'
    # 定义列对象
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(32), unique=True)
    user = db.relationship('User', backref='role')

    #repr()方法显示一个可读字符串
    def __repr__(self):
        return '<Role: %s %s>' % (self.name, self.id)

class User(db.Model):
    __tablename__ = 'users'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(32), unique=True, index=True)
    email = db.Column(db.String(32),unique=True)
    password = db.Column(db.String(32))
    role_id = db.Column(db.Integer, db.ForeignKey('roles.id'))

    def __repr__(self):
        return '<User: %s %s %s %s>' % (self.name, self.id, self.email, self.password)

if __name__ == '__main__':

    # 创建表：
    db.create_all()
    # 删除表
    db.drop_all()

    app.run(debug=True)
#### 2.2 数据的增删改
```python
# 进入ipython一次执行
In [1]: from demo3_sqlalchemy import *

# 添加一条Role数据
In [2]: role = Role(name='admin')
In [3]: db.session.add(role)
In [4]: db.session.commit()

# 添加一条User数据, 数据有误可以使用回滚, 将add的对象从session移除
In [5]: user = User(name='zhangsan')
In [6]: db.session.add(user)
In [7]: db.session.rollback()
In [9]: user.role_id = 1
In [6]: db.session.add(user)
In [4]: db.session.commit()

# 修改数据
In [13]: user.name = 'lisi'
In [14]: db.session.commit()

# 删除数据
In [16]: db.session.delete(user)
In [17]: db.session.commit()