database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
zy-kkk
2024-05-13 18:08:18 +08:00
committed by GitHub
parent 20a6f2a659
commit 40a1041651
2 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/JdbcExternalCatalog.java
View File

@ -309,6 +309,7 @@ public class JdbcExternalCatalog extends ExternalCatalog {
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());

12
fe/fe-core/src/main/java/org/apache/doris/tablefunction/QueryTableValueFunction.java
View File

@ -44,12 +44,6 @@ 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);
@ -57,6 +51,12 @@ public abstract class QueryTableValueFunction extends TableValuedFunctionIf {
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