Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

persist view column comments #866

Closed
wants to merge 10 commits into from
Closed

persist view column comments #866

Changes from 2 commits
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
82ee516
persist view column comments
jurasan Aug 9, 2023
2bc4914
format: whitespace
jurasan Aug 14, 2023
2b8fef6
extracted get_matched_column macro
jurasan Aug 17, 2023
a15cada
move parenthesis to the calling macro
jurasan Aug 17, 2023
9c5138f
changelog
jurasan Aug 17, 2023
5658e5b
Merge branch 'main' into persist_view_column_comments
jurasan Aug 21, 2023
50e602e
fix: remove matching column in different case
jurasan Sep 8, 2023
1ea4178
fix: remove get_matched_column macro - not much logic left there.
jurasan Sep 8, 2023
9916483
Merge branch 'main' into persist_view_column_comments
jurasan Sep 8, 2023
f8ff20a
Merge branch 'main' into persist_view_column_comments
jurasan Sep 12, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
29 changes: 29 additions & 0 deletions dbt/include/spark/macros/adapters.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -229,9 +229,38 @@
{% endfor %}
{% endmacro %}

{% macro get_column_comment_sql(column_name, column_dict) -%}
{% if (column_name|upper in column_dict) -%}
mikealfare marked this conversation as resolved.
Show resolved Hide resolved
{% set matched_column = column_name|upper -%}
{% elif (column_name|lower in column_dict) -%}
{% set matched_column = column_name|lower -%}
{% elif (column_name in column_dict) -%}
{% set matched_column = column_name -%}
{% else -%}
{% set matched_column = None -%}
{% endif -%}
{% if matched_column and column_dict[matched_column]["description"] -%}
mikealfare marked this conversation as resolved.
Show resolved Hide resolved
{% set column_comment_clause = "comment '" ~ column_dict[matched_column]["description"] ~ "'" %}
{%- endif -%}
{{ adapter.quote(column_name) }} {{ column_comment_clause }}
mikealfare marked this conversation as resolved.
Show resolved Hide resolved
{% endmacro %}

{% macro get_persist_docs_column_list(model_columns, query_columns) %}
(
mikealfare marked this conversation as resolved.
Show resolved Hide resolved
{% for column_name in query_columns %}
{{ get_column_comment_sql(column_name, model_columns) }}
{{- ", " if not loop.last else "" }}
mikealfare marked this conversation as resolved.
Show resolved Hide resolved
{% endfor %}
)
{% endmacro %}

{% macro spark__create_view_as(relation, sql) -%}
create or replace view {{ relation }}
{% if config.persist_column_docs() -%}
{% set model_columns = model.columns %}
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Where are the model columns coming from?

{% set query_columns = get_columns_in_query(sql) %}
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Does this mean that the SQL of the view executed when creating the view with persist_docs.columns = true?

Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Issuing the get_columns_in_query query against one of the largest table internally at Databricks returned in 148 ms. It is sufficiently performant.

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Regardless of the time, does it execute the SQL to get the columns?

Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It executes a limit 0.

{{ get_persist_docs_column_list(model_columns, query_columns) }}
{% endif %}
{{ comment_clause() }}
{%- set contract_config = config.get('contract') -%}
{%- if contract_config.enforced -%}
Expand Down