Databricks/Spark SQL中CTE能否与INSERT配合使用？请求验证指定SQL语句有效性

嗨，没问题！Databricks/Spark SQL完全支持在INSERT语句中搭配CTE（公用表表达式）使用，你写的这条SQL从语法层面来看是有效的，不过我可以给你提几个细节点和优化建议：

• 首先，你的语句结构完全合规：通过两个CTE分别处理数据映射和计算，最后将CTE的查询结果插入目标表，这种写法在Spark SQL里是标准用法，Databricks可以正常解析执行。
• 小细节优化：
  • 第一个CTE city_mapping 里的 group by 1,2,3,4 其实没有必要——你只是查询了四个字段，没有使用任何聚合函数，这个分组操作不会改变数据结果，反而会增加额外的计算开销，建议直接去掉。
  • 语句里的 current_date-1 最好写成 current_date()-1，虽然部分环境允许省略函数括号，但标准的Spark SQL语法要求函数带括号，这样能避免潜在的解析问题。
  • 请确认目标表 pqr.public.abc 的字段结构：你最终插入的是 city, store_id, total_rr 三个字段，要保证目标表的字段数量、顺序、数据类型和这三个字段完全匹配，否则会出现插入失败的情况。

你的原SQL语句格式化后如下：

insert into pqr.public.abc
with city_mapping as
(
 select date, store_id, code, city from pqr.public.def where date >= current_date-1
 group by 1,2,3,4
)
, runrate as(
select a.date,
  case when city is null then 'Null' else city end as city,
  a.store_id, b.code, round(sum(runrate),4) total_rr from pqr.public.lmn a
left join city_mapping b
on a.store_id = b.store_id and a.date = b.date
where a.date >= current_date-1
group by 1,2,3,4
)
select city, store_id, total_rr from runrate

备注：内容来源于stack exchange，提问作者azuresnowflake1