Merge pull request #545 from xxzuo/feature-543

xxzuo · web-flow · commit 88b85755ea37 · 2025-09-14T09:44:34.000+08:00
[Feature][Connector] postgre sql meta support get foreign table
diff --git a/datavines-connector/datavines-connector-plugins/datavines-connector-postgresql/src/main/java/io/datavines/connector/plugin/PostgreSqlConnector.java b/datavines-connector/datavines-connector-plugins/datavines-connector-postgresql/src/main/java/io/datavines/connector/plugin/PostgreSqlConnector.java
@@ -27,6 +27,10 @@
 
 public class PostgreSqlConnector extends JdbcConnector {
 
+    protected static final String FOREIGN_TABLE = "FOREIGN TABLE";
+
+    protected static final String[] TABLE_TYPES = new String[]{TABLE, VIEW, FOREIGN_TABLE};
+
     public PostgreSqlConnector(DataSourceClient dataSourceClient) {
         super(dataSourceClient);
     }
@@ -41,4 +45,10 @@ public ResultSet getMetadataDatabases(Connection connection) throws SQLException
         DatabaseMetaData metaData = connection.getMetaData();
         return metaData.getCatalogs();
     }
+
+
+    @Override
+    public ResultSet getMetadataTables(DatabaseMetaData metaData, String catalog, String schema) throws SQLException {
+        return metaData.getTables(catalog, schema, null, TABLE_TYPES);
+    }
 }

Original file line number	Diff line number	Diff line change
`@@ -27,6 +27,10 @@`
`27`	`27`
`28`	`28`	`public class PostgreSqlConnector extends JdbcConnector {`
`29`	`29`
	`30`	`+ protected static final String FOREIGN_TABLE = "FOREIGN TABLE";`
	`31`	`+`
	`32`	`+ protected static final String[] TABLE_TYPES = new String[]{TABLE, VIEW, FOREIGN_TABLE};`
	`33`	`+`
`30`	`34`	`public PostgreSqlConnector(DataSourceClient dataSourceClient) {`
`31`	`35`	`super(dataSourceClient);`
`32`	`36`	`}`
`@@ -41,4 +45,10 @@ public ResultSet getMetadataDatabases(Connection connection) throws SQLException`
`41`	`45`	`DatabaseMetaData metaData = connection.getMetaData();`
`42`	`46`	`return metaData.getCatalogs();`
`43`	`47`	`}`
	`48`	`+`
	`49`	`+`
	`50`	`+ @Override`
	`51`	`+ public ResultSet getMetadataTables(DatabaseMetaData metaData, String catalog, String schema) throws SQLException {`
	`52`	`+ return metaData.getTables(catalog, schema, null, TABLE_TYPES);`
	`53`	`+ }`
`44`	`54`	`}`