Django多数据库联用实现方法解析
本文讲述在一个djangoproject中使用多个数据库的方法,多个数据库的联用以及多数据库时数据导入导出的方法。
直接给出一种简单的方法吧，想了解更多的到官方教程，点击此处
代码
1.每个app都可以单独设置一个数据库
settings.py中有数据库的相关设置，有一个默认的数据库default,我们可以再加一些其它的，比如：
#Database
#https://docs.djangoproject.com/en/1.8/ref/settings/#databases
DATABASES={
'default':{
'ENGINE':'django.db.backends.sqlite3',
'NAME':os.path.join(BASE_DIR,'db.sqlite3'),
},
'db1':{
'ENGINE':'django.db.backends.mysql',
'NAME':'dbname1',
'USER':'your_db_user_name',
'PASSWORD':'yourpassword',
"HOST":"localhost",
},
'db2':{
'ENGINE':'django.db.backends.mysql',
'NAME':'dbname2',
'USER':'your_db_user_name',
'PASSWORD':'yourpassword',
"HOST":"localhost",
},
}
#usemulti-databaseindjango
#addbyWeizhongTu
DATABASE_ROUTERS=['project_name.database_router.DatabaseAppsRouter']
DATABASE_APPS_MAPPING={
#example:
#'app_name':'database_name',
'app1':'db1',
'app2':'db2',
}
在project_name文件夹中存放database_router.py文件，内容如下：
#-*-coding:utf-8-*-
fromdjango.confimportsettings
DATABASE_MAPPING=settings.DATABASE_APPS_MAPPING
classDatabaseAppsRouter(object):
"""
Aroutertocontrolalldatabaseoperationsonmodelsfordifferent
databases.
Incaseanappisnotsetinsettings.DATABASE_APPS_MAPPING,therouter
willfallbacktothe`default`database.
Settingsexample:
DATABASE_APPS_MAPPING={'app1':'db1','app2':'db2'}
"""
defdb_for_read(self,model,**hints):
""""Pointallreadoperationstothespecificdatabase."""
ifmodel._meta.app_labelinDATABASE_MAPPING:
returnDATABASE_MAPPING[model._meta.app_label]
returnNone
defdb_for_write(self,model,**hints):
"""Pointallwriteoperationstothespecificdatabase."""
ifmodel._meta.app_labelinDATABASE_MAPPING:
returnDATABASE_MAPPING[model._meta.app_label]
returnNone
defallow_relation(self,obj1,obj2,**hints):
"""Allowanyrelationbetweenappsthatusethesamedatabase."""
db_obj1=DATABASE_MAPPING.get(obj1._meta.app_label)
db_obj2=DATABASE_MAPPING.get(obj2._meta.app_label)
ifdb_obj1anddb_obj2:
ifdb_obj1==db_obj2:
returnTrue
else:
returnFalse
returnNone
#forDjango1.4-Django1.6
defallow_syncdb(self,db,model):
"""Makesurethatappsonlyappearintherelateddatabase."""
ifdbinDATABASE_MAPPING.values():
returnDATABASE_MAPPING.get(model._meta.app_label)==db
elifmodel._meta.app_labelinDATABASE_MAPPING:
returnFalse
returnNone
#Django1.7-Django1.11
defallow_migrate(self,db,app_label,model_name=None,**hints):
printdb,app_label,model_name,hints
ifdbinDATABASE_MAPPING.values():
returnDATABASE_MAPPING.get(app_label)==db
elifapp_labelinDATABASE_MAPPING:
returnFalse
returnNone
这样就实现了指定的app使用指定的数据库了,当然你也可以多个sqlite3一起使用，相当于可以给每个app都可以单独设置一个数据库！如果不设置或者没有设置的app就会自动使用默认的数据库。
2.使用指定的数据库来执行操作
在查询的语句后面用using(dbname)来指定要操作的数据库即可
#查询
YourModel.objects.using('db1').all()
或者YourModel.objects.using('db2').all()
#保存或删除
user_obj.save(using='new_users')
user_obj.delete(using='legacy_users')
3.多个数据库联用时数据导入导出
使用的时候和一个数据库的区别是:
如果不是defalut(默认数据库）要在命令后边加--database=数据库对应的settings.py中的名称如：--database=db1或--database=db2
数据库同步（创建表）
#Django1.6及以下版本
pythonmanage.pysyncdb#同步默认的数据库，和原来的没有区别
#同步数据库db1(注意：不是数据库名是db1,是settings.py中的那个db1，不过你可以使这两个名称相同，容易使用)
pythonmanage.pysyncdb--database=db1
#Django1.7及以上版本
pythonmanage.pymigrate--database=db1
数据导出
pythonmanage.pydumpdataapp1--database=db1>app1_fixture.json
pythonmanage.pydumpdataapp2--database=db2>app2_fixture.json
pythonmanage.pydumpdataauth>auth_fixture.json
数据库导入
pythonmanage.pyloaddataapp1_fixture.json--database=db1
pythonmanage.pyloaddataapp2_fixture.json--database=db2
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。