查找最大同时出现次数，如果满足条件则增加变量答案

【问题标题】：Find max simultanius occurences, increasse variable if criteria is meet查找最大同时出现次数，如果满足条件则增加变量
【发布时间】：2021-06-19 00:46:47
【问题描述】：

我有一项任务，旨在将进入给定端口（中继）集的几个连接汇总到时隙中并计算结果。问题是我想实现两种类型的计数：

一个计数应计算给定插槽中与Trunk 的连接总数（每个插槽 30 分钟）
其次，我想找出同时发生的最大连接数：例如总共有 10 个连接，但其中只有 3 个同时连接。表中的 cmets 表示“计数组”

表：RAW_DATA

GatewayName StartDateTime               DisconnectDateTime      ConDur  Trunk
GW1         2021-02-24 20:01:00.0       2021-02-24 20:05:30.0   270000  T1  --1, nextRow.Start is before discon   
GW1         2021-02-24 20:04:50.0       2021-02-24 20:08:24.0   214000  T1  --2   
GW1         2021-02-24 20:05:20.6       2021-02-24 20:07:50.1   149500  T1  --3   
GW1         2021-02-24 20:15:50.0       2021-02-24 20:17:00.0   70000   T1  --0   
GW1         2021-02-24 20:20:50.0       2021-02-24 20:21:00.0   10000   T1  --1   
GW1         2021-02-24 20:20:59.0       2021-02-24 20:24:00.0   181000  T1  --2   
GW1         2021-02-24 20:23:59.0       2021-02-24 20:28:30.0   271000  T1  --3   
GW1         2021-02-24 20:26:00.0       2021-02-24 20:29:30.0   210000  T1  --4   
GW1         2021-02-24 20:27:00.0       2021-02-24 20:29:31.0   151000  T1  --5   
GW3         2021-02-24 22:46:54.2       2021-02-24 22:48:25.2   91000   T1  --0  
GW2         2021-02-24 20:41:49.0       2021-02-24 20:43:24.0   95000   T2  --0   
GW99        2021-02-24 22:47:25.1       2021-02-24 22:47:54.4   29300   T2  --0

目前的结果

我正在运行一个存储过程，该过程创建一个计数表，我用它来生成我的时间段。

另外，我创建了一个在运行时间段排序之前运行的临时表，该表的目的是查看下一行 StartDateTime 以查看它是否在当前行 DisconnectDateTime 之前。该表是作为测试表构建的，以查看是否可以在遇到零 (0) 之前以某种方式对事件进行计数和分组，以便稍后执行 max 以一次获得最大数量的事件。不幸的是，我无法弄清楚这个机制。

GatewayName StartDateTime               DisconnectDateTime      ConDur  Trunk   nrDDT                   sim
GW1         2021-02-24 20:01:00.0       2021-02-24 20:05:30.0   270000  T1      2021-02-24 20:04:50.0   1 -- count row below
GW1         2021-02-24 20:04:50.0       2021-02-24 20:08:24.0   214000  T1      2021-02-24 20:05:20.6   1 -- counted
GW1         2021-02-24 20:05:20.6       2021-02-24 20:07:50.1   149500  T1      2021-02-24 20:15:50.0   0 -- counted
GW1         2021-02-24 20:15:50.0       2021-02-24 20:17:00.0   70000   T1      2021-02-24 20:20:50.0   0 -- jump to else
GW1         2021-02-24 20:20:50.0       2021-02-24 20:21:00.0   10000   T1      2021-02-24 20:20:59.0   1
GW1         2021-02-24 20:20:59.0       2021-02-24 20:24:00.0   181000  T1      2021-02-24 20:23:59.0   1
GW1         2021-02-24 20:23:59.0       2021-02-24 20:28:30.0   271000  T1      2021-02-24 20:26:00.0   1
GW1         2021-02-24 20:26:00.0       2021-02-24 20:29:30.0   210000  T1      2021-02-24 20:27:00.0   1
GW1         2021-02-24 20:27:00.0       2021-02-24 20:29:31.0   151000  T1      2021-02-24 22:46:54.2   0
GW3         2021-02-24 22:46:54.2       2021-02-24 22:48:25.2   91000   T1      NULL                    0
GW2         2021-02-24 20:41:49.0       2021-02-24 20:43:24.0   95000   T2      2021-02-24 22:47:25.1   0
GW99        2021-02-24 22:47:25.1       2021-02-24 22:47:54.4   29300   T2      NULL                    0

问题是，如果满足我的case（sim 列），我想增加计数，我尝试同时使用全局变量和局部变量，但是它正在为每一行重置，我无法强制如果输入了我的else 子句，则返回0。

