yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-06 07:32:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

MINOR: Fix Table constraint relationships for SoftDeleted entities. (#19129)

Browse Source 
* Update TableRepository.java

* Fix Checkstyle
This commit is contained in:
IceS2 2024-12-19 10:20:21 +01:00 committed by Sriharsha Chintalapani
parent d5360073c6
commit ae4658f85d
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/TableRepository.java
View File

@ -1138,7 +1138,7 @@ public class TableRepository extends EntityRepository<Table> {
String toParent = FullyQualifiedName.getParentFQN(column); String toParent = FullyQualifiedName.getParentFQN(column);
String columnName = FullyQualifiedName.getColumnName(column); String columnName = FullyQualifiedName.getColumnName(column);
try { try {
Table toTable = findByName(toParent, NON_DELETED); Table toTable = findByName(toParent, ALL);
validateColumn(toTable, columnName); validateColumn(toTable, columnName);
} catch (EntityNotFoundException e) { } catch (EntityNotFoundException e) {
throw new EntitySpecViolationException("Table not found: " + toParent); throw new EntitySpecViolationException("Table not found: " + toParent);
@ -1232,8 +1232,7 @@ public class TableRepository extends EntityRepository<Table> {
for (String column : constraint.getReferredColumns()) { for (String column : constraint.getReferredColumns()) {
String toParent = FullyQualifiedName.getParentFQN(column); String toParent = FullyQualifiedName.getParentFQN(column);
try { try {
EntityReference toTable = EntityReference toTable = Entity.getEntityReferenceByName(TABLE, toParent, ALL);
Entity.getEntityReferenceByName(TABLE, toParent, NON_DELETED);
addRelationship( addRelationship(
table.getId(), toTable.getId(), TABLE, TABLE, Relationship.RELATED_TO); table.getId(), toTable.getId(), TABLE, TABLE, Relationship.RELATED_TO);
} catch (EntityNotFoundException e) { } catch (EntityNotFoundException e) {