1

我的项目使用 Django 的内置多数据库支持，我试图通过从一个数据库中获取记录并将其插入另一个数据库来同步 2 个不同数据库中的数据。

我尝试使用RelatedManager的add方法以通常的方式执行此操作，但它不起作用，并且没有在第二个数据库的中间表中插入记录，而是在默认数据库中执行此操作。

我是这样做的：我有一个Person模型，它有一个 ManyToMany 字段到Dbs模型：

...
class Person(models.Model):
    ...
    tenant_dbs = models.ManyToManyField(to=Dbs, blank=True)

和 Dbs 模型，其中包含一个列，其中包含一个人可以访问的数据库的名称：

...
class Dbs(models.Model):
    person_id = models.CharField(primary_key=True,
                                 max_length=20
                                 )

所以我想从默认数据库中获取一些 Person、Dbs 和中间记录并将它们全部复制到另一个数据库（假设它的名称是“辅助”）。所以我做了以下事情：

from core.models import Person
from .models import Dbs

#  here I take the objects from default db as I did not mention any other
#  db manually and save them in the 'secondary' db. This works fine and 
#  the records are duplicated to the db 'secondary'

p = Person.objects.get(pk='111')
p.save(using='secondary')
d = Dbs.objects.get(pk='some_db')
d.save(using='secondary')

# and now I retrieve the newly inserted records from the 'secondary' db and 
#  create a relation (insert a record into intermediary table, in other words)
#  using *add* method:
p2 = Person.objects.using('secondary').get(pk='111')
d2 = Dbs.objects.using('secondary').get(pk='some_db')

# **here is the problem: record is again inserted into default db
#  although it was retrieved from the 'secondary db'!**
p2.tenant_dbs.add(d)

我清楚地看到，表person_tenantdbs中没有添加任何记录，该表是作为“辅助”数据库中数据库级别的中间表自动创建的。

所以我想知道如果数据库不是默认的，如何处理并在这个表中插入一条记录？

我已经尝试过使用这里描述的管理器，如下所示：

...
p2.tenant_dbs.db_manager('secondary').add(d)

但它仍然不起作用。

根据Django源代码，这种方法似乎只需要路由器提供的db，以防多db场景，见这里：

db = router.db_for_write(self.model, instance=self.instance)

那么，有没有办法插入它并手动分配数据库，或者这只能通过路由器来完成？

我想在这方面寻求帮助，非常感谢。

4

1 回答 1

0

这不是因为添加多对多。您只是忘记使用“使用”方法。

你应该改变这些

p = Person.objects.get(pk='111')
d = Dbs.objects.get(pk='some_db')

和

p = Person.objects.using('secondary').get(pk='111')
d = Dbs.objects.using('secondary').get(pk='some_db')
于 2019-08-21T13:02:35.087 回答