flask入门5-model

2024年4月18日 195次阅读来源: rottengeek

Flask-SQLalchemy flask的ORM模型

使用ORM模型的原因

当项目越来越大的时候会出现很多问题

原生SQL较多重复使用率低
如果你的数据库发生了改变所有的原生SQL就都要进行修改
写原生SQL的时候会有安全隐患

ORM：中文件关系对象的映射使用ORM去操作数据库的时候不会再去写原生的SQL了通过把表映射成类字段为你的属性 ORM在执行的时候也会最终转换为 SQL语句去操作数据库

易用性使用ORM可以减少重复SQL的概率写出来的模型也更加的直观清晰
可移植性 ORM支持很多不同的数据库

安装：

sudo pip3 install flask-sqlalchemy

一、执行原生SQL

(1) 创建数据库

create database if not exists 库名 character set utf8;

(2) 安装pymysql

sudo pip3 install pymysql

(3) 配置数据库

DB_URI = ‘mysql+pymysql://用户名:密码@主机:端口号/库名’

实例

from sqlalchemy import create_engine

DATABASE = 'hz03'
USERNAME = 'root'
PASSWORD = '123456'
HOST = '127.0.0.1'
PORT = '3306'
#创建连接和操作数据库的URI
DB_URI = 'mysql+pymysql://{}:{}@{}:{}/{}'.format(USERNAME,PASSWORD,HOST,PORT,DATABASE)

#创建操作数据库的引擎
engine = create_engine(DB_URI)

with engine.connect() as con:
    # con.execute('create table user(id int,username varchar(255),sex tinyint)')
    con.execute('insert into user values(1,"xxx",1)')

二、在flask中使用ORM

(1) 当前字段类型

类型名	说明
integer	整形
SmallInteger	小整形
BigInteger	长整型
Float	浮点型
String	varchar类型
Text	长文本
Boolean	tingint
Date	日期 datetime.date
Time	时间 datetime.time
DateTime	时间和日期 datetime.datetim

(2) 约束条件

选项	选项说明
primary_key	主键默认 False
index	常规默认 False
Unique	唯一默认 False
nullable	是否为null 默认True
default	默认值

注意：

其中的default默认值并不是更改表结构的默认值而是在插入数据的时候如果不插入数据则插入默认值

实例

配置

from flask import Flask,render_template
from flask_script import Manager
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)
#创建连接数据的URI
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:123456@127.0.0.1:3306/hz03'

app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True #开启自动提交
#数据的追踪 当数据发生改变时 会返回信号量 进行关闭 
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
db = SQLAlchemy(app)
manager = Manager(app)

创建模型

class User(db.Model):
    id = db.Column(db.Integer,primary_key=True)
    username = db.Column(db.String(20),index=True)
    age = db.Column(db.Integer)
    icon = db.Column(db.String(40),default='default.jpg')

数据的添加修改删除

@app.route('/create_table/')
def create_table():
    db.drop_all() #删除 和当前模型类同名的表
    db.create_all() #创建当前模型类的表
    return '创建表'


@app.route('/insert/')
def insert():
    try:
        u = User(username='张三',age=18)
        # print(u)
        db.session.add(u)
        db.session.commit() #因为sqlalchemy开启事物 所有所以需要提交或者回滚
    except:
        db.session.rollback()
    return '添加数据'
#开启了自动提交功能 不需要手动commit了
@app.route('/insert_two/')
def insert_two():
    u = User(username='李四',age=20)
    db.session.add(u)
    return '走我了'
#修改
@app.route('/update/')
def update():
    u = User.query.get(1)
    # print(u.id)
    # print(u.username)
    u.username = '王五'
    db.session.add(u)
    return 'update'

#删除
@app.route('/delete/')
def delete():
    u = User.query.get(2) #查询成功返回 对象 失败返回None
    # print(u)
    db.session.delete(u)
    return '删除'

拆分MVT

目录结构

project/
    App/
        __init__.py  包文件必须的
        model.py    模块
        views.py    视图
    ext.py  extensions.py  加载第三方扩展的文件
    settings.py    配置文件
    static/
    templates/
    manage.py 启动项

细致的

