Optimised PostgresMetadataFetcher

suddendust · suddendust · commit 13cb0b0180fc · 2026-03-30T18:52:38.000+05:30
diff --git a/document-store/src/main/java/org/hypertrace/core/documentstore/postgres/PostgresMetadataFetcher.java b/document-store/src/main/java/org/hypertrace/core/documentstore/postgres/PostgresMetadataFetcher.java
@@ -62,6 +62,10 @@ public Map<String, PostgresColumnMetadata> fetch(String tableName) {
                   isPrimaryKey));
         }
       }
+      if (metadataMap.isEmpty()) {
+        throw new RuntimeException(
+            "No columns found for table: " + tableName + ". Table may not exist.");
+      }
       return metadataMap;
     } catch (SQLException e) {
       throw new RuntimeException("Failed to fetch Postgres metadata for table: " + tableName, e);

Original file line number	Diff line number	Diff line change
`@@ -62,6 +62,10 @@ public Map<String, PostgresColumnMetadata> fetch(String tableName) {`
`62`	`62`	`isPrimaryKey));`
`63`	`63`	`}`
`64`	`64`	`}`
	`65`	`+ if (metadataMap.isEmpty()) {`
	`66`	`+ throw new RuntimeException(`
	`67`	`+ "No columns found for table: " + tableName + ". Table may not exist.");`
	`68`	`+ }`
`65`	`69`	`return metadataMap;`
`66`	`70`	`} catch (SQLException e) {`
`67`	`71`	`throw new RuntimeException("Failed to fetch Postgres metadata for table: " + tableName, e);`