From c092735fce8b0a32e2e60fe9504a2229d3987b5f Mon Sep 17 00:00:00 2001 From: aji-aju <37380177+aji-aju@users.noreply.github.com> Date: Wed, 16 Apr 2025 16:27:17 +0530 Subject: [PATCH] Column tag glossary export (#20858) * Column tags/ glossary not importing bug fic * Column tags/ glossary not importing bug fix --------- Co-authored-by: Ashish Gupta --- .../org/openmetadata/service/jdbi3/DatabaseRepository.java | 3 ++- .../openmetadata/service/jdbi3/DatabaseSchemaRepository.java | 3 +++ 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/DatabaseRepository.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/DatabaseRepository.java index 29a89bad62b..807c5b0a9b1 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/DatabaseRepository.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/DatabaseRepository.java @@ -28,6 +28,7 @@ import java.util.ArrayList; import java.util.Comparator; import java.util.List; import java.util.Objects; +import java.util.Set; import java.util.UUID; import lombok.extern.slf4j.Slf4j; import org.apache.commons.csv.CSVPrinter; @@ -315,7 +316,7 @@ public class DatabaseRepository extends EntityRepository { for (Table table : tables) { // Add the table entity addEntityToCSV(csvFile, table, TABLE); - + tableRepository.setFieldsInternal(table, new Fields(Set.of("columns", "tags"))); // Add all columns as separate rows tableRepository.exportColumnsRecursively(table, csvFile); } diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/DatabaseSchemaRepository.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/DatabaseSchemaRepository.java index 545dceab1cd..f60d1c9d513 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/DatabaseSchemaRepository.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/DatabaseSchemaRepository.java @@ -30,6 +30,7 @@ import java.util.Collections; import java.util.Comparator; import java.util.List; import java.util.Objects; +import java.util.Set; import java.util.UUID; import lombok.extern.slf4j.Slf4j; import org.apache.commons.csv.CSVPrinter; @@ -210,6 +211,8 @@ public class DatabaseSchemaRepository extends EntityRepository { tableRepository.listAllForCSV( tableRepository.getFields("owners,tags,domain,extension"), schema.getFullyQualifiedName()); + tables.forEach( + table -> tableRepository.setFieldsInternal(table, new Fields(Set.of("columns", "tags")))); tables.sort(Comparator.comparing(EntityInterface::getFullyQualifiedName)); // Get stored procedures under this schema