Adding ability to install re_data for Greenplum database (#102)

Author: mrprigun

macros/db/postgres/postgres_type_db.sql

@@ -0,0 +1,3 @@
+{% macro postgres_type_db() %}
+    {{ ('postgres', 'greenplum') }}
+{% endmacro %}

macros/utils/json/to_single_json.sql

@@ -1,11 +1,11 @@
 {% macro to_json_string_value_or_null(column) %}
     (
         case 
-            when {{column}} is null then 'null'
+            when {{ column }} is null then 'null'
             else '"' ||
                 regexp_replace(
-                    replace(cast({{column}} as {{string_type()}}), '"', {{escape_seq_for_json('"') }}),
-                    '\n', {{ quote_new_line() }} {% if target.type == 'postgres' %}, 'g' {% endif %}
+                    replace(cast({{ column }} as {{ string_type() }}), '"', {{ escape_seq_for_json('"') }}),
+                    '\n', {{ quote_new_line() }} {% if target.type in postgres_type_db() %}, 'g' {% endif %}
                 ) || '"'
         end
     )
@@ -19,4 +19,4 @@
         {%- if not loop.last %} || ',' || {%- endif %}
     {%- endfor %}
     || '}'
-{% endmacro %}
+{% endmacro %}

models/metrics/for_anomalies/re_data_last_stats.sql

@@ -6,7 +6,7 @@ with median_value as (
         column_name,
         metric,
         interval_length_sec,
-        avg(value) {% if target.type != 'postgres' %} over(partition by {{ columns_to_group_by }}) {% endif %} as last_avg,
+        avg(value) {% if target.type not in postgres_type_db() %} over(partition by {{ columns_to_group_by }}) {% endif %} as last_avg,
         {{ percentile(percentile_field='value', partition_field=columns_to_group_by, percent='0.25') }} as last_first_quartile,
         {{ percentile(percentile_field='value', partition_field=columns_to_group_by, percent='0.5') }} as last_median,
         {{ percentile(percentile_field='value', partition_field=columns_to_group_by, percent='0.75') }} as last_third_quartile
@@ -15,7 +15,7 @@ with median_value as (
     where
         time_window_end > {{- anamaly_detection_time_window_start() -}} and
         time_window_end <= {{- time_window_end() -}}
-    {% if target.type == 'postgres' %} 
+    {% if target.type in postgres_type_db() %} 
         group by
             {{ columns_to_group_by }}
     {% endif %}
@@ -46,11 +46,11 @@ with median_value as (
         column_name,
         metric,
         interval_length_sec,
-        avg(absolute_deviation_from_mean) {% if target.type != 'postgres' %} over(partition by {{ columns_to_group_by }}) {% endif %} as mean_absolute_deviation,
+        avg(absolute_deviation_from_mean) {% if target.type not in postgres_type_db() %} over(partition by {{ columns_to_group_by }}) {% endif %} as mean_absolute_deviation,
         {{ percentile(percentile_field='absolute_deviation_from_median', partition_field=columns_to_group_by, percent='0.5') }} as median_absolute_deviation
     from
         abs_deviation
-    {% if target.type == 'postgres' %} 
+    {% if target.type in postgres_type_db() %} 
         group by
             {{ columns_to_group_by }}
     {% endif %}