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

fix

Browse Source 
metamap
This commit is contained in:
snoop 2017-04-26 20:18:48 +09:00
parent e00e49b429
commit fa41f19e48
2 changed files with 9 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -12,11 +12,7 @@ import com.mongodb.ServerAddress;
import com.mongodb.client.MongoDatabase; import com.mongodb.client.MongoDatabase;
import org.bson.Document; import org.bson.Document;
import java.util.ArrayList; import java.util.*;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class MongoCrawler extends Crawler { public class MongoCrawler extends Crawler {
@ -47,11 +43,13 @@ public class MongoCrawler extends Crawler {
List<String> row = null; List<String> row = null;
for (Item item : items) { for (Item item : items) {
row = new ArrayList<>();
ofResultSet = OFResultSet.newInstance(item); ofResultSet = OFResultSet.newInstance(item);
Map<String,Integer> metaMap = ofResultSet.getMeta(); Map<String,Integer> metaMap = ofResultSet.getMeta();
row = new ArrayList<>(Arrays.asList(new String[metaMap.size()]));
dataBaseName = item.getQueryInfo().getExtend().get("dataBaseName"); dataBaseName = item.getQueryInfo().getExtend().get("dataBaseName");
statusCommand = item.getQueryInfo().getExtend().get("statusCommand"); statusCommand = item.getQueryInfo().getExtend().get("statusCommand");
@ -62,21 +60,11 @@ public class MongoCrawler extends Crawler {
Map<String, String> re = (Map<String, String>)serverStatus.get(item.getQueryInfo().getQuery()); Map<String, String> re = (Map<String, String>)serverStatus.get(item.getQueryInfo().getQuery());
// Map<String,Object> resultMap = new HashMap<String, Object>(); for (Map.Entry<String, Integer> info : metaMap.entrySet()) {
// for (Map.Entry<String, Object> set : serverStatus.entrySet()){ row.set(info.getValue().intValue(), String.valueOf(re.get(info.getKey())));
// resultMap.put(set.getKey(), set.getValue());
// }
// Map<String, String> re = (Map<String, String>) resultMap.get(query.getQueryInfo().get("query"));
for( String key : metaMap.keySet()) {
row.add(String.valueOf(re.get(key)));
} }
ofResultSet.addRow(row); ofResultSet.addRow(row);
ofResultSets.add(ofResultSet); ofResultSets.add(ofResultSet);
} }

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

@ -2,7 +2,7 @@
"id" : "SOEJWEOJWOEJOSDJFOASDJFOSDFO2903870928734", "id" : "SOEJWEOJWOEJOSDJFOASDJFOSDFO2903870928734",
"target" : { "target" : {
"connection" : { "connection" : {
"ip" : "192.168.1.104", "ip" : "192.168.1.215",
"port" : "27017", "port" : "27017",
"ssl" : false, "ssl" : false,
"portType" : "tcp" "portType" : "tcp"