flask入門5-model

Godtoy 發(fā)布于2019-07-30 16:48 / 2184人閱讀

摘要：的模型使用模型的原因當(dāng)項目越來越大的時候會出現(xiàn)很多問題原生較多重復(fù)使用率低如果你的數(shù)據(jù)庫發(fā)生了改變所有的原生就都要進行修改寫原生的時候會有安全隱患中文件關(guān)系對象的映射使用去操作數(shù)據(jù)庫的時候不會再去寫原生的了通過把表映射成類字段為你的屬性在

Flask-SQLalchemy flask的ORM模型 使用ORM模型的原因

當(dāng)項目越來越大的時候會出現(xiàn)很多問題

原生SQL較多重復(fù)使用率低

如果你的數(shù)據(jù)庫發(fā)生了改變所有的原生SQL就都要進行修改

寫原生SQL的時候會有安全隱患

ORM：中文件關(guān)系對象的映射使用ORM去操作數(shù)據(jù)庫的時候不會再去寫原生的SQL了通過把表映射成類字段為你的屬性 ORM在執(zhí)行的時候也會最終轉(zhuǎn)換為 SQL語句去操作數(shù)據(jù)庫

易用性使用ORM可以減少重復(fù)SQL的概率寫出來的模型也更加的直觀清晰

可移植性 ORM支持很多不同的數(shù)據(jù)庫

安裝：

sudo pip3 install flask-sqlalchemy

一、執(zhí)行原生SQL (1) 創(chuàng)建數(shù)據(jù)庫

create database if not exists 庫名 character set utf8;

(2) 安裝pymysql

sudo pip3 install pymysql

(3) 配置數(shù)據(jù)庫

DB_URI = "mysql+pymysql://用戶名:密碼@主機:端口號/庫名"

實例

from sqlalchemy import create_engine

DATABASE = "hz03"
USERNAME = "root"
PASSWORD = "123456"
HOST = "127.0.0.1"
PORT = "3306"
#創(chuàng)建連接和操作數(shù)據(jù)庫的URI
DB_URI = "mysql+pymysql://{}:{}@{}:{}/{}".format(USERNAME,PASSWORD,HOST,PORT,DATABASE)

#創(chuàng)建操作數(shù)據(jù)庫的引擎
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) 當(dāng)前字段類型

類型名	說明
integer	整形
SmallInteger	小整形
BigInteger	長整型
Float	浮點型
String	varchar類型
Text	長文本
Boolean	tingint
Date	日期 datetime.date
Time	時間 datetime.time
DateTime	時間和日期 datetime.datetim

(2) 約束條件

選項	選項說明
primary_key	主鍵默認(rèn) False
index	常規(guī) 默認(rèn) False
Unique	唯一默認(rèn) False
nullable	是否為null 默認(rèn)True
default	默認(rèn)值

注意：

其中的default默認(rèn)值并不是更改表結(jié)構(gòu)的默認(rèn)值而是在插入數(shù)據(jù)的時候如果不插入數(shù)據(jù) 則插入默認(rèn)值

實例

配置

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

app = Flask(__name__)
#創(chuàng)建連接數(shù)據(jù)的URI
app.config["SQLALCHEMY_DATABASE_URI"] = "mysql+pymysql://root:123456@127.0.0.1:3306/hz03"

app.config["SQLALCHEMY_COMMIT_ON_TEARDOWN"] = True #開啟自動提交
#數(shù)據(jù)的追蹤 當(dāng)數(shù)據(jù)發(fā)生改變時 會返回信號量 進行關(guān)閉 
app.config["SQLALCHEMY_TRACK_MODIFICATIONS"] = False
db = SQLAlchemy(app)
manager = Manager(app)

創(chuàng)建模型

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")

數(shù)據(jù)的添加修改刪除

@app.route("/create_table/")
def create_table():
    db.drop_all() #刪除 和當(dāng)前模型類同名的表
    db.create_all() #創(chuàng)建當(dāng)前模型類的表
    return "創(chuàng)建表"


@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 "添加數(shù)據(jù)"
#開啟了自動提交功能 不需要手動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 目錄結(jié)構(gòu)

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/

三、數(shù)據(jù)的操作

創(chuàng)建模型類

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 "數(shù)據(jù)添加一條成功"

添加多條

@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) 自定義增刪改的基礎(chǔ)類

class Base:
    #定義一個添加一條數(shù)據(jù)的方法
    def save(self):
        try:
            db.session.add(self)
            db.session.commit()
        except:
            db.session.rollback()

    #定義添加多條數(shù)據(jù)的方法
    @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 "數(shù)據(jù)添加一條成功"

@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 "刪除"

四、數(shù)據(jù)庫操作 查詢集

查詢數(shù)據(jù)的集合

分類

原始查詢集

