DATABASES = { 'default': { 'ENGINE': 'django.db.backends.sqlite3', 'NAME': os.path.join(BASE_DIR, 'db.sqlite3'), }, 'db2': { 'ENGINE': 'django.db.backends.sqlite3', 'NAME': os.path.join(BASE_DIR, 'db2.sqlite3'), }, }
默认迁移的是default,固然也能够指定迁移的数据库:python
python manage.py migrate --database db2
在进行ORM查询的时候指定对应的数据库就行了:sql
models.Student.objects.using('db2').all() obj = models.Student.objects.using('db2').get(name='zhazha') obj.name = 'star' obj.save(using='default')
settings中:数据库
# 自定义的类写在了myrouter.py文件中的Router类中
DATABASE_ROUTERS = ['myrouter.Router']
自定义类:django
class Router: """ 读写分离 """ def db_for_write(self, model, **kwargs): return 'db2' def db_for_read(self, model, **kwargs): return 'default'
一主多从:app
class Router: """ 一主多从 """ def db_for_write(self, model, **kwargs): return 'db1' def db_for_read(self, model, **kwargs): return random.choices['db2', 'db3', 'db4']
分库分表:dom
class Router: """ 分库分表 app01 model db1 app02 model db2 """ def db_for_write(self, model, **kwargs):
# 获取应用的名称 app_name = model._meta.app_label if app_name == 'app01': return 'db1' elif app_name == 'app02': return 'db2' def db_for_read(self, model, **kwargs):
# 获取应用的名称 app_name = model._meta.app_label if app_name == 'app01': return 'db1' elif app_name == 'app02': return 'db2'
~~spa