Django中一个项目使用多个数据库(原生sql 的使用，亲测)

╰半橙微兮° 2023-10-06 11:33 16阅读 0赞

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

参考：http://blog.csdn.net/songfreeman/article/details/70229839

1. 修改项目的 settings 配置  
在 `settings.py` 中配置需要连接的多个数据库连接串

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 </td> 
 <td> <code>DATABASES&nbsp;</code><code>=</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'default'</code><code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'ENGINE'</code><code>:&nbsp;</code><code>'django.db.backends.sqlite3'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'NAME'</code><code>: os.path.join(BASE_DIR,&nbsp;</code><code>'db.sqlite3'</code><code>),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'ora1'</code><code>: {&nbsp;&nbsp;&nbsp;</code><code># 配置第二个数据库节点名称</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'ENGINE'</code><code>:&nbsp;</code><code>'django.db.backends.oracle'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'NAME'</code><code>:&nbsp;</code><code>'devdb'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'USER'</code><code>:&nbsp;</code><code>'hysh'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'PASSWORD'</code><code>:&nbsp;</code><code>'hysh'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'HOST'</code><code>:&nbsp;</code><code>'192.168.191.3'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'PORT'</code><code>:&nbsp;</code><code>'1521'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

2. 设置数据库的路由规则方法

在 `settings.py` 中配置 `DATABASE_ROUTERS`

<table> 
 <tbody> 
 <tr> 
 <td> 1 </td> 
 <td> <code>DATABASE_ROUTERS&nbsp;</code><code>=</code>&nbsp;<code>[</code><code>'Prject.database_router.DatabaseAppsRouter'</code><code>]</code> </td> 
 </tr> 
 </tbody> 
</table>

Project: 建立的django项目名称(project\_name)  
database\_router: 定义路由规则`database_router.py` 文件名称, 这个文件名可以自己定义  
DatabaseAppsRouter: 路由规则的类名称，这个类是在`database_router.py` 文件中定义

3. 设置APP对应的数据库路由表

每个APP要连接哪个数据库，需要在做匹配设置，在 `settings.py` 文件中做如下配置：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 </td> 
 <td> <code>DATABASE_APPS_MAPPING&nbsp;</code><code>=</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code># example:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code># 'app_name':'database_name',</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'report'</code><code>:&nbsp;</code><code>'ora1'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'admin'</code><code>:&nbsp;</code><code>'defualt'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'regs'</code><code>:&nbsp;&nbsp;</code><code>'defualt'</code><code>,</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

以上的report， regs是项目中的 APP名，分别指定到 ora1， default的数据库。

*为了使django自己的表也创建到你自己定义的数据库中，你可以指定 : admin, auth, contenttypes, sessions 到设定的数据库中，如果不指定则会自动创建到默认（default）的数据库中.*

*4. 创建数据库路由规则  
在项目工程根路径下(与 settings.py 文件一级）创建 `database_router.py` 文件:*

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 </td> 
 <td> <code>from</code>&nbsp;<code>django.conf&nbsp;</code><code>import</code>&nbsp;<code>settings</code> &nbsp; <code>DATABASE_MAPPING&nbsp;</code><code>=</code>&nbsp;<code>settings.DATABASE_APPS_MAPPING</code> &nbsp; &nbsp; <code>class</code>&nbsp;<code>DatabaseAppsRouter(</code><code>object</code><code>):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"""</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>A router to control all database operations on models for different</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>databases.</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>In case an app is not set in settings.DATABASE_APPS_MAPPING, the router</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>will fallback to the `default` database.</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Settings example:</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>DATABASE_APPS_MAPPING = {'app1': 'db1', 'app2': 'db2'}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"""</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code>&nbsp;<code>db_for_read(</code><code>self</code><code>, model,&nbsp;</code><code>*</code><code>*</code><code>hints):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>""""Point all read operations to the specific database."""</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>model._meta.app_label&nbsp;</code><code>in</code>&nbsp;<code>DATABASE_MAPPING:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>DATABASE_MAPPING[model._meta.app_label]</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>None</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code>&nbsp;<code>db_for_write(</code><code>self</code><code>, model,&nbsp;</code><code>*</code><code>*</code><code>hints):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"""Point all write operations to the specific database."""</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>model._meta.app_label&nbsp;</code><code>in</code>&nbsp;<code>DATABASE_MAPPING:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>DATABASE_MAPPING[model._meta.app_label]</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>None</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code>&nbsp;<code>allow_relation(</code><code>self</code><code>, obj1, obj2,&nbsp;</code><code>*</code><code>*</code><code>hints):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"""Allow any relation between apps that use the same database."""</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>db_obj1&nbsp;</code><code>=</code>&nbsp;<code>DATABASE_MAPPING.get(obj1._meta.app_label)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>db_obj2&nbsp;</code><code>=</code>&nbsp;<code>DATABASE_MAPPING.get(obj2._meta.app_label)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>db_obj1&nbsp;</code><code>and</code>&nbsp;<code>db_obj2:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>db_obj1&nbsp;</code><code>=</code><code>=</code>&nbsp;<code>db_obj2:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>True</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>else</code><code>:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>False</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>None</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code>&nbsp;<code>allow_syncdb(</code><code>self</code><code>, db, model):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"""Make sure that apps only appear in the related database."""</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>db&nbsp;</code><code>in</code>&nbsp;<code>DATABASE_MAPPING.values():</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>DATABASE_MAPPING.get(model._meta.app_label)&nbsp;</code><code>=</code><code>=</code>&nbsp;<code>db</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>elif</code>&nbsp;<code>model._meta.app_label&nbsp;</code><code>in</code>&nbsp;<code>DATABASE_MAPPING:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>False</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>None</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code>&nbsp;<code>allow_migrate(</code><code>self</code><code>, db, app_label, model</code><code>=</code><code>None</code><code>,&nbsp;</code><code>*</code><code>*</code><code>hints):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"""</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Make sure the auth app only appears in the 'auth_db'</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>database.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"""</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>db&nbsp;</code><code>in</code>&nbsp;<code>DATABASE_MAPPING.values():</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>DATABASE_MAPPING.get(app_label)&nbsp;</code><code>=</code><code>=</code>&nbsp;<code>db</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>elif</code>&nbsp;<code>app_label&nbsp;</code><code>in</code>&nbsp;<code>DATABASE_MAPPING:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>False</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>None</code> </td> 
 </tr> 
 </tbody> 
</table>

5.原生sql 的使用：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 </td> 
 <td> <code>def</code>&nbsp;<code>exc_sql(sql):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor&nbsp;</code><code>=</code>&nbsp;<code>connections[</code><code>'ora1'</code><code>].cursor()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code># cursor = connection.cursor()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cursor.execute(sql)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>result&nbsp;</code><code>=</code>&nbsp;<code>cursor.fetchall()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>result</code> </td> 
 </tr> 
 </tbody> 
</table>

参考：https://docs.djangoproject.com/en/2.0/topics/db/sql/

6. Models创建样例  
在各自的 APP 中创建数据表的models时，必须要指定表的 app\_label 名字，如果不指定则会创建到 `default` 中配置的数据库名下，  
如下：

在`app01`下创建models

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 </td> 
 <td> <code>class</code>&nbsp;<code>Users(models.Model):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>name&nbsp;</code><code>=</code>&nbsp;<code>models.CharField(max_length</code><code>=</code><code>50</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>passwd&nbsp;</code><code>=</code>&nbsp;<code>models.CharField(max_length</code><code>=</code><code>100</code><code>)</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code>&nbsp;<code>__str__(</code><code>self</code><code>):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>"app01 %s "</code>&nbsp;<code>%</code>&nbsp;<code>self</code><code>.name</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>class</code>&nbsp;<code>Meta:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>app_label&nbsp;</code><code>=</code>&nbsp;<code>"app01"</code> </td> 
 </tr> 
 </tbody> 
</table>

在`app02`下创建models

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 </td> 
 <td> <code>class</code>&nbsp;<code>Users(models.Model):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>username&nbsp;</code><code>=</code>&nbsp;<code>models.CharField(max_length</code><code>=</code><code>100</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>password&nbsp;</code><code>=</code>&nbsp;<code>models.CharField(max_length</code><code>=</code><code>50</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>age&nbsp;</code><code>=</code>&nbsp;<code>models.IntegerField()</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code>&nbsp;<code>__str__(</code><code>self</code><code>):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>"app02 %s"</code>&nbsp;<code>%</code>&nbsp;<code>self</code><code>.username</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>class</code>&nbsp;<code>Meta:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>app_label&nbsp;</code><code>=</code>&nbsp;<code>"app02"</code> &nbsp; <code>class</code>&nbsp;<code>Book(models.Model):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>user&nbsp;</code><code>=</code>&nbsp;<code>models.ForeignKey(</code><code>"Users"</code><code>, on_delete</code><code>=</code><code>models.CASCADE)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bookname&nbsp;</code><code>=</code>&nbsp;<code>models.CharField(max_length</code><code>=</code><code>100</code><code>)</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>def</code>&nbsp;<code>__str__(</code><code>self</code><code>):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>"%s: %s"</code>&nbsp;<code>%</code>&nbsp;<code>(</code><code>self</code><code>.user.username,&nbsp;</code><code>self</code><code>.bookname)</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>class</code>&nbsp;<code>Meta:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>app_label&nbsp;</code><code>=</code>&nbsp;<code>"app02"</code> </td> 
 </tr> 
 </tbody> 
</table>

7. 生成数据表  
在使用django的 migrate 创建生成表的时候，需要加上 –database 参数，如果不加则将 未 指定 app\_label 的 APP的models中的表创建到default指定的数据库中,如:

将app01下models中的表创建到db01的数据库”db\_01”中

./ manage.py  migrate  --database=db01

将app02下models中的表创建到db02的数据库”db\_02”中

./ manage.py  migrate  --database=db02

将app03下models中的表创建到default的数据库”sqlite3”中

./ manage.py  migrate

以上创建完成后,其它所有的创建、查询、删除等操作就和普通一样操作就可以了,无需再使用类似  
models.User.objects.using(dbname).all(）  
这样的方式来操作

来源:[https://www.cnblogs.com/fu-yong/p/9889423.html][https_www.cnblogs.com_fu-yong_p_9889423.html]

[https_www.cnblogs.com_fu-yong_p_9889423.html]: https://www.cnblogs.com/fu-yong/p/9889423.html