project/
    App/
        __init__.py
        static/
            js/
            img/
            upload/
            css/
        templates/
            common/
            ...
        forms/
            __init__.py
            ...
        models/
            __init__.py
        views/
            __init.py__.py
            ...
        settings.py
        email.py
        extensions.py
    manager.py
    migrations/
    venv/

三、数据的操作

创建模型类

class User(Base,db.Model):
    __tablename__ = 'user' #给表起名
    id = db.Column(db.Integer,primary_key=True)
    username = db.Column(db.String(20),index=True)
    age = db.Column(db.Integer)
    icon = db.Column(db.String(40),default='default.jpg')
    def __init__(self,username='',age=0,icon='default.jpg'):
        self.username = username
        self.age = age
        self.icon = icon

(1) 添加 add add_all

添加一条

@main.route('/add/')
def add():
    u = User(username='张三',age=18)
    db.session.add(u)
    db.session.commit()
    return '数据添加一条成功'

添加多条

@main.route('/add_all/')
def add_all():
    u1 = User(username='李四',age=20)
    u2 = User(username='王五',age=22)
    db.session.add_all([u1,u2])
    db.session.commit()
    return '添加多条'

(2) 自定义增删改的基础类

class Base:
    #定义一个添加一条数据的方法
    def save(self):
        try:
            db.session.add(self)
            db.session.commit()
        except:
            db.session.rollback()

    #定义添加多条数据的方法
    @staticmethod
    def save_all(*args):
        try:
            db.session.add_all(args)
            db.session.commit()
        except:
            db.session.rollback()

    #自定义删除方法
    def delete(self):
        try:
            db.session.delete(self)
            db.session.commit()
        except:
            db.session.rollback()

使用

class User(Base,db.Model):
    ...

在视图中使用

@main.route('/add/')
def add():
    # u = User(username='张三',age=18)
    u = User('张三',18)
    # db.session.add(u)
    # db.session.commit()
    u.save() #使用自定义的添加方法
    return '数据添加一条成功'

@main.route('/add_all/')
def add_all():
    # u1 = User(username='李四',age=20)
    # u2 = User(username='王五',age=22)
    u1 = User('赵六',27)
    u2 = User('李七',12)
    # db.session.add_all([u1,u2])
    # db.session.commit()
    User.save_all(u1,u2)
    return '添加多条'

@main.route('/delete/')
def delete():
    u = User.query.get(1)
    u.delete()
    return '删除'

四、数据库操作

查询集

查询数据的集合

分类

原始查询集
类名.query得到的结果就为原始查询集
数据查询集
加上各种的过滤器的方法最终返回的结果为数据查询集都使用数据查询集

过滤器

(1) all 查询所有以列表形式返回不支持连贯操作

类名.query.all()

@main.route('/all/')
def all():
    data = User.query.all()
    print(data)
    return render_template('show.html',data=data)

(2) filter() 过滤

类名.query.filter([类名.属性名条件操作符值])

默认返回所有

#支持连贯操作
@main.route('/filter/')
def filter():
    # data = User.query.filter() #返回所有
    # data = User.query.filter(User.age>20) #查询年龄大于20的数据
    data = User.query.filter(User.age>20,User.age<40) #查询年龄大于20的数据 and 小于40
    print(data)
    return render_template('show.html',data=data)

(3) filter_by 只支持参数为关键字参数

类名.query.filter_by(属性名=值…)

@main.route('/filter_by/')
def filter_by():
    # data = User.query.filter_by(id=2)
    # data = User.query.filter_by(id>2) #错误写法
    data = User.query.filter_by(id=2,age=27)
    return render_template('show.html',data=data)

(4) offset 偏移量

offset(num)

#偏移量取值
@main.route('/offset/')
def offset():
    data = User.query.filter().offset(2)
    return render_template('show.html',data=data)

(5) limit 取值

limit(num)

@main.route('/limit/')
def limit():
    # data = User.query.limit(2)
    data = User.query.filter(User.age>30).limit(2)
    return render_template('show.html',data=data)

(6) offset和limit组合使用

