mongodb crud示例

public class MongoTest {

@BeforeClass
public static void setUpBeforeClass() throws Exception {
}

// 查询所有
@Test public void list()throws Exception{
// 连接客户端
Mongo mongo=new Mongo("localhost",27017);
// 获得数据库
DB db=mongo.getDB("test1");
// 获得文档对象
DBCollection dbCollection=db.getCollection("t_person");
// 获得结果集对象
DBCursor dbCursor=dbCollection.find();
// 遍历
while(dbCursor.hasNext()){
System.out.println(dbCursor.next());
}
// 关闭连接
mongo.close();
}

// 添加文档对象
@Test public void add()throws Exception{
// 连接客户端
Mongo mongo=new Mongo("localhost",27017);
// 获得数据库
DB db=mongo.getDB("test1");
// 获得文档对象
DBCollection dbCollection=db.getCollection("t_person");

DBObject dbObject=new BasicDBObject();
dbObject.put("name", "liming");
dbObject.put("sex", "nan");
dbObject.put("hobby", "拍电影");

//保存
dbCollection.save(dbObject);

// 关闭连接
mongo.close();
}

// 根据id查询单条的记录
@Test public void get()throws Exception{
// 连接客户端
Mongo mongo=new Mongo("localhost",27017);
// 获得数据库
DB db=mongo.getDB("test1");
// 获得文档对象
DBCollection dbCollection=db.getCollection("t_person");
DBObject dbObject=new BasicDBObject("_id",new ObjectId("5316a13901206702d963899b"));
DBObject obj=dbCollection.findOne(dbObject);
System.out.println("obj对象是:"+obj);
// 关闭连接
mongo.close();
}

// 查询文档的总记录数目
@Test public void getCount()throws Exception{
// 连接客户端
Mongo mongo=new Mongo("localhost",27017);
// 获得数据库
DB db=mongo.getDB("test1");
// 获得集合对象
DBCollection dbCollection=db.getCollection("t_person");
long result=dbCollection.count();
System.out.println("t_person集合的总记录数目是:"+result);
// 关闭连接
mongo.close();
}

// 更新文档
@Test public void update()throws Exception{
// 连接客户端
Mongo mongo=new Mongo("localhost",27017);
// 获得数据库
DB db=mongo.getDB("test1");
// 获得集合对象
DBCollection dbCollection=db.getCollection("t_person");

DBObject dbObject=new BasicDBObject();
dbObject.put("name", "liming2");
dbObject.put("sex", "nan2");
dbObject.put("hobby", "拍电影2");
DBObject q=new BasicDBObject("_id",new ObjectId("5317157e019db6569eba6555"));
// 更新
dbCollection.update(q, dbObject);
// 关闭连接
mongo.close();
}
// 移除文档
@Test public void remove()throws Exception{
// 连接客户端
Mongo mongo=new Mongo("localhost",27017);
// 获得数据库
DB db=mongo.getDB("test1");
// 获得集合对象
DBCollection  dbCollection=db.getCollection("t_person");
DBObject dbObject=new BasicDBObject("_id",new ObjectId("53171802019df2c3563abf52"));
// 移除
dbCollection.remove(dbObject);
// 关闭连接
mongo.close();
}

}