add databricks support

Author: tkiehn

macros/hooks/clean_up_pits.sql

@@ -123,4 +123,15 @@ WHERE snap.{{ sdts }} IS NULL
 {{ log("PIT " ~ this ~ " successfully cleaned!", True) }}
 {%- endif -%}
 
+{%- endmacro -%}
+
+{%- macro databricks__clean_up_pit(snapshot_relation, snapshot_trigger_column, sdts) -%}
+
+DELETE FROM {{ this }} pit
+WHERE pit.{{ sdts }} not in (SELECT {{ sdts }} FROM {{ ref(snapshot_relation) }} snap WHERE {{ snapshot_trigger_column }}=TRUE)
+
+{%- if execute -%}
+{{ log("PIT " ~ this ~ " successfully cleaned!", True) }}
+{%- endif -%}
+
 {%- endmacro -%}

macros/internal/metadata_processing/escape_column_names.sql

@@ -184,4 +184,16 @@
 
     {%- do return(escaped_column_name) -%}
 
+{%- endmacro -%}
+
+
+{%- macro databricks__escape_column_name(column) -%}
+
+    {%- set escape_char_left  = var('escape_char_left',  "") -%}
+    {%- set escape_char_right = var('escape_char_right', "") -%}
+
+    {%- set escaped_column_name = escape_char_left ~ column | upper | replace(escape_char_left, '') | replace(escape_char_right, '') | trim ~ escape_char_right | indent(4) -%}
+
+    {%- do return(escaped_column_name) -%}
+
 {%- endmacro -%}