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

MINOR: Fix delete lineage in case of override lineage enabled (#17625)

Browse Source
This commit is contained in:
Mayur Singal 2024-08-29 15:46:58 +05:30 committed by ulixius9
parent c23fdc88b4
commit d8ec47e787
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/CollectionDAO.java
View File

@ -1020,13 +1020,13 @@ public interface CollectionDAO {
value = value =
"DELETE FROM entity_relationship " "DELETE FROM entity_relationship "
+ "WHERE JSON_UNQUOTE(JSON_EXTRACT(json, '$.source')) = :source AND toId = :toId AND toEntity = :toEntity " + "WHERE JSON_UNQUOTE(JSON_EXTRACT(json, '$.source')) = :source AND toId = :toId AND toEntity = :toEntity "
+ "AND relation = :relation ORDER BY fromId", + "AND relation = :relation",
connectionType = MYSQL) connectionType = MYSQL)
@ConnectionAwareSqlUpdate( @ConnectionAwareSqlUpdate(
value = value =
"DELETE FROM entity_relationship " "DELETE FROM entity_relationship "
+ "WHERE json->>'source' = :source AND (toId = :toId AND toEntity = :toEntity) " + "WHERE json->>'source' = :source AND (toId = :toId AND toEntity = :toEntity) "
+ "AND relation = :relation ORDER BY fromId", + "AND relation = :relation",
connectionType = POSTGRES) connectionType = POSTGRES)
void deleteLineageBySource( void deleteLineageBySource(
@BindUUID("toId") UUID toId, @BindUUID("toId") UUID toId,