This is an automated email from the ASF dual-hosted git repository.
zykkk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new b27fa70558 [fix](jdbc) fix presto jdbc catalog pushDown and nameFormat
(#21447)
b27fa70558 is described below
commit b27fa70558469c564d9297792806d62c0bc714e0
Author: zy-kkk <[email protected]>
AuthorDate: Tue Jul 4 18:58:33 2023 +0800
[fix](jdbc) fix presto jdbc catalog pushDown and nameFormat (#21447)
---
fe/fe-core/src/main/java/org/apache/doris/catalog/JdbcTable.java | 1 +
fe/fe-core/src/main/java/org/apache/doris/planner/JdbcScanNode.java | 5 +++--
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/JdbcTable.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/JdbcTable.java
index e2fac4ee53..33f5454ffd 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/JdbcTable.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/JdbcTable.java
@@ -378,6 +378,7 @@ public class JdbcTable extends Table {
case POSTGRESQL:
case CLICKHOUSE:
case TRINO:
+ case PRESTO:
case OCEANBASE_ORACLE:
case SAP_HANA:
return formatName(name, "\"", "\"", false, false);
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/planner/JdbcScanNode.java
b/fe/fe-core/src/main/java/org/apache/doris/planner/JdbcScanNode.java
index 8a7de98505..77ff2239e1 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/JdbcScanNode.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/JdbcScanNode.java
@@ -192,6 +192,7 @@ public class JdbcScanNode extends ExternalScanNode {
|| jdbcType == TOdbcTableType.CLICKHOUSE
|| jdbcType == TOdbcTableType.SAP_HANA
|| jdbcType == TOdbcTableType.TRINO
+ || jdbcType == TOdbcTableType.PRESTO
|| jdbcType == TOdbcTableType.OCEANBASE)) {
sql.append(" LIMIT ").append(limit);
}
@@ -301,8 +302,8 @@ public class JdbcScanNode extends ExternalScanNode {
return filter;
}
}
- if (tableType.equals(TOdbcTableType.TRINO) &&
expr.contains(DateLiteral.class)
- && (expr instanceof BinaryPredicate)) {
+ if ((tableType.equals(TOdbcTableType.TRINO) ||
tableType.equals(TOdbcTableType.PRESTO))
+ && expr.contains(DateLiteral.class) && (expr instanceof
BinaryPredicate)) {
ArrayList<Expr> children = expr.getChildren();
if (children.get(1).isConstant() &&
(children.get(1).getType().isDate()) || children
.get(1).getType().isDateV2()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
