SQL按动态15分钟时间间隔分组请求数据问题求助

嘿，我完全懂你要的是动态的15分钟滑动分组——不是那种固定时间片（比如每小时0-15分、15-30分）的分组，而是以每个组的第一个请求时间为起点，往后覆盖15分钟，只要超过这个窗口的请求就开启全新的分组。你的现有查询用了RANGE BETWEEN INTERVAL '15' MINUTE PRECEDING，但这个逻辑是基于当前行的时间往前推15分钟，不是基于组的起始时间，所以没法正确划分你要的动态分组。

我给你两种可行的解决方案，适用于不同的场景：

方案1：递归CTE（逻辑直观，适合中小数据量） #

这个方法会逐个处理每个用户的请求，判断当前请求是否属于上一个组的时间窗口，不属于就开新组：

WITH sorted_requests AS (
    SELECT 
        ID_CREACION,
        ID_PERSONA,
        ID_MOTIVO,
        ID_FEC_CREACION,
        ID_NUM_SOL,
        ID_SOL,
        -- 给每个用户的请求按时间排序，生成行号方便递归关联
        ROW_NUMBER() OVER (PARTITION BY ID_PERSONA ORDER BY ID_FEC_CREACION) AS rn
    FROM VITAR_AGUS_SOL
),
grouped_requests AS (
    -- 初始组：每个用户的第一个请求，组起始时间就是它的创建时间
    SELECT 
        *,
        ID_FEC_CREACION AS group_start,
        1 AS group_id
    FROM sorted_requests
    WHERE rn = 1

    UNION ALL

    -- 递归判断：当前请求是否在上一个组的15分钟窗口内
    SELECT 
        sr.*,
        -- 若在窗口内则沿用旧组起始时间，否则用当前时间作为新组起点
        CASE WHEN sr.ID_FEC_CREACION <= gr.group_start + (15/1440) 
             THEN gr.group_start 
             ELSE sr.ID_FEC_CREACION 
        END AS group_start,
        -- 若在窗口内组ID不变，否则组ID+1
        CASE WHEN sr.ID_FEC_CREACION <= gr.group_start + (15/1440) 
             THEN gr.group_id 
             ELSE gr.group_id + 1 
        END AS group_id
    FROM sorted_requests sr
    JOIN grouped_requests gr ON sr.ID_PERSONA = gr.ID_PERSONA AND sr.rn = gr.rn + 1
)
-- 最终输出：包含每个请求的分组信息和时间窗口
SELECT 
    ID_CREACION,
    ID_PERSONA,
    ID_MOTIVO,
    ID_FEC_CREACION,
    group_start + (15/1440) AS group_end, -- 组的结束时间（起点+15分钟）
    ID_NUM_SOL,
    ID_SOL,
    group_id
FROM grouped_requests
ORDER BY ID_PERSONA, ID_FEC_CREACION;

方案2：窗口函数累积求和（效率更高，适合大数据量） #

这个方法用窗口函数标记新组，再通过累积求和生成组ID，逻辑更简洁，性能更好：

WITH sorted_requests AS (
    SELECT 
        ID_CREACION,
        ID_PERSONA,
        ID_MOTIVO,
        ID_FEC_CREACION,
        ID_NUM_SOL,
        ID_SOL,
        -- 判断当前请求是否和上一个请求的时间差超过15分钟，是则标记为新组
        CASE WHEN ID_FEC_CREACION > LAG(ID_FEC_CREACION) OVER (PARTITION BY ID_PERSONA ORDER BY ID_FEC_CREACION) + (15/1440)
             THEN 1
             ELSE 0
        END AS is_new_group
    FROM VITAR_AGUS_SOL
)
SELECT 
    *,
    -- 累积求和生成组ID（每次新组加1，最终得到组序号）
    SUM(is_new_group) OVER (PARTITION BY ID_PERSONA ORDER BY ID_FEC_CREACION) + 1 AS group_id,
    -- 获取当前组的起始时间（组内第一个请求的时间）
    FIRST_VALUE(ID_FEC_CREACION) OVER (
        PARTITION BY ID_PERSONA, SUM(is_new_group) OVER (PARTITION BY ID_PERSONA ORDER BY ID_FEC_CREACION) 
        ORDER BY ID_FEC_CREACION
    ) AS group_start,
    -- 组的结束时间
    FIRST_VALUE(ID_FEC_CREACION) OVER (
        PARTITION BY ID_PERSONA, SUM(is_new_group) OVER (PARTITION BY ID_PERSONA ORDER BY ID_FEC_CREACION) 
        ORDER BY ID_FEC_CREACION
    ) + (15/1440) AS group_end
FROM sorted_requests
ORDER BY ID_PERSONA, ID_FEC_CREACION;

说明 #

• 我用了(15/1440)代替INTERVAL '15' MINUTE，因为你的原查询用了类似的日期计算（ID_FEC_CREACION+(1/1440*15)），这更适配Oracle等用天数计算时间差的数据库。如果你的数据库支持INTERVAL语法（比如PostgreSQL），可以直接换成INTERVAL '15 minutes'。
• 两种方案都会按ID_PERSONA分组，确保每个用户的请求独立划分时间窗口。

内容的提问来源于stack exchange，提问作者R P