ToB企服应用市场:ToB评测及商务社交产业平台

标题: django使用多个数据库实现 [打印本页]
作者: 立聪堂德州十三局店    时间: 2023-4-21 12:22
标题: django使用多个数据库实现
一、说明：

　　在开发 Django 项目的时候，很多时候都是使用一个数据库，即 settings 中只有 default 数据库，但是有一些项目确实也需要使用多个数据库，这样的项目，在数据库配置和使用的时候，就比较麻烦一点。
二、Django使用多个数据库中settings中的DATABASES的设置

　　2.1 默认只是用一个数据库时 DATABASES 的设置（以 SQLite 为例）
  1. DATABASES = {
  2.     'default': {
  3.         'ENGINE': 'django.db.backends.sqlite3',         
  4.         'NAME': 'db.sqlite3',
  5.     }
  6. }
复制代码
　　2.2 Django 数据库支持的 ENGINE 类型
　　2.3 设置了多个数据库后 settings 中的 DATABASES 的设置
  1. DATABASES = {
  2.     'default': {
  3.         'ENGINE': 'django.db.backends.sqlite3',
  4.         'NAME': 'db.sqlite3',
  5.     },
  6.     'db1': {
  7.         'ENGINE': 'django.db.backends.mysql',
  8.         'NAME': 'mysql_test_db1',
  9.         'USER': 'root',
  10.         'PASSWORD': 'Se7eN521',
  11.         'HOST': '127.0.0.1',
  12.         'PORT': '3306'
  13.     },
  14.     'db2': {
  15.         'ENGINE': 'django.db.backends.mysql',
  16.         'NAME': 'mysql_test_db2',
  17.         'USER': 'root',
  18.         'PASSWORD': 'Se7eN521',
  19.         'HOST': '127.0.0.1',
  20.         'PORT': '3306'
  21.     }
  22. }
复制代码
三、实现思路

四、案例实现

　　第一步：创建需要的 应用app,并且在 INSTALLED_APPS 中引用

　　　　其中db1_app这个应用主要是用来对接数据库db1的
　　　　其中db2_app这个应用主要是用来对接数据库db2的
　　　　其中test_app这个应用主要用来实现业务逻辑的
                 
 
　　第二步：创建 应用app 和 数据库之间的映射关系

　　　　在settings.py 文件夹中设置 DATABASE_APPS_MAPPING 的字典，里面主要是配置 应用app 和数据库的对应关系
  1. DATABASE_APPS_MAPPING = {
  2.     "db1_app": "db1",   # db1_app 对应 db1 数据库
  3.     "db2_app": "db2"    # db2_app 对应 db2 数据库
  4. }
复制代码
　　第三步：创建数据库路由

　　　　在项目的主文件夹即 settings.py 的同目录下创建一个 database_router.py 文件，该文件的作用就是给不同应用app 配置不同的数据库。
  1. # _*_ coding:utf-8 _*_
  2. # @Time : 2023/4/20 5:37 下午
  4. from django.conf import settings
  6. DATABASE_MAPPING = settings.DATABASE_APPS_MAPPING
  7. print('DATABASE_MAPPING = {}'.format(DATABASE_MAPPING))
  9. class DatabaseAppsRouter(object):
  11.     # 设置 应用app 读取时数据库的设置
  12.     def db_for_read(self, model, **hints)if model._meta.app_label in DATABASE_MAPPING:
  13.             return DATABASE_MAPPING[model._meta.app_label]
  14.         return None
  16.     def db_for_write(self, model, **hints):
  17.         if model._meta.app_label in DATABASE_MAPPING:
  18.             return DATABASE_MAPPING[model._meta.app_label]
  19.         return None
  21.     def allow_relation(self, obj1, obj2, **hints):
  22.         db_obj1 = DATABASE_MAPPING.get(obj1._meta.app_label)
  23.         db_obj2 = DATABASE_MAPPING.get(obj2._meta.app_label)
  24.         if db_obj1 and db_obj2:
  25.             if db_obj1 == db_obj2:
  26.                 return True
  27.             else:
  28.                 return False
  29.         return None
  31.     def allow_migrate(self, db, app_label, model_name=None, **hints):
  32.         """
  33.         Make sure that apps only appear in the related database.
  34.         根据app_label的值只在相应的数据库中创建一个表，如果删除该def或
  35.         不指定过滤条件，则一个Model会在每个数据库里都创建一个表。
  36.         """
  37.         if db in DATABASE_MAPPING.values():return DATABASE_MAPPING.get(app_label) == db
  38.         elif app_label in DATABASE_MAPPING:
  39.             return False
  40.         return None
复制代码
　　第四步：在setting.py中配置 DATABASE_ROUTERS 指定自由路由文件：
  1. #test_django为项目名，database_router为路由文件名，DatabaseAppsRouter为路由中创建的类名
  2. DATABASE_ROUTERS = ['django_db_demo.database_router.DatabaseAppsRouter']
复制代码
　　第五步：创建model类

　　　　说明：model 可以根据需要卸载任何一个应用app的model.py文件中，也可以分散写在多个应用的model.py中，这个根据自己的需要即可，但是如何推荐一定要在model类的Meta中指定app_label。不然会全部将表创建到default数据库中
  1. from django.db import models
  3. class SqliteModel(models.Model):
  4.     """帐号和用户关联"""
  6.     sqlite_name = models.CharField(max_length=20)
  7.     class Meta:
  8.         # 当前这个 SqliteModel 定义的数据库的表将会创建在test_app 对应的default 数据库中
  9.         app_label = "test_app"      # 当有多个数据库链接的时候，要通过app_label 来区分这个model对应那个数据库
  10.         db_table = "sqlite_test_table"   # 自定义的表名
  12. class Db1Model(models.Model):
  13.     """帐号和用户关联"""
  15.     db1_name = models.CharField(max_length=20)
  16.     class Meta:
  17.         # 当前这个Db1Model 定义的数据库的表将会创建在 db1_app 对应的 db1 数据库中
  18.         app_label = "db1_app"        # 当有多个数据库链接的时候，要通过app_label 来区分这个model对应那个数据库
  19.         db_table = "db1_test_table"    # 自定义的表名
  21. class Db2Model(models.Model):
  22.     """帐号和用户关联"""
  24.     db2_name = models.CharField(max_length=20)
  25.     class Meta:
  26.         # 当前这个Db2Model 定义的数据库的表将会创建在 db2_app 对应的 db1 数据库中
  27.         app_label = "db2_app"       # 当有多个数据库链接的时候，要通过app_label 来区分这个model对应那个数据库
  28.         db_table = "db2_test_table"   # 自定义的表名
复制代码
　　
　　第六步：数据迁移
  1. python3 manage.py makemigrations  
  2. python3 manage.py migrate --database=default   # 当有多个数据库，需要迁移多次
  3. python3 manage.py migrate --database=db1
  4. python3 manage.py migrate --database=db2
复制代码
　　第七步：查看迁移：

　　　　model对应的表，分别迁移到不同的数据库成功，剩下的增删改查的就正常引入model对象即可，这样就实现了，不同的model对象，对应不用数据库的表。
　　　　
 第五步：总结


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4