Django ORM如何实现关联自定义字段表的扁平化单表查询

Django ORM完全可以实现你描述的自定义字段行转列、输出单表扁平化结果的需求，不需要编写冗余杂乱的原生SQL，以下是两种可直接落地的实现方案，适配不同业务场景。

相关表结构参考 #

• contacts表：存储联系人基础数据，通过外键关联所属公司
  
• custom_fields表：存储自定义字段元信息，包含字段名称、所属公司关联
  
• custom_field_data（对应模型ContactCustomFieldValue）：存储联系人与自定义字段的关联取值，分别关联联系人和自定义字段实体
  

目标输出为行转列后的扁平化宽表，效果参考：

你提供的模型定义如下，后续方案均基于该模型编写：

class Contact(models.Model):
    company = models.ForeignKey(Company, on_delete=models.PROTECT, null=True, blank=True) 

class CustomField(models.Model):  
    name = models.CharField(max_length=100)  
    company = models.ForeignKey(Company, on_delete=models.PROTECT, null=False, blank=False) 

class ContactCustomFieldValue(models.Model):  
    custom_field = models.ForeignKey(CustomField, on_delete=models.PROTECT, related_name='contact_values')  
    contact = models.ForeignKey(Contact, on_delete=models.PROTECT, related_name='custom_field_values', null=True)
    value = models.TextField(null=True)  

方案1：内存组装结果（推荐中小数据量场景） #

该方案通过预加载关联数据避免N+1查询，在Python层完成结果拼装，无数据库类型依赖，代码可维护性最高，适合单公司联系人数据量在10w条以内、自定义字段动态增减频繁的场景。

1. 先查询目标公司下的所有自定义字段，建立ID到字段名的映射

# 替换为实际要查询的公司ID
target_company_id = 1
custom_fields = list(
    CustomField.objects.filter(company_id=target_company_id).values('id', 'name')
)
cf_id_name_map = {cf['id']: cf['name'] for cf in custom_fields}
all_cf_names = list(cf_id_name_map.values())

2. 预加载关联的自定义字段值，查询所有目标联系人

contacts = Contact.objects.filter(
    company_id=target_company_id
).prefetch_related('custom_field_values__custom_field')

3. 遍历结果组装扁平化宽表数据

flat_result = []
for contact in contacts:
    # 初始化行数据，先填充联系人原生字段，可根据模型实际字段扩展
    row = {
        'contact_id': contact.id,
        'company_id': contact.company_id,
        # 所有自定义字段默认值置为None
        **{name: None for name in all_cf_names}
    }
    # 填充已存在的自定义字段取值
    for cf_value in contact.custom_field_values.all():
        cf_name = cf_id_name_map.get(cf_value.custom_field_id)
        if cf_name:
            row[cf_name] = cf_value.value
    flat_result.append(row)

最终得到的flat_result是字典组成的列表，结构和单表查询结果完全一致，可以直接用于接口返回、数据导出等场景。

方案2：数据库层动态行转列（推荐大数据量场景） #

如果联系人数据量较大，需要在数据库侧完成过滤、排序、分页操作，可以通过动态生成annotate注释的方式，在ORM层直接生成和单表查询一致的QuerySet，支持所有链式调用操作。

from django.db.models import Value, OuterRef, Subquery, TextField
from django.db.models.functions import Coalesce

target_company_id = 1
# 查询目标公司下所有自定义字段
custom_fields = CustomField.objects.filter(company_id=target_company_id)
# 动态构造每个自定义字段对应的注释逻辑
annotate_params = {}
for cf in custom_fields:
    annotate_params[cf.name] = Coalesce(
        Subquery(
            ContactCustomFieldValue.objects.filter(
                contact_id=OuterRef('pk'),
                custom_field_id=cf.id
            ).values('value')[:1]
        ),
        Value(None),
        output_field=TextField()
    )
# 生成最终扁平化QuerySet，支持filter、order_by、分页等所有原生ORM操作
flat_contact_queryset = Contact.objects.filter(
    company_id=target_company_id
).annotate(**annotate_params)

你可以直接对flat_contact_queryset调用.values()、.all()获取结果，也可以接入DRF序列化、分页组件，用法和普通单表QuerySet无区别。

注意事项 #

• 自定义字段是按公司隔离的，所有查询必须加上company_id过滤条件，避免跨公司字段名冲突
• 单公司下自定义字段数量建议不超过100个，否则行转列查询性能会出现明显下降
• 方案2生成的QuerySet支持直接对自定义字段做过滤，例如flat_contact_queryset.filter(自定义字段名="目标值")即可

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