sub_strategy

Author: borjavb

dbt/include/bigquery/macros/materializations/incremental_strategy/insert_overwrite.sql

@@ -212,4 +212,4 @@
         raise using message = FORMAT("Error: %s", @@error.message);
         rollback transaction;
     end
-{% endmacro %}
+{% endmacro %}

tests/functional/adapter/incremental/incremental_strategy_fixtures.py

@@ -611,3 +611,51 @@
 }}
 select * from {{ ref('input_model') }}
 """
+
+overwrite_static_day_delete_and_insert_sub_strategy_sql = """
+{% set partitions_to_replace = [
+  "'2020-01-01'",
+  "'2020-01-02'",
+] %}
+
+{{
+    config(
+        materialized="incremental",
+        incremental_strategy="insert_overwrite",
+        insert_overwrite_fn='delete+insert',
+        cluster_by="id",
+        partition_by={
+            "field": "date_time",
+            "data_type": "datetime",
+            "granularity": "day"
+        },
+        partitions=partitions_to_replace,
+        on_schema_change="sync_all_columns"
+    )
+}}
+
+
+with data as (
+
+    {% if not is_incremental() %}
+
+        select 1 as id, cast('2020-01-01' as datetime) as date_time union all
+        select 2 as id, cast('2020-01-01' as datetime) as date_time union all
+        select 3 as id, cast('2020-01-01' as datetime) as date_time union all
+        select 4 as id, cast('2020-01-01' as datetime) as date_time
+
+    {% else %}
+
+        -- we want to overwrite the 4 records in the 2020-01-01 partition
+        -- with the 2 records below, but add two more in the 2020-01-02 partition
+        select 10 as id, cast('2020-01-01' as datetime) as date_time union all
+        select 20 as id, cast('2020-01-01' as datetime) as date_time union all
+        select 30 as id, cast('2020-01-02' as datetime) as date_time union all
+        select 40 as id, cast('2020-01-02' as datetime) as date_time
+
+    {% endif %}
+
+)
+
+select * from data
+""".lstrip()

tests/functional/adapter/incremental/test_incremental_strategies.py

@@ -27,6 +27,7 @@
     overwrite_day_with_time_ingestion_sql,
     overwrite_day_with_time_partition_datetime_sql,
     overwrite_static_day_sql,
+    overwrite_static_day_delete_and_insert_sub_strategy_sql,
 )
 
 
@@ -50,6 +51,7 @@ def models(self):
             "incremental_overwrite_day_with_time_partition.sql": overwrite_day_with_time_ingestion_sql,
             "incremental_overwrite_day_with_time_partition_datetime.sql": overwrite_day_with_time_partition_datetime_sql,
             "incremental_overwrite_static_day.sql": overwrite_static_day_sql,
+            "incremental_overwrite_static_day_with_deleteinsert.sql": overwrite_static_day_delete_and_insert_sub_strategy_sql
         }
 
     @pytest.fixture(scope="class")
@@ -85,6 +87,7 @@ def test__bigquery_assert_incremental_configurations_apply_the_right_strategy(se
                 "incremental_overwrite_day_with_time_partition_expected",
             ),
             ("incremental_overwrite_static_day", "incremental_overwrite_day_expected"),
+            ("incremental_overwrite_static_day_with_deleteinsert", "incremental_overwrite_day_expected"),
         ]
         db_with_schema = f"{project.database}.{project.test_schema}"
         for incremental_strategy in incremental_strategies: