百木园-与人分享,
就是让自己快乐。

flask操作数据库

flask操作数据库

准备工作

  1. 安装flask-script(版本过高可能会报错)
pip install flask-script==2.0.3

使用flask-script里的Manager类实例化来管理项目的启动等

from apps import create_app
from flask_script import Manager

app = create_app()

manager = Manager(app=app)

if __name__ == \'__main__\':
    # 运行app模块
    manager.run()

在启动项目时由原来的python app.py 改成了python app.py runserver

  1. 安装pymysql
pip install pymysql
  1. 安装flask-sqlalchemy
pip install flask-sqlalchemy
  1. 安装flask-migrate,版本过高可能出现问题
pip install flask-migrate==2.7.0

配置数据库

  1. 在settings里配置一下数据库连接路径
class DevelopmentConfig:
    ENV = \'development\' # 设置环境为开发环境
    DEBUG = True  # 设置debug为true
    SQLALCHEMY_DATABASE_URI=\'mysql+pymysql://root:root@127.0.0.1:3306/flaskday05\'#访问的数据库+用的驱动://数据库的用户名:密码@服务器地址:端口号/数据库
    # 设置sqlalchemy不自动更跟踪数据库
    SQLALCHEMY_TRACK_MODIFICATIONS=False
    SQLALCHEMY_ECHO=True#调试模式
  1. 在项目文件下新建一个ext包,在包的init文件内建立映射对象
# 创建一个映射对象
from flask_sqlalchemy import SQLAlchemy

db = SQLAlchemy()
  1. 创建完之后,需要将映射对象与app进行关联,在apps包的init文件内进行关联
    # 将db(orm映射)对象和app进行关联
    db.init_app(app)
  1. flask-migrate是一个为Flask应用处理SQLAlchemy数据库迁移的扩展,使得可以通过Flask的命令行接口或者Flask-Scripts对数据库进行操作。
