问题[sql-server](coding)

我最近更改了表上的索引，发现一个查询的性能损失很大。我想知道为什么会发生这种情况。

这是查询。外键就像From和To一样在变化，但其余部分保持不变并且经常重复。

SELECT COUNT(*) 
FROM Table_With_Values 
WHERE FK_ObjectTheValuesBelongTo_Id = 460 
AND [From]>=CONVERT([datetime2](3),'07.10.2024 00:00:00',(104)) 
AND [To]<=CONVERT([datetime2](3),'08.10.2024 00:00:00',(104))

最初，表的索引TableWithValues如下所示：

CREATE NONCLUSTERED INDEX [Idx_TableWithValues_Fk_ObjectTheValuesBelongTo_Id_From_To] ON [dbo].[TableWithValues]
(
    [Fk_ObjectTheValuesBelongTo_Id] ASC,
    [From] ASC,
    [To] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, SORT_IN_TEMPDB = OFF, DROP_EXISTING = OFF, ONLINE = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON, OPTIMIZE_FOR_SEQUENTIAL_KEY = OFF) ON [PRIMARY]

然后我阅读了SQL Server 文档并看到了以下内容：

如果索引包含多个列，请考虑列的顺序。在 WHERE 子句中用于等于 (=)、大于 (>)、小于 (<) 或 BETWEEN 搜索条件的列，或参与连接的列应放在最前面。其他列应根据其独特性级别进行排序，即从最独特到最不独特。

From和列To有大约 140,000 个不同的值，而外键列只有 1,600 个。因此，我决定更改它们的顺序，并使索引看起来像这样：

CREATE NONCLUSTERED INDEX [Idx_TableWithValues_From_To_Fk_ObjectTheValuesBelongTo_Id] ON [dbo].[TableWithValues]
(
    [From] ASC,
    [To] ASC,
    [Fk_ObjectTheValuesBelongTo_Id] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, SORT_IN_TEMPDB = OFF, DROP_EXISTING = OFF, ONLINE = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON, OPTIMIZE_FOR_SEQUENTIAL_KEY = OFF) ON [PRIMARY]

然而，这导致此查询的性能下降。执行时间增加了 1,000 倍。我知道这一点，因为我在数据库副本上激活了查询存储。然后我运行了发送查询的 IT 系统并检查了avg_duration表中的值query_store_runtime_stats。

该表本身如下所示：

CREATE TABLE [dbo].[TableWithValues](
    [Id] [bigint] IDENTITY(1,1) NOT NULL,
    [Fk_ObjectTheValuesBelongTo_Id] [int] NOT NULL,
    [Value] [decimal](9, 3) NOT NULL,
    [From] [smalldatetime] NOT NULL,
    [To] [smalldatetime] NOT NULL,
 CONSTRAINT [Pk_TableWithValues_Id] PRIMARY KEY NONCLUSTERED 
(
    [Id] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON, OPTIMIZE_FOR_SEQUENTIAL_KEY = OFF) ON [PRIMARY],
 CONSTRAINT [Uq_TableWithValues_ObjectTheValuesBelongTo_Id_From] UNIQUE NONCLUSTERED 
(
    [Fk_ObjectTheValuesBelongTo_Id] ASC,
    [From] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON, OPTIMIZE_FOR_SEQUENTIAL_KEY = OFF) ON [PRIMARY]
) ON [PRIMARY]
GO

ALTER TABLE [dbo].[TableWithValues]  WITH CHECK ADD  CONSTRAINT [Fk_TableWithValues_ObjectTheValuesBelongTo_Id] FOREIGN KEY([Fk_ObjectTheValuesBelongTo_Id])
REFERENCES [dbo].[ObjectTheValuesBelongTo] ([Id])
GO

使用两个索引运行的查询计划看起来几乎相同。但有两点不同。它们使用不同的索引（隐藏在屏幕截图中），在一种情况下百分比为 13% 和 87%（Fk first in Index），在另一种情况下百分比为 20% 和 80%（Fk last in index）。

有什么想法吗，为什么我的数据库的行为不像阅读文档时所预期的那样？

我有一个 IIS 模块，可同时处理多个请求。在每个请求的入口处，我想记录上次访问该服务的时间：

update log set last_access = getdate()

但是，由于有时我会拥有的并发级别，我担心很容易发生冲突。

因为我的日志不需要毫秒的精度（它将被查阅以检查服务器在过去 X 分钟内是否被访问过，而不是毫秒），所以如果我的日志遇到冲突，它可以完全忽略该日志而不执行任何操作。

