1. 环境准备
下载 mongoDB 对 Java 支持的驱动包
驱动包下载地址:
2. 查询集合中所有文档
- 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();
3. 删除集合中的文档
- 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();
4. 向集合中插入文档
- 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();
5. 更新集合中的文档
- Mongo mongo = new Mongo("localhost",27017);
- DB db = mongo.getDB("test");
- DBCollection collection = db.getCollection("customer");
- BasicDBObject query = new BasicDBObject("_id",new ObjectId("519e2e393296cf3baccdb10c"));
- BasicDBObject object = (BasicDBObject) collection.findOne(query);
- object.put("name", "wangwu");
- int n = collection.update(query, object).getN();
- System.out.println(n);
- mongo.close();
来源: