[Refactor][Connector] Refactor connector config

datavines-connector/datavines-connector-plugins/datavines-connector-impala/src/main/java/io/datavines/connector/plugin/ImpalaConnector.java

@@ -19,6 +19,9 @@
 import io.datavines.common.datasource.jdbc.BaseJdbcDataSourceInfo;
 import io.datavines.connector.api.DataSourceClient;
 
+import java.sql.DatabaseMetaData;
+import java.sql.ResultSet;
+import java.sql.SQLException;
 import java.util.Map;
 
 public class ImpalaConnector extends JdbcConnector {
@@ -31,4 +34,19 @@ public ImpalaConnector(DataSourceClient dataSourceClient) {
     public BaseJdbcDataSourceInfo getDatasourceInfo(Map<String,String> param) {
         return new ImpalaDataSourceInfo(param);
     }
+
+    @Override
+    public ResultSet getMetadataColumns(DatabaseMetaData metaData, String catalog, String schema, String tableName, String columnName) throws SQLException {
+        return metaData.getColumns(null, catalog, tableName, columnName);
+    }
+
+    @Override
+    protected ResultSet getMetadataTables(DatabaseMetaData metaData, String catalog, String schema) throws SQLException {
+        return metaData.getTables(null, catalog, null, TABLE_TYPES);
+    }
+
+    @Override
+    protected ResultSet getPrimaryKeys(DatabaseMetaData metaData, String catalog, String schema, String tableName) throws SQLException {
+        return null;
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-presto/src/main/java/io/datavines/connector/plugin/PrestoConnector.java

@@ -25,6 +25,8 @@
 import io.datavines.connector.api.DataSourceClient;
 
 import java.sql.*;
+import java.util.Arrays;
+import java.util.List;
 import java.util.Map;
 import java.util.Properties;
 
@@ -95,4 +97,9 @@ public ConnectorResponse testConnect(TestConnectionRequestParam param) {
         }
     }
 
+    @Override
+    public List<String> keyProperties() {
+        return Arrays.asList("host","port","catalog","database");
+    }
+
 }