diff --git a/src/main/java/com/njcn/influx/core/InfluxExecutor.java b/src/main/java/com/njcn/influx/core/InfluxExecutor.java index 0762a81..95f24f8 100644 --- a/src/main/java/com/njcn/influx/core/InfluxExecutor.java +++ b/src/main/java/com/njcn/influx/core/InfluxExecutor.java @@ -109,7 +109,7 @@ public class InfluxExecutor { String columnName = columns.get(i); //属性名有下划线的替换掉 for (Field declaredField : fields) { - if (columnName.replace("_","").equalsIgnoreCase(InfluxQueryWrapper.getColumnName(declaredField))) { + if (columnName.replace("_","").equalsIgnoreCase(InfluxQueryWrapper.getColumnName(declaredField).replace("_",""))) { //获取属性定义的类型 declaredField.setAccessible(true); //判断是否过滤该条记录,当数据返回 null时