Middleware/influxdb-springboot-starter
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改引用传递导致查询多条数据成一条

Browse Source
This commit is contained in:
huangzj
2023-06-20 08:52:51 +08:00
parent cef1a5d66c
commit 45a4bd0983
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/main/java/com/njcn/influx/core/InfluxExecutor.java
View File

@@ -98,9 +98,8 @@ public class InfluxExecutor {
List<String> columns = series.getColumns(); List<String> columns = series.getColumns();
List<List<Object>> values = series.getValues(); List<List<Object>> values = series.getValues();
for (List<Object> columnValue : values) { for (List<Object> columnValue : values) {
if(ObjectUtil.isNull(obj)){ Object object = domainClass.newInstance();
obj = domainClass.newInstance();
}
for (int i = 0; i < columnValue.size(); i++) { for (int i = 0; i < columnValue.size(); i++) {
String columnName = columns.get(i); String columnName = columns.get(i);
//属性名有下划线的替换掉 //属性名有下划线的替换掉
@@ -110,24 +109,24 @@ public class InfluxExecutor {
declaredField.setAccessible(true); declaredField.setAccessible(true);
//时间格式 //时间格式
if (declaredField.getType() == Instant.class) { if (declaredField.getType() == Instant.class) {
declaredField.set(obj, InstantUtil.stringToInstant(columnValue.get(i).toString().replace("+08:00", "Z"))); declaredField.set(object, InstantUtil.stringToInstant(columnValue.get(i).toString().replace("+08:00", "Z")));
//字符串 //字符串
} else if (declaredField.getType() == String.class) { } else if (declaredField.getType() == String.class) {
declaredField.set(obj, columnValue.get(i).toString()); declaredField.set(object, columnValue.get(i).toString());
//浮点双精度 //浮点双精度
} else if (declaredField.getType() == Double.class) { } else if (declaredField.getType() == Double.class) {
declaredField.set(obj, Double.parseDouble(columnValue.get(i).toString())); declaredField.set(object, Double.parseDouble(columnValue.get(i).toString()));
//浮点 //浮点
} else if (declaredField.getType() == Float.class) { } else if (declaredField.getType() == Float.class) {
declaredField.set(obj, Float.parseFloat(columnValue.get(i).toString())); declaredField.set(object, Float.parseFloat(columnValue.get(i).toString()));
//整型 //整型
} else if (declaredField.getType() == Integer.class) { } else if (declaredField.getType() == Integer.class) {
declaredField.set(obj, Integer.parseInt(columnValue.get(i).toString())); declaredField.set(object, Integer.parseInt(columnValue.get(i).toString()));
} }
} }
} }
} }
results.add((E) obj); results.add((E) object);
} }
} }
} }