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); }