CREATE OR ALTER PROCEDURE GenerateTrunkSum
@date datetime2(7),
@period int
AS
BEGIN

DECLARE @raw_data table
(
GatewayName varchar(23),
StartDateTime datetime2(7),
DisconnectDateTime datetime2(7),
ConnectionDuration int ,
Trunk varchar(10)
);
-- Createing test data
INSERT INTO @raw_data values('GW1', '2021-02-24 20:01:00.0', '2021-02-24 20:05:30.0', DATEDIFF(millisecond, '2021-02-24 20:01:00.0', '2021-02-24 20:05:30.0'), 'T1')
INSERT INTO @raw_data values('GW1', '2021-02-24 20:05:20.6', '2021-02-24 20:07:50.1', DATEDIFF(millisecond, '2021-02-24 20:05:20.6', '2021-02-24 20:07:50.1'), 'T1')
INSERT INTO @raw_data values('GW1', '2021-02-24 20:04:50.0', '2021-02-24 20:08:24.0', DATEDIFF(millisecond, '2021-02-24 20:04:50.0', '2021-02-24 20:08:24.0'), 'T1')
INSERT INTO @raw_data values('GW1', '2021-02-24 20:15:50.0', '2021-02-24 20:17:00.0', DATEDIFF(millisecond, '2021-02-24 20:15:50.0', '2021-02-24 20:17:00.0'), 'T1')
INSERT INTO @raw_data values('GW1', '2021-02-24 20:20:50.0', '2021-02-24 20:21:00.0', DATEDIFF(millisecond, '2021-02-24 20:20:50.0', '2021-02-24 20:21:00.0'), 'T1')
INSERT INTO @raw_data values('GW1', '2021-02-24 20:20:59.0', '2021-02-24 20:24:00.0', DATEDIFF(millisecond, '2021-02-24 20:20:59.0', '2021-02-24 20:24:00.0'), 'T1')
INSERT INTO @raw_data values('GW1', '2021-02-24 20:25:00.0', '2021-02-24 20:28:30.0', DATEDIFF(millisecond, '2021-02-24 20:25:00.0', '2021-02-24 20:28:30.0'), 'T1')
INSERT INTO @raw_data values('GW2', '2021-02-24 20:41:49.0 ', '2021-02-24 20:43:24.0', DATEDIFF(millisecond, '2021-02-24 20:41:49.0 ', '2021-02-24 20:43:24.0'), 'T2')
INSERT INTO @raw_data values('GW3', '2021-02-24 22:46:54.2', '2021-02-24 22:48:25.2', DATEDIFF(millisecond, '2021-02-24 22:46:54.2', '2021-02-24 22:48:25.2'), 'T1')
INSERT INTO @raw_data values('GW99', '2021-02-24 22:47:25.1', '2021-02-24 22:47:54.4', DATEDIFF(millisecond, '2021-02-24 22:47:25.1', '2021-02-24 22:47:54.4'), 'T2')


-- Variable should be increased if not null 
declare @localvar int 
set @localvar = 0
-- Store value in max if 0 is meet and current @localvar is greater then @max
declare @max int 
set @max = 0

   SELECT GatewayName, StartDateTime, DisconnectDateTime, ConnectionDuration, Trunk, LEAD(StartDateTime, 1, NULL) OVER ( PARTITION BY Trunk ORDER BY  StartDateTime ) as nrDDT,
       CASE 
           WHEN DATEDIFF(MILLISECOND, LEAD(StartDateTime, 1, NULL) OVER ( PARTITION BY Trunk ORDER BY  StartDateTime ), DisconnectDateTime) >= 0 THEN @localvar + 1 -- Add if Match 1 = 1 M3 = 3 etc
           ELSE -- possible update @max and Reset @localvar = 0
       END AS sim
   INTO #Temp
   FROM @raw_data;

       select * from #Temp;
   
   -- Creat timeslotable
       with numbers(val) as 
           (select 1 union all select val + 1 from numbers where val < 48)
       select @date, nbr.val, 
           dateadd(minute, (nbr.val - 1) * 30, @date) as period_start, 
           dateadd(minute, (nbr.val    ) * 30, @date) as period_end 
       from numbers as nbr 
       order by nbr.val;

       --Enummerate
       with numbers(val) as 
           (select 1 union all select val + 1 from numbers where val < 48),
       periods as (
           select @date as [date], nbr.val, 
           dateadd(minute, (nbr.val - 1) * 30, @date) as period_start, 
           dateadd(minute, (nbr.val    ) * 30, @date) as period_end 
           from numbers as nbr)
       select pers.period_start, @period as Period, src.trunk, count(src.GatewayName) as 'all', 
           -- Case Added in update 2
           CASE
               WHEN MAX(src.sim) < 1 THEN 1 -- if max is 0 set 1, defaults to at least one active
               ELSE MAX(src.sim)
           END AS simultaneous
       --from periods as pers left  join HDO.CDR_RAW as src 
       from periods as pers inner join #Temp as src 
       on src.StartDateTime >= pers.period_start and src.StartDateTime < pers.period_end
       group by src.trunk, pers.period_start
       order by src.trunk 
