yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-26 01:15:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix Duplicate table constraints (#19502)

Browse Source
This commit is contained in:
Suman Maharana 2025-01-24 13:35:53 +05:30 committed by GitHub
parent 1e7377c2e4
commit 94ed7e3c1a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 15 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ingestion/src/metadata/ingestion/source/database/common_db_source.py
View File

@ -683,7 +683,7 @@ class CommonDbSourceService(
foreign_constraint = self._prepare_foreign_constraints(
supports_database, column, table_name, schema_name, db_name, columns
)
if foreign_constraint:
if foreign_constraint and foreign_constraint not in foreign_constraints:
foreign_constraints.append(foreign_constraint)
return foreign_constraints
@ -707,7 +707,11 @@ class CommonDbSourceService(
)
if foreign_table_constraints:
if table_constraints:
table_constraints.extend(foreign_table_constraints)
table_constraints.extend(
constraint
for constraint in foreign_table_constraints
if constraint not in table_constraints
)
else:
table_constraints = foreign_table_constraints
return table_constraints

14
ingestion/src/metadata/ingestion/source/database/sql_column_handler.py
View File

@ -226,12 +226,16 @@ class SqlColumnHandlerMixin:
if len(col) == 1:
column_level_unique_constraints.add(col[0])
else:
table_constraints.append(
TableConstraint(
constraintType=ConstraintType.UNIQUE,
columns=col,
if not any(
tc.constraintType == ConstraintType.UNIQUE and tc.columns == col
for tc in table_constraints
):
table_constraints.append(
TableConstraint(
constraintType=ConstraintType.UNIQUE,
columns=col,
)
)
)
if len(pk_columns) > 1:
table_constraints.append(
TableConstraint(