Início / coding / Perguntas / 79472957
Accepted
bur
Asked: 2025-02-27 22:17:34 +0800 CST

Agregação condicional e distinta

  • 772

Usar StringAgg com o distinct=Trueargumento funciona em circunstâncias normais, por exemplo:

entities = entities.annotate(roles=StringAgg(
    "credits__role__name",
    delimiter=", ",
    distinct=True,
    ordering="credits__role__name"
))

Mas quando usado com uma condicional expression, ele lança a exceção django.db.utils.ProgrammingError: in an aggregate with DISTINCT, ORDER BY expressions must appear in argument list, por exemplo:

releases = releases.annotate(credits_primary=StringAgg(
    Case(When(credits__type="primary", then="credits__entity__name")),
    delimiter=", ",
    distinct=True,
    ordering="credits__entity__name"
))

Por que isso acontece e há uma maneira de fazer o segundo exemplo funcionar?

Editar: aqui está o exemplo de código completo que estou usando atualmente e funciona. O que eu quero fazer é eliminar entitys duplicados da string da lista agregada.

    if request.GET.get("order[0][name]"):
        order = request.GET["order[0][name]"]
        if order == "credits_primary":
            releases = releases.annotate(credits_primary=StringAgg(
                Case(When(credits__type="primary", then="credits__entity__name")),
                delimiter=", ",
                ordering="credits__entity__name"
            ))
        elif order == "credits_secondary":
            releases = releases.annotate(credits_secondary=StringAgg(
                Case(When(credits__type="secondary", then="credits__entity__name")),
                delimiter=", ",
                ordering="credits__entity__name"
            ))
    else:
        order = "title"
    
    # Order releases
    if request.GET.get("order[0][dir]") == "desc":
        releases = releases.order_by(F(order).desc(nulls_last=True), "title")
    else:
        releases = releases.order_by(F(order).asc(nulls_last=True), "title")

Observe que um aluno releasenão pode ter créditos primários ou secundários, e entitypode ter mais de um crédito primário ou secundário para o mesmo aluno release(com rolecréditos diferentes).

django

3 respostas

  1. Best Answer

    Tente a seguinte consulta, ela deve dar os resultados esperados:

    from django.db import models  
from django.contrib.postgres.aggregates import StringAgg  
  
releases.annotate(  
    credits_primary=StringAgg(  
        'credits__entity__name',  
        #  or `models.Q(credits__type='secondary')` in elif condition  
        filter=models.Q(credits__type='primary'),  
        delimiter=', ',  
        distinct=True,  
        ordering='credits__entity__name',  
    ),  
)

    Você deve usar filterinside StringAgg, não encontrei tal exemplo na documentação para StringAgg, mas você pode vê-lo aqui olhando a assinatura. Nesta página você pode ver o uso de filterna Countfunção de agregação.

    ...
from django.db.models import Q
above_5 = Count("book", filter=Q(book__rating__gt=5))
...
    • 2

  2. Edição: veja esta resposta para uma solução mais elegante e legível.

    Por razões que francamente não entendo, ele parece classificar por credits__entity__namemesmo quando ordering="credits__entity__name"é omitido. Talvez por padrão ele ordene alfabeticamente, ou pelo campo cujo valor é passado no conditional expression. A documentação do Django não especifica o comportamento padrão. (note que a Creditordenação padrão do modelo não é por entidade)

    Em outras palavras, isso produz o resultado desejado:

    releases = releases.annotate(credits_primary=StringAgg(
    Case(When(credits__type="primary", then="credits__entity__name")),
    delimiter=", ",
    distinct=True,
))

    Espero que alguém com um conhecimento mais profundo de Django e/ou PostgreSQL possa produzir uma resposta que explique por que isso acontece.

    • 0

  3. O erro ocorre porque o PostgreSQL exige que ORDER BYas colunas apareçam em DISTINCT.

    garanta que tanto a ORDER BYexpressão quanto o DISTINCTargumento estejam alinhados. Você pode usar Filterpara pré-filtrar antes da agregação, assim:

    from django.db.models import StringAgg, Case, When, Value
from django.db.models.functions import Cast

releases = releases.annotate(
    credits_primary=StringAgg(
        Cast(Case(When(credits__type="primary", then="credits__entity__name"), default=Value("")), output_field=models.TextField()),
        delimiter=", ",
        distinct=True,
        ordering="credits__entity__name"
    )
)

    Alternativa: Use FilterEm vez de Case Se sua Caseexpressão estiver agindo como um filter, outra abordagem é usar Filter diretamente na agregação:

    from django.db.models import Q, F

releases = releases.annotate(
    credits_primary=StringAgg(
        F("credits__entity__name"),
        delimiter=", ",
        distinct=True,
        ordering="credits__entity__name"
    ).filter(credits__type="primary")
)

    Diga-me se ajudou.

    • -1

relate perguntas