Skip to content

Commit fe70b94

Browse files
committed
remove transaction for bigquery
1 parent 2c599d1 commit fe70b94

File tree

1 file changed

+15
-0
lines changed

1 file changed

+15
-0
lines changed

macros/utils/table_operations/delete_and_insert.sql

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -132,3 +132,18 @@
132132

133133
{% do return(queries) %}
134134
{% endmacro %}
135+
136+
{% macro bigquery__get_delete_and_insert_queries(relation, insert_relation, delete_relation, delete_column_key) %}
137+
{% set query %}
138+
{% if delete_relation %}
139+
delete from {{ relation }}
140+
where
141+
{{ delete_column_key }} is null
142+
or {{ delete_column_key }} in (select {{ delete_column_key }} from {{ delete_relation }});
143+
{% endif %}
144+
{% if insert_relation %}
145+
insert into {{ relation }} select * from {{ insert_relation }};
146+
{% endif %}
147+
{% endset %}
148+
{% do return([query]) %}
149+
{% endmacro %}

0 commit comments

Comments
 (0)