1.環境准備
下載mongoDB對Java支持的驅動包
驅動包下載地址:https://github.com/mongodb/mongo-java-driver/downloads
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();