Untitled

 avatar
unknown
plain_text
a year ago
433 B
5
Indexable
merge_columns = ["name", "value"]

# Create the dynamic merge query
merge_query = f"""
MERGE INTO hive_db.target_table AS target
USING temp_view AS source
ON target.id = source.id
WHEN MATCHED THEN
    UPDATE SET {', '.join([f'target.{col} = source.{col}' for col in merge_columns])}
WHEN NOT MATCHED THEN
    INSERT (id, {', '.join(merge_columns)})
    VALUES (source.id, {', '.join([f'source.{col}' for col in merge_columns])})
"""
Editor is loading...
Leave a Comment