我最初的想法是在 try-catch 块内保护我的日志记录并忽略冲突。

begin try
  update log set last_access = getdate()
end try
begin catch
  -- We do nothing and ignore that another request has logged an access at the same time
end catch

但这是正确的吗？如果发生冲突，将自动跳转到 catch 部分，不执行任何操作，因此我的后端可以继续正常处理其余请求？

我担心它可能会等待死锁解除，然后在超时后继续。有没有更好的方法来更新值，同时告诉 SQL Server 如果另一个会话已经同时执行了该更新，则忽略该更新？

PS：此更新日志将在其自己的事务中运行，而服务请求所需的任何 SQL 操作都将在单独的事务中运行。

谢谢。

我正在尝试根据案例表达式进行分组。下面的 JOOQ 似乎是正确的做法，并且或多或少产生了我期望的 SQL。从“sakila”数据库（请原谅我的 Kotlin，它必须转义“when”和“as”）：

val shared = `when`(ACTOR.LAST_NAME.like("A%"), "A")
    .`when`(ACTOR.LAST_NAME.like("B%"), "B")
    .otherwise("C")

val r = ctx.select(
    count(), shared.`as`("code")
)
    .from(ACTOR)
    .groupBy(shared)
    .fetch()

SQL Server 2017 Express（v14）抱怨：

列“DTB_DEV_SAKILA.dbo.actor.last_name”在选择列表中无效，因为它不包含在聚合函数或 GROUP BY 子句中。

这很令人惊讶，因为确实如此。以下是完整的调试/堆栈跟踪（我已将其半格式化以便于阅读）：

Exception in thread "main" org.jooq.exception.DataAccessException: SQL [
select count(*), 
case when [DTB_DEV_SAKILA].[dbo].[actor].[last_name] like ? then ? 
when [DTB_DEV_SAKILA].[dbo].[actor].[last_name] like ? then ? 
else ? end [code] 
from [DTB_DEV_SAKILA].[dbo].[actor] 
group by case when [DTB_DEV_SAKILA].[dbo].[actor].[last_name] like ? then ? 
when [DTB_DEV_SAKILA].[dbo].[actor].[last_name] like ? then ? else ? end
]; Column 'DTB_DEV_SAKILA.dbo.actor.last_name' is invalid in the select list because it is not contained in either an aggregate function or the GROUP BY clause.

令人恼火的是，如果我剪切/粘贴查询（由堆栈跟踪吐出）并用实际值替换占位符/准备好的语句“？”，SSMS 就可以很好地执行它。

select 
    count(*), 
    case 
        when [DTB_DEV_SAKILA].[dbo].[actor].[last_name] like 'A%' 
            then 'A' 
        when [DTB_DEV_SAKILA].[dbo].[actor].[last_name] like 'B%' 
            then 'B' 
        else 'C' 
    end as code
from
    [DTB_DEV_SAKILA].[dbo].[actor] 
group by 
    case 
        when [DTB_DEV_SAKILA].[dbo].[actor].[last_name] like 'A%' then 'A' 
        when [DTB_DEV_SAKILA].[dbo].[actor].[last_name] like 'B%' then 'B' 
        else 'C' 
    end as code

笔记：

• 如果我使用 JOOQ 的inline()函数来摆脱准备好的语句“？”（呃，绑定变量），它可以正常工作；
• 使用 IIF 而不是 CASE WHE N ...没有任何喘息的机会，它抱怨同样的事情。

但是这段代码（我猜没有绑定变量，只是列引用）运行得很好：

val shared = length(ACTOR.LAST_NAME)

val r = ctx.select(
    count(), shared.`as`("voluminousness")
)
    .from(ACTOR)
    .groupBy(shared)
    .fetch()

因此，问题在于，在尝试编译时，根据 case 语句进行分组的一些联系PreparedStatement。

这似乎更像是 JDBC / SQL Server 问题，而不是 JOOQ 问题。但是 JOOQ 用户通常会采用与此处不同的方法吗？有解决方法吗？其他数据库是否也有这样的分组限制CASE？

JOOQ 3.19.10、MS JDBC 12.8.1.jre11、SQL Server 2017（v14.0.2065）

我有一个名为 的表Device和另一个名为 的表Action。我将它们与两个 PK 上的连接表链接起来DeviceActions。

这是一个简化的 ERD 模型：

