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

An error occurs when the time expression contains keywords (#1527)

Browse Source
This commit is contained in:
ylhh353
2024-08-09 10:13:01 +08:00
committed by GitHub
parent f06cd0b296
commit e88e381302
1 changed files with 20 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
headless/core/src/main/java/com/tencent/supersonic/headless/core/utils/SysTimeDimensionBuilder.java
View File

@@ -8,6 +8,8 @@ import com.tencent.supersonic.headless.core.adaptor.db.DbAdaptor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import java.util.List; import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
/** /**
* generate system time dimension tools * generate system time dimension tools
@@ -15,6 +17,11 @@ import java.util.List;
@Slf4j @Slf4j
public class SysTimeDimensionBuilder { public class SysTimeDimensionBuilder {
// Defines the regular expression pattern for the time keyword
private static final Pattern TIME_KEYWORD_PATTERN =
Pattern.compile("\\b(DATE|TIME|TIMESTAMP|YEAR|MONTH|DAY|HOUR|MINUTE|SECOND)\\b",
Pattern.CASE_INSENSITIVE);
public static void addSysTimeDimension(List<Dim> dims, DbAdaptor engineAdaptor) { public static void addSysTimeDimension(List<Dim> dims, DbAdaptor engineAdaptor) {
log.debug("addSysTimeDimension before:{}, engineAdaptor:{}", dims, engineAdaptor); log.debug("addSysTimeDimension before:{}, engineAdaptor:{}", dims, engineAdaptor);
Dim timeDim = getTimeDim(dims); Dim timeDim = getTimeDim(dims);
@@ -65,10 +72,22 @@ public class SysTimeDimensionBuilder {
return dim; return dim;
} }
private static boolean containsTimeKeyword(String fieldName) {
Matcher matcher = TIME_KEYWORD_PATTERN.matcher(fieldName);
return matcher.find();
}
// Check whether the time field contains keywords,Generation time expression
private static String generateTimeExpr(Dim timeDim, String dateType, DbAdaptor engineAdaptor) { private static String generateTimeExpr(Dim timeDim, String dateType, DbAdaptor engineAdaptor) {
String bizName = timeDim.getBizName(); String bizName = timeDim.getBizName();
String dateFormat = timeDim.getDateFormat(); String dateFormat = timeDim.getDateFormat();
return engineAdaptor.getDateFormat(dateType, dateFormat, bizName); if (containsTimeKeyword(bizName)) {
String bizNameWithBackticks = String.format("`%s`", bizName);
return engineAdaptor.getDateFormat(dateType, dateFormat, bizNameWithBackticks);
} else {
return engineAdaptor.getDateFormat(dateType, dateFormat, bizName);
}
} }
private static Dim getTimeDim(List<Dim> timeDims) { private static Dim getTimeDim(List<Dim> timeDims) {