Teradata SQL行转列实现电商客户旅程数据转换咨询

你之前操作效果不佳的核心原因是混淆了转置方向：你需要的是行转列（PIVOT），而TD_UNPIVOT是列转行操作，方向完全相反；CASE语句失效通常是因为没加聚合函数匹配分组语法。

以下是三种可行方案，按适配场景排序：

方案1：通用CASE WHEN聚合（适配所有SQL环境） #

这是兼容性最高的方案，只需要给每个序号的CASE语句套一层聚合函数（MAX/MIN均可，因为同一会话同一步骤只会有一条页面记录，聚合仅用来匹配GROUP BY语法，不会修改结果）：

SELECT
  session_id,
  MAX(CASE WHEN visit_index = 1 THEN page_type END) AS step_1_page,
  MAX(CASE WHEN visit_index = 2 THEN page_type END) AS step_2_page,
  MAX(CASE WHEN visit_index = 3 THEN page_type END) AS step_3_page,
  -- 按实际业务中会话的最大访问步长依次补充即可
  MAX(CASE WHEN visit_index = N THEN page_type END) AS step_N_page
FROM session_page_log -- 替换为你的实际表名
GROUP BY session_id
ORDER BY session_id;

方案2：Teradata原生PIVOT函数（代码更简洁） #

因为你使用的是Teradata环境，可以直接用原生PIVOT函数减少重复代码：

SELECT *
FROM session_page_log -- 替换为你的实际表名
PIVOT (
  MAX(page_type) -- 同上述聚合逻辑
  FOR visit_index IN (
    1 AS step_1_page,
    2 AS step_2_page,
    3 AS step_3_page,
    -- 补充到你需要的最大步长
    N AS step_N_page
  )
) AS pivoted_session_journey
ORDER BY session_id;

方案3：动态SQL生成列（适配访问步长不固定场景） #

如果会话访问步长波动很大，手动写列成本过高，可以用动态SQL自动拼接语句执行，Teradata下的存储过程实现逻辑参考：

-- 第一步：查询所有会话的最大访问步长
SELECT MAX(visit_index) INTO :max_step FROM session_page_log;

-- 第二步：动态拼接查询语句
SET @sql = 'SELECT session_id ';
FOR i IN 1..max_step DO
  SET @sql = @sql || ', MAX(CASE WHEN visit_index = ' || i || ' THEN page_type END) AS step_' || i || '_page';
END FOR;
SET @sql = @sql || ' FROM session_page_log GROUP BY session_id ORDER BY session_id;';

-- 第三步：执行拼接完成的SQL
EXECUTE IMMEDIATE @sql;

特殊场景备选方案 #

如果单会话最大访问步长超过50，不建议强行转成宽表，可以直接用数组聚合整段旅程，Teradata支持直接生成数组字段：

SELECT
  session_id,
  ARRAY_AGG(page_type ORDER BY visit_index) AS page_journey
FROM session_page_log
GROUP BY session_id;

后续使用时直接按下标读取对应步骤的页面类型即可，存储和查询效率都更高。

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