我有一个t-sql语句。其检查日期,并且如果其为真,则其将继续执行(插入)。
IF EXISTS (SELECT dateadd(day,+1,CAST(SnapshotDate as date)) FROM CONFIG.[SnapshotDateTables] WHERE dateadd(day,+1,CAST(SnapshotDate as date)) = CAST(GETDATE() as date))
INSERT INTO [DWH].[F_TIMESHEET_FREEZE]
我怎么能用sql或pyspark在数据库中实现类似的事情,没有偏好。
2条答案
按热度按时间xtfmy6hx1#
您可以尝试在databricks SQL中使用
where
子句,如注解中所建议的。通过下面的演示:
这里我在sample2表中有两行。
我已经创建了所需的地方,我们需要插入值,我插入表的条件如下。
条件为true时:
条件为false时:
5vf7fwbs2#
如果在Databricks中使用SQL:
然后将
SELECT ...
替换为您的查询,以便插入到DWH.F_TIMESHEET_FREEZE
表中。如果你在Databricks中使用PySpark:
用DataFrame创建逻辑替换
df_insert = ...
,以便插入到DWH.F_TIMESHEET_FREEZE
表中。