diff --git a/src/main/java/com/njcn/influx/query/InfluxQueryWrapper.java b/src/main/java/com/njcn/influx/query/InfluxQueryWrapper.java index bc81d9f..ec888a2 100644 --- a/src/main/java/com/njcn/influx/query/InfluxQueryWrapper.java +++ b/src/main/java/com/njcn/influx/query/InfluxQueryWrapper.java @@ -888,7 +888,7 @@ public class InfluxQueryWrapper { * 输出 columnName */ @SafeVarargs - public final InfluxQueryWrapper groupBy(ICFunction... columnName) { + public final InfluxQueryWrapper groupBy(ICFunction... columnName) { for (ICFunction tricFunction : columnName) { groupColumn.add(this.getColumnName(measurement, LambdaUtil.columnToString(tricFunction))); } @@ -996,17 +996,7 @@ public class InfluxQueryWrapper { */ private String getColumnName(Class clazz, String fieldName) { Field field = this.getTargetClassField(clazz, fieldName); - Column column = field.getAnnotation(Column.class); - //数据库字段 - String influxColumn; - if (Objects.isNull(column)) { - //没有注解,就用属性名 - influxColumn = fieldName; - } else { - //获取注解映射的名称 - influxColumn = column.name(); - } - return influxColumn; + return getColumnName(field); }