This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 1cb650f add text support for grafana (#906)
1cb650f is described below
commit 1cb650fac7c5e11d3ba55ad6f5dd4e48e7b9a878
Author: Jialin Qiao <[email protected]>
AuthorDate: Sat Mar 14 09:54:42 2020 +0800
add text support for grafana (#906)
---
.../org/apache/iotdb/web/grafana/bean/TimeValues.java | 6 +++---
.../grafana/controller/DatabaseConnectController.java | 2 +-
.../apache/iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 17 ++++-------------
3 files changed, 8 insertions(+), 17 deletions(-)
diff --git
a/grafana/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java
b/grafana/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java
index 9d09030..dd5d5a1 100644
--- a/grafana/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java
+++ b/grafana/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java
@@ -24,7 +24,7 @@ package org.apache.iotdb.web.grafana.bean;
public class TimeValues {
private long time;
- private float value;
+ private Object value;
@Override
public String toString() {
@@ -39,11 +39,11 @@ public class TimeValues {
this.time = time;
}
- public float getValue() {
+ public Object getValue() {
return value;
}
- public void setValue(float value) {
+ public void setValue(Object value) {
this.value = value;
}
}
diff --git
a/grafana/src/main/java/org/apache/iotdb/web/grafana/controller/DatabaseConnectController.java
b/grafana/src/main/java/org/apache/iotdb/web/grafana/controller/DatabaseConnectController.java
index b4dee8b..2643c1f 100644
---
a/grafana/src/main/java/org/apache/iotdb/web/grafana/controller/DatabaseConnectController.java
+++
b/grafana/src/main/java/org/apache/iotdb/web/grafana/controller/DatabaseConnectController.java
@@ -173,7 +173,7 @@ public class DatabaseConnectController {
JSONArray dataPoints = new JSONArray();
for (TimeValues tv : timeValues) {
long time = tv.getTime();
- float value = tv.getValue();
+ Object value = tv.getValue();
JSONArray jsonArray = new JSONArray();
jsonArray.add(value);
jsonArray.add(time);
diff --git
a/grafana/src/main/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImpl.java
b/grafana/src/main/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImpl.java
index a1b7af7..eef7689 100644
---
a/grafana/src/main/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImpl.java
+++
b/grafana/src/main/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImpl.java
@@ -123,8 +123,6 @@ public class BasicDaoImpl implements BasicDao {
static class TimeValuesRowMapper implements RowMapper<TimeValues> {
- static final String TRUE_STR = "true";
- static final String FALSE_STR = "false";
String columnName;
TimeValuesRowMapper(String columnName) {
@@ -137,17 +135,10 @@ public class BasicDaoImpl implements BasicDao {
tv.setTime(resultSet.getLong("Time") / TIMESTAMP_RADIX);
String valueString = resultSet.getString(columnName);
if (valueString != null) {
- if (TRUE_STR.equalsIgnoreCase(valueString)) {
- tv.setValue(1);
- } else if (FALSE_STR.equalsIgnoreCase(valueString)) {
- tv.setValue(0);
- } else {
- try {
- tv.setValue(Float.parseFloat(resultSet.getString(columnName)));
- } catch (Exception e) {
- logger.error("Can not parse the value {}",
resultSet.getString(columnName));
- tv.setValue(0);
- }
+ try {
+ tv.setValue(Float.parseFloat(resultSet.getString(columnName)));
+ } catch (Exception e) {
+ tv.setValue(resultSet.getString(columnName));
}
}
return tv;