如果每个设备的每个操作只记录一次DeviceActions，则一切正常。但是，一个设备可能不止一次执行相同的操作。如果不违反和DeviceActions上的 PK/FK 约束，我就无法将相同的操作输入表中。DeviceIdActionId

我如何设置连接表以便它可以存储具有相同操作 ID 的相同设备 ID？

以下是我所寻找的记录示例：

设备 2536 有两次相同的操作 ID (1)。我在连接表中添加了一个 PKDeviceActions并创建了DeviceIdFK，ActionId但我不知道这是否是正确的方法，尤其是对于表开始增长后的性能而言：

本质上，我的问题归结为观察这两个查询计划（来自 SQL Server 2019）：

1. 使用 SQL 定义的标量函数进行计划。
   • 链接至计划

2. 使用 CLR 定义的标量函数进行规划。
   • 链接至计划

我定义了一个标量函数，用于将 IP 地址的字符串表示解析为binary(16)IPv6 地址的值（将 IPv4 地址映射到 IPv6）。我首先在 SQL 中实现它，然后我也在 C# 中使用内置类IPAddress来解析该值。我试图使用此函数将包含 IP 地址字符串的表连接到包含解析出的 CIDR 块列表的表（聚集索引[Start]和[End] binary(16)值）。

我编写 SQL 查询的方法有两种：

1. 直接在条件中使用标量函数JOIN。

SELECT
    *
FROM
    [dbo].[values]
    val
LEFT JOIN
    [dbo].[cidr]
    cidr
        ON [dbo].[fn_ParseIP](val.[IpAddress]) BETWEEN cidr.[Start] AND cidr.[End]
;

2. APPLY在引用子句中的标量函数之前，先计算它JOIN。

SELECT
    val.*, cidr.*
FROM
    [dbo].[values]
    val
CROSS APPLY
    (
        SELECT [ParsedIpAddress] = [dbo].[fn_ParseIP](val.[IpAddress])
    )
    calc
LEFT JOIN
    [dbo].[cidr]
    cidr
        ON calc.[ParsedIpAddress] BETWEEN cidr.[Start] AND cidr.[End]
;

在我的测试中，[dbo].[values]包含 17 行（并且是使用实际表定义的VALUES而不是实际表）并且[dbo].[cidr]包含 986,320 行。

当使用 SQL 中定义的标量函数时，查询 1 大约需要 7.5 分钟才能运行，而查询 2 则需要不到 1 秒。

使用 CLR 标量函数时，两个查询大约需要 2.5 分钟才能运行，但查询 2 在查询计划中有一个额外的节点用于在连接后计算标量函数。

最终的区别在于，当引用 SQL 中定义的标量函数时，我可以让它生成第一个计划，该计划首先计算标量函数的结果，然后[dbo].[cidr]在执行连接时将这些结果用作查找谓词进入聚集索引。但是当使用 CLR 函数时，它总是将计算作为聚集索引查找（和过滤）的一部分来执行，因此它会更频繁地运行该函数来获取结果。

我的假设是，这种行为可能是由于查询规划器认为该函数是不确定的，但我已经使用以下属性实现了 CLR 函数：

    [SqlFunction(
        DataAccess = DataAccessKind.None,
        IsDeterministic = true,
        IsPrecise = true
    )]
    [return: SqlFacet(IsFixedLength = true, IsNullable = true, MaxSize = 16)]
    public static SqlBinary fn_CLR_ParseIP([SqlFacet(MaxSize = 50)] SqlString ipAddress)
    { }

我希望可以依靠 .NET 标准库在 SQL 中帮我处理 IP 地址解析。目前，我们有一些流程仅适用于 IPv4 地址，我需要更新它们以使其也适用于 IPv6。在我们的一些大型数据库中，这种处理非常缓慢，因此我希望 .NET 中的解析逻辑更高效。看起来 CLR 函数本身比我的 SQL 实现更快，但对查询计划的影响明显更差。

我可以重写查询以首先使用临时表解析 IP 地址，这应该可以解决这个问题。定义一个等效的 CLR 表值函数（该函数仅返回一行）时，我也可以获得不错的结果。

但是，我想知道我是否遗漏了某些东西，以便更轻松地将 CLR 标量函数用作过滤谓词的一部分。这是否是个坏主意，我应该继续使用其中一些替代方案，或者我可以做些什么来更轻松地使用 CLR 函数作为 SQL 函数的替代品？

对于任何感兴趣的人，这里是使用 T N 的答案中给出的概念表现良好的最终查询。

SELECT
    *
