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 5913ce6..dd9fa63 100644 --- a/src/main/java/com/loafle/overflow/crawler/mongo/MongoCrawler.java +++ b/src/main/java/com/loafle/overflow/crawler/mongo/MongoCrawler.java @@ -50,16 +50,16 @@ public class MongoCrawler extends Crawler { row = new ArrayList<>(); ofResultSet = new OFResultSetCol(item); - Query query = item.getQuery(); - dataBaseName = (String)item.getQuery().getQueryInfo().get("dataBaseName"); - statusCommand = (String)item.getQuery().getQueryInfo().get("statusCommand"); + + dataBaseName = (String)item.getQueryInfo().get("dataBaseName"); + statusCommand = (String)item.getQueryInfo().get("statusCommand"); MongoDatabase database = mongoClient.getDatabase(dataBaseName); Document serverStatus = database.runCommand(new Document(statusCommand, 1)); - Map re = (Map)serverStatus.get(query.getQueryInfo().get("query")); + Map re = (Map)serverStatus.get(item.getQueryInfo().get("query")); // Map resultMap = new HashMap(); // for (Map.Entry set : serverStatus.entrySet()){ @@ -70,8 +70,8 @@ public class MongoCrawler extends Crawler { // Map re = (Map) resultMap.get(query.getQueryInfo().get("query")); - for (int index =0 ; index < query.getKeys().size() ; ++index) { - row.add(String.valueOf(re.get(query.getKeys().get(index)))); + for (int index =0 ; index < item.getKeys().size() ; ++index) { + row.add(String.valueOf(re.get(item.getKeys().get(index)))); } ofResultSet.addRow(row); diff --git a/src/test/resources/config/example.json b/src/test/resources/config/example.json index 5e43f4f..091e6da 100644 --- a/src/test/resources/config/example.json +++ b/src/test/resources/config/example.json @@ -28,23 +28,22 @@ "memory.usage.mapped", "memory.usage.mappedWithJournal" ], - "query": - { - "queryInfo": { - "query":"mem", - "dataBaseName":"admin", - "statusCommand":"serverStatus", - "parseDirection" : "col" - }, - "keys" : [ - "bits", - "resident", - "virtual", - "supported", - "mapped", - "mappedWithJournal" - ] - } + + "queryInfo": { + "query":"mem", + "dataBaseName":"admin", + "statusCommand":"serverStatus", + "parseDirection" : "col" + }, + "keys" : [ + "bits", + "resident", + "virtual", + "supported", + "mapped", + "mappedWithJournal" + ] + } ]