END
GO

EXECUTE GenerateTrunkSum @date = '20210224', @period = 1800;

所以我的问题是：有人知道如何让这个计数机制起作用吗？我想要这样的原因是能够在我的最后一个选择语句中执行MAX（请参阅CASE）

--- Current output
period_start            period  trunk all   simultaneous
2021-02-24 20:00:00.0   1800    T1    9     1
2021-02-24 22:30:00.0   1800    T1    1     1
2021-02-24 20:30:00.0   1800    T2    1     1
2021-02-24 22:30:00.0   1800    T2    1     1

--- What it should be based on input
period_start            period  trunk all   simultaneous
2021-02-24 20:00:00.0   1800    T1    9     5 -- See RAW_table for clarification
2021-02-24 22:30:00.0   1800    T1    1     1
2021-02-24 20:30:00.0   1800    T2    1     1
2021-02-24 22:30:00.0   1800    T2    1     1

示例输出

Trunk  Start                                Period   All  sim
T1       2021:02:24 22:30:0.0     1800      5     2

更新 1

看着 Sørens 的回答，我尝试在 30 分钟内使用 inner join 它。
因此设置无计数使用 [dbo_CDR] 去吧

CREATE OR ALTER PROCEDURE [dbo].[GenerateTrunkSumv1]
@date datetime2(1),
@ST datetime2(1),
@DT datetime2(1),
@tn varchar(23),
@period int
AS
BEGIN

WITH TrunkGroup
AS (
    SELECT
        IngressTrunkGroup as Trunk
    ,StartDateTime
    ,DisconnectDateTime
    FROM 
        [dbo].[CDR_RAW]

    UNION ALL

    SELECT 
        EgressTrunkGroup
    ,StartDateTime
    ,DisconnectDateTime
    FROM 
        [dbo].[CDR_RAW]
),
Times AS
(SELECT
        rd.StartDateTime tm
    ,rd.Trunk
    FROM TrunkGroup rd
    UNION
    SELECT
        rd.DisconnectDateTime
    ,rd.Trunk
    FROM TrunkGroup rd),
intervals
AS
(SELECT
        tm tm1
    ,LEAD(tm, 1) OVER (PARTITION BY Trunk ORDER BY tm) tm2
    ,Trunk
    FROM Times)
SELECT
    i.Trunk
,i.tm1
,i.tm2
,COUNT(*) simultaneous
INTO #TEMP
FROM intervals i
INNER JOIN TrunkGroup rd
    ON rd.DisconnectDateTime >= i.tm1
        AND rd.StartDateTime < i.tm2
        AND i.Trunk = rd.Trunk
        AND i.tm2 IS NOT null
GROUP BY i.Trunk
        ,i.tm1
        ,i.tm2
ORDER BY i.Trunk,i.tm1

;

WITH Numbers(val) AS
(
SELECT
    1 
    
    UNION ALL
    
SELECT
    val + 1 
FROM
    numbers 
WHERE
    val < 48
)
SELECT
PeriodSummary.period_start
,PeriodSummary.period_end
,PeriodSummary.Period
,PeriodSummary.Trunk
,PeriodSummary.[all]
,PeriodSummary.simultaneous
FROM
(
    SELECT
    pers.period_start
    ,pers.period_end
    ,@period as [Period]
    ,src.Trunk
    ,src.simultaneous
    ,COUNT(*) as [all]
    FROM
    (
        SELECT
        dateadd(minute, (val - 1) * 30, '20210224') as period_start
        ,dateadd(minute, (val    ) * 30, '20210224') as period_end 
        FROM
        numbers
    ) pers 
INNER JOIN
    #TEMP as src 
    ON  src.tm1 >= pers.period_start
            AND src.tm1 < pers.period_end
GROUP BY
    src.Trunk
    ,pers.period_start
    ,pers.period_end
    ,src.simultaneous
) PeriodSummary

END
GO

