如何在Django中复刻PostgreSQL复杂键关联以支持ORM查询

你的核心问题是未给关联字段配置Django外键关系，导致无法使用ORM联表查询。实际上ForeignKey完全能满足你的需求——即使关联的主键是文本类型，只要正确指定to_field参数即可。以下是具体实现方案：

1. 重构模型，配置外键关联 #

将原模型中用于关联的TextField替换为ForeignKey，指定关联的目标模型和对应字段（因目标表主键为文本类型contact_name/sn_sys_id，需显式声明to_field）：

from django.db import models

class ContactsModel(models.Model):
    contact_name = models.TextField(primary_key=True)  # 对应contact ID
    full_name = models.TextField(null=True)

    def __str__(self):
        return self.full_name or self.contact_name

class GroupsModel(models.Model):
    sn_sys_id = models.TextField(primary_key=True)  # 对应group ID
    workgroup = models.TextField(null=True)
    manager = models.ForeignKey(
        ContactsModel,
        on_delete=models.DO_NOTHING,
        null=True,
        to_field='contact_name',
        related_name='managed_groups'
    )

    def __str__(self):
        return self.workgroup or self.sn_sys_id

class HierarchyModel(models.Model):
    cntc_person_id = models.OneToOneField(
        ContactsModel,
        on_delete=models.DO_NOTHING,
        primary_key=True,
        to_field='contact_name',
        related_name='hierarchy'
    )
    hier_supervisor_level_1 = models.ForeignKey(
        ContactsModel,
        on_delete=models.DO_NOTHING,
        null=True,
        to_field='contact_name',
        related_name='subordinates_level_1'
    )
    hier_supervisor_level_2 = models.ForeignKey(
        ContactsModel,
        on_delete=models.DO_NOTHING,
        null=True,
        to_field='contact_name',
        related_name='subordinates_level_2'
    )
    # 以下层级3到13的外键配置和上面一致，复制后修改level数字即可
    hier_supervisor_level_3 = models.ForeignKey(
        ContactsModel,
        on_delete=models.DO_NOTHING,
        null=True,
        to_field='contact_name',
        related_name='subordinates_level_3'
    )
    # ... 省略level4到12的代码
    hier_supervisor_level_13 = models.ForeignKey(
        ContactsModel,
        on_delete=models.DO_NOTHING,
        null=True,
        to_field='contact_name',
        related_name='subordinates_level_13'
    )

class TicketsModel(models.Model):
    ticket_id = models.TextField(primary_key=True)
    opened_by_id = models.ForeignKey(
        ContactsModel,
        on_delete=models.DO_NOTHING,
        null=True,
        to_field='contact_name',
        related_name='opened_tickets'
    )
    open_time = models.DateTimeField(null=True)
    closed_by_id = models.ForeignKey(
        ContactsModel,
        on_delete=models.DO_NOTHING,
        null=True,
        to_field='contact_name',
        related_name='closed_tickets'
    )
    close_time = models.DateTimeField(null=True)
    assignee_name = models.ForeignKey(
        ContactsModel,
        on_delete=models.DO_NOTHING,
        null=True,
        to_field='contact_name',
        related_name='assigned_tickets'
    )
    sn_wg_sys_id = models.ForeignKey(
        GroupsModel,
        on_delete=models.DO_NOTHING,
        null=True,
        to_field='sn_sys_id',
        related_name='tickets'
    )

    def __str__(self):
        return self.ticket_id

关键配置说明： #

• to_field='contact_name'：指定关联目标模型的主键字段（因目标表主键不是默认的id）
• on_delete=models.DO_NOTHING：避免删除关联数据时触发级联操作，符合复刻外部库的需求
• related_name：定义反向查询的名称，方便从关联模型反向查询当前模型的数据

2. 使用ORM实现联表查询 #

配置外键后，即可通过Django ORM的select_related（一对一/一对多）和prefetch_related（多对多/反向查询）实现高效联表查询，完全无需原生SQL：

示例1：查询工单的创建人、所属组及组经理信息 #

# 一次性获取所有关联数据，避免N+1查询
ticket = TicketsModel.objects.select_related(
    'opened_by_id',
    'sn_wg_sys_id',
    'sn_wg_sys_id__manager'
).get(ticket_id='TICKET-001')

# 直接访问关联对象的字段
print(f"创建人全名: {ticket.opened_by_id.full_name}")
print(f"所属组: {ticket.sn_wg_sys_id.workgroup}")
print(f"组经理: {ticket.sn_wg_sys_id.manager.full_name}")

示例2：查询某个联系人的所有工单及他的一级主管 #

contact = ContactsModel.objects.select_related(
    'hierarchy__hier_supervisor_level_1',
).prefetch_related(
    'opened_tickets',
    'assigned_tickets'
).get(contact_name='CONTACT-001')

# 获取主管信息
if contact.hierarchy and contact.hierarchy.hier_supervisor_level_1:
    print(f"一级主管: {contact.hierarchy.hier_supervisor_level_1.full_name}")

# 获取该联系人创建的所有工单
for ticket in contact.opened_tickets.all():
    print(f"工单ID: {ticket.ticket_id}, 创建时间: {ticket.open_time}")

3. 处理多级层级查询 #

针对HierarchyModel的13级主管，可以在ContactsModel中自定义方法简化多级查询：

class ContactsModel(models.Model):
    # ... 原有字段 ...

    def get_supervisor(self, level=1):
        """获取指定层级的主管"""
        if not hasattr(self, 'hierarchy'):
            return None
        supervisor_field = f'hier_supervisor_level_{level}'
        return getattr(self.hierarchy, supervisor_field, None)

# 使用示例
contact = ContactsModel.objects.get(contact_name='CONTACT-001')
level3_supervisor = contact.get_supervisor(level=3)
if level3_supervisor:
    print(f"三级主管: {level3_supervisor.full_name}")

4. 数据同步注意事项 #

• 导入数据时需保证关联ID的存在性：先导入ContactsModel和GroupsModel的数据，再导入HierarchyModel和TicketsModel，避免外键约束报错
• 若外部库数据存在关联ID缺失的情况，可设置null=True允许空值，或在导入时做数据校验

内容的提问来源于stack exchange，提问作者user13471346