[#676] feat(jdbc): Support jdbc operations in JDBC catalog.

apache · Nov 17, 2023 · 8b0f23f · 8b0f23f
1 parent d878628
commit 8b0f23f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/...og-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/config/JdbcConfig.java b/...og-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/config/JdbcConfig.java
@@ -72,4 +72,8 @@ public JdbcConfig(Map<String, String> properties) {
     loadFromMap(properties, k -> true);
     assert null != getJdbcUrl();
   }
+
+  public Map<String, String> getAllProperties() {
+    return getConfigsWithPrefix("");
+  }
 }
diff --git a/...dbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/utils/DataSourceUtils.java b/...dbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/utils/DataSourceUtils.java
@@ -57,8 +57,7 @@ private static DataSource createDBCPDataSource(JdbcConfig jdbcConfig) throws Exc
 
   private static Properties getProperties(JdbcConfig jdbcConfig) {
     Properties properties = new Properties();
-    Map<String, String> configsWithPrefix = jdbcConfig.getConfigsWithPrefix("");
-    properties.putAll(configsWithPrefix);
+    properties.putAll(jdbcConfig.getAllProperties());
     return properties;
   }