Merge pull request #242 from ScalefreeCOM/fix-hub-key-renaming-for-single-source-hubs

fix hub key renaming if there are different namings for bk and hkey

Author: tkirschke

macros/tables/bigquery/hub.sql

@@ -147,7 +147,7 @@ WITH
         SELECT
             {{ hk_column }} AS {{ hashkey }},
             {% for bk in source_model['bk_columns'] -%}
-            {{ bk }},
+            {{ bk }} AS {{ business_keys[loop.index - 1] }},
             {% endfor -%}
 
             {{ src_ldts }},
@@ -188,7 +188,7 @@ source_new_union AS (
         {{ hashkey }},
 
         {% for bk in source_model['bk_columns'] -%}
-            {{ bk }} AS {{ business_keys[loop.index - 1] }},
+            {{ business_keys[loop.index - 1] }},
         {% endfor -%}
 
         {{ src_ldts }},

macros/tables/exasol/hub.sql

@@ -145,7 +145,7 @@ WITH
         SELECT
             {{ hk_column }} AS {{ hashkey }},
             {% for bk in source_model['bk_columns'] -%}
-            {{ bk }},
+            {{ bk }} AS {{ business_keys[loop.index - 1] }},
             {% endfor -%}
 
             {{ src_ldts }},
@@ -186,7 +186,7 @@ source_new_union AS (
         {{ hashkey }},
 
         {% for bk in source_model['bk_columns'] -%}
-            {{ bk }} AS {{ business_keys[loop.index - 1] }},
+            {{ business_keys[loop.index - 1] }},
         {% endfor -%}
 
         {{ src_ldts }},

macros/tables/postgres/hub.sql

@@ -147,7 +147,7 @@ WITH
         SELECT
             {{ hk_column }} AS {{ hashkey }},
             {% for bk in source_model['bk_columns'] -%}
-            {{ bk }},
+            {{ bk }} AS {{ business_keys[loop.index - 1] }},
             {% endfor -%}
 
             {{ src_ldts }},
@@ -188,7 +188,7 @@ source_new_union AS (
         {{ hashkey }},
 
         {% for bk in source_model['bk_columns'] -%}
-            {{ bk }} AS {{ business_keys[loop.index - 1] }},
+            {{ business_keys[loop.index - 1] }},
         {% endfor -%}
 
         {{ src_ldts }},

macros/tables/redshift/hub.sql

@@ -147,7 +147,7 @@ WITH
         SELECT
             {{ hk_column }} AS {{ hashkey }},
             {% for bk in source_model['bk_columns'] -%}
-            {{ bk }},
+            {{ bk }} AS {{ business_keys[loop.index - 1] }},
             {% endfor -%}
 
             {{ src_ldts }},
@@ -188,7 +188,7 @@ source_new_union AS (
         {{ hashkey }},
 
         {% for bk in source_model['bk_columns'] -%}
-            {{ bk }} AS {{ business_keys[loop.index - 1] }},
+            {{ business_keys[loop.index - 1] }},
         {% endfor -%}
 
         {{ src_ldts }},

macros/tables/synapse/hub.sql

@@ -147,7 +147,7 @@ WITH
         SELECT
             {{ hk_column }} AS {{ hashkey }},
             {% for bk in source_model['bk_columns'] -%}
-            {{ bk }},
+            {{ bk }} AS {{ business_keys[loop.index - 1] }},
             {% endfor -%}
 
             {{ src_ldts }},
@@ -188,7 +188,7 @@ source_new_union AS (
         {{ hashkey }},
 
         {% for bk in source_model['bk_columns'] -%}
-            {{ bk }} AS {{ business_keys[loop.index - 1] }},
+            {{ business_keys[loop.index - 1] }},
         {% endfor -%}
 
         {{ src_ldts }},