fix flink sql jdbc limit statement for support sqlserver query

Sleepy0521 · Sleepy0521 · commit 6ff74ffd7d80 · 2025-04-02T16:59:28.000+08:00
diff --git a/flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/JdbcDynamicTableSource.java b/flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/JdbcDynamicTableSource.java
@@ -179,7 +179,7 @@ public ScanRuntimeProvider getScanRuntimeProvider(ScanContext runtimeProviderCon
         }
 
         if (limit >= 0) {
-            if ("SqlServer".equals(dialectName)) {
+            if ("SqlServer".equals(this.dialectName)) {
                 query = query.replace("SELECT", String.format("SELECT TOP %s ", limit));
             } else {
                 query = String.format("%s %s", query, dialect.getLimitClause(limit));

Original file line number	Diff line number	Diff line change
`@@ -179,7 +179,7 @@ public ScanRuntimeProvider getScanRuntimeProvider(ScanContext runtimeProviderCon`
`179`	`179`	`}`
`180`	`180`
`181`	`181`	`if (limit >= 0) {`
`182`		`- if ("SqlServer".equals(dialectName)) {`
	`182`	`+ if ("SqlServer".equals(this.dialectName)) {`
`183`	`183`	`query = query.replace("SELECT", String.format("SELECT TOP %s ", limit));`
`184`	`184`	`} else {`
`185`	`185`	`query = String.format("%s %s", query, dialect.getLimitClause(limit));`