Merge pull request #803 from elementary-data/support-athena-in-deprecated-tests

Support athena in deprecated tests

Author: GuyEshdat

integration_tests/deprecated_tests/models/schema.yml

@@ -347,7 +347,7 @@ models:
   - name: groups
     columns:
       - name: group_a
-        data_type: "{{ 'strIng' if (target.type == 'bigquery' or target.type == 'databricks') else 'CHArACTER varying' if target.type == 'redshift' else 'teXt' }}"
+        data_type: "{{ 'strIng' if (target.type == 'bigquery' or target.type == 'databricks' or target.type == 'athena') else 'CHArACTER varying' if target.type == 'redshift' else 'teXt' }}"
       - name: group_b
         data_type: double
       - name: group_c
@@ -365,7 +365,7 @@ models:
   - name: stats_players
     columns:
       - name: player
-        data_type: "{{ 'STRING' if (target.type == 'bigquery' or target.type == 'databricks') else 'character varying' if target.type == 'redshift' else 'TEXT' }}"
+        data_type: "{{ 'STRING' if (target.type == 'bigquery' or target.type == 'databricks' or target.type == 'athena') else 'character varying' if target.type == 'redshift' else 'TEXT' }}"
       - name: goals
         data_type: BOOLEAN
       - name: coffee_cups_consumed

macros/edr/system/system_utils/full_names.sql

@@ -60,6 +60,19 @@
     trim(split_part(full_table_name,'.',{{ part_index }}),'"') as {{ part_name }}
 {% endmacro %}
 
+{% macro athena__full_name_split(part_name) %}
+    {%- if part_name == 'database_name' -%}
+        {%- set part_index = 1 -%}
+    {%- elif part_name == 'schema_name' -%}
+        {%- set part_index = 2 -%}
+    {%- elif part_name == 'table_name' -%}
+        {%- set part_index = 3 -%}
+    {%- else -%}
+        {{ return('') }}
+    {%- endif -%}
+    trim(split_part(full_table_name,'.',{{ part_index }}),'"') as {{ part_name }}
+{% endmacro %}
+
 
 {% macro databricks__full_name_split(part_name) %}
     {%- if part_name == 'database_name' -%}

macros/utils/cross_db_utils/contains.sql

@@ -30,4 +30,16 @@
             lower({{ string }}) like lower('%{{ string_to_search }}%') then true
         else false end
     {%- endif %}
+{% endmacro %}
+
+{% macro athena__contains(string, string_to_search, case_sensitive) %}
+    {%- if case_sensitive %}
+        case when
+            {{ string }} like '%{{ string_to_search }}%' then true
+        else false end
+    {%- else %}
+        case when
+            lower({{ string }}) like lower('%{{ string_to_search }}%') then true
+        else false end
+    {%- endif %}
 {% endmacro %}