django數據庫分庫migrate
- 2020 年 3 月 13 日
- 筆記
最近在研究微服務和分佈式，設計到了數據庫分庫，記錄一下
首先，創建多個數據庫，如果是已經生成的數據庫，可以分庫，這裡我是新創建的項目，剛好可以用來嘗試
我是用docker創建的mysql數據庫容器
拉取docker鏡像：
docker pull mysql:5.7
創建容器：
docker run --name=mysql5.7 -p 13306:3306 -e MYSQL_ROOT_PASSWORD=123456 -d mysql:5.7
創建多個mysql容器之後，django配置好相應數據庫，我這裡分成了三個數據庫，一個是默認，放django的user，group，permission，session之類的，另外一個是order和sale兩個app的，這裡我打算下一步微服務的時候再拆開，這裡先記錄分庫的事情，數據庫代碼如下：
DATABASES = { 'default': { 'ENGINE': 'django.db.backends.mysql', 'HOST': '192.168.1.112', 'PORT': '13308', 'NAME': 'default', 'USER': 'root', 'PASSWORD': '0123456789', 'TEST': { 'MIRROR': 'default' } }, 'sale': { 'ENGINE': 'django.db.backends.mysql', 'HOST': '192.168.1.112', 'PORT': '13306', 'NAME': 'sale', 'USER': 'root', 'PASSWORD': '0123456789', 'TEST': { 'MIRROR': 'default' } }, 'order': { 'ENGINE': 'django.db.backends.mysql', 'HOST': '192.168.1.112', 'PORT': '13307', 'NAME': 'order', 'USER': 'root', 'PASSWORD': '0123456789', 'TEST': { 'MIRROR': 'default' } } }分庫之後，在settings.py同級目錄下，創建一個databaserouter
DATABASE_MAPPING = { # example: # 'app_name':'database_name', 'sale': 'sale', 'order': 'order', 'admin': 'default', 'auth': 'default', 'contenttypes': 'default', 'sessions': 'default', } class DBAppsRouter(object): def db_for_read(self, model, **hints): """"Point all read operations to the specific database.""" if model._meta.app_label in DATABASE_MAPPING: return DATABASE_MAPPING[model._meta.app_label] return None def db_for_write(self, model, **hints): """Point all write operations to the specific database.""" if model._meta.app_label in DATABASE_MAPPING: return DATABASE_MAPPING[model._meta.app_label] return None def allow_relation(self, obj1, obj2, **hints): """Allow any relation between apps that use the same database.""" db_obj1 = DATABASE_MAPPING.get(obj1._meta.app_label) db_obj2 = DATABASE_MAPPING.get(obj2._meta.app_label) if db_obj1 and db_obj2: if db_obj1 == db_obj2: return True else: return False return None def allow_syncdb(self, db, model): """Make sure that apps only appear in the related database.""" if db in DATABASE_MAPPING.values(): return DATABASE_MAPPING.get(model._meta.app_label) == db elif model._meta.app_label in DATABASE_MAPPING: return False return None def allow_migrate(self, db, app_label, model=None, **hints): """ Make sure the auth app only appears in the 'auth_db' database. """ if db in DATABASE_MAPPING.values(): return DATABASE_MAPPING.get(app_label) == db elif app_label in DATABASE_MAPPING: return False return None這裡一定要把DATABASE_MAPPING裏面的app名字和app名字對應，不然會讀寫不到，具體可以看上述代碼，然後在模型類後面給每個模型添加一個app_label：
class Meta: app_label = 'order'最後就是migrate數據庫了，先makemigrations order,然後migrate --database order
後面sale app一樣
