AskOverflow.Dev

AskOverflow.Dev Logo AskOverflow.Dev Logo

AskOverflow.Dev Navigation

  • Início
  • system&network
  • Ubuntu
  • Unix
  • DBA
  • Computer
  • Coding
  • LangChain

Mobile menu

Close
  • Início
  • system&network
    • Recentes
    • Highest score
    • tags
  • Ubuntu
    • Recentes
    • Highest score
    • tags
  • Unix
    • Recentes
    • tags
  • DBA
    • Recentes
    • tags
  • Computer
    • Recentes
    • tags
  • Coding
    • Recentes
    • tags
Início / coding / Perguntas / 79419126
Accepted
T N
T N
Asked: 2025-02-07 03:30:11 +0800 CST2025-02-07 03:30:11 +0800 CST 2025-02-07 03:30:11 +0800 CST

Substituir a função de janela OVER() pela referência da cláusula WINDOW produz resultados diferentes

  • 772

Ao preparar uma resposta para outra pergunta aqui , codifiquei uma consulta que continha múltiplas funções de janela com a mesma OVER(...)cláusula. Os resultados foram os esperados.

select ...
    sum(sum(s.price)) over (partition by p.productid
                            order by c.date
                            rows between 6 preceding and current row)
        / nullif(
             sum(count(s.price)) over(partition by p.productid
                                      order by c.date
                                      rows between 6 preceding and current row),
             0)
        as avg7DayPrice
...

Quando tentei substituir as OVER(...)cláusulas duplicadas por uma WINDOWreferência de cláusula compartilhada OVER Last7Days, definida posteriormente como WINDOW Last7Days AS (...), os resultados foram inesperadamente diferentes. (Consulte WINDOWcláusula - nova em 2022.)

select ...
    sum(sum(s.price)) over last7days
        / nullif(sum(count(s.price)) over last7days, 0)
        as avg7DayPrice
...
window last7days as (partition by p.productid
                     order by c.date
                     rows between 6 preceding and current row)

Consulta original completa:

-- Inline window over() clauses
-- Results are as expected
with calendar as (
    select min(date) as date, max(date) as endDate
    from sales
    union all
    select dateadd(day, 1, date), endDate
    from calendar
    where date < enddate
),
products as (
    select distinct productid
    from sales
)
select
    p.productid,
    c.date as salesDate, 
    avg(price) as avg1DayPrice,
    sum(sum(s.price)) over (partition by p.productid
                            order by c.date
                            rows between 6 preceding and current row)
        / nullif(
             sum(count(s.price)) over(partition by p.productid
                                      order by c.date
                                      rows between 6 preceding and current row),
             0)
        as avg7DayPrice
from calendar c
cross join products p
left join sales s
    on s.date = c.date
    and s.productid = p.productid
group by p.productid, c.date

Consulta modificada completa:

-- Reference to common defined window clause
-- Expect same results, but that is not what I get.
with calendar as (
    select min(date) as date, max(date) as endDate
    from sales
    union all
    select dateadd(day, 1, date), endDate
    from calendar
    where date < enddate
),
products as (
    select distinct productid
    from sales
)
select
    p.productid,
    c.date as salesDate, 
    avg(price) as avg1DayPrice,
    sum(sum(s.price)) over last7days
        / nullif(
             sum(count(s.price)) over last7days,
             0)
        as avg7DayPrice
from calendar c
cross join products p
left join sales s
    on s.date = c.date
    and s.productid = p.productid
group by p.productid, c.date
window last7days as (partition by p.productid
                     order by c.date
                     rows between 6 preceding and current row)

Tabela de vendas:

ID do produto data preço
1 2025-02-01 10.00
1 2025-02-02 20,00
1 2025-02-02 30,00
1 2025-02-03 40,00

Resultados originais:

produtoid data de venda preço médio de 1 dia preço médio do dia7
1 2025-02-01 10.000000 10.000000
1 2025-02-02 25.000000 20.000000
1 2025-02-03 40.000000 25.000000

Resultados modificados:

produtoid data de venda preço médio de 1 dia preço médio do dia7
1 2025-02-01 10.000000 2.500000
1 2025-02-02 25.000000 15.000000
1 2025-02-03 40.000000 25.000000

Veja este db<>fiddle .

Não entendo por que os resultados são diferentes. Parece que a sum(count(s.price)) over(...)parte do cálculo é 1, 3, 4para a primeira consulta, mas 4, 4, 4na segunda. O plano de execução também é significativamente diferente. Alguém pode explicar isso?

sql
  • 1 1 respostas
  • 292 Views