FROM
    [dbo].[values]
    val
CROSS APPLY
    (
        SELECT [IpAddress] = [dbo].[fn_CLR_ParseIP](val.[IpAddress])
    )
    parsed
OUTER APPLY
    (
        SELECT TOP (1)
            *
        FROM
            [dbo].[cidr]
            _cidr
        WHERE
                _cidr.[range_start] <= parsed.[IpAddress]
            AND _cidr.[range_end]   >= parsed.[IpAddress]
        ORDER BY
            _cidr.[range_start] DESC
    )
    cidr
;

我在 SQL Server 2016 中有一个名为的表df：

-- Create a new table with department and gender columns
CREATE TABLE df 
(
    country VARCHAR(50),
    year INT,
    val1 INT,
    val2 INT,
    val3 INT,
    department VARCHAR(50),
    gender VARCHAR(10)
);

-- Insert data into the new table, including department and gender
INSERT INTO df (country, year, val1, val2, val3, department, gender) 
VALUES ('USA', 2020, 4, 4, 5, 'Sales', 'Male'),
('USA', 2020, 4, 4, 5, 'Sales', 'Male'),
('USA', 2020, 5, 5, 5, 'Sales', 'Female'),
('USA', 2020, 5, 5, 5, 'Sales', 'Female'),
('USA', 2020, 1, 1, 5, 'Sales', 'Male'),
('USA', 2020, 3, 3, 5, 'Sales', 'Female'),
('USA', 2020, 4, 2, 5, 'Sales', 'Male'),
('USA', 2020, 1, 1, 5, 'Sales', 'Female'),
('USA', 2020, 2, 2, 5, 'Sales', 'Male'),
('Canada', 2020, 2, 2, 3, 'HR', 'Female'),
('Canada', 2020, 2, 2, 3, 'HR', 'Female'),
('Canada', 2020, 2, 2, 3, 'HR', 'Male'),
('Canada', 2020, 2, 2, 3, 'HR', 'Male'),
('Canada', 2020, 5, 5, 3, 'HR', 'Female'),
('Canada', 2020, 5, 5, 3, 'HR', 'Male'),
('Canada', 2020, 1, 1, 3, 'HR', 'Female'),
('Canada', 2020, 1, 1, 3, 'HR', 'Male'),
('Canada', 2020, 3, 4, 3, 'HR', 'Female'),
('Canada', 2020, 3, 4, 3, 'HR', 'Male'),
('Canada', 2020, 5, 4, 3, 'HR', 'Female'),
('Canada', 2020, 5, 4, 5, 'HR', 'Male'),
('Canada', 2020, 5, 4, 5, 'HR', 'Female'),
('Germany', 2022, 5, 5, 4, 'IT', 'Male'),
('France', 2020, 1, 1, 2, 'Finance', 'Female'),
('France', 2020, 1, 1, 2, 'Finance', 'Female'),
('France', 2020, 3, 2, 2, 'Finance', 'Male'),
('France', 2020, 3, 4, 2, 'Finance', 'Female'),
('France', 2020, 3, 5, 5, 'Finance', 'Male'),
('France', 2020, 3, 4, 4, 'Finance', 'Female'),
('France', 2020, 3, 4, 4, 'Finance', 'Male'),
('France', 2020, 3, 4, 3, 'Finance', 'Female'),
('UK', 2021, 4, 2, 3, 'Marketing', 'Male'),
('Australia', 2022, 3, 3, 4, 'Support', 'Female'),
('Italy', 2020, 5, 5, 5, 'Operations', 'Male'),
('Italy', 2020, 5, 5, 5, 'Operations', 'Female'),
('Italy', 2020, 5, 1, 1, 'Operations', 'Male'),
('Italy', 2020, 4, 4, 1, 'Operations', 'Female'),
('Italy', 2020, 2, 1, 2, 'Operations', 'Male'),
('Italy', 2020, 3, 5, 3, 'Operations', 'Female'),
('Spain', 2021, 1, 2, 3, 'Customer Service', 'Male'),
('Mexico', 2022, 4, 4, 4, 'Logistics', 'Female'),
('Brazil', 2020, 4, 1, 1, 'R&D', 'Male'),
('Brazil', 2020, 4, 1, 1, 'R&D', 'Female'),
('Brazil', 2020, 4, 3, 4, 'R&D', 'Male'),
('Brazil', 2020, 5, 3, 5, 'R&D', 'Female'),
('Brazil', 2020, 5, 3, 5, 'R&D', 'Male'),
('Brazil', 2020, 3, 3, 1, 'R&D', 'Female'),
('Brazil', 2020, 2, 3, 1, 'R&D', 'Male');

