SQL如何新增session_age列计算会话已持续时长

算力阿峰

2026-10-3

SQL实现会话持续时长计算需求

需求说明

现有用户访问行为数据表，包含timestamp、user_id、session_id、url四个字段，需要新增列session_age，存储对应会话从首次访问到当前记录已持续的时长，单位为分钟。

样例输入表

timestamp	user_id	session_id	url
10:00	1	123	https://a
10:05	1	123	https://b
10:08	2	456	https://b
10:10	1	123	https://c

预期输出表

timestamp	user_id	session_id	url	session_age
10:00	1	123	https://a	0
10:05	1	123	https://b	5
10:08	2	456	https://b	0
10:10	1	123	https://c	10

实现SQL语句

通用写法（支持MySQL8.0+、PostgreSQL、Hive、Spark SQL等所有支持窗口函数的数据库）

SELECT 
    timestamp,
    user_id,
    session_id,
    url,
    -- 时间差计算可根据数据库类型调整，以下为MySQL语法示例
    TIMESTAMPDIFF(MINUTE, FIRST_VALUE(timestamp) OVER (PARTITION BY session_id ORDER BY timestamp), timestamp) AS session_age
FROM 
    user_behavior;

不同数据库适配调整

PostgreSQL版本时间差计算：

EXTRACT(MINUTE FROM (timestamp - FIRST_VALUE(timestamp) OVER (PARTITION BY session_id ORDER BY timestamp))) AS session_age

Hive/Spark SQL版本时间差计算：

(unix_timestamp(timestamp, 'HH:mm') - unix_timestamp(FIRST_VALUE(timestamp) OVER (PARTITION BY session_id ORDER BY timestamp), 'HH:mm')) / 60 AS session_age