最近需要用到Django的MySQL讀寫分離技術,查了一些資料,把方法整理了下來。
在Django裡實作對MySQL的讀寫分離,實際上就是将不同的讀寫請求按一定的規則路由到不同的資料庫上(可以是不同類型的資料庫),我們需要做的就是,定義不同的資料庫,定義不同的路由規則。
首先定義我們的主從資料庫:
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.mysql',
'NAME': sae.const.MYSQL_DB,
'USER': sae.const.MYSQL_USER,
'PASSWORD': sae.const.MYSQL_PASS,
'HOST': sae.const.MYSQL_HOST,
'PORT': sae.const.MYSQL_PORT,
},
'slave': {
'HOST': sae.const.MYSQL_HOST_S,
},
}
定義我們的路由規則,路由規則可以有好多個,每個規則是一個類。如下所示:
# -*- coding:utf-8 -*-
class DBRouter(object):
def db_for_read(self, model, **hints):
return 'slave'
def db_for_write(self, model, **hints):
return 'default'
def allow_relation(self, obj1, obj2, **hints):
return None
def allow_syncdb(self, db, model):
最後在setting.py中加上這個路由規則:
DATABASE_ROUTERS = ['opensound.models.DBRouter']
因為Django不負責主從資料庫之間的同步,是以如果在讀取完資料後馬上要對資料進行操作,可以顯式地使用主資料庫來讀取并修改資料。
>>> Author.objects.using('other').all()
>>> my_object.save(using='legacy_users')
參考資料:https://docs.djangoproject.com/en/dev/topics/db/multi-db/
http://www.truease.com/thread-262-1-1.html
本文轉自aaron428 51CTO部落格,原文連結http://blog.51cto.com/aaronsa/1741768:,如需轉載請自行聯系原作者