来源：本文章摘抄于《知了课堂》，本人也是知了课堂的学生

相关

Python-SQLAlchemy介绍和基本使用
Python-SQLAlchemy（1）
Python-SQLAlchemy（2）
Python-SQLAlchemy（3）
Python-SQLAlchemy（4）
Python-SQLAlchemy（5）

SQLAlchemy介绍和基本使用

数据库是一个网站的基础，Flask 可以使用多种数据库，比如MySQL，MongoDB，SQLite，PostgreSQL 等。这里我们以 MySQL 为例进行讲解。而在Flask 中，如果想要操作数据库，我们可以使用 ORM 来操作数据库，使用 ORM 操作数据库将变得非常简单。

在讲解 Flask 中的数据库操作之前，先确保你已经安装了以下软件：

• mysql：如果是在 windows 上，到官网下载。如果是 ubuntu，通过命令 sudo apt-get install mysql-server 进行安装
• MySQLdb：MySQLdb 是用 python 来操作的包，因此通过 pip 安装，命令如下：pip install mysql-python
• SQLAlchemy：SQLAlchemy 是一个数据库的 ORM 框架，我们在后面会用到。安装命令：pip3 install SQLAlchemy

通过 SQLAlchemy 连接数据库：

首先先看一段代码：

    from sqlalchemy import create_engine
    # 数据库的配置变量
    HOSTNAME = '127.0.0.1'
    PORT = '3306'
    DATABASE = 'xt_flask'
    USERNAME = 'root'
    PASSWORD = '123456'
    DB_URI = 'mysql+mysqldb://{}:{}@{}:{}/{}'.format(USERNAME, PASSWORD, HOSTNAME, PORT, DATABASE)
    # 创建数据库引擎
    engine = create_engine(DB_URI)
    # 创建连接
    with engine.connect() as con:
        rs = con.execute('SELECT 1')
        print rs.fetchone()

首先从 sqlalchmey 中导入 create_engine ，用这个函数来创建引擎，然后用 engine.connect() 来连接数据库。其中一个比较重要的一点是，通过 create_engine 函数的时候，需要传递一个满足某种格式的字符串：
dialect+driver://username:password@host:port/database?charset=utf8
dialect 是数据库的实现，比如 MySQL，PostgreSQL，SQLite，并且转换成小写。driver 是Python 对应的驱动，如果不指定，会选择默认的驱动，比如 MySQL 的默认驱动是 MySQLdb。其他字段就不一一说明。
如果输出了 1，说明SQLAlchemy 能连接到数据库。

用 SQLAlchemy 执行原生SQL：

我们将上一个例子中的数据库配置选项单独放到一个 constants.py 的文件中，看以下例子：

    from sqlalchemy import create_engine
    from constants import DB_URI
    # 连接数据库
    engine = create_engine(DB_URI, echo=True)
    # 使用 with 语句连接数据库，如果发生异常会捕获
    with engine.connect() as con:
        # 先删除 users 表
        con.execute('drop table if exists authors')
        # 创建一个 users 表，有自增id 和 name
        con.execute('create table authors (id int primary key auto_increment, name varchar(25))')
        # 插入两条数据到表中
        con.execute('insert into presons(name) values("abx")')
        con.execute('insert into persons(name) values("xiaooming")')
        # 执行查询操作
        results = con.execute('select * from presons;')
        # 遍历查询结果
        for result in results:
            print result