flask入门5-model

Flask-SQLalchemy flask的ORM模型

使用ORM模型的缘由

当项目愈来愈大的时候 会出现不少问题

1. 原生SQL较多 重复使用率低
2. 若是你的数据库发生了改变 全部的原生SQL就都要进行修改
3. 写原生SQL的时候 会有安全隐患

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

1. 易用性 使用ORM能够减小重复SQL的几率 写出来的模型也更加的直观清晰
2. 可移植性 ORM支持不少不一样的数据库

安装：

sudo pip3 install flask-sqlalchemy

1、执行原生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)')

2、在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/

3、数据的操做

建立模型类

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 '删除'

4、数据库操做

查询集

查询数据的集合

分类

1. 原始查询集

   类名.query获得的结果就为原始查询集

2. 数据查询集

   加上各类的过滤器的方法 最终返回的结果 为数据查询集 都使用数据查询集

过滤器

(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) 比较运算符

1. __gt__
2. __ge__
3. __lt__
4. __le__
5. >
6. <
7. >=
8. <=
9. ==
10. !=

@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()

4、文件的迁移

模块：

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

注意

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