diff --git a/src/main/java/com/njcn/influx/core/InfluxExecutor.java b/src/main/java/com/njcn/influx/core/InfluxExecutor.java
index 04c8a8c..fd4c556 100644
--- a/src/main/java/com/njcn/influx/core/InfluxExecutor.java
+++ b/src/main/java/com/njcn/influx/core/InfluxExecutor.java
@@ -98,9 +98,8 @@ public class InfluxExecutor {
                                     List<String> columns = series.getColumns();
                                     List<List<Object>> values = series.getValues();
                                     for (List<Object> columnValue : values) {
-                                        if(ObjectUtil.isNull(obj)){
-                                            obj = domainClass.newInstance();
-                                        }
+                                        Object object = domainClass.newInstance();
+
                                         for (int i = 0; i < columnValue.size(); i++) {
                                             String columnName = columns.get(i);
                                             //属性名有下划线的替换掉
@@ -110,24 +109,24 @@ public class InfluxExecutor {
                                                     declaredField.setAccessible(true);
                                                     //时间格式
                                                     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) {
-                                                        declaredField.set(obj, columnValue.get(i).toString());
+                                                        declaredField.set(object, columnValue.get(i).toString());
                                                         //浮点双精度
                                                     } 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) {
-                                                        declaredField.set(obj, Float.parseFloat(columnValue.get(i).toString()));
+                                                        declaredField.set(object, Float.parseFloat(columnValue.get(i).toString()));
                                                         //整型
                                                     } 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);
                                     }
                                 }
                             }