@main.route('/offsetlimit/')
def offsetlimit():
    data = User.query.offset(2).limit(2)
    # limit 2,2
    return render_template('show.html',data=data)

(7) order_by() 排序

@main.route('/order_by/')
def order_by():
    # data = User.query.order_by(User.age) #升序
    data = User.query.order_by(-User.age) #降序
    return render_template('show.html',data=data)

(8) first 取出第一条数据返回对象

@main.route('/first/')
def first():
    # data = User.query.first() == User.query.get(2)
    print(data)
    print(data.id)
    print(data.username)
    return '取出第一条数据'

(9) get 获取id对应的数据

查询成功返回对象查询失败返回None

@main.route('/first/')
def first():
    data = User.query.get(2)
    return '取出第一条数据'

(10) contains 包含关系

@main.route('/contains/')
def contains():
    #username中包含数字7的数据
    data = User.query.filter(User.username.contains('7'))
    return render_template('show.html',data=data)

(11) like 模糊查询

@main.route('/like/')
def like():
    #username中包含数字7的数据
    # data = User.query.filter(User.username.like('%7%'))
    # data = User.query.filter(User.username.like('李%')) #以李作为开头的
    data = User.query.filter(User.username.like('%6')) #以6作为结尾的数据
    return render_template('show.html',data=data)

(12) startswith endswith 以…开头以…结尾

#startswith  endswith
@main.route('/startend/')
def startend():
    # data = User.query.filter(User.username.startswith('李'))
    data = User.query.filter(User.username.endswith('6'))
    return render_template('show.html',data=data)

(13) 比较运算符

__gt__
__ge__
__lt__
__le__
>
<
>=
<=
==
!=

@main.route('/bjiao/')
def bjiao():
    # data = User.query.filter(User.age.__gt__(20))
    # data = User.query.filter(User.age.__ge__(99))
    data = User.query.filter(User.age!=99)
    return render_template('show.html',data=data)

(14) in 和 not in

@main.route('/in/')
def myIn():
    # data = User.query.filter(User.age.in_([27,12,1,30,40,50]))
    data = User.query.filter(~User.age.in_([27,12,1,30,40,50]))
    return render_template('show.html',data=data)

(15) is null

@main.route('/null/')
def null():
    # data = User.query.filter(User.username == None)
    # data = User.query.filter(User.username != None)
    # data = User.query.filter(User.username.is_(None))
    data = User.query.filter(User.username.isnot(None))
    return render_template('show.html',data=data)

(16) and_

多个条件用逗号隔开，为and操作

from sqlalchemy import and_

@main.route('/and/')
def myAnd():
    # data = User.query.filter(User.age==27,User.id==2)
    data = User.query.filter(and_(User.age==27,User.id==2))
    return render_template('show.html',data=data)

(17) or_

from sqlalchemy import or_

@main.route('/and/')
def myAnd():
    data = User.query.filter(or_(User.age==27,User.id==2))
    data = User.query.filter(and_(User.username.like('%6%')),or_(User.age>=27,User.id==2))
    return render_template('show.html',data=data)

(18) not_

from sqlalchemy import not_

@main.route('/and/')
def myAnd():    
    # data = User.query.filter(not_(User.age>27,User.id==1))\
    #错误写法只能给一个条件取反
    data = User.query.filter(not_(User.age>27))
    return render_template('show.html',data=data)

(19) count 统计

    data = User.query.filter(not_(User.age>27)).count()

四、文件的迁移

模块：

pip install flask-migrate

pip install flask-script

使用

(1) 实例化

from flask_migrate import Migrate,MigrateCommand
from flask_sqlalchemy import SQLalchemy
app = Flask(__name__)
db = SQLalchemy(app)
migrate = Migrate(app,db=db)
manager = Manager(app)
manager.add_command('db',MigrateCommand)

(2) 初始化迁移文件目录

python manage.py db init

(3) 生成迁移文件

python manage.py db migrate

(4) 执行迁移文件

python manage.py db upgrade

注意

如果当前存在模型但是执行创建迁移文件的时候提示没有任何改变的时候需要查看当前的模型类是否有使用(导入)

    原文作者：rottengeek
    原文地址: https://segmentfault.com/a/1190000015240882
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。