diff --git a/src/main/java/com/njcn/influx/query/InfluxQueryWrapper.java b/src/main/java/com/njcn/influx/query/InfluxQueryWrapper.java index fdcfb26..d1cb84f 100644 --- a/src/main/java/com/njcn/influx/query/InfluxQueryWrapper.java +++ b/src/main/java/com/njcn/influx/query/InfluxQueryWrapper.java @@ -132,7 +132,19 @@ public class InfluxQueryWrapper { } return this; } + public InfluxQueryWrapper select(String columnName,String resultColumnName) { + StringBuilder selectFragment = new StringBuilder(); + selectFragment.append(StrPool.C_SPACE) + .append(columnName) + .append(StrPool.C_SPACE) + .append(InfluxDbSqlConstant.AS) + .append(StrPool.C_SPACE) + .append(resultColumnName) + .append(StrPool.C_SPACE); + selectColumns.add(selectFragment+""); + return this; + } // /*** // * 查询的结果属性 @@ -160,6 +172,7 @@ public class InfluxQueryWrapper { // } + /************常见的简单函数处理比如max/min/mean/percentile****************/ /*** @@ -917,6 +930,34 @@ public class InfluxQueryWrapper { return this; } + public InfluxQueryWrapper between(String fieldName, Object val1, Object val2) { + StringBuilder selectFragment = new StringBuilder(); + selectFragment.append(StrPool.C_SPACE) + .append(fieldName) + .append(InfluxDbSqlConstant.GE); + + if (val1 instanceof String) { + //需要用单引号包装下 + selectFragment.append(InfluxDbSqlConstant.QM) + .append(val1) + .append(InfluxDbSqlConstant.QM) + .append(InfluxDbSqlConstant.AND) + .append(fieldName) + .append(InfluxDbSqlConstant.LE) + .append(InfluxDbSqlConstant.QM) + .append(val2) + .append(InfluxDbSqlConstant.QM); + } else { + selectFragment.append(val1) + .append(InfluxDbSqlConstant.AND) + .append(fieldName) + .append(InfluxDbSqlConstant.LE) + .append(val2); + } + this.conditions.add(selectFragment.toString()); + return this; + } + /*** * 指定字段等于某个值 @@ -1267,6 +1308,13 @@ public class InfluxQueryWrapper { return this; } + public final InfluxQueryWrapper groupBy(String columnName) { + + groupColumn.add(columnName); + + return this; + } + /*** * 指定字段降序