1 respostas

  • Voted
  1. Best Answer
    Martin Smith
    2025-02-07T05:07:27+08:002025-02-07T05:07:27+08:00

    Alguém pode explicar isso?

    Este é certamente um bug ( relatado aqui ), uma reprodução mais simples é

    SELECT grp, 
           val,
           sum(val) over wf as input_to_nullif,
           nullif(sum(val) over wf, 30) as wrong_result,
           IIF(sum(val) over wf = 30, NULL, sum(val) over ()) as faulty_expansion,
           IIF(sum(val) over wf = 30, NULL, sum(val) over wf) as correct_expansion
    FROM (VALUES
    (1, 1),
    (1, 3),
    (2, 10),
    (2, 20),
    (2, 20)
    ) V(grp, val)
    window wf as (partition by grp order by val rows unbounded preceding);
    

    que retorna

    grupo vale entrada_para_nullif resultado_errado expansão_defeituosa expansão_correta
    1 1 1 54 54 1
    1 3 4 54 54 4
    2 10 10 54 54 10
    2 20 30 NULO NULO NULO
    2 20 50 54 54 50

    O problema é que isso NULLIFé expandido para uma expressão em que o primeiro argumento aparece duas vezes e a moldura da janela só é preservada corretamente para a primeira referência.

    ou seja, em vez de ser expandido conforme correct_expansionacima, ele é expandido para a faulty_expansionvariante.

    Executando o abaixo...

    
    SELECT 
           NULLIF(sum(val) over wf,-1) as wrong_result_nullif
    FROM (VALUES
    (1, 1),
    (1, 3)
    ) V(grp, val)
    window wf as (partition by grp order by val)
    option (RECOMPILE, querytraceon 3604,querytraceon 8605);
    

    mostra isso em parte da saída (nenhum quadro de janela após o segundo stopSum)

                AncOp_PrjList 
    
                    AncOp_PrjEl COL: Expr1006 
    
                        ScaOp_AggFunc stopSum partition[CALC:COL: Union1004  TI(int,ML=4)] order[CALC:COL: Union1005  TI(int,ML=4) ASC] range between unbounded and current
    
                            ScaOp_Identifier COL: Union1005 
    
                    AncOp_PrjEl COL: Expr1007 
    
                        ScaOp_AggFunc stopSum
    
                            ScaOp_Identifier COL: Union1005 
    
    • 9

relate perguntas

  • Atualizando todas as linhas, exceto uma que tenha os mesmos valores em determinadas colunas

  • Existe uma maneira de inverter apenas os números quando eu retornar uma coluna sql? (hebraico)

  • SQL menor/maior comparação entre booleanos produz resultados inesperados

  • Como atualizar valores na tabela Postgres com base em uma correspondência em uma matriz

  • Como somar colunas no sql server

Sidebar

Stats

  • Perguntas 205573
  • respostas 270741
  • best respostas 135370
  • utilizador 68524
  • Highest score
  • respostas
  • Marko Smith

    Reformatar números, inserindo separadores em posições fixas

    • 6 respostas
  • Marko Smith

    Por que os conceitos do C++20 causam erros de restrição cíclica, enquanto o SFINAE antigo não?

    • 2 respostas
  • Marko Smith

    Problema com extensão desinstalada automaticamente do VScode (tema Material)

    • 2 respostas
  • Marko Smith

    Vue 3: Erro na criação "Identificador esperado, mas encontrado 'import'" [duplicado]

    • 1 respostas
  • Marko Smith

    Qual é o propósito de `enum class` com um tipo subjacente especificado, mas sem enumeradores?

    • 1 respostas
  • Marko Smith

    Como faço para corrigir um erro MODULE_NOT_FOUND para um módulo que não importei manualmente?

    • 6 respostas
  • Marko Smith

    `(expression, lvalue) = rvalue` é uma atribuição válida em C ou C++? Por que alguns compiladores aceitam/rejeitam isso?

    • 3 respostas
  • Marko Smith

    Um programa vazio que não faz nada em C++ precisa de um heap de 204 KB, mas não em C

    • 1 respostas
  • Marko Smith

    PowerBI atualmente quebrado com BigQuery: problema de driver Simba com atualização do Windows

    • 2 respostas
  • Marko Smith

    AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos

    • 1 respostas
  • Martin Hope
    Fantastic Mr Fox Somente o tipo copiável não é aceito na implementação std::vector do MSVC 2025-04-23 06:40:49 +0800 CST
  • Martin Hope
    Howard Hinnant Encontre o próximo dia da semana usando o cronógrafo 2025-04-21 08:30:25 +0800 CST
  • Martin Hope
    Fedor O inicializador de membro do construtor pode incluir a inicialização de outro membro? 2025-04-15 01:01:44 +0800 CST
  • Martin Hope
    Petr Filipský Por que os conceitos do C++20 causam erros de restrição cíclica, enquanto o SFINAE antigo não? 2025-03-23 21:39:40 +0800 CST
  • Martin Hope
    Catskul O C++20 mudou para permitir a conversão de `type(&)[N]` de matriz de limites conhecidos para `type(&)[]` de matriz de limites desconhecidos? 2025-03-04 06:57:53 +0800 CST
  • Martin Hope
    Stefan Pochmann Como/por que {2,3,10} e {x,3,10} com x=2 são ordenados de forma diferente? 2025-01-13 23:24:07 +0800 CST
  • Martin Hope
    Chad Feller O ponto e vírgula agora é opcional em condicionais bash com [[ .. ]] na versão 5.2? 2024-10-21 05:50:33 +0800 CST
  • Martin Hope
    Wrench Por que um traço duplo (--) faz com que esta cláusula MariaDB seja avaliada como verdadeira? 2024-05-05 13:37:20 +0800 CST
  • Martin Hope
    Waket Zheng Por que `dict(id=1, **{'id': 2})` às vezes gera `KeyError: 'id'` em vez de um TypeError? 2024-05-04 14:19:19 +0800 CST
  • Martin Hope
    user924 AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos 2024-03-20 03:12:31 +0800 CST

Hot tag

python javascript c++ c# java typescript sql reactjs html

Explore

  • Início
  • Perguntas
    • Recentes
    • Highest score
  • tag
  • help

Footer

AskOverflow.Dev

About Us

  • About Us
  • Contact Us

Legal Stuff

  • Privacy Policy

Language

  • Pt
  • Server
  • Unix

© 2023 AskOverflow.DEV All Rights Reserve