From f2b2a568def6fc7481b38d495c21089d612c2ca1 Mon Sep 17 00:00:00 2001 From: "yongkang.zhong" Date: Thu, 18 May 2023 22:05:51 +0800 Subject: [PATCH] [fix](jdbc catalog)fixed oceanbase catalog row limit bug (#19796) --- .../main/java/org/apache/doris/planner/JdbcScanNode.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) 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 e718bad667..c839d5ea95 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 @@ -162,7 +162,8 @@ public class JdbcScanNode extends ScanNode { StringBuilder sql = new StringBuilder("SELECT "); // Oracle use the where clause to do top n - if (shouldPushDownLimit() && jdbcType == TOdbcTableType.ORACLE) { + if (shouldPushDownLimit() && (jdbcType == TOdbcTableType.ORACLE + || jdbcType == TOdbcTableType.OCEANBASE_ORACLE)) { filters.add("ROWNUM <= " + limit); } @@ -187,7 +188,8 @@ public class JdbcScanNode extends ScanNode { || jdbcType == TOdbcTableType.MONGODB || jdbcType == TOdbcTableType.CLICKHOUSE || jdbcType == TOdbcTableType.SAP_HANA - || jdbcType == TOdbcTableType.TRINO)) { + || jdbcType == TOdbcTableType.TRINO + || jdbcType == TOdbcTableType.OCEANBASE)) { sql.append(" LIMIT ").append(limit); }