#在app.py文件中,当创建完app对象之后
from flask_migrate import Migrate, MigrateCommand
migrate=Migrate(app=app,db=db)#建立app影响数据库的映射
manager.add_command(\'db\',MigrateCommand)#将命令交给manager管理
  1. 在各蓝图中创建模型(类)时,要用到db的model
#在model.py文件中
from exts import db
class User(db.Model):
  1. 模型的基础创建格式和字段类型

image

  1. 将创建好的模型(自定义的类)导入到app.py文件中
from apps.user.models import User
  1. 使用terminal运行flask项目
初始化(一个项目只需要初始化一次,用来生成migrations文件夹)python app.py db init
更新版本(每次修改后要运行,用来在versions文件中生成最新的版本py文件)python app.py db migrate
数据库同步(每次修改要运行,用来将最新版本的内容更新到数据库上)python app.py db upgrade
删除时:python app.py db downgrate 降级并删除版本文件

往数据库插入数据

每次插入单挑数据

image

一次性插入多条数据

    # 一次性插入多条数据
    user1 = User(name=\'wang\',email=\'wang@163.com\',pswd=\'123456\',role_id=role1.id)
    user2 = User(name=\'zhang\',email=\'zhang@189.com\',pswd=\'201512\',role_id=role2.id)
    user3 = User(name=\'chen\',email=\'chen@126.com\',pswd=\'987654\',role_id=role2.id)
    user4 = User(name=\'zhou\',email=\'zhou@163.com\',pswd=\'456789\',role_id=role1.id)
    db.session.add_all([user1,user2,user3,user4])
    db.session.commit()

查询数据库

  1. filter模糊查询,返回名字结尾字符为g的所有数据。
User.query.filter(User.name.endswith(\'g\')).all()

查询结果为:列表里套着对象
[<User 1>, <User 2>]
  1. 查询:filter_by精确查询
返回名字等于wang的所有user
User.query.filter_by(name=\'wang\').all()

后面加.first()返回查询到的第一个对象
all()返回查询到的所有对象
  1. get(),参数为主键,如果主键不存在没有返回内容
User.query.get(2)
  1. 逻辑非,返回名字不等于wang的所有数据
User.query.filter(User.name!=\'wang\').all()
  1. 逻辑或,需要导入or_
from sqlalchemy import or_
User.query.filter(or_(User.name!=\'wang\',User.email.endswith(\'163.com\'))).all()
  1. 逻辑与,需要导入and,返回and()条件满足的所有数据
from sqlalchemy import and_
User.query.filter(and_(User.name!=\'wang\',User.email.endswith(\'163.com\'))).all()
  1. not_ 相当于取反
from sqlalchemy import not_
User.query.filter(not_(User.name==\'chen\')).all()
  1. 其他

image

  1. 排序order_by

image

  1. limit限制

image

删除数据

user = User.query.first()
db.session.delete(user)
db.session.commit()

更新数据

user = User.query.first()
user.name = \'dong\'
db.session.commit()

模型表直接的关联

  1. 一对多
class Role(db.Model):
    ...
    #关键代码
    user = db.relationship(\'User\', backref=\'role\', lazy=\'dynamic\')
    ...

class User(db.Model):
    ...
    role = db.Column(db.Integer, db.ForeignKey(\'roles.id\'))
  • 其中realtionship描述了Role和User的关系。在此文中,第一个参数为对应参照的类\"User\"
  • 第二个参数backref表示当使用user对象反向查询时,使用user.role查询到role表中的数据
  • 第三个参数lazy决定了什么时候SQLALchemy从数据库中加载外键模型数据

如果设置为子查询方式(subquery),则会在加载完Role对象后,就立即加载与其关联的对象,这样会让总查询数量减少,但如果返回的条目数量很多,就会比较慢
设置为 subquery 的话,role.users 返回所有数据列表
另外,也可以设置为动态方式(dynamic),这样关联对象会在被使用的时候再进行加载,并且在返回前进行过滤,如果返回的对象数很多,或者未来会变得很多,那最好采用这种方式
设置为 dynamic 的话,role.users 返回查询对象,并没有做真正的查询,可以利用查询对象做其他逻辑,比如:先排序再返回结果

关联查询

角色和用户的关系是一对多的关系,一个角色可以有多个用户,一个用户只能属于一个角色。

  • 查询角色的所有用户
#查询roles表id为1的角色
ro1 = Role.query.get(1)
#查询该角色的所有用户
ro1.use.all()
  • 查询用户所属角色
#查询users表id为3的用户
us1 = User.query.get(3)
#查询用户属于什么角色
us1.role
  1. 多对多

需要定义一个中间表,包含两个模型的外键字段就可以了,并作为一个“复合主键”
在两个需要做多对多的模型中随便选择一个模型,定义一个relationship属性,来绑定三者之间的关系,在使用relationship的时候,需要传入一个secondary=中间表模型名。

# 中间表,也可以重新定义一个类class,表示中间表
article_tag = db.Table(
    \'article_tag\',
    db.Column(\'article_id\', db.Integer,db.ForeignKey(\"article.id\"),primary_key=True),
    db.Column(\'tag_id\', db.Integer, db.ForeignKey(\"tag.id\"), primary_key=True)
)
# 文章表
class Article(db.Model):
    __tablename__ = \'article\'
    id = db.Column(db.Integer, primary_key=True)
    title = db.Column(db.String(64))
    tags = db.relationship(\'Tag\', secondary=article_tag, backref=db.backref(\'articles\'))
	# 这里需要指定一个参数secondary,值为中间表的表名
# 标签表
class Tag(db.Model):
    __tablename__ = \'tag\'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(32))

多对多关系的查询
1.查询文章所有的标签:
article = Article.query.filter(Article.title==\"xxx\").first()
tags = article.tags

2.查询一个标签涉及的所有文章:
tag = Tag.query.get(2)
articles = tag.articles

flask数据库常见的数据类型和字段

image


来源:https://www.cnblogs.com/suncolor/p/16971364.html
本站部分图文来源于网络,如有侵权请联系删除。

未经允许不得转载:百木园 » flask操作数据库

相关推荐

  • 暂无文章