這篇文章將為大家詳細講解有關(guān)Python如何實現(xiàn)自定義讀寫分離,小編覺得挺實用的,因此分享給大家做個參考,希望大家閱讀完這篇文章后可以有所收獲。
我們注重客戶提出的每個要求,我們充分考慮每一個細節(jié),我們積極的做好成都做網(wǎng)站、網(wǎng)站設(shè)計、外貿(mào)營銷網(wǎng)站建設(shè)服務(wù),我們努力開拓更好的視野,通過不懈的努力,創(chuàng)新互聯(lián)建站贏得了業(yè)內(nèi)的良好聲譽,這一切,也不斷的激勵著我們更好的服務(wù)客戶。 主要業(yè)務(wù):網(wǎng)站建設(shè),網(wǎng)站制作,網(wǎng)站設(shè)計,微信小程序,網(wǎng)站開發(fā),技術(shù)開發(fā)實力,DIV+CSS,PHP及ASP,ASP.Net,SQL數(shù)據(jù)庫的技術(shù)開發(fā)工程師。思路
自定義Session類
重寫get_bind方法
根據(jù)self._flushing判斷讀寫操作, 選擇對應(yīng)的數(shù)據(jù)庫
自定義SQLAlchemy類
重寫create_session, 在其中使用自定義的Session類
from flask import Flask from flask_sqlalchemy import SQLAlchemy, SignallingSession, get_state from sqlalchemy import orm class RoutingSession(SignallingSession): def get_bind(self, mapper=None, clause=None): state = get_state(self.app) # 判斷讀寫操作 if self._flushing: # 寫操作 ,使用主數(shù)據(jù)庫 print("寫入數(shù)據(jù)") return state.db.get_engine(self.app, bind='master') else: # 讀操作, 使用從數(shù)據(jù)庫 print('讀取數(shù)據(jù)') return state.db.get_engine(self.app, bind='slave') class RoutingSQLAlchemy(SQLAlchemy): def create_session(self, options): return orm.sessionmaker(class_=RoutingSession, db=self, **options) app = Flask(__name__) # 設(shè)置數(shù)據(jù)庫的連接地址 app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:mysql@192.168.105.134:3306/demo' # 設(shè)置數(shù)據(jù)庫的綁定地址 app.config['SQLALCHEMY_BINDS'] = { 'master': "mysql://root:mysql@192.168.105.134:3306/demo", 'slave': "mysql://root:mysql@192.168.105.134:8306/demo" } # 設(shè)置是否追蹤數(shù)據(jù)庫變化 一般不會開啟, 影響性能 app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False # 設(shè)置是否打印底層執(zhí)行的SQL語句 app.config['SQLALCHEMY_ECHO'] = False # 創(chuàng)建數(shù)據(jù)庫連接對象 db = RoutingSQLAlchemy(app) # 用戶表 一 class User(db.Model): __tablename__ = 't_user' id = db.Column(db.Integer, primary_key=True) name = db.Column(db.String(20), unique=True) @app.route('/') def index(): # 增加數(shù)據(jù) user1 = User(name='zs') db.session.add(user1) db.session.commit() # 查詢數(shù)據(jù) users = User.query.all() print(users) return "index" if __name__ == '__main__': # 刪除所有繼承自db.Model的表 db.drop_all() # 創(chuàng)建所有繼承自db.Model的表 db.create_all() app.run(debug=True)
關(guān)于“Python如何實現(xiàn)自定義讀寫分離”這篇文章就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,使各位可以學(xué)到更多知識,如果覺得文章不錯,請把它分享出去讓更多的人看到。
網(wǎng)頁標題:Python如何實現(xiàn)自定義讀寫分離-創(chuàng)新互聯(lián)
網(wǎng)頁地址:http://muchs.cn/article42/dpsoec.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供面包屑導(dǎo)航、App設(shè)計、服務(wù)器托管、ChatGPT、靜態(tài)網(wǎng)站、網(wǎng)站設(shè)計
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容