-- Select all rows from the new table to check the data
SELECT * FROM df;

通过此表，我根据一些过滤创建了一些百分比和计数列。

-- Parameters
DECLARE @Year INT = 2020;
DECLARE @Metric VARCHAR(50) = 'count'; 
DECLARE @Gender VARCHAR(20) = NULL; -- Set to specific gender (e.g., 'Male', 'Female') or NULL to include all
DECLARE @Department VARCHAR(50) = NULL; -- Set to specific department (e.g., 'HR', 'Engineering') or NULL to include all
-- Set @Metric to 'dissatisfaction', 'satisfaction', or 'count'

WITH UnpivotedData AS 
(
    SELECT country, gender, department, year, Vals
    FROM 
        (SELECT country, gender, department, year, val1, val2, val3
         FROM df) AS SourceTable
    UNPIVOT 
        (Vals FOR ValueColumn IN (val1, val2, val3)) AS Unpivoted
    WHERE year = @Year
),
Proportions AS 
(
    SELECT 
        country,
        gender,
        department,
        CASE 
            WHEN Vals = 1 THEN 'Very Dissatisfied'
            WHEN Vals = 2 THEN 'Dissatisfied'
            WHEN Vals = 3 THEN 'Neutral'
            WHEN Vals = 4 THEN 'Satisfied'
            WHEN Vals = 5 THEN 'Very Satisfied'
        END AS SatisfactionLevel,
        COUNT(*) * 1.0 / SUM(COUNT(*)) OVER (PARTITION BY country, gender, department) AS Proportion
    FROM 
        UnpivotedData
    GROUP BY 
        country, gender, department, Vals
),
Pivoted AS 
(
    SELECT country, gender, department, 
           [Very Dissatisfied], 
           [Dissatisfied], 
           [Neutral], 
           [Satisfied], 
           [Very Satisfied]
    FROM Proportions
    PIVOT 
        (MAX(Proportion)
         FOR SatisfactionLevel IN ([Very Dissatisfied], [Dissatisfied], [Neutral], [Satisfied], [Very Satisfied])) AS p
),
CountryCounts AS 
(
    SELECT 
        CASE WHEN country IS NULL THEN 'Unknown' ELSE country END AS country,
        gender, 
        department,
        COUNT(*) AS Total
    FROM df
    WHERE year = @Year
    -- Apply filters for gender and department if provided
    AND (@Gender IS NULL OR gender = @Gender)
    AND (@Department IS NULL OR department = @Department)
    GROUP BY CASE WHEN country IS NULL THEN 'Unknown' ELSE country END, gender, department
),
OrderedData AS 
(
    SELECT 
        p.country,
        p.gender,
        p.department,
        [Very Dissatisfied],
        [Dissatisfied],
        [Neutral],
        [Satisfied],
        [Very Satisfied],
        c.Total,
        CASE 
            WHEN @Metric = 'satisfaction' THEN ISNULL([Satisfied], 0) + ISNULL([Very Satisfied], 0)
            WHEN @Metric = 'dissatisfaction' THEN ISNULL([Very Dissatisfied], 0) + ISNULL([Dissatisfied], 0)
            WHEN @Metric = 'count' THEN c.Total
        END AS SortValue
    FROM Pivoted AS p
    INNER JOIN CountryCounts AS c ON p.country = c.country AND p.gender = c.gender AND p.department = c.department
)
SELECT 
    country,
    gender,
    department,
    [Very Dissatisfied],
    [Dissatisfied],
    [Neutral],
    [Satisfied],
    [Very Satisfied],
    Total
FROM 
    OrderedData
ORDER BY 
    SortValue DESC;

我想创建一个具有 3 个参数的表函数：

1. 公制
2. 年
3. 因素

Factor可以是性别或部门，或者两者皆可。例如，如果Factor是性别，则表格按性别分组；如果是部门，则表格按部门分组。

如果两者同时进行分组。如果Factor为空或默认，则根本不进行分组。

关于Year：如果Year传入的是按年份分组，如果Year是空，则显示所有年份，不进行分组。

有没有办法在 SQL Server 中做到这一点？

我这里有一把小提琴

我正在使用动态 SQL 将默认值插入表中，并希望返回SCOPE_IDENTITY()代理键的值。但是，由于某种原因，它SCOPE_IDENTITY()返回了NULL。我遗漏了什么吗？

