[fix](jdbc catalog) fix jdbc table checksum and query jdbc tvf (#34780)

apache · May 13, 2024 · 40a1041 · 40a1041
1 parent 20a6f2a
commit 40a1041
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/JdbcExternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/JdbcExternalCatalog.java
@@ -309,6 +309,7 @@ public void configureJdbcTable(JdbcTable jdbcTable, String tableName) {
         jdbcTable.setJdbcPasswd(this.getJdbcPasswd());
         jdbcTable.setDriverClass(this.getDriverClass());
         jdbcTable.setDriverUrl(this.getDriverUrl());
+        jdbcTable.setCheckSum(this.getCheckSum());
         jdbcTable.setResourceName(this.getResource());
         jdbcTable.setConnectionPoolMinSize(this.getConnectionPoolMinSize());
         jdbcTable.setConnectionPoolMaxSize(this.getConnectionPoolMaxSize());

diff --git a/fe/fe-core/src/main/java/org/apache/doris/tablefunction/QueryTableValueFunction.java b/fe/fe-core/src/main/java/org/apache/doris/tablefunction/QueryTableValueFunction.java
@@ -44,19 +44,19 @@ public abstract class QueryTableValueFunction extends TableValuedFunctionIf {
     protected final String query;
 
     public QueryTableValueFunction(Map<String, String> params) throws AnalysisException {
-        if (params.size() != 2) {
-            throw new AnalysisException("Query TableValueFunction must have 2 arguments: 'catalog' and 'query'");
-        }
-        if (!params.containsKey(CATALOG) || !params.containsKey(QUERY)) {
-            throw new AnalysisException("Query TableValueFunction must have 2 arguments: 'catalog' and 'query'");
-        }
         String catalogName = params.get(CATALOG);
         this.query = params.get(QUERY);
         this.catalogIf = Env.getCurrentEnv().getCatalogMgr().getCatalog(catalogName);
     }
 
     public static QueryTableValueFunction createQueryTableValueFunction(Map<String, String> params)
             throws AnalysisException {
+        if (params.size() != 2) {
+            throw new AnalysisException("Query TableValueFunction must have 2 arguments: 'catalog' and 'query'");
+        }
+        if (!params.containsKey(CATALOG) || !params.containsKey(QUERY)) {
+            throw new AnalysisException("Query TableValueFunction must have 2 arguments: 'catalog' and 'query'");
+        }
         String catalogName = params.get(CATALOG);
 
         // check priv