SQLAlchemy是flask的扩展，是一个功能强大的OR映射器，支持多种数据库后台，可以将类的对象映射至数据库表。
使用这个工具，可以创建数据库，创建表，并为数据库添加数据，进行查询操作等。
参考：Flask SQLAlchemy - Flask 教程 | BootWiki.com
创建实例
app=Flask(name) #创建Flask实例
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///students.sqlite3'#设置数据库URL
app.config[]可以为Flask实例添加一些配置。
这个配置指明当前文件夹下students.sqlite3数据库文件作为数据库访问的URL，这个数据库文件当前可以不存在，在程序运行时create。
在Flask-SQLAlchemy中，数据库使用URL指定。几种最流行的数据库引擎使用的URL格式
app.config['SECRET_KEY'] = "random string"
这个配置设置了secret_key，用于session，在学习session的时候已经知道，服务器加密会话数据时需要一个secret_key，至于这里为什么要用到session，在后面会说到。
db=SQLAlchemy(app) 创建一个SQLAlchemy类的对象。 该对象包含ORM操作的辅助函数。 它还提供了一个使用其声明用户定义模型的父级模型类。
类和模型
模型这个术语表示应用使用的持久化实体。在ORM中，模型一般是一个Python类，类中的属性对应于数据库表中的列。
定义一个类（students模型），继承Model模型。这个类和数据库的表对应，类的属性分别对应表的字段。
class students(db.Model): id = db.Column('student_id', db.Integer, primary_key=True) name = db.Column(db.String(100)) city = db.Column(db.String(50)) addr = db.Column(db.String(200)) pin = db.Column(db.String(10)) def __init__(self,name,city,addr,pin): self.name=name self.city=city self.addr=addr self.pin=pin
db.Column类构造函数的第一个参数是数据库列和模型属性的类型
常用的类型
db.Column的其余参数指定属性的配置选项
常用的SQLAlchemy配置选项
通过属性定义，也为表添加了字段。id为主键。
db.create_all()
使用这个语句，执行创建数据库操作。
CRUD操作
SQLAlchemy的Session对象管理ORM对象的所有持久性操作。
db.session.add(模型对象) - 将一条记录插入到映射表中 准备把对象写入数据库之前，要先将其添加到会话中
db.session.delete(模型对象) - 从表中删除记录
模型.query.all() - 从表中检索所有记录(对应于SELECT查询)。db.session.commit()提交修改 为了把对象写入数据库，我们要调用commit()方法提交会话
可以使用filter属性将筛选器应用于检索到的记录集。例如，要在students表中检索city ='Haikou'的记录，请使用以下语句
Students.query.filter_by(city = 'Haikou').all()
数据库会话db.session和Flask的session对象没有关系。数据库会话也称为事务， 能保证数据库的一致性。提交操作使用原子方式把会话中的对象全部写入数据库。如果在写入会话的过程中发生了错误，那么整个会话都会失效。如果你始终把相关改动放在会话中提交，就能避免因部分更新导致的数据库不一致。
实战
实现一个添加学生信息并展示信息的小应用。
点击添加学生，打开添加学生页面，提交信息后，展示所有学生信息列表。
这个应用，一共有两个页面，一个展示所有信息show_all.html，一个添加学生信息new.html。
在展示所有信息页面，首先显示闪现消息flash，当没有闪现消息的时候不显示。添加学生链接至new页面，最下方读取数据库数据并显示，数据库无数据时不显示数据。
show_all.html如下
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
<title>Flask示例</title>
</head>
<body>
<h1>
Flask
SQLAlchemy示例
</h1>
<hr/>
{%- for message in get_flashed_messages() %}
{{ message }}
{%- endfor %}
<h1>(<a href = "{{ url_for('new') }}">添加学生
</a>)</h1>
<table>
<thead>
<tr>
<th>姓名</th>
<th>城市</th>
<th>地址</th>
<th>Pin</th>
</tr>
</thead>
<tbody>
{% for student in students %}
<tr>
<td>{{ student.name }}</td>
<td>{{ student.city }}</td>
<td>{{ student.addr }}</td>
<td>{{ student.pin }}</td>
</tr>
{% endfor %}
</tbody>
</table>
</body>
</html>
对于的视图函数如下
@app.route('/')
def show_all():
return render_template('show_all.html',students=students.query.all())
添加学生信息页面new.html，也会显示flash，下放展示一个表单，点击提交按钮后，表单数据以post方式提交给服务器，并使用视图函数new接收表单数据进行处理。对表单数据进行校验，不满足校验显示flash，满足校验，则向数据库添加数据，并重定向至展示信息页面。
new.html页面如下：
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
<title>Flask示例</title>
</head>
<h3>添加学生信息</h3>
<hr/>
{%- for category, message in get_flashed_messages(with_categories = true) %}
<div class = "alert alert-danger">
{{ message }}
</div>
{%- endfor %}
<form action = "/new" method = "post">
<label for = "name">姓名</label><br>
<input type = "text" name = "name" placeholder = "Name" /><br>
<label for = "email">城市</label><br>
<input type = "text" name = "city" placeholder = "city" /><br>
<label for = "addr">地址</label><br>
<textarea name = "addr" placeholder = "addr"></textarea><br>
<label for = "PIN">邮编</label><br>
<input type = "text" name = "pin" placeholder = "pin" /><br>
<input type = "submit" value = "提交" />
</form>
</body>
</html>
对于视图函数如下
@app.route('/new',methods=['GET','POST'])
def new():
if request.method=='POST':
if not request.form['name']or not request.form['city']or not request.form['addr']:
flash('Please enter all the fields','error') #如果有一个没填写，闪现消息
else:
student = students(request.form['name'], request.form['city'], request.form['addr'], request.form['pin'])
print(student)
db.session.add(student)#把数据添加到数据库
db.session.commit()#提交数据
flash('Record was successfully added')#闪现消息添加成功
return redirect(url_for('show_all')) #一个函数可以有两个return
return render_template('new.html') #点击添加按钮，渲染new.html页面
最后附上程序入口，运行程序，即可访问。
if __name__ == '__main__':
db.create_all()
app.run(debug=True)
完整代码：
from flask_sqlalchemy import SQLAlchemy
from flask import Flask,render_template,request,flash,redirect,url_for
app=Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///students.sqlite3'#设置数据库URL
#创建一个SQLAlchemy类的对象。 该对象包含ORM操作的辅助函数。 它还提供了一个使用其声明用户定义模型的父级模型类。
app.config['SECRET_KEY'] = "random string"
db=SQLAlchemy(app)
class students(db.Model):
id = db.Column('student_id', db.Integer, primary_key=True)
name = db.Column(db.String(100))
city = db.Column(db.String(50))
addr = db.Column(db.String(200))
pin = db.Column(db.String(10))
def __init__(self,name,city,addr,pin):
self.name=name
self.city=city
self.addr=addr
self.pin=pin
@app.route('/')
def show_all():
db.create_all()
return render_template('show_all.html',students=students.query.all())
@app.route('/new',methods=['GET','POST'])
def new():
if request.method=='POST':
if not request.form['name']or not request.form['city']or not request.form['addr']:
flash('Please enter all the fields','error') #如果有一个没填写，闪现消息
else:
student = students(request.form['name'], request.form['city'], request.form['addr'], request.form['pin'])
print(student)
db.session.add(student)#把数据添加到数据库
db.session.commit()#提交数据
flash('Record was successfully added')#闪现消息添加成功
return redirect(url_for('show_all')) #一个函数可以有两个return
return render_template('new.html') #点击添加按钮，渲染new.html页面
if __name__ == '__main__':
db.create_all()
app.run(debug=True)
总结：文本学习了Flask数据库相关扩展SQLAlchemy的使用，并实现了一个添加并展示学生信息的应用。
版权归原作者 东方不败就是我 所有， 如有侵权，请联系我们删除。