[fix](jdbc catalog) fix trino jdbc catalog varchar type err (#19298)

This commit is contained in:
yongkang.zhong
2023-05-06 17:16:28 +08:00
committed by GitHub
parent 4c6ca88088
commit 2fe9ba7c2a

View File

@ -876,6 +876,8 @@ public class JdbcClient {
fieldSchema.setDataTypeName(trinoArrType);
Type type = trinoTypeToDoris(fieldSchema);
return ArrayType.create(type, true);
} else if (trinoType.startsWith("varchar")) {
return ScalarType.createStringType();
}
switch (trinoType) {
case "integer":
@ -892,8 +894,6 @@ public class JdbcClient {
return Type.FLOAT;
case "boolean":
return Type.BOOLEAN;
case "varchar":
return ScalarType.createStringType();
case "date":
return ScalarType.createDateV2Type();
default: