diff --git a/src/main/java/com/njcn/influx/query/InfluxQueryWrapper.java b/src/main/java/com/njcn/influx/query/InfluxQueryWrapper.java index 970dd10..c862164 100644 --- a/src/main/java/com/njcn/influx/query/InfluxQueryWrapper.java +++ b/src/main/java/com/njcn/influx/query/InfluxQueryWrapper.java @@ -238,6 +238,20 @@ public class InfluxQueryWrapper { return this; } + public InfluxQueryWrapper count(String columnName,String resultName) { + String selectFragment = InfluxDbSqlConstant.COUNT + + InfluxDbSqlConstant.LBK + + InfluxDbSqlConstant.DQM + + columnName + + InfluxDbSqlConstant.DQM + + InfluxDbSqlConstant.RBK + + InfluxDbSqlConstant.AS + + resultName + + StrPool.C_SPACE; + selectColumns.add(selectFragment); + return this; + } + /*** * 统计平均值