logo
搜索
我的图书馆

发文章

发文工具

其他工具

留言交流
搜索
分享

Django项目中如何使用多数据库

 明灭的烟头 2020-10-03

原作AlunE, 链接：https://blog.51cto.com/alun51cto/2423000

在django项目中, 一个工程中存在多个APP应用很常见；有时候希望不同的APP连接不同的数据库，这个时候需要建立多个数据库连接。


默认数据库设置

在Django的setting中使用DATABASES设置定义数据库，可以将数据库映射到特定的别名字典中;DATABASES定义的是要给嵌套字典，该设置必须配置default默认数据库。默认使用SQLite进行单一数据库设置：

  1. DATABASES = {
  2. 'default': {
  3. 'ENGINE': 'django.db.backends.sqlite3',
  4. 'NAME': 'mydatabase',
  5. }
  6. }

如不使用默认数据库定义可以将默认配置为空字典形式：

'default':{}

（1） DATABASES内部选项：

ATOMIC_REQUESTS：为True时数据库事务包装每个视图，默认为False

AUTOCOMMIT：为False时禁用Django事务管理，默认为True

ENGINE：设置数据库类型

  1. 'django.db.backends.postgresql'
  2. 'django.db.backends.mysql'
  3. 'django.db.backends.sqlite3'
  4. 'django.db.backends.oracle'

HOST：指定连接的主机名或ip地址，如果使用（‘/’）正斜杠开头则通过套接字连接：

'HOST':'127.0.0.1'   #TCP套接字连接'HOST':'/var/run/mysql'   #UNIX套接字

NAME：制定使用的数据库名，对于SQLite它是指定数据库文件的路径，在window上也要使用正斜杠。

  1. 'NAME':'databasename'
  2. 'NAME':'C:/user/mysite/sqlite3.db'

CONN_MAX_AGE：数据库连接的生命周期，默认为0请求结束时关闭数据库，设置为None无限持久连接。

OPTIONS：链接到数据库时使用的额外参数，可用参数因数据库类型而异。

'OPTIONS':{'read_default_file':'path/to/my.cnf',} #优先于NAME,USER,PASSWORD,HOST,PORT#设置mysql启用严格模式'OPTIONS':{'init_command':'SET sql_mode='STRICT_TRANS_TABLES''}

PASSWORD：设置密码，不与SQLite一起使用

PORT：指定端口

TIME_ZONE：设置时区

DISABLE_SERVER_SIDE_CURSORS：True时禁用服务器端游标

USER：链接用户名

TEST：测试数据库

自定义数据库

  1. #自定义两个mysql数据库映射到db1和db2上
  2. 'db1':{
  3. 'ENGINE': 'django.db.backends.mysql',
  4. 'NAME': 'db1',
  5. 'USER': 'root',
  6. 'PASSWORD': '123.com',
  7. 'HOST': '172.16.32.133',
  8. 'PORT': '3306',
  9. 'OPTIONS': {
  10. 'init_command': 'SET sql_mode='STRICT_TRANS_TABLES'',
  11. }, #mysql使用严格模式，不指定会有警告信息
  12. },
  13. 'db2':{
  14. 'ENGINE': 'django.db.backends.mysql',
  15. 'NAME': 'db2',
  16. 'USER': 'root',
  17. 'PASSWORD': '123.com',
  18. 'HOST': '172.16.32.133',
  19. 'PORT': '3306',
  20. 'OPTIONS': {
  21. 'init_command': 'SET sql_mode='STRICT_TRANS_TABLES'',
  22. }

如果访问没有在DATABASES中定义的数据库，Django会报: django.db.utils.ConnectionDoesNotExist 异常。

同步数据库

migrate管理命令会同时在每一个数据库上运行，默认情况下它在default数据库上运行 ，可以通过选项 --database来指定需要同步的数据库。如不指定会同步到default数据库上。

迁移同步命令：

  • makemigrations：根据简称到的变化创建新的迁移。

  • migrate：将模型和迁移数据同步到数据库中。

通过上面的列子，将每个应用程序同步到特定的数据库：

python manage.py migrate   #同步默认数据库python manage.py migrate --database=db1python manage.py migrate --database=db2

多个数据库导出：

  1. python manage.py dumpdata app01 --database=db1 > app1_fixture.json
  2. python manage.py dumpdata app02 --database=db2 > app2_fixture.json
  3. python manage.py dumpdata auth > auth_fixture.json

多个数据库导入：

python manage.py loaddata app1_fixture.json --database=db1python manage.py loaddata app2_fixture.json --database=db2

自动数据库路由

使用多个数据库时最简单的方法是设置数据库路由方案，以保证对象对原始数据库的“粘性',默认所有的查询都会返回到default数据库中。

数据库路由器是一个最多提供四种方法的类：

  • db_for_read(model,**hints) ：应用于读取类型对象的数据库模型，如果数据库提供附加信息会在hints字典中提供，最后如果没有则返回None

  • db_for_write(model,**hints)：应用于写入类型对象的数据库模型，hints字典提供附加信息，如果没有则返回None

  • allow_relation(obj1,obj2,**hints)：外键操作，判断两个对象之间是否是应该允许关系，是返回True,否则返回False，如果路由允许返回None

  • allow_migrate(db,app_label,model_name=None,**hints)：db确定是否允许在具有别名的数据库上运行迁移操作，操作运行返回True，否则返回False，或者返回None，如果路由器没有意见。

  • app_label：位置参数是正在迁移的应用程序的标签。

  • model_name：多个迁移操作设置模型的值，如：model._meta.app_label

（1). 定义数据库路由方法类

