database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](catalog) Fix ClickHouse DataTime64 precision parsing (#26977)

Browse Source
This commit is contained in:
zy-kkk
2023-11-15 10:23:21 +08:00
committed by GitHub
parent 15c43d8b8a
commit df867a1531
6 changed files with 21 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcClickHouseClient.java
View File

@ -73,20 +73,14 @@ public class JdbcClickHouseClient extends JdbcClient {
if (ckType.startsWith("DateTime(") || ckType.equals("DateTime")) {
return ScalarType.createDatetimeV2Type(0);
} else {
int indexStart = ckType.indexOf('(');
int indexEnd = ckType.indexOf(')');
if (indexStart != -1 && indexEnd != -1) {
String scaleStr = ckType.substring(indexStart + 1, indexEnd);
int scale = Integer.parseInt(scaleStr);
if (scale > JDBC_DATETIME_SCALE) {
scale = JDBC_DATETIME_SCALE;
}
// return with the actual scale
return ScalarType.createDatetimeV2Type(scale);
} else {
// default precision if not specified
return ScalarType.createDatetimeV2Type(JDBC_DATETIME_SCALE);
// DateTime64 with millisecond precision
// Datetime64(6) / DateTime64(6, 'Asia/Shanghai')
String[] accuracy = ckType.substring(11, ckType.length() - 1).split(", ");
int precision = Integer.parseInt(accuracy[0]);
if (precision > 6) {
precision = JDBC_DATETIME_SCALE;
}
return ScalarType.createDatetimeV2Type(precision);
}
}