Skip to content

Commit 044d5a8

Browse files
committed
do it the same as in trino
1 parent fe70b94 commit 044d5a8

File tree

1 file changed

+15
-7
lines changed

1 file changed

+15
-7
lines changed

macros/utils/table_operations/delete_and_insert.sql

Lines changed: 15 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -134,16 +134,24 @@
134134
{% endmacro %}
135135

136136
{% macro bigquery__get_delete_and_insert_queries(relation, insert_relation, delete_relation, delete_column_key) %}
137-
{% set query %}
138-
{% if delete_relation %}
137+
{% set queries = [] %}
138+
139+
{% if delete_relation %}
140+
{% set delete_query %}
139141
delete from {{ relation }}
140142
where
141143
{{ delete_column_key }} is null
142144
or {{ delete_column_key }} in (select {{ delete_column_key }} from {{ delete_relation }});
143-
{% endif %}
144-
{% if insert_relation %}
145+
{% endset %}
146+
{% do queries.append(delete_query) %}
147+
{% endif %}
148+
149+
{% if insert_relation %}
150+
{% set insert_query %}
145151
insert into {{ relation }} select * from {{ insert_relation }};
146-
{% endif %}
147-
{% endset %}
148-
{% do return([query]) %}
152+
{% endset %}
153+
{% do queries.append(insert_query) %}
154+
{% endif %}
155+
156+
{% do return(queries) %}
149157
{% endmacro %}

0 commit comments

Comments
 (0)