谢谢！

DECLARE @SQL NVARCHAR(MAX),
        @SurrogateKey INT,
        @SchemaName VARCHAR(128) = 'dim',
        @TableName VARCHAR(128) = 'Sales',
        @NaturalKeyColumn VARCHAR(128) = 'SalesID',
        @NaturalKeyValue VARCHAR(40) = '100',
        @SurrogateKeyColumn VARCHAR(128) = 'SalesKey';

SET @SQL = N'SELECT @SurrogateKey = ' + QUOTENAME(@SurrogateKeyColumn) + 
           ' FROM ' + QUOTENAME(@SchemaName) + '.' + QUOTENAME(@TableName) + 
           ' WHERE ' + QUOTENAME(@NaturalKeyColumn) + ' = @NaturalKeyValue';

EXEC sp_executesql @SQL, N'@SurrogateKey INT OUTPUT, @NaturalKeyValue VARCHAR(40)', @SurrogateKey OUTPUT, @NaturalKeyValue;

IF @SurrogateKey IS NULL
BEGIN
    BEGIN TRANSACTION;

    SET @SQL = N'INSERT INTO ' + QUOTENAME(@SchemaName) + '.' + QUOTENAME(@TableName) + 
               ' (' + QUOTENAME(@NaturalKeyColumn) + ', InferredFlag)
                VALUES (@NaturalKeyValue, 1)';

    EXEC sp_executesql @SQL, N'@NaturalKeyValue VARCHAR(40)', @NaturalKeyValue;

    -- Check if the INSERT was successful
    IF @@ROWCOUNT > 0
    BEGIN
        SET @SQL = N'SELECT @SurrogateKey = SCOPE_IDENTITY()';

        EXEC sp_executesql @SQL, N'@SurrogateKey INT OUTPUT', @SurrogateKey OUTPUT;
    END

    COMMIT TRANSACTION;
END

SELECT @SurrogateKey;

我正在尝试从 #tableA 中删除 #tableB 中不存在的记录。这似乎很简单，但是，我收到了

无法绑定多部分标识符 #TABLEA.MODELNO

即使 tableA 中存在“modelno”列。我遗漏了什么？

DELETE FROM #TABLEA
WHERE EXISTS (SELECT 1 FROM #TABLEB WHERE #TABLEB.MODEL = #TABLEA.MODELNO)

WHERE MODELNO IN()出于性能原因，我想避免使用。

我有一张下表，其中列出了每项保单的交易。每项保单的其中一行都标有“Y”，表示该保单存在某个“问题”。我想创建一个新列，将标有“Y”的行以及标有 1 的同一保单的后续行标记为“Y”。

基本上，对于每项政策，在政策生命周期的某个阶段都会出现一个问题，我想识别标记为“Y”的 PolicyVersion 以及标记为“Y”的行之后的同一政策的任何后续行。

我不太清楚正确的分区

我有以下 SQL 逻辑，由三个 where 语句组成，每个语句都用“OR”分隔。我的目标是检索第一个 where 语句中的所有数据，但仅排除符合后两个 where 语句中的条件的记录。当我按原样运行它时，我会获得所有记录。我认为这是因为第一个 where 语句，但我不知道如何更改它，以便它仅排除符合后两个 where 语句中的条件的记录。如果您能提供任何帮助来重写此逻辑，我将不胜感激。

WHERE 
(
    (ord_billto = 'CATGRI'
    AND o.ord_status = 'CMP'
    AND o.ord_startdate >= @StartDate and o.ord_startdate < @EndDate+1
    AND o.ord_invoicestatus = 'XIN')
OR
    (o.ord_billto = 'CATGRI'
    AND o.ord_status = 'CMP'
    AND o.ord_startdate >= @StartDate and o.ord_startdate < @EndDate+1
    AND o.ord_invoicestatus = 'XIN'
    AND o.ord_revtype4 IN ('GRIFF3')
    AND s.cmp_id NOT IN ('CATLAF10','ORDBEL', 'SKYLIV','SKYPLY'))
OR
    (o.ord_billto = 'CATGRI'
    AND o.ord_status = 'CMP'
    AND o.ord_startdate >= @StartDate and o.ord_startdate < @EndDate+1
    AND o.ord_invoicestatus = 'XIN'
    AND o.ord_revtype4 IN ('GRIFF1')
    AND s.cmp_id NOT IN ('CATGRI02','CATWAC01'))
)