|
@@ -83,22 +83,14 @@ public class TaskRedisRead implements Runnable {
|
|
|
StringBuilder sb = new StringBuilder();
|
|
|
sb.append("INSERT INTO ");
|
|
|
|
|
|
- String value;
|
|
|
- String datetime;
|
|
|
- double val;
|
|
|
- long ts;
|
|
|
- boolean bl;
|
|
|
- List<String> response;
|
|
|
- String sb2str;
|
|
|
+ //String value;
|
|
|
+ //String datetime;
|
|
|
+ //double val;
|
|
|
+ //long ts;
|
|
|
+ //boolean bl;
|
|
|
+ //List<String> response;
|
|
|
getPointData(objects, sb);
|
|
|
- for (Object obj : objects) {
|
|
|
- if (b) {
|
|
|
- getPointData(response, sb);
|
|
|
- } else {
|
|
|
- getPointData(response, sb);
|
|
|
- }
|
|
|
- }
|
|
|
- sb2str = sb.toString();
|
|
|
+ String sb2str = sb.toString();
|
|
|
if ("INSERT INTO ".equals(sb2str)) return;
|
|
|
for (String taosUrl : redisConfig.getTaosUrls().split(",")) {
|
|
|
redis2TaosApi.putSql(URI.create(taosUrl), sb2str);
|