提交 ae90ed3a authored 作者: taojinlong's avatar taojinlong

fix: ck 时间过滤

上级 236c7616
...@@ -803,12 +803,29 @@ public class CKQueryProvider extends QueryProvider { ...@@ -803,12 +803,29 @@ public class CKQueryProvider extends QueryProvider {
} else if (StringUtils.containsIgnoreCase(request.getTerm(), "like")) { } else if (StringUtils.containsIgnoreCase(request.getTerm(), "like")) {
whereValue = "'%" + value + "%'"; whereValue = "'%" + value + "%'";
} else { } else {
whereValue = String.format(CKConstants.WHERE_VALUE_VALUE, value); if(field.getDeType() == DeTypeConstants.DE_TIME){
whereValue = String.format(CKConstants.toDateTime, "'" + value + "'");
}else {
whereValue = String.format(CKConstants.WHERE_VALUE_VALUE, value);
}
} }
list.add(SQLObj.builder() if(field.getDeType() == DeTypeConstants.DE_TIME && StringUtils.equalsIgnoreCase(request.getTerm(), "null")){
.whereField(whereName) list.add(SQLObj.builder()
.whereTermAndValue(whereTerm + whereValue) .whereField(whereName)
.build()); .whereTermAndValue("is null")
.build());
}else if(field.getDeType() == DeTypeConstants.DE_TIME && StringUtils.equalsIgnoreCase(request.getTerm(), "not_null")){
list.add(SQLObj.builder()
.whereField(whereName)
.whereTermAndValue("is not null")
.build());
}else {
list.add(SQLObj.builder()
.whereField(whereName)
.whereTermAndValue(whereTerm + whereValue)
.build());
}
} }
return list; return list;
} }
...@@ -870,10 +887,23 @@ public class CKQueryProvider extends QueryProvider { ...@@ -870,10 +887,23 @@ public class CKQueryProvider extends QueryProvider {
} else { } else {
whereValue = String.format(CKConstants.WHERE_VALUE_VALUE, value.get(0)); whereValue = String.format(CKConstants.WHERE_VALUE_VALUE, value.get(0));
} }
list.add(SQLObj.builder()
.whereField(whereName) if(field.getDeType() == DeTypeConstants.DE_TIME && StringUtils.equalsIgnoreCase(request.getOperator(), "null")){
.whereTermAndValue(whereTerm + whereValue) list.add(SQLObj.builder()
.build()); .whereField(whereName)
.whereTermAndValue("is null")
.build());
}else if(field.getDeType() == DeTypeConstants.DE_TIME && StringUtils.equalsIgnoreCase(request.getOperator(), "not_null")){
list.add(SQLObj.builder()
.whereField(whereName)
.whereTermAndValue("is not null")
.build());
}else {
list.add(SQLObj.builder()
.whereField(whereName)
.whereTermAndValue(whereTerm + whereValue)
.build());
}
} }
return list; return list;
} }
...@@ -991,11 +1021,26 @@ public class CKQueryProvider extends QueryProvider { ...@@ -991,11 +1021,26 @@ public class CKQueryProvider extends QueryProvider {
} else { } else {
whereValue = String.format(CKConstants.WHERE_VALUE_VALUE, f.getValue()); whereValue = String.format(CKConstants.WHERE_VALUE_VALUE, f.getValue());
} }
list.add(SQLObj.builder()
.whereField(fieldAlias) if(y.getDeType() == DeTypeConstants.DE_TIME && StringUtils.equalsIgnoreCase(f.getTerm(), "null")){
.whereAlias(fieldAlias) list.add(SQLObj.builder()
.whereTermAndValue(whereTerm + whereValue) .whereField(fieldAlias)
.build()); .whereAlias(fieldAlias)
.whereTermAndValue("is null")
.build());
}else if(y.getDeType() == DeTypeConstants.DE_TIME && StringUtils.equalsIgnoreCase(f.getTerm(), "not_null")){
list.add(SQLObj.builder()
.whereField(fieldAlias)
.whereAlias(fieldAlias)
.whereTermAndValue("is not null")
.build());
}else {
list.add(SQLObj.builder()
.whereField(fieldAlias)
.whereAlias(fieldAlias)
.whereTermAndValue(whereTerm + whereValue)
.build());
}
}); });
} }
return list; return list;
......
...@@ -156,7 +156,7 @@ export default { ...@@ -156,7 +156,7 @@ export default {
return 'PostgreSQL' return 'PostgreSQL'
} else if (type === 'es') { } else if (type === 'es') {
return 'Elasticsearch' return 'Elasticsearch'
} else if (type === 'ch') { } else if (type === 'ck') {
return 'ClickHouse' return 'ClickHouse'
} }
}, },
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论