您好,登錄后才能下訂單哦!
本文小編為大家詳細(xì)介紹“flask-SQLALchemy連接數(shù)據(jù)庫如何實現(xiàn)”,內(nèi)容詳細(xì),步驟清晰,細(xì)節(jié)處理妥當(dāng),希望這篇“flask-SQLALchemy連接數(shù)據(jù)庫如何實現(xiàn)”文章能幫助大家解決疑惑,下面跟著小編的思路慢慢深入,一起來學(xué)習(xí)新知識吧。
sqlalchemy是數(shù)據(jù)庫的orm框架,讓我們操作數(shù)據(jù)庫的時候不要再用sql語句了,跟直接操作模型一樣。
請求鉤子:
在請求開始時,建立數(shù)據(jù)庫連接;
在請求開始時,根據(jù)需求進(jìn)行權(quán)限校驗;
在請求結(jié)束時,指定數(shù)據(jù)的交互格式;
@app.before_first_request #只有第一次請求之前調(diào)用,可以在此方法內(nèi)部做一些初始化操作 @app.before_request #每次請求之前都會觸發(fā) #在每一次請求之前調(diào)用,這時候已經(jīng)有請求了,可能在這個方法里面做請求的校驗 #如果請求的校驗不成功,可以直接在此方法中進(jìn)行響應(yīng),直接return之后那么就不會執(zhí)行視圖函數(shù) @app.after_request #在每次執(zhí)行完視圖函數(shù)之后會調(diào)用,要傳入函數(shù)響應(yīng) #在執(zhí)行完視圖函數(shù)之后會調(diào)用,并且會把視圖函數(shù)所生成的響應(yīng)傳入,可以在此方法中對應(yīng)響應(yīng)做最后一步統(tǒng)一的處理 @app.teardown_request #每一次請求之后都會調(diào)用,會接受一個參數(shù),參數(shù)是服務(wù)器出現(xiàn)的錯誤信息
sqlalchemy:是一個獨(dú)立的ORM框架,可以獨(dú)立于Flask存在,也可以在其他項目中使用,比如Django中。
Flask-sqlalchemy:對sqlalchemy的一個封裝,能夠更適合在flask中使用。
一、安裝
1、安裝連接數(shù)據(jù)庫的庫:pip install pymysql
2、安裝:pip install flask-sqlalchemy
二、連接數(shù)據(jù)庫:
基本的配置:
1: 首先先安裝兩個依賴的包。
2:配置數(shù)據(jù)庫的連接:app.config[‘SQLALCHEMY_DATABASE_URI’] = “mysql://root:mysql@192.168.44.128:3306/test39”
3:關(guān)閉數(shù)據(jù)庫的跟蹤:app.config[‘SQLALCHEMY_TRACK_MODIFICATIONS’] = False
4:開啟輸出sql語句:app.config[‘SQLALCHEMY_ECHO’] = True
5:兩種處理python2和python3的名字不一致問題。
from flask import Flask from flask_restful import Api, Resource from flask_sqlalchemy import SQLAlchemy #import pymysql #pymysql.install_as_MySQLdb() """ python2中數(shù)據(jù)庫客戶端: MySqldb python3中數(shù)據(jù)庫客戶端:pymysql 解決方案一:讓python2和python3的包進(jìn)行轉(zhuǎn)換。 import pymysql pymysql.install_as_MySQLdb() 方案二:表示只使用python3的包,不使用python2的包 app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root:mysql@192.168.44.128:3306/test39" """ app = Flask(__name__) db = SQLAlchemy(app) #創(chuàng)建一個對象,設(shè)置名為db # app.config['SQLALCHEMY_DATABASE_URI'] = "mysql://賬號:密碼@數(shù)據(jù)庫ip地址:端口號/數(shù)據(jù)庫名" app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root:mysql@192.168.44.128:3306/test39" # app.config['SQLALCHEMY_BINDS'] = {} # 關(guān)閉數(shù)據(jù)庫修改跟蹤操作[提高性能],可以設(shè)置為True,這樣可以跟蹤操作: app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False # 開啟輸出底層執(zhí)行的sql語句 app.config['SQLALCHEMY_ECHO'] = True # 開啟數(shù)據(jù)庫的自動提交功能[一般不使用] app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True @app.route('/') def hello_word(): return "hello, word" if __name__ == '__main__': print(app.url_map) app.run(host='0.0.0.0', port= 8000, debug=True)
from flask import Flask from flask_sqlalchemy import SQLAlchemy app = Flask(__name__) db = SQLAlchemy(app) #創(chuàng)建一個對象,設(shè)置名為db #建立數(shù)據(jù)庫連接 #app.config['SQLALCHEMY_DATABASE_URI'] = "mysql://賬號:密碼@數(shù)據(jù)庫ip地址:端口號/數(shù)據(jù)庫名" app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root:mysql@192.168.44.128:3306/test39" 驗證是否連接成功 @app.route('/') def hello_word(): engine = db.get_engine() conn = engine.connect() conn.close() #跟open函數(shù)一樣,可以用with語句 #with engine.connect() as conn: # result = conn.execute('select 1') #這兩步打開數(shù)據(jù)庫并且創(chuàng)建表 # print (result.fetchone()) #打印一條數(shù)據(jù) return "hello, word" 創(chuàng)建模型并進(jìn)行數(shù)據(jù)增刪改查 #創(chuàng)建orm模型--- class mmm(db.Model): __tablename__ = 'mmm' # 設(shè)置表名 id = db.Column(db.Integer,primary_key,autoincreament) title = db.Column(db.string(200),nullable=Flase) content = db.Column(db.Text,nullable=Flase) db.create_all() # 刪除所有繼承自db.Model的表 # db.drop_all() # 創(chuàng)建所有繼承自db.Model的表 #db.create_all() 數(shù)據(jù)操作——增刪改查 1:給模型對象設(shè)置數(shù)據(jù) 可以通過 初始化參數(shù) 或者 賦值屬性 兩種方式 2:session.add(模型對象) 添加單條數(shù)據(jù)到會話中, session.add_all(列表) 添加多條數(shù)據(jù)到會話中 3:sqlalchemy 會 自動創(chuàng)建事務(wù), 并將數(shù)據(jù)操作包含在事務(wù)中, 提交會話時就會提交事務(wù),事務(wù)提交失敗會自動回滾。 @app.route('/mmm") def mmm_view(): #1. 添加數(shù)據(jù) # sql語句為 insert table mmm value (xxx),這里不用 #之前創(chuàng)建了mmm類對象,所以直接調(diào)用即可 article = mmm(title= "",content="") #數(shù)據(jù)添加 db.session.add(article) #數(shù)據(jù)提交 db.session.commit() #最后進(jìn)行返回操作 return "數(shù)據(jù)操作成功" #2.查詢數(shù)據(jù) # filter_by() 返回一個類列表的對象 artice = mmm.query.filter_by(id=1)[0] #進(jìn)行查詢,根據(jù)誰進(jìn)行查詢,必須用 []將值取出來 print(artice.title) #將id為1的title取出來 return "數(shù)據(jù)操作成功" #3.修改數(shù)據(jù) artice = mmm.query.filter_by(id=1)[0] artice.content = "xxx" #將id為一的content的數(shù)據(jù)改成xxx #修改數(shù)據(jù)的進(jìn)行數(shù)據(jù)提交 db.session.commit return "數(shù)據(jù)操作成功" #4.刪除數(shù)據(jù) mmm.query.filter_by(id=1).delete() db.session.commit() return "數(shù)據(jù)操作成功"
表之間的關(guān)系存在三種:
一對一,一對多,多對多,而SQLAlchemy中的ORM也可以模擬這三種關(guān)系,因為一對一其實在SQLAlchemy中底層是通過一對多的方式模擬的,所以先看一下一對多的關(guān)系:
外鍵:
在mysql中,外鍵可以讓表之間的關(guān)系更加緊密,而SQLAlchemy同樣也支持外鍵,通過foreignkey類來實現(xiàn),并且可以指定表的外鍵約束。
class user(db.Model): __tablename__ = 'mmm' # 設(shè)置表名 id = db.Column(db.Integer,primary_key,autoincreament) username = db.Column(db.string(200),nullable=) class Article(db.Model): __tablename__ = 'ggg' # 設(shè)置表名 id = db.Column(db.Integer,primary_key,autoincreament) title = db.Column(db.string(200),nullable=Flase) content = db.Column(db.Text,nullable=Flase) #外鍵 #1.外鍵的數(shù)據(jù)類型一定要看所引用的字段類型,要一樣 #2. db.Foreignkey("表名. 字段名") #3.外鍵是屬于數(shù)據(jù)庫層面的,不推薦直接在ORM直接使用 author_id = db.Column(db.Integer,db.Foreignkey("user.id")) #relationship #1.第一個參數(shù)是模型的名字,必須要和模型的名字一致 #2.backref(bsck reference):代表反向引用,代表對方訪問我的時候的字段名稱 author = db.relationship("user",backref="articles") #一對一: # db.backref #1. 在反向引用的時候,如果需要傳遞一些其他的參數(shù),那么就需要用到這個函數(shù),否則不需要使用,只要在relationship的backref參數(shù)上,設(shè)置反向引用的名稱就可以了。 #2. uselist=Flase :代表反向引用的名稱就可以了 user = db.relationship("User",backref=db.backref("extension",uselist=Flase))
在實際的開發(fā)環(huán)境中,經(jīng)常會發(fā)生數(shù)據(jù)庫修改的行為。一般我們修改數(shù)據(jù)庫不會直接手動的去修改,而是去修改ORM對應(yīng)的模型,然后再把模型映射到數(shù)據(jù)庫中。這時候如果有一個工具能專門做這種事情,就顯得非常有用了,而flask-migrate就是做這個事情的。flask-migrate是基于Alembic進(jìn)行的一個封裝,并集成到Flask中,而所有的遷移操作其實都是Alembic做的,他能跟蹤模型的變化,并將變化映射到數(shù)據(jù)庫中。
使用Flask-Migrate需要安裝,命令如下:
pip install flask-migrate
一、基本用法
要讓Flask-Migrate能夠管理app中的數(shù)據(jù)庫,需要使用Migrate(app,db)來綁定app和數(shù)據(jù)庫。假如現(xiàn)在有以下app文件: from flask import Flask from flask_sqlalchemy import SQLAlchemy from constants import DB_URI from flask_migrate import Migrate app = Flask(__name__) app.config['SQLALCHEMY_DATABASE_URI'] = DB_URI app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True db = SQLAlchemy(app) # 綁定app和數(shù)據(jù)庫 migrate = Migrate(app,db) class User(db.Model): id = db.Column(db.Integer,primary_key=True) username = db.Column(db.String(20)) addresses = db.relationship('Address',backref='user') class Address(db.Model): id = db.Column(db.Integer,primary_key=True) email_address = db.Column(db.String(50)) user_id = db.Column(db.Integer,db.ForeignKey('user.id')) db.create_all() @app.route('/') def hello_world(): return 'Hello World!' if __name__ == '__main__': app.run()
之后,就可以在命令行中映射ORM了。首先需要初始化一個遷移文件夾:
flask db init
然后再把當(dāng)前的模型添加到遷移文件中:
flask db migrate
最后再把遷移文件中對應(yīng)的數(shù)據(jù)庫操作,真正的映射到數(shù)據(jù)庫中:
flask db upgrade
二、項目重構(gòu):
現(xiàn)在是所有代碼都寫在一個文件中,這樣會導(dǎo)致文件會越來越亂。所以進(jìn)行一下項目重構(gòu),設(shè)置為以下的目錄結(jié)構(gòu):
以下對各個文件的作用進(jìn)行解釋。
constants.py文件:
常量文件,用來存放數(shù)據(jù)庫配置。
# constants.py HOSTNAME = '127.0.0.1' PORT = '3306' DATABASE = 'xt_flask_migrate' USERNAME = 'root' PASSWORD = 'root' DB_URI = 'mysql+mysqldb://{}:{}@{}:{}/{}'.format(USERNAME,PASSWORD,HOSTNAME,PORT,DATABASE)
ext.py文件:
把db變量放到一個單獨(dú)的文件,而不是放在主app文件。這樣做的目的是為了在大型項目中如果db被多個模型文件引用的話,會造成from your_app import db這樣的方式,但是往往也在your_app.py中也會引入模型文件定義的類,這就造成了循環(huán)引用。所以最好的辦法是把它放在不依賴其他模塊的獨(dú)立文件中。
# ext.py from flask_sqlalchemy import SQLAlchemy db = SQLAlchemy()
models.py文件:
模型文件,用來存放所有的模型,并且注意,因為這里使用的是flask-script的方式進(jìn)行模型和表的映射,因此不需要使用db.create_all()的方式創(chuàng)建數(shù)據(jù)庫。
# models.py from ext import db class User(db.Model): id = db.Column(db.Integer,primary_key=True) username = db.Column(db.String(50)) addresses = db.relationship('Address',backref='user') def __init__(self,username): self.username = username class Address(db.Model): id = db.Column(db.Integer,primary_key=True) email_address = db.Column(db.String(50)) user_id = db.Column(db.Integer,db.ForeignKey('user.id')) def __init__(self,email_address): self.email_address = email_address
app.py文件:
這個是主app文件,運(yùn)行文件。并且因為db被放到另外一個文件中,所以使用db.init_app(app)的方式來綁定數(shù)據(jù)庫。
# app.py from flask import Flask from ext import db app = Flask(__name__) db.init_app(app) @app.route('/') def hello_world(): return 'Hello World!' if __name__ == '__main__': app.run()
通過以上項目重構(gòu)后,后續(xù)我們就只要通過以下三個命令即可完成遷移操作了。
在命令行中映射ORM了。首先需要初始化一個遷移文件夾:
flask db init
然后再把當(dāng)前的模型添加到遷移文件中:
flask db migrate
最后再把遷移文件中對應(yīng)的數(shù)據(jù)庫操作,真正的映射到數(shù)據(jù)庫中:
flask db upgrade
讀到這里,這篇“flask-SQLALchemy連接數(shù)據(jù)庫如何實現(xiàn)”文章已經(jīng)介紹完畢,想要掌握這篇文章的知識點還需要大家自己動手實踐使用過才能領(lǐng)會,如果想了解更多相關(guān)內(nèi)容的文章,歡迎關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。