ongoException e) {
e.printStackTrace();
}
}
public MongDbCRUD(String host, int port, String datablease, String tablelename){
try {
mongo = new Mongo(host, port);
// 连接池
MongoOptions opt = mongo.getMongoOptions();
opt.connectionsPerHost = 10 ; //poolsize
opt.threadsAllowedToBlockForConnectionMultiplier = 10 ;
//获取temp DB；如果默认没有创建，mongodb会自动创建
db = mongo.getDB(datablease);
//获取users DBCollection；如果默认没有创建，mongodb会自动创建
table = db.getCollection(tablelename);
//DO SOMETHING
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (MongoException e) {
e.printStackTrace();
}
}
public static void free(){
if(mongo!=null){
mongo.close();
}
mongo = null;
db = null;
table = null;
System.gc();
}
public static DBCollection getDBCollection(){
return table;
}
public void add(DBObject row){
table.save(row);
}
public void query(){
DBCursor cur = table.find();
while (cur.hasNext()) {
DBObject dbobject = cur.next();
System.out.println(dbobject.get("key"));//get value
}
}
}
/*注：mongo.properties的内容如下，
#mongodb setting
mongo.host=192.168.20.38
mongo.port=27017
mongo.database=map
mongo.table.bound=bound
mongo.username=username
mongo.pwd=pwd*/