Athena中如何在子查询用主查询列？解决关联子查询不支持问题

Athena基于Presto引擎，对**关联子查询（子查询引用外部查询列）**的支持有限，你遇到的Given correlated subquery is not supported错误就是因为原SQL中IN子查询引用了主查询的t1.year/t1.month/t1.day字段。

重构思路 #

将关联子查询转换为LEFT JOIN + 聚合判断的形式，同时优化日期转换逻辑（用DATE_FROM_PARTS替代字符串拼接，更高效易读），实现原逻辑：判断t1.id在table2中是否存在过去12个月内的记录，不存在返回Something，否则返回Something else。

重构后的SQL #

SELECT 
  t1.id,
  t1.year, 
  t1.month, 
  t1.day,
  CASE 
    WHEN COUNT(t2.id) = 0 THEN 'Something' 
    ELSE 'Something else' 
  END AS action
FROM table1 t1
LEFT JOIN table2 t2
  ON t1.id = t2.id
  AND DATE_FROM_PARTS(t2.year, t2.month, t2.day) 
      BETWEEN DATE_FROM_PARTS(t1.year, t1.month, t1.day) - INTERVAL '12' MONTH 
          AND DATE_FROM_PARTS(t1.year, t1.month, t1.day)
GROUP BY t1.id, t1.year, t1.month, t1.day;

关键说明 #

1. 日期转换优化：DATE_FROM_PARTS(year, month, day)直接将数字类型的年月日转换为日期，比字符串拼接+LPAD的方式更高效，且避免格式错误。
2. LEFT JOIN替代关联子查询：通过LEFT JOIN关联t1和t2，关联条件包含原逻辑中的日期范围判断，再通过COUNT(t2.id)统计匹配的记录数：
   • 若COUNT(t2.id) = 0，说明t1.id在table2的过去12个月内无匹配记录，返回Something；
   • 否则返回Something else。
3. GROUP BY的作用：确保t1的每一行数据只返回一条结果，聚合统计对应id的匹配情况。

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