如何将 SQL Date ADD 脚本迁移为 Spark 支持的 SQL 格式

Question

我必须为了增量加载目的实现删除操作，因此我必须执行以下查询语句来迁移支持的 Spark SQL。 基于 SQL 的查询

DATEADD(DAY, 1, EOMONTH(CURRENT_TIMESTAMP, -2))

期望如何在不更改上述脚本的输出的情况下使用支持的spark。

Answer 1

使用下面的databricks SQL查询来实现您的要求。这里它使用

add_months()

和

last_day()

函数的组合，其中

last_day()

函数给出该月的最后一天，下一个函数添加或删除所需的月份。

select date_add(add_months(last_day(current_date()),-2),1) as mydate;

结果：