EXECUTE [dbo].[GenerateTrunkSumv1] @date = '20210224', @period = 1800, @ST = '2021-02-24 20:00:00.0', @DT = '2021-02-24 22:30:00.0000000', @tn = 'test';
SELECT @@ROWCOUNT as 'Inserted'
GO

此解决方案的问题是，如果时间段使用其中一个值（开始/断开时间）超过 30 分钟标记，我将收到重复的行

电流输出

period_start              period_end                Period  Trunk   all     simultaneous
2021-02-24 20:00:00.0     2021-02-24 20:30:00.0     1800    I1      1       1
2021-02-24 20:00:00.0     2021-02-24 20:30:00.0     1800    I1      1       2
2021-02-24 20:30:00.0     2021-02-24 21:00:00.0     1800    I1      6       1
2021-02-24 20:30:00.0     2021-02-24 21:00:00.0     1800    I1      22      2
2021-02-24 20:30:00.0     2021-02-24 21:00:00.0     1800    I1      16      3
2021-02-24 20:30:00.0     2021-02-24 21:00:00.0     1800    I2      1       1
2021-02-24 20:30:00.0     2021-02-24 21:00:00.0     1800    I2      2       2

正如您在上面看到的，第一行出现了两次，因为它有一个通过标记的条目。

--Surrounding rows causing this issue
I1  2021-02-24 20:23:43.1   2021-02-24 20:24:34.6   1
I1  2021-02-24 20:24:34.6   2021-02-24 20:31:09.5   2
I1  2021-02-24 20:31:09.5   2021-02-24 20:32:32.9   3
I1  2021-02-24 20:32:32.9   2021-02-24 20:32:42.3   3
I1  2021-02-24 20:32:42.3   2021-02-24 20:32:51.4   3
I1  2021-02-24 20:32:51.4   2021-02-24 20:33:05.1   3

有没有人知道一种解决方案，该解决方案可以从必须每 30 分钟（00:00 / 00:30）开始的锁定时段转变为从第一个时间段开始创建 30 分钟。

如果可以更改第二行以反映异常值的开始/断开时间（可选）。

【问题讨论】：

我认为您的逻辑仍然存在故障：您评估每个连接，如果它在前一个连接的时间内。现在想象以下设置：第一个连接从 07:00 开始到 07:15 结束，第二个连接从 07:05 开始到 07:07 结束（在第一个连接内），第三个连接开始在 07:10 到 07:13 结束 - ehich 在第一个连接内，但不在前一个连接内...在这种情况下，您不会将其识别为同时连接，对吗？
这是一个非常好的观点，我已经监督过了。我将看看下面发布的解决方案，女巫不只关注一行。在验证/测试时，我也会考虑这个评论。谢谢！

标签： sql-server stored-procedures aggregate-functions sql-server-2019

【解决方案1】：

如果我要找到同时连接，我不会只看下一个条目。

假设您有每个连接的开始时间和结束时间。使用这些时间制作所有连续的间隔，您将拥有数据集的所有“有趣”间隔。然后将这些间隔与您的原始数据连接起来，您可以计算每个间隔中有多少个连接。因为你总是有事情发生，所以你一定会抓住ecerything。

首先我选择所有时间：

