SQLAlchemy介绍和基本使用
数据库是一个网站的基础,在Flask
中可以自由的使用MySQL
、PostgreSQL
、SQLite
、Redis
、MongoDB
来写原生的语句实现功能,也可以使用更高级别的数据库抽象方式,如SQLAlchemy
或MongoEngine
这样的OR(D)M
。本文以MySQL+SQLAlchemy
的组合来进行讲解。
在讲解Flask
中的数据库操作之前,先确保你已经安装了以下软件:
-
mysql
:如果是在windows
上,到官网下载。如果是ubuntu
,通过命令sudo apt-get install mysql-server libmysqlclient-dev -yq
进行下载安装。 -
MySQLdb
:MySQLdb
是用Python
来操作mysql
的包,因此通过pip
来安装,命令如下:pip install mysql-python
。 -
pymysql
:pymysql
是用Python
来操作mysql
的包,因此通过pip
来安装,命令如下:pip3 install pymysql
。 -
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 = 'root'
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()
首先从sqlalchemy
中导入create_engine
,用这个函数来创建引擎,然后用engine.connect()
来连接数据库。其中一个比较重要的一点是,通过create_engine
函数的时候,需要传递一个满足某种格式的字符串,对这个字符串的格式来进行解释:
dialect+driver://username:password@host:port/database
dialect
是数据库的实现,比如MySQL
、PostgreSQL
、SQLite
,并且转换成小写。driver
是Python
对应的驱动,如果不指定,会选择默认的驱动,比如MySQL的默认驱动是MySQLdb
。username
是连接数据库的用户名,password
是连接数据库的密码,host
是连接数据库的域名,port
是数据库监听的端口号,database
是连接哪个数据库的名字。
如果以上输出了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 users')
# 创建一个users表,有自增长的id和name
con.execute('create table users(id int primary key auto_increment,'
'name varchar(25))')
# 插入两条数据到表中
con.execute('insert into users(name) values("xiaoming")')
con.execute('insert into users(name) values("xiaotuo")')
# 执行查询操作
rs = con.execute('select * from users')
# 从查找的结果中遍历
for row in rs:
print row
网友评论