類名.query得到的結(jié)果就為原始查詢集

數(shù)據(jù)查詢集

加上各種的過濾器的方法最終返回的結(jié)果為數(shù)據(jù)查詢集都使用數(shù)據(jù)查詢集

過濾器 (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([類名.屬性名條件操作符值])

默認(rèn)返回所有

#支持連貫操作
@main.route("/filter/")
def filter():
    # data = User.query.filter() #返回所有
    # data = User.query.filter(User.age>20) #查詢年齡大于20的數(shù)據(jù)
    data = User.query.filter(User.age>20,User.age<40) #查詢年齡大于20的數(shù)據(jù) and 小于40
    print(data)
    return render_template("show.html",data=data)

(3) filter_by 只支持參數(shù)為關(guān)鍵字參數(shù)

類名.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 取出第一條數(shù)據(jù) 返回對象

@main.route("/first/")
def first():
    # data = User.query.first() == User.query.get(2)
    print(data)
    print(data.id)
    print(data.username)
    return "取出第一條數(shù)據(jù)"

(9) get 獲取id對應(yīng)的數(shù)據(jù)

查詢成功返回對象查詢失敗返回None

@main.route("/first/")
def first():
    data = User.query.get(2)
    return "取出第一條數(shù)據(jù)"

(10) contains 包含關(guān)系

@main.route("/contains/")
def contains():
    #username中包含數(shù)字7的數(shù)據(jù)
    data = User.query.filter(User.username.contains("7"))
    return render_template("show.html",data=data)

(11) like 模糊查詢

@main.route("/like/")
def like():
    #username中包含數(shù)字7的數(shù)據(jù)
    # data = User.query.filter(User.username.like("%7%"))
    # data = User.query.filter(User.username.like("李%")) #以李作為開頭的
    data = User.query.filter(User.username.like("%6")) #以6作為結(jié)尾的數(shù)據(jù)
    return render_template("show.html",data=data)

(12) startswith endswith 以...開頭以...結(jié)尾

#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 統(tǒng)計

    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) 執(zhí)行遷移文件

python manage.py db upgrade

注意

如果當(dāng)前存在模型但是執(zhí)行創(chuàng)建遷移文件的時候提示沒有任何改變的時候需要查看當(dāng)前的模型類是否有使用(導(dǎo)入)

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://www.ezyhdfw.cn/yun/41833.html

發(fā)表評論

登陸后可評論

0條評論

Godtoy

男|高級講師

我要關(guān)注我要私信

TA的文章

Linux驅(qū)動實踐：你知道【字符設(shè)備驅(qū)動程序】的兩種寫法嗎？

閱讀 2992·2021-11-19 11:35
騰訊云雙11活動 2021 - 云服務(wù)器低至年48元及值得買的云服務(wù)

閱讀 2644·2021-11-02 14:40
【騰訊雲(yún)】DNSPod解析套餐全面升配降價，更高的套餐配置規(guī)格，更優(yōu)的價格方案，全面提升可用性及響應(yīng)

閱讀 1477·2021-09-04 16:48
CSS3實現(xiàn)微信小程序瀑布流布局

閱讀 3085·2019-08-30 15:55
父元素line-height設(shè)為0后，inline-block的空元素終于安分了

閱讀 1850·2019-08-30 13:11
關(guān)于特定位置進度條的加載

閱讀 2014·2019-08-29 11:12
細節(jié)：解析XML文檔和XML字符串

閱讀 1161·2019-08-27 10:52
項目在啟動時究竟是怎么運行的（項目運行的步驟）

閱讀 3235·2019-08-26 18:36

亚洲中字慕日产2020,大陆极品少妇内射AAAAAA,无码av大香线蕉伊人久久,久久精品国产亚洲av麻豆网站

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

flask入門5-model

相關(guān)文章

flask入門4-文件上傳與郵件發(fā)送

**從零開始搭建論壇（三）：Flask框架簡單介紹**

flask入門3-表單

發(fā)表評論

0條評論

Godtoy

男|高級講師

TA的文章

Linux驅(qū)動實踐：你知道【字符設(shè)備驅(qū)動程序】的兩種寫法嗎？

騰訊云雙11活動 2021 - 云服務(wù)器低至年48元及值得買的云服務(wù)

【騰訊雲(yún)】DNSPod解析套餐全面升配降價，更高的套餐配置規(guī)格，更優(yōu)的價格方案，全面提升可用性及響應(yīng)

CSS3實現(xiàn)微信小程序瀑布流布局

父元素line-height設(shè)為0后，inline-block的空元素終于安分了

關(guān)于特定位置進度條的加載

細節(jié)：解析XML文檔和XML字符串

項目在啟動時究竟是怎么運行的（項目運行的步驟）

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

flask入門5-model

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！