overflow_backup_2018_0455/mongodb_crawler_java
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

changed

Browse Source 
config
This commit is contained in:
snoop 2017-04-26 11:30:05 +09:00
parent 142d897ab0
commit ed76faa24b
2 changed files with 22 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/com/loafle/overflow/crawler/mongo/MongoCrawler.java
View File

@ -50,16 +50,16 @@ public class MongoCrawler extends Crawler {
row = new ArrayList<>(); row = new ArrayList<>();
ofResultSet = new OFResultSetCol(item); 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); MongoDatabase database = mongoClient.getDatabase(dataBaseName);
Document serverStatus = database.runCommand(new Document(statusCommand, 1)); Document serverStatus = database.runCommand(new Document(statusCommand, 1));
Map<String, String> re = (Map<String, String>)serverStatus.get(query.getQueryInfo().get("query")); Map<String, String> re = (Map<String, String>)serverStatus.get(item.getQueryInfo().get("query"));
// Map<String,Object> resultMap = new HashMap<String, Object>(); // Map<String,Object> resultMap = new HashMap<String, Object>();
// for (Map.Entry<String, Object> set : serverStatus.entrySet()){ // for (Map.Entry<String, Object> set : serverStatus.entrySet()){
@ -70,8 +70,8 @@ public class MongoCrawler extends Crawler {
// Map<String, String> re = (Map<String, String>) resultMap.get(query.getQueryInfo().get("query")); // Map<String, String> re = (Map<String, String>) resultMap.get(query.getQueryInfo().get("query"));
for (int index =0 ; index < query.getKeys().size() ; ++index) { for (int index =0 ; index < item.getKeys().size() ; ++index) {
row.add(String.valueOf(re.get(query.getKeys().get(index)))); row.add(String.valueOf(re.get(item.getKeys().get(index))));
} }
ofResultSet.addRow(row); ofResultSet.addRow(row);

33
src/test/resources/config/example.json
View File

@ -28,23 +28,22 @@
"memory.usage.mapped", "memory.usage.mapped",
"memory.usage.mappedWithJournal" "memory.usage.mappedWithJournal"
], ],
"query":
{ "queryInfo": {
"queryInfo": { "query":"mem",
"query":"mem", "dataBaseName":"admin",
"dataBaseName":"admin", "statusCommand":"serverStatus",
"statusCommand":"serverStatus", "parseDirection" : "col"
"parseDirection" : "col" },
}, "keys" : [
"keys" : [ "bits",
"bits", "resident",
"resident", "virtual",
"virtual", "supported",
"supported", "mapped",
"mapped", "mappedWithJournal"
"mappedWithJournal" ]
]
}
} }
] ]