一部の集計変換が壊れています

この問題は、複数のANYの場合にのみ発生する可能性があります 集計が存在し、集計データにnullが含まれています。前述のように、この問題は Stream Aggregateにのみ影響します と熱心なハッシュ骨材 演算子; 個別の並べ替え およびFlowDistinct 影響を受けません。

SQL Server 2016以降では、複数のANYの導入を回避するように努めています。 ソース列がnull許容の場合、グループごとの任意の1行の行番号付けクエリパターンの集計。これが発生すると、実行プランにはセグメントが含まれます。 、シーケンスプロジェクト 、およびフィルタ 集合体の代わりに演算子。 ANYがないため、このプランの形状は常に安全です。 集計が使用されます。

SQLServer2016+でのバグの再現

SQL Serverオプティマイザーは、列が元々NOT NULLに制約されていた場合の検出に完全ではありません。 データ操作によってnullの中間値が生成される可能性があります。

これを再現するために、すべての列がNOT NULLとして宣言されているテーブルから始めます。 ：

IF OBJECT_ID(N'tempdb..#Data', N'U') IS NOT NULL
BEGIN
    DROP TABLE #Data;
END;
 
CREATE TABLE #Data
(
    c1 integer NOT NULL,
    c2 integer NOT NULL,
    c3 integer NOT NULL
);
 
CREATE CLUSTERED INDEX c ON #Data (c1);
 
INSERT #Data
    (c1, c2, c3)
VALUES
    -- Group 1
    (1, 1, 1),
    (1, 2, 2),
    (1, 3, 3),
    -- Group 2
    (2, 1, 1),
    (2, 2, 2),
    (2, 3, 3);

このデータセットからさまざまな方法でnullを生成できますが、そのほとんどはオプティマイザーが正常に検出できるため、ANYの導入は避けてください。 最適化中に集計されます。

レーダーの下に滑り込むヌルを追加する1つの方法を以下に示します。

SELECT
    D.c1,
    OA1.c2,
    OA2.c3
FROM #Data AS D
OUTER APPLY (SELECT D.c2 WHERE D.c2 <> 1) AS OA1
OUTER APPLY (SELECT D.c3 WHERE D.c3 <> 2) AS OA2;

そのクエリは次の出力を生成します：

次のステップは、そのクエリ仕様を標準の「グループごとに任意の1行」クエリのソースデータとして使用することです。

WITH
    SneakyNulls AS 
    (
        -- Introduce nulls the optimizer can't see
        SELECT
            D.c1,
            OA1.c2,
            OA2.c3
        FROM #Data AS D
        OUTER APPLY (SELECT D.c2 WHERE D.c2 <> 1) AS OA1
        OUTER APPLY (SELECT D.c3 WHERE D.c3 <> 2) AS OA2
    ),
    Numbered AS 
    (
        SELECT
            D.c1,
            D.c2,
            D.c3,
            rn = ROW_NUMBER() OVER (
                PARTITION BY D.c1
                ORDER BY D.c1) 
        FROM SneakyNulls AS D
    )
SELECT
    N.c1, 
    N.c2, 
    N.c3
FROM Numbered AS N
WHERE
    N.rn = 1;

任意のバージョン SQL Serverの場合、次の計画が作成されます。

Stream Aggregate 複数のANYが含まれています 集計すると、結果は間違っています 。返された行はどちらもソースデータセットに表示されません：

db<>フィドルオンラインデモ

DECLARE @Target table
(
    c1 integer PRIMARY KEY, 
    c2 integer NOT NULL, 
    c3 integer NOT NULL
);
 
DECLARE @Source table 
(
    c1 integer NULL, 
    c2 integer NULL, 
    c3 integer NULL, 
 
    INDEX c CLUSTERED (c1)
);
 
INSERT @Target 
    (c1, c2, c3) 
VALUES 
    (1, 0, 0);
 
INSERT @Source 
    (c1, c2, c3) 
VALUES 
    (1, 2, NULL),
    (1, NULL, 3);
 
UPDATE T
SET T.c2 = S.c2,
    T.c3 = S.c3
FROM @Target AS T
JOIN @Source AS S
    ON S.c1 = T.c1;
 
SELECT * FROM @Target AS T;