SQL中的递归滞后列计算

Question

我正在尝试编写一个将计算表数据插入另一个表的过程。

我遇到的问题是我需要每一行的计算列受到前一行计算列的结果的影响。我试图滞后计算本身，但这不起作用！

如：

（Max 是我创建的一个函数，它返回两个值中的最大值）

Id   Product      Model      Column1    Column2
1    A            1          5          =MAX(Column1*2, Lag(Column2))
2    A            2          2          =MAX(Column1*2, Lag(Column2))
3    B            1          3          =MAX(Column1*2, Lag(Column2))

如果我在 SQL 中尝试上述操作：

SELECT
    Column1, 
    MyMAX(Column1,LAG(Column2, 1, 0) OVER (PARTITION BY Product ORDER BY Model ASC) As Column2 
FROM Source

...它说 column2 是未知的。

如果我 LAG Column2 计算得到的输出：

Select Column1, MyMAX(Column1,LAG(Column1*2, 1, 0) OVER (PARTITION BY Product ORDER BY Model ASC) As Column2

Id   Column1    Column2
1    5          10
2    2          10
3    3          6

为什么第 3 行有 6 个？因为 3*2 > 2*2。

我想要的输出：

Id   Column1    Column2
1    5          10
2    2          10
3    3          10

为什么第 3 行有 10 个？因为之前的结果 10 > 3*2

问题是我不能滞后 Column2 的结果 - 我只能滞后其他列或它们的计算！

是否有使用 LAG 实现此目的的技术，或者我必须使用递归 CTE 吗？我读到 LAG 成功了 CTE，所以我认为这是可能的。如果不是，这个“CTE”会是什么样子？

编辑：或者，我还能做些什么来解决这个计算？

Answer 1

编辑

事后看来，这个问题是超过Column1 * 2 的运行分区最大值。它可以像这样简单地完成

SELECT Id, Column1, Model, Product,
       MAX(Column1 * 2) OVER (Partition BY Model, Product Order BY ID ASC) AS Column2
FROM Table1;

Fiddle

原答案

这是一种使用递归 CTE 完成此操作的方法，完全没有 LAG，方法是加入递增的行号。我没有假设您的Id 是连续的，因此添加了一个额外的ROW_NUMBER()。你没有提到任何分区，所以没有应用相同的。查询只是从第一行开始，然后投影当前Column1 * 2 或前面的Column2 中的较大者

WITH IncrementingRowNums AS
(
    SELECT Id, Column1, Column1 * 2 AS Column2, 
           ROW_NUMBER() OVER (Order BY ID ASC) AS RowNum
    FROM Table1
),
lagged AS
(
    SELECT Id, Column1, Column2, RowNum
    FROM IncrementingRowNums
    WHERE RowNum = 1

    UNION ALL

    SELECT i.Id, i.Column1, 
        CASE WHEN (i.Column2 > l.Column2) 
            THEN i.Column2 
            ELSE l.Column2 
        END, 
        i.RowNum
    FROM IncrementingRowNums i
    INNER JOIN lagged l
    ON i.RowNum = l.RowNum + 1
)
SELECT Id, Column1, Column2
FROM lagged;

SqlFiddle here

编辑、重新分区

分区大致相同，只需拖动 Model + Product 列，然后在行编号中按这些列进行分区（即每次 Product 或 Model 重置时从 1 开始），包括 CTE JOIN 条件和也在最终排序中。

WITH IncrementingRowNums AS
(
    SELECT Id, Column1, Column1 * 2 AS Column2, Model, Product,
           ROW_NUMBER() OVER (Partition BY Model, Product Order BY ID ASC) AS RowNum
    FROM Table1
),
lagged AS
(
    SELECT Id, Column1, Column2, Model, Product, RowNum
    FROM IncrementingRowNums
    WHERE RowNum = 1

    UNION ALL

    SELECT i.Id, i.Column1, 
        CASE WHEN (i.Column2 > l.Column2) 
            THEN i.Column2 
            ELSE l.Column2 
        END, 
        i.Model, i.Product,
        i.RowNum
    FROM IncrementingRowNums i
    INNER JOIN lagged l
    ON i.RowNum = l.RowNum + 1 
    AND i.Model = l.Model AND i.Product = l.Product
)
SELECT Id, Column1, Column2, Model, Product
FROM lagged
ORDER BY Model, Product, Id;

Updated Fiddle