yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-10-27 16:55:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix #20746: DB columns in Vertica (#21288)

Browse Source
This commit is contained in:
Mayur Singal 2025-05-20 11:06:29 +05:30 committed by GitHub
parent bbc450b2d1
commit 35d8c2a25c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
ingestion/src/metadata/ingestion/source/database/vertica/queries.py
View File

@ -28,20 +28,6 @@ import textwrap
# v_catalog.comments with v_catalog.columns.
VERTICA_GET_COLUMNS = textwrap.dedent(
"""
WITH column_projection as (
SELECT
column_id,
proj.projection_name
FROM v_catalog.columns col,
v_catalog.projections proj
where lower(table_name) = '{table}'
AND {schema_condition}
AND proj.projection_id in (
select
min(projection_id)
from v_catalog.projections sub_proj
where col.table_id=sub_proj.anchor_table_id
))
select
column_name,
data_type,
@ -50,12 +36,11 @@ VERTICA_GET_COLUMNS = textwrap.dedent(
comment
from
v_catalog.columns col
LEFT JOIN column_projection proj ON proj.column_id = col.column_id
LEFT JOIN v_catalog.comments com ON com.object_type = 'COLUMN'
AND com.object_name = CONCAT(
CONCAT(proj.projection_name, '.'),
col.column_name
)
LEFT JOIN v_catalog.comments cm
ON col.table_schema = cm.object_schema
AND col.table_name = cm.object_name
AND col.column_name = cm.child_object
AND cm.object_type = 'COLUMN'
WHERE
lower(table_name) = '{table}'
AND {schema_condition}