Flask

Flask模型

1. Flask模型

Flask默认并没有提供任何数据库操作的API

我们可以选择任何适合自己项目的数据库来使用

Flask中可以自己的选择数据，用原生语句实现功能，也可以选择ORM（SQLAlchemy，MongoEngine）

SQLAlchemy是一个很强大的关系型数据库框架，支持多种数据库后台。SQLAlchemy提供了高层ORM，也提供了使用数据库原生SQL的低层功能。

ORM：

将对对象的操作转换为原生SQL
优点
	易用性，可以有效减少重复SQL
	性能损耗少
	设计灵活，可以轻松实现复杂查询
	移植性好

针对于Flask的支持，官网地址

pip install flask-sqlalchemy

安装驱动

pip install pymysql

2.定义模型

使用SQLALchemy的对象去创建字段

其中__tablename__指定创建的数据库的名称

创建models.py文件, 其中定义模型

from flask_sqlalchemy import SQLAlchemy

db = SQLAlchemy()

class Student(db.Model):
	
	s_id = db.Coumn(db.Integer, primary_key=Ture, autoincrement=Ture)
	s_name = db.Coumn(db.String(16), unique=Ture)
	s_age = db.Coumn(db.Integer, default=1)

	__tablename__ = 'student'

其中：

Integer表示创建的s_id字段的类型为整形，

primary_key表示是否为主键

String表示该字段为字符串

unique表示该字段唯一

default表示默认值

autoincrement表示是否自增

3. 创建数据表

在视图函数中我们引入models.py中定义的db

from App.models imprt db

@blue.route('/createdb/')
def create_db():
	db.create_all()
	return '创建成功'
	
@blue.route('/dropdb/')
def drop_db():
	db.drop_all()
	return '删除成功'

其中： db.create_all()表示创建定义模型中对应到数据库中的表

db.drop_all()表示删除数据库中的所有的表

4. 初始化SQLALchemy

在定义的init.py文件中使用SQLALchemy去整合一个或多个Flask的应用

有两种方式：

第一种:

from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)
	db = SQLAlchemy(app)

第二种:

db = SQLAlchemy()

def create_app():
	app = Flask(__name__)
	db.init_app(app)
	return app

5. 配置数据库的访问地址

官网配置参数

数据库连接的格式：

dialect_driver://username:password@host:port/database

dialect 数据库实现

driver数据库的驱动

例子： 访问mysql数据库，驱动为pymysql，用户为root，密码为123456，数据库的地址为本地，端口为3306，数据库名称HelloFlask

设置如下： “mysql+pymysql://root:123456@localhost:3306/HelloFlask”

在初始化init.py文件中如下配置：

app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root:123456@localhoust:3306/HelloFlask"
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = Flase

6.对学生数据进行CRUD操作

语法:

类名.query.xxx

获取查询集:

all()

filter(类名.属性名==xxx)

filter_by(属性名=xxx)

数据操作:

在事务中处理, 数据插入

db.session.add(object)

db.session.add_all(list[object])

db.session.delete(object)

db.session.commit()

修改和删除基于查询

6.1向学生表中添加数据

@blue.route('/createstu/')
def create_stu():

	s = Student()
	s.s_name = '小白%d' % random.randrange(100)
	s.s_age = '%d' % random.randrange(30)
	
	db.session.add(s)
	db.session.commit()
	
	return '添加成功'

提交事务, 使用commit提交我们的添加数据的操作

6.2获取所有学生信息

将学生的全部信息获取到，并且返回给页面，在页面中使用for循环去解析即可

@blue.route("/getstudents/")
def get_students():
	students = Student.query.all()
	return reender_template("StudentList.html", students=students)

6.3获取s_id的学生的信息

写法一:

students = Student.query.filter(Student.s_id==1)

写法二:

students = Student.query.filter_by(s_id=2)

注意: filter中可以接多个过滤条件

写法三:

sql = 'select * from student where s_id=1'
students = db.session.execute(sql)

修改学生信息

写法一:

students = Student.query.filter_by(s-id=3).first()
student.s_name = '呵呵'
db.session.commit()

写法二:

Student.query.filter_by(s_id=3).update({'s_name': '呵呵哒'})
db.session.commit()

6.5删除一个学生的信息

写法一:

student = Student.query.filter_by(s_id=2).first()
db.session.delete(students)
db.session.commit()

写法二:

students = Student.query.filter_by(s_id=1).all()
db.session.delete(student[0])
db.session.commit()

注意：filter_by后的结果是一个list的结果集

重点注意：在增删改中如果不commit的话，数据库中的数据并不会更新，只会修改本地缓存中的数据，所以一定需要db.session.commit()

最后更新： 2018年06月12日 20:26

原始链接： http://yoursite.com/2018/06/12/Flask模型/

lronLin

赏

× 请我吃糖~