File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
dbt/include/oracle/macros/materializations/incremental Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 99
99
{%- set target_relation = args_dict[" target_relation" ] -%}
100
100
{%- set dest_column_names = dest_columns | map(attribute='name') | list -%}
101
101
{%- set dest_cols_csv = get_quoted_column_csv(model, dest_column_names) -%}
102
- INSERT INTO {% if parallel %} /*+parallel ({{ parallel }})*/ {% endif %} {{ target_relation }} ({{ dest_cols_csv }})
102
+ INSERT {% if parallel %} /*+PARALLEL ({{ parallel }})*/ {% endif %} INTO {{ target_relation }} ({{ dest_cols_csv }})
103
103
(
104
104
SELECT {{ dest_cols_csv }}
105
105
FROM {{ temp_relation }}
122
122
{%- set unique_key_result = oracle_check_and_quote_unique_key_for_incremental_merge(unique_key, incremental_predicates) -%}
123
123
{%- set unique_key_list = unique_key_result['unique_key_list'] -%}
124
124
{%- set unique_key_merge_predicates = unique_key_result['unique_key_merge_predicates'] -%}
125
- merge into {% if parallel %} /*+parallel({{ parallel }})*/ {% endif %} {{ target_relation }} DBT_INTERNAL_DEST
125
+ merge {% if parallel %} /*+parallel({{ parallel }})*/ {% endif %} into {{ target_relation }} DBT_INTERNAL_DEST
126
126
using {{ temp_relation }} DBT_INTERNAL_SOURCE
127
127
on ({{ unique_key_merge_predicates | join(' AND ') }})
128
128
when matched then
138
138
{% endfor -%}
139
139
)
140
140
{%- else -%}
141
- insert into {% if parallel %} /*+parallel({{ parallel }})*/ {% endif %} {{ target_relation }} ({{ dest_cols_csv }})
141
+ insert {% if parallel %} /*+parallel({{ parallel }})*/ {% endif %} into {{ target_relation }} ({{ dest_cols_csv }})
142
142
(
143
143
select {{ dest_cols_csv }}
144
144
from {{ temp_relation }}
You can’t perform that action at this time.
0 commit comments