窗口函数累积聚合

Windowing functions cumulative aggregation

我正在通过对一些列求和来计算累积值。该代码正在运行。但我只想为第一行包含一个额外的变量。然后它计算错误。

我想在第 1 行中执行的操作:

SUM(@devir + netTakas - ToplamCikis + YeniKrediKullanımı - Islem)

除了第 1 行我想做什么:

SUM(netTakas - ToplamCikis + YeniKrediKullanımı - Islem)

当我对 case 执行此操作时,得到了错误的结果。

SQL代码:

declare @devir float = 1308973;
    WITH asilTablo AS(
        select * from #tmpbrut1
        union
        select * from #tmpbrut
    )
    SELECT 
        *,
        CASE WHEN ROW_NUMBER() OVER(order by takasTarihi) >= 2 then
        SUM(netTakas - ToplamCikis + YeniKrediKullanımı - Islem) OVER (ORDER BY takasTarihi ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW)
        else SUM(@devir + netTakas - ToplamCikis + YeniKrediKullanımı - Islem)  OVER (ORDER BY takasTarihi ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW) end AS [Kümülatif Toplam]
    FROM asilTablo

例如在第 1 行,它会这样做:

@devir+netTakas-ToplamCikis+YeniKredKullanımı-Islem = Kümülatif Toplam

在第1行以外的地方,会这样:

Kümülatif Toplam + netTakas-ToplamCikis+YeniKredKullanımı-Islem

@devir = 10第一行操作:

@devir + netTakas - ToplamCikis + YeniKrediKullanımı - Islem

对线操作:

netTakas - ToplamCikis + YeniKrediKullanımı - Islem

第一行的变量和列的运算,第1行的列和下一行“累计总数”的列的总和

CREATE TABLE #Tmp1(
     tarih date,
    netTakas int,
    ToplamCikis int,
    YeniKrediKullanımı int,
    Islem int
)

CREATE TABLE #Tmp2(
     tarih date,
    netTakas int,
    ToplamCikis int,
    YeniKrediKullanımı int,
    Islem int
)

insert into #Tmp1 (tarih, netTakas, ToplamCikis, YeniKrediKullanımı, Islem) VALUES ('20211227', 125, 34, 57, 347)
insert into #Tmp1 (tarih, netTakas, ToplamCikis, YeniKrediKullanımı, Islem) VALUES ('20211228', 135, 34, 587, 3624)
insert into #Tmp1 (tarih, netTakas, ToplamCikis, YeniKrediKullanımı, Islem) VALUES ('20211229', 125, 347, 577, 34)
insert into #Tmp1 (tarih, netTakas, ToplamCikis, YeniKrediKullanımı, Islem) VALUES ('20211230', 175, 344, 597, 374)
insert into #Tmp1 (tarih, netTakas, ToplamCikis, YeniKrediKullanımı, Islem) VALUES ('20211231', 1875, 364, 587, 38684)
insert into #Tmp1 (tarih, netTakas, ToplamCikis, YeniKrediKullanımı, Islem) VALUES ('20220103', 1295, 354, 575, 344)
insert into #Tmp1 (tarih, netTakas, ToplamCikis, YeniKrediKullanımı, Islem) VALUES ('20220104', 1285, 344, 547, 344)

insert into #Tmp2 (tarih, netTakas, ToplamCikis, YeniKrediKullanımı, Islem) VALUES ('20211226', 12453485, 3444, 5447, 34544)

declare @devir float = 1308973;
WITH asilTablo AS
(
    SELECT *
    FROM #Tmp1
union
Select *
from #Tmp2
)
SELECT  
    tarih,
    netTakas,
    ToplamCikis,
    YeniKrediKullanımı,
    Islem,
    CASE WHEN ROW_NUMBER() OVER(order by tarih) >= 2 then SUM(netTakas - ToplamCikis + YeniKrediKullanımı - Islem) OVER (ORDER BY tarih ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW) 
    else  SUM(@devir + netTakas - ToplamCikis + YeniKrediKullanımı - Islem) OVER (ORDER BY tarih ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW)  end  AS [Kümülatif Toplam]
FROM
    asilTablo

对内部查询使用 ROW_NUMBER()。在外部查询中检查何时 ROW_NUMBER() = 1 在计算中包含 @devir

SELECT
    SUM (CASE WHEN RN = 1 THEN @devir ELSE 0 END
         + netTakas - ToplamCikis + YeniKrediKullanımı - Islem) 
    OVER (ORDER BY tarih)
FROM
(
    SELECT *, RN = ROW_NUMBER() OVER(order by tarih ROWS UNBOUNDED PRECEDING)
    FROM   asilTablo
) a