WITH Times
AS
(SELECT
        rd.StartDateTime tm
       ,rd.Trunk
    FROM #raw_data rd
    UNION
    SELECT
        rd.DisconnectDateTime
       ,rd.Trunk
    FROM #raw_data rd)

这只是您数据集的所有时间 - 按主干分组，因为我们希望将它们分开。

然后创建所有区间：

intervals
AS
(SELECT
        tm tm1
       ,LEAD(tm, 1) OVER (PARTITION BY Trunk ORDER BY tm) tm2
       ,Trunk
    FROM Times)

在这里，我们得到一天中的第一个时间，一天中的第二个时间，一天中的第二个时间到一天中的第三个时间等等。也就是说，我们已将所有连接的时间段划分为以 a 开头或结尾的确切时间间隔连接开始或断开。

现在我们只需要结合原始数据来查看每个间隔中有多少连接：

SELECT
    i.Trunk
   ,i.tm1
   ,i.tm2
   ,COUNT(*) simultaneous
FROM intervals i
INNER JOIN #raw_data rd
    ON rd.DisconnectDateTime >= i.tm1
        AND rd.StartDateTime < i.tm2
        AND i.Trunk = rd.Trunk
        AND i.tm2 IS NOT null
GROUP BY i.Trunk
        ,i.tm1
        ,i.tm2
ORDER BY i.trunk,i.tm1

这给出了这个表：

+-------+-----------------------------+-----------------------------+--------------+
| Trunk |             tm1             |             tm2             | simultaneous |
+-------+-----------------------------+-----------------------------+--------------+
| T1    | 2021-02-24 20:01:00.0000000 | 2021-02-24 20:04:50.0000000 |            1 |
| T1    | 2021-02-24 20:04:50.0000000 | 2021-02-24 20:05:20.6000000 |            2 |
| T1    | 2021-02-24 20:05:20.6000000 | 2021-02-24 20:05:30.0000000 |            3 |
| T1    | 2021-02-24 20:05:30.0000000 | 2021-02-24 20:07:50.1000000 |            3 |
| T1    | 2021-02-24 20:07:50.1000000 | 2021-02-24 20:08:24.0000000 |            2 |
| T1    | 2021-02-24 20:08:24.0000000 | 2021-02-24 20:15:50.0000000 |            1 |
| T1    | 2021-02-24 20:15:50.0000000 | 2021-02-24 20:17:00.0000000 |            1 |
| T1    | 2021-02-24 20:17:00.0000000 | 2021-02-24 20:20:50.0000000 |            1 |
| T1    | 2021-02-24 20:20:50.0000000 | 2021-02-24 20:20:59.0000000 |            1 |
| T1    | 2021-02-24 20:20:59.0000000 | 2021-02-24 20:21:00.0000000 |            2 |
| T1    | 2021-02-24 20:21:00.0000000 | 2021-02-24 20:24:00.0000000 |            2 |
| T1    | 2021-02-24 20:24:00.0000000 | 2021-02-24 20:25:00.0000000 |            1 |
| T1    | 2021-02-24 20:25:00.0000000 | 2021-02-24 20:28:30.0000000 |            1 |
| T1    | 2021-02-24 20:28:30.0000000 | 2021-02-24 22:46:54.2000000 |            1 |
| T1    | 2021-02-24 22:46:54.2000000 | 2021-02-24 22:48:25.2000000 |            1 |
| T2    | 2021-02-24 20:41:49.0000000 | 2021-02-24 20:43:24.0000000 |            1 |
| T2    | 2021-02-24 20:43:24.0000000 | 2021-02-24 22:47:25.1000000 |            1 |
| T2    | 2021-02-24 22:47:25.1000000 | 2021-02-24 22:47:54.4000000 |            1 |
+-------+-----------------------------+-----------------------------+--------------+

现在您可以将其加入到您设定的时间段，记住将时间间隔设为开放式，您可以找到每个时间段内同时连接的最大数量。

完整的查询在这里：

WITH Times
AS
(SELECT
        rd.StartDateTime tm
       ,rd.Trunk
    FROM #raw_data rd
    UNION
    SELECT
        rd.DisconnectDateTime
       ,rd.Trunk
    FROM #raw_data rd),
intervals
AS
(SELECT
        tm tm1
       ,LEAD(tm, 1) OVER (PARTITION BY Trunk ORDER BY tm) tm2
       ,Trunk
    FROM Times)
SELECT
    i.Trunk
   ,i.tm1
   ,i.tm2
   ,COUNT(*) simultaneous
FROM intervals i
INNER JOIN #raw_data rd
    ON rd.DisconnectDateTime >= i.tm1
        AND rd.StartDateTime < i.tm2
        AND i.Trunk = rd.Trunk
        AND i.tm2 IS NOT null
GROUP BY i.Trunk
        ,i.tm1
        ,i.tm2
ORDER BY i.trunk,i.tm1

【讨论】：

感谢您将其扩大到比单行更大的范围；我不确定如何存档。我今天将看看这个实现，以确保我完全理解它:)。一旦我尝试一下，您就会收到我的来信。
这项工作非常好，适合我的大部分要求，但是，它对我来说还不是很顺利，目前，正如你提到的，这个时期是开放式的。但是我一直面临着需要将它们分组为块大小（等 30 分钟）以允许 SSRS 中的记者从下拉列表中选择时间跨度（30 分钟、1 小时、24 小时等）的挑战你对此有任何指示吗?
如果我还想计算每个时间段的“所有”连接，你会添加这个吗，因为我们在这里合并表格，我似乎得到了重复的计数（在某些值上）当尝试“选择计数（*）作为全部”时，我将使用示例输出更新我的问题
嘿@søren-kongstad，我现在花了几天时间试图弄清楚如何加入生成的输出以匹配我的 30 分钟标准。不幸的是，虽然我无法完成它。我添加了一个更新，显示了当前结果和我用来实现它的代码。您是否有时间详细说明如何存档？