package com.xinsight.server;
import java.net.UnknownHostException;
import java.util.HashMap;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.Mongo;
/**
*查找Mongodb中某一列包含Map集合的所有数据
*/
public class FindMongodbMap {
private static Mongo mg ;
private static DB db;
private static int num = 0;
public static void main(String args[]){
try {
mg = new Mongo("localhost",27017);
db = mg.getDB("admin");
boolean auth = db.authenticate("aa","aa".toCharArray() );
if(!auth){
System.err.println("链接Mongodb失败");
}else{
db = mg.getDB("zq1");
DBCollection collection = db.getCollection("zq1");
DBCursor u = collection.find();
while(u.hasNext()){
num++;
BasicDBObject basi = (BasicDBObject)u.next();
HashMap map = (HashMap)basi.get("m");
if(num % 100 == 0){
System.err.println("--------------------------------------------------------------------");
Thread.sleep(3000);
}
System.out.println(basi.get("v1") + " " + basi.get("v2") + " " +basi.get("v3") + " " +basi.get("v4") + " " + map.get("time") + " " + map.get("sex") + " " + map.get("age") + " " + map.get("name"));
}
System.out.println("共找到:" + num + "条数据");
}
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}