From fa41f19e48097547ac429ee64992589d3e22f86c Mon Sep 17 00:00:00 2001 From: snoop Date: Wed, 26 Apr 2017 20:18:48 +0900 Subject: [PATCH] fix metamap --- .../overflow/crawler/mongo/MongoCrawler.java | 28 ++++++------------- src/test/resources/config/example.json | 2 +- 2 files changed, 9 insertions(+), 21 deletions(-) diff --git a/src/main/java/com/loafle/overflow/crawler/mongo/MongoCrawler.java b/src/main/java/com/loafle/overflow/crawler/mongo/MongoCrawler.java index cb4fff4..7aa2acc 100644 --- a/src/main/java/com/loafle/overflow/crawler/mongo/MongoCrawler.java +++ b/src/main/java/com/loafle/overflow/crawler/mongo/MongoCrawler.java @@ -12,11 +12,7 @@ import com.mongodb.ServerAddress; import com.mongodb.client.MongoDatabase; import org.bson.Document; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - +import java.util.*; public class MongoCrawler extends Crawler { @@ -47,11 +43,13 @@ public class MongoCrawler extends Crawler { List row = null; for (Item item : items) { - row = new ArrayList<>(); - ofResultSet = OFResultSet.newInstance(item); - Map metaMap = ofResultSet.getMeta(); + row = new ArrayList<>(Arrays.asList(new String[metaMap.size()])); + + + + dataBaseName = item.getQueryInfo().getExtend().get("dataBaseName"); statusCommand = item.getQueryInfo().getExtend().get("statusCommand"); @@ -62,21 +60,11 @@ public class MongoCrawler extends Crawler { Map re = (Map)serverStatus.get(item.getQueryInfo().getQuery()); -// Map resultMap = new HashMap(); -// for (Map.Entry set : serverStatus.entrySet()){ -// resultMap.put(set.getKey(), set.getValue()); -// } - - - -// Map re = (Map) resultMap.get(query.getQueryInfo().get("query")); - - for( String key : metaMap.keySet()) { - row.add(String.valueOf(re.get(key))); + for (Map.Entry info : metaMap.entrySet()) { + row.set(info.getValue().intValue(), String.valueOf(re.get(info.getKey()))); } ofResultSet.addRow(row); - ofResultSets.add(ofResultSet); } diff --git a/src/test/resources/config/example.json b/src/test/resources/config/example.json index 6967a5e..9cfb0fe 100644 --- a/src/test/resources/config/example.json +++ b/src/test/resources/config/example.json @@ -2,7 +2,7 @@ "id" : "SOEJWEOJWOEJOSDJFOASDJFOSDFO2903870928734", "target" : { "connection" : { - "ip" : "192.168.1.104", + "ip" : "192.168.1.215", "port" : "27017", "ssl" : false, "portType" : "tcp"