topdog/supersonic
1
0
Fork 0
mirror of https://github.com/tencentmusic/supersonic.git synced 2025-12-12 12:37:55 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

[fix][headless]Fix issue in determining mysql version to support with statement.

Browse Source
This commit is contained in:
jerryjzhang
2024-12-21 22:50:55 +08:00
parent 8c6ae62522
commit 5de5b0a5e2
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
headless/core/src/main/java/com/tencent/supersonic/headless/core/config/ExecutorConfig.java
View File

@@ -8,7 +8,7 @@ import org.springframework.context.annotation.Configuration;
@Configuration @Configuration
public class ExecutorConfig { public class ExecutorConfig {
@Value("${s2.metricParser.agg.mysql.lowVersion:5.7}") @Value("${s2.metricParser.agg.mysql.lowVersion:8.0}")
private String mysqlLowVersion; private String mysqlLowVersion;
@Value("${s2.metricParser.agg.ck.lowVersion:20.4}") @Value("${s2.metricParser.agg.ck.lowVersion:20.4}")

2
headless/core/src/main/java/com/tencent/supersonic/headless/core/utils/SqlGenerateUtils.java
View File

@@ -260,7 +260,7 @@ public class SqlGenerateUtils {
public boolean isSupportWith(EngineType engineTypeEnum, String version) { public boolean isSupportWith(EngineType engineTypeEnum, String version) {
if (engineTypeEnum.equals(EngineType.MYSQL) && Objects.nonNull(version) if (engineTypeEnum.equals(EngineType.MYSQL) && Objects.nonNull(version)
&& version.startsWith(executorConfig.getMysqlLowVersion())) { && StringUtil.compareVersion(version, executorConfig.getMysqlLowVersion()) < 0) {
return false; return false;
} }
if (engineTypeEnum.equals(EngineType.CLICKHOUSE) && Objects.nonNull(version) if (engineTypeEnum.equals(EngineType.CLICKHOUSE) && Objects.nonNull(version)