mongoDB和java交互demo

下载mongoDB的java驱动包  https://mongodb.github.io/mongo-java-driver/

查询数据库中的文档：

//连接数据库服务

Mongo mongo = new Mongo("localhost",27017);

//连接数据库

DB db = mongo.getDB("test");

//查询集合

DBCollection collection = db.getCollection("customer");

//遍历文档

DBCursor dbCursor = collection.find();

System.out.println(collection.getCount());

while(dbCursor.hasNext()){

System.out.println(dbCursor.next());

}

//关闭连接

mongo.close();

删除集合中的文档：

Mongo mongo = new Mongo("localhost",27017);

DB db = mongo.getDB("test");

DBCollection collection = db.getCollection("customer");

BasicDBObject o = new BasicDBObject("_id", new ObjectId("5199ee647d5fc789bc760c07"));

collection.remove(o);

mongo.close();

向集合中插入文档：

Mongo mongo = new Mongo("localhost",27017);

DB db = mongo.getDB("test");

DBCollection collection = db.getCollection("customer");

DBObject c = new BasicDBObject();

c.put("name","jack");

c.put("age",24);

collection.insert(c);

mongo.close();

更新集合中的文档:

//连接数据库服务

Mongo mongo = new Mongo("localhost",27017);

//连接数据库

DB db = mongo.getDB("test");

//查询集合

DBCollection person = db.getCollection("person");

//创建id对象

BasicDBObject query = new BasicDBObject("_id",new ObjectId("51b2eff29f7c0d9e8a511fb4"));

//根据id查询集合数据

DBObject one = person.findOne(query);

//修改数据

one.put("name", "wangwu");

//更新数据库信息

WriteResult update = person.update(query, one);

//打印返回参数

System.out.println(update.getN());

//关闭连接

mongo.close();