AWS Athena中含Select查询的Merge语句执行失败求助

错误原因 #

你遇到的mismatched input 'select'错误，是因为Athena对Iceberg Merge语句的USING子句有严格语法要求：如果数据源是查询语句，必须将查询包裹在括号内，或者使用TABLE()语法包裹，不能直接以SELECT开头。

正确写法示例 #

假设你的目标Iceberg表为target_table，包含主键id和时间戳字段update_time，新数据需要根据id匹配更新或插入，以下是两种可行写法：

1. 直接使用子查询作为数据源 #

MERGE INTO target_table t
USING (
    SELECT id, new_update_time FROM new_data_source
) s
ON t.id = s.id
WHEN MATCHED THEN
    UPDATE SET t.update_time = s.new_update_time
WHEN NOT MATCHED THEN
    INSERT (id, update_time) VALUES (s.id, s.new_update_time)

2. 使用CTE作为数据源 #

如果需要用CTE处理数据，需将CTE整体放在USING的括号内：

MERGE INTO target_table t
USING (
    WITH processed_data AS (
        SELECT id, new_update_time 
        FROM new_data_source 
        WHERE new_update_time IS NOT NULL
    )
    SELECT id, new_update_time FROM processed_data
) s
ON t.id = s.id
WHEN MATCHED THEN
    UPDATE SET t.update_time = s.new_update_time
WHEN NOT MATCHED THEN
    INSERT (id, update_time) VALUES (s.id, s.new_update_time)

3. 使用TABLE()语法包裹查询 #

也可以用TABLE()替代括号包裹查询：

MERGE INTO target_table t
USING TABLE(
    SELECT id, new_update_time FROM new_data_source
) s
ON t.id = s.id
WHEN MATCHED THEN
    UPDATE SET t.update_time = s.new_update_time
WHEN NOT MATCHED THEN
    INSERT (id, update_time) VALUES (s.id, s.new_update_time)

额外注意事项 #

• 确保目标表是Iceberg格式，且Athena引擎版本为2.x及以上（仅引擎2.x支持Iceberg的Merge操作）
• ON子句的匹配条件建议使用主键或唯一键，避免全表扫描导致性能问题
• 插入时需保证字段顺序和目标表一致，或明确指定字段名

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