在Django 4.1.5（PostgreSQL）中实现CTAS临时表需求

针对你的需求，这里提供两种可行的实现方式，基于PostgreSQL原生CTAS语法结合Django数据库操作能力，完全满足每次视图调用时重建临时表、整合多模型字段的需求：

方案一：直接执行原生SQL（轻量快速） #

这种方式无需额外定义模型，直接通过Django的数据库连接执行CTAS语句，适合快速实现或不需要ORM查询临时表的场景。

代码示例 #

from django.db import connection
from django.shortcuts import render

def combined_data_view(request):
    # 1. 创建/重建临时表：先删除旧表（如果存在），再通过CTAS生成新临时表
    with connection.cursor() as cursor:
        cursor.execute("""
            DROP TABLE IF EXISTS temp_combined_data;
            -- ON COMMIT DROP 确保请求结束（事务提交）后自动删除临时表，避免会话残留
            CREATE TEMP TABLE temp_combined_data ON COMMIT DROP AS
            SELECT 
                m1.id AS model1_id,
                m1.name AS model1_name,
                m2.id AS model2_id,
                m2.value AS model2_value,
                m3.status AS model3_status
            FROM myapp_model1 m1
            INNER JOIN myapp_model2 m2 ON m1.related_model2_id = m2.id
            LEFT JOIN myapp_model3 m3 ON m1.id = m3.model1_id
            WHERE m1.is_active = TRUE;
        """)

        # 2. 查询临时表数据并转换为字典格式（方便模板渲染）
        cursor.execute("SELECT * FROM temp_combined_data WHERE model2_value > 50;")
        columns = [col[0] for col in cursor.description]
        combined_data = [dict(zip(columns, row)) for row in cursor.fetchall()]

    return render(request, 'data_template.html', {'data': combined_data})

方案二：配合未托管模型（支持ORM查询） #

如果希望用Django ORM操作临时表（如使用过滤、排序、序列化等ORM特性），可以定义一个未托管模型（managed=False）映射临时表，再结合CTAS语句使用。

步骤1：定义未托管模型 #

# models.py
from django.db import models

class TempCombinedData(models.Model):
    model1_id = models.IntegerField()
    model1_name = models.CharField(max_length=100)
    model2_id = models.IntegerField()
    model2_value = models.FloatField()
    model3_status = models.BooleanField(null=True)

    class Meta:
        managed = False  # 告诉Django不要自动创建/迁移这个表
        db_table = 'temp_combined_data'  # 与CTAS创建的临时表名一致

步骤2：视图中使用模型查询 #

from django.db import connection
from django.shortcuts import render
from .models import TempCombinedData

def combined_data_view(request):
    # 重建临时表
    with connection.cursor() as cursor:
        cursor.execute("""
            DROP TABLE IF EXISTS temp_combined_data;
            CREATE TEMP TABLE temp_combined_data ON COMMIT DROP AS
            SELECT 
                m1.id AS model1_id,
                m1.name AS model1_name,
                m2.id AS model2_id,
                m2.value AS model2_value,
                m3.status AS model3_status
            FROM myapp_model1 m1
            INNER JOIN myapp_model2 m2 ON m1.related_model2_id = m2.id
            LEFT JOIN myapp_model3 m3 ON m1.id = m3.model1_id
            WHERE m1.is_active = TRUE;
        """)

    # 用ORM查询临时表，支持所有ORM特性
    combined_data = TempCombinedData.objects.filter(model2_value__gt=50).order_by('model1_name')

    return render(request, 'data_template.html', {'data': combined_data})

关键注意事项 #

• 临时表隔离性：PostgreSQL的临时表是会话级别的，不同请求（不同数据库会话）的临时表互不干扰，不会出现并发冲突。
• 数据新鲜度：每次视图调用都会执行DROP TABLE IF EXISTS + CREATE TABLE AS SELECT，确保临时表数据是最新的。
• 事务与自动清理：使用ON COMMIT DROP可以让临时表在请求结束（事务提交）后自动删除，避免占用数据库资源；如果需要在同一个会话中多次使用临时表，可以去掉这个参数，但必须保证每次调用都先删除旧表。
• 字段类型匹配：如果使用未托管模型，模型字段的类型必须与CTAS查询返回的字段类型完全匹配，否则ORM查询会抛出类型错误。

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