在项目工程根路径下(与 settings.py 文件一级）创建数据库路由表，app应用会根据指定的路由选择数据库：

app01，app02分别使用db1和db2数据库：

  1. #!/usr/bin/env python
  2. #coding:utf8
  3. from django.conf import settings
  5. DATABASE_MAPPING = settings.DATABASE_APPS_MAPPING #在setting中定义的路由表
  7. class DatabaseAppsRouter(object):
  8. def db_for_read(self, model, **hints):
  9. if model._meta.app_label in DATABASE_MAPPING:
  10. return DATABASE_MAPPING[model._meta.app_label]
  11. return None
  13. def db_for_write(self, model, **hints):
  15. if model._meta.app_label in DATABASE_MAPPING:
  16. return DATABASE_MAPPING[model._meta.app_label]
  17. return None
  19. def allow_relation(self, obj1, obj2, **hints):
  21. db_obj1 = DATABASE_MAPPING.get(obj1._meta.app_label)
  22. db_obj2 = DATABASE_MAPPING.get(obj2._meta.app_label)
  23. if db_obj1 and db_obj2:
  24. if db_obj1 == db_obj2:
  25. return True
  26. else:
  27. return False
  28. return None
  30. def allow_syncdb(self, db, model):
  32. if db in DATABASE_MAPPING.values():
  33. return DATABASE_MAPPING.get(model._meta.app_label) == db
  34. elif model._meta.app_label in DATABASE_MAPPING:
  35. return False
  36. return None
  38. def allow_migrate(self, db, app_label, model_name=None, **hints):
  39. if db in DATABASE_MAPPING.values():
  40. return DATABASE_MAPPING.get(app_label) == db
  41. elif app_label in DATABASE_MAPPING:
  42. return False
  43. return None

(2). 使用路由数据库

在setting.py中配置DATABASE_ROUTERS指定自由路由文件：

#test_django为项目名，database_router为路由文件名，DatabaseAppsRouter为路由中创建的类名DATABASE_ROUTERS = ['test_django.database_router.DatabaseAppsRouter']

在setting.py中DATABASE_ROUTERS下面设置app与数据库匹配路由表，采用字典方式app名对应数据库映射名：

  1. DATABASE_APPS_MAPPING = {
  2. 'app01':'db1',
  3. 'app02':'db2',
  5. }

（3）生成数据表并同步数据

分别在app01和app02下创建model类，用于生成数据表：

app01:

from django.db import models# Create your models here.class ap1(models.Model):username = models.CharField(max_length=30)class Meta:#app_label = 'app02'  #如果指定将在app02对应的数据库下创建数据表class ap2(models.Model):first_name = models.CharField(max_length=50)last_name = models.CharField(max_length=50)birth_date = models.DateField()

app02:

  1. from django.db import models
  3. class ap3(models.Model):
  4. app2_name = models.CharField(max_length=50)
  5. sex = models.CharField(max_length=50)
  6. data = models.DateField()
  8. class ap4(models.Model):
  9. app2 = models.CharField(max_length=50)
  10. sex1 = models.CharField(max_length=50)
  11. data1 = models.DateField()
  12. class Meta:
  13. db_table = 'mytable' #自定义表名称

migrate管理命令一次只能操作一个数据库，默认操作default数据库，使用--database指定同步的数据库：

#python manage.py migrate  #生成表数据同步#python manage.py makemigrations #创建变动数据#python manage.py migrate --database=db1 #同步指定数据库#python manage.py migrate --database=db2

需要注意：在多个app分库时，必须指定每个app对应的数据库，否则在同步数据 库时将没指定的app模板都同步到同步数据库中。

手动选择数据库

用using()指定查询的数据库的别名：

  1. >>> # So will this.
  2. >>> Author.objects.using('default').all()
  4. >>> # This will run on the 'other' database.
  5. >>> Author.objects.using('other').all()

保存数据，Model.save()指定将数据保存到哪个数据库中：

>>> my_object.save(using='legacy_users')#会将数据保存到legacy_users数据库中，如不指定会保持到默认数据库中。>>> my_object.delete(using='legacy_users')#删除指定数据库

移动对象到另一个数据库时会发生主键冲突，可以使用obj.pk方法清除主键再保存对象。

  1. >>> p = Person(name='Fred')
  2. >>> p.save(using='first')
  3. >>> p.pk = None # Clear the primary key.
  4. >>> p.save(using='second') # Write a

    本站是提供个人知识管理的网络存储空间，所有内容均由用户发布，不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息，谨防诈骗。如发现有害或侵权内容，请点击一键举报。
    转藏 分享 献花（0）

    来自： 明灭的烟头 > 《IT》

    举报/认领

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多