如何使用 django 在 mysql 中的两个不同模式中使用两个具有相同名称的表

Question

我正在使用两个 mysql 模式 X 和 Y，它们都包含多个表，但是两个模式中都有一个同名的表。

两种架构如下：

+--------------+--+--------------+
| X            |  | Y            |
+--------------+--+--------------+
| name         |  | album_info   |
+--------------+--+--------------+
| invite       |  | photo_info   |
+--------------+--+--------------+
|   photo      |  |   photo      |
+--------------+--+--------------+
| user_details |  | temp         |
+--------------+--+--------------+

现在，我想查询这两个表，但是当我在具有相同名称的 models.py 文件中编写表结构时，它会引发错误/异常。 我在 routers.py 文件中声明了这两个表，如下所示：

  modelDatabaseMap = {
    .
    'photo': 'default',
    .
    .
    .
    'photo': 'y',
}

（X 是我的默认架构）。 声明 i models.py 如下：

 class Photo(models.Model):
     id = models.AutoField(db_column='ID', primary_key=True)
     has_tagged_with = models.IntegerField()
     has_reposted_with = models.IntegerField()
     .
     .

     class Meta:
        managed = False
        db_table = 'photo'

 class Photo(models.Model):
     id = models.AutoField(db_column='ID', primary_key=True)
     account_id = models.IntegerField()
     p_id = models.IntegerField()
     is_profile = models.IntegerField()
     .
     .

     class Meta:
        managed = False
        db_table = 'photo'

现在，歧义首先出现在名称中，在 models.py 中的声明中，其次在查询中。 我被困在如何通过 orm 分别查询两个表。 对此的任何帮助/引导都会有所帮助。提前致谢。

Answer 1

鉴于您的DATABASES 配置，您可以尝试：

1. 更改您的模型名称或为每个架构创建一个具有不同 models 模块的新应用：

   class YPhoto(models.Model):
       ...
   
   class XPhoto(models.Model):
       ...
   

2. 创建一个router.py 模块：

   class MyRouter(object):
   
   def db_for_read(self, model, **hints):
       if model.__name__ == 'YPhoto':
           return 'Y'
       return None
   
   def db_for_write(self, model, **hints):
       if model.__name__ == 'YPhoto':
           return 'Y'
       return None
   
   def allow_relation(self, obj1, obj2, **hints):
       # Maybe you want to prevent relations between different schemas, it's up to you
       return True
   
   def allow_syncdb(self, db, model):
       return True
   

3. 将路由器添加到settings.py:

   DATABASE_ROUTERS = ['myapp.models.MyRouter',]
   

查看docs关于数据库路由的信息。