来源:本文章摘抄于《知了课堂》,本人也是知了课堂的学生
相关
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