Hik*_*ari 6 sql-server recursion lag sql-server-2012
我进行了涉及LAG()的以下计算:
(lag(fValue,1,fValue) OVER (PARTITION BY Cluster ORDER BY iSequence) + fValue) / 2 as fValueAjusted
它取前一个(基于iSequence)记录的fValue,与当前记录之和,然后除以2。
但是,必须使用先前记录的fValueAjusted来执行此操作,而不是使用fValue。
这意味着第一条记录的fValueAjusted将是其自己的fValue。第二条记录的fValueAjusted将基于第一条记录的fValue。并且,从第三条记录开始,将基于前一条记录的fValueAjusted进行计算。
我需要对上一条记录的fValueAjusted进行递归计算的fValueAjusted。我不知道该怎么做。
更新1:这是源数据的示例。实际表具有数百条记录和80个群集。
CREATE TABLE dbo.example (
iUnity int NOT NULL,
Cluster char(2) NOT NULL,
fValue float NOT NULL
)
15 A1 150
17 A1 170
21 B2 210
23 B2 230
71 C3 710
Run Code Online (Sandbox Code Playgroud)
这是计算顺序的CTE:
WITH cteSequencing AS (
SELECT
iUnity,Cluster
,fValue as fValueOriginal
,row_number() OVER (PARTITION BY Cluster ORDER BY fValueOriginal) as iSequence
FROM dbo.example
)
Run Code Online (Sandbox Code Playgroud)
如果将基于fValueOriginal计算fValueAjusted,则查询将类似于:
SELECT
iUnity,Cluster,fValueOriginal
,(
lag(fValue,1,fValue) OVER (PARTITION BY Cluster ORDER BY iSequence)
+ fValueOriginal
) / 2 as fValueAjusted
FROM cteSequencing
Run Code Online (Sandbox Code Playgroud)
但是,必须基于先前记录的fValueAjusted计算一条记录的fValueAjusted。就像这样:
SELECT
iUnity,Cluster,fValueOriginal
,(
lag(fValueAjusted,1,fValueOriginal) OVER (PARTITION BY Cluster ORDER BY iSequence)
+ fValueOriginal
) / 2 as fValueAjusted
FROM cteSequencing
Run Code Online (Sandbox Code Playgroud)
当然,fValueAjusted在执行时不可用。LAG()必须递归进行,计算记录的列,然后提供此列供下一个记录使用。
更新:原始答案不正确
这是正确的:
该代码使用递归CTE
CREATE TABLE #example (
iUnity int NOT NULL,
Cluster char(2) NOT NULL,
fValue float NOT NULL
)
INSERT INTO #example
VALUES
( 15, 'A1', 150 ),
( 16, 'A1', 170 ),
( 17, 'A1', 190 ),
( 18, 'A1', 210 ),
( 21, 'B2', 210 ),
( 23, 'B2', 230 ),
( 71, 'C3', 710 )
WITH cteSequencing AS (
-- Get Values Order
SELECT iUnity, Cluster, fValue, fValue AS fValueAjusted,
ROW_NUMBER() OVER (PARTITION BY Cluster ORDER BY fValue) AS iSequence
FROM #example
),
Recursion AS(
-- Anchor - the first value in clusters
SELECT iUnity, Cluster, fValue, fValueAjusted, iSequence
FROM cteSequencing
WHERE iSequence = 1
UNION ALL
-- Calculate next value based on the previous
SELECT b.iUnity As iUnity, b.Cluster, b.fValue,
( a.fValueAjusted + b.fValue ) / 2 AS fValueAjusted,
b.iSequence
FROM Recursion AS a
INNER JOIN cteSequencing AS b ON a.iSequence + 1 = b.iSequence AND a.Cluster = b.Cluster
)
SELECT * FROM Recursion ORDER BY Cluster, fValue
-- Manually check results
SELECT ( 150 + 170 ) / 2
SELECT ( 190 + 160 ) / 2
SELECT ( 190 + 170 ) / 2
Run Code Online (Sandbox Code Playgroud)
输出:
iUnity Cluster fValue fValueAjusted iSequence
----------- ------- ---------------------- ---------------------- --------------------
15 A1 150 150 1
16 A1 170 160 2
17 A1 190 175 3
18 A1 210 192.5 4
21 B2 210 210 1
23 B2 230 220 2
71 C3 710 710 1
Run Code Online (Sandbox Code Playgroud)
如果遇到
语句完成之前已用尽最大递归100
错误,然后使用OPTION (MAXRECURSION xxx)设置更大的递归限制,最高为32,767。
| 归档时间: |
|
| 查看次数: |
2165 次 |
| 最近记录: |