Merge pull request #74 from fishtown-analytics/adapter-hash

hash macro + update surrogate_key

integration_tests/data/cross_db/data_hash.csv

@@ -0,0 +1,5 @@
+input_1,output
+ab,187ef4436122d1cc2f40dc2b92f0eba0
+a,0cc175b9c0f1b6a831c399e269772661
+1,c4ca4238a0b923820dcc509a6f75849b
+,d41d8cd98f00b204e9800998ecf8427e	

integration_tests/models/cross_db_utils/schema.yml

@@ -24,6 +24,11 @@ test_datediff:
         assert_equal:
             - { actual: actual, expected: expected }
 
+test_hash:
+    constraints:
+        assert_equal:
+            - { actual: actual, expected: expected }
+
 test_last_day:
     constraints:
         assert_equal:

integration_tests/models/cross_db_utils/test_hash.sql

@@ -0,0 +1,12 @@
+
+with data as (
+
+    select * from {{ ref('data_hash') }}
+
+)
+
+select
+    {{ dbt_utils.hash('input_1') }} as actual,
+    output as expected
+
+from data

macros/cross_db_utils/hash.sql

@@ -0,0 +1,13 @@
+{% macro hash(field) -%}
+  {{ adapter_macro('dbt_utils.hash', field) }}
+{%- endmacro %}
+
+
+{% macro default__hash(field) -%}
+    md5(cast({{field}} as {{dbt_utils.type_string()}}))
+{%- endmacro %}
+
+
+{% macro bigquery__hash(field) -%}
+    to_hex({{dbt_utils.default__hash(field)}})
+{%- endmacro %}

macros/sql/surrogate_key.sql

@@ -14,6 +14,6 @@
 
 {%- endfor -%}
 
-md5({{dbt_utils.concat(fields)}})
+{{dbt_utils.hash(dbt_utils.concat(fields))}}
 
 {%- endmacro -%}