一：設定要連結的主機名稱和埠號

MongoClient client = new MongoClient("localhost",27001);

 二：確定連線資料庫

DB db = client.getDB("mldn");

 三：確定連線表 

DBCollection col = db.getCollection("dept");

 四：操作資料 

    4.1： 新增    

for (int i = 0; i < 5; i++) {

	    BasicDBObject obj = new BasicDBObject();
	    obj.append("depton", 10+i);
	    obj.append("dname", "技術部" + i);
	    obj.append("loc", "瀋陽" + 2 + i);
	    col.insert(obj);
		}	
		
 

    4.2：檢視全部（無條件）

DBCursor cursor = col.find().skip(0).limit(3);
	while(cursor.hasNext()) {
				
		//得到每個內容
		DBObject object = cursor.next();
				
		System.out.println("部門編號:"+object.get("depton") + "   部門名稱： "+object.get("dname"));
	}

    4.3：篩選條件        

//範圍查詢
cond.put("depton", new BasicDBObject("$gte",11).append("$lte", 13));

//in查詢
cond.put("depton", new BasicDBObject("$in",new int[] {11,13,15}));

//模糊查詢,設定過濾條件
Pattern pattern = Pattern.compile("3");
cond.put("dname", new BasicDBObje("$regex",pattern));

//條件查詢
DBCursor cursor = col.find(cond);
 

    4.4：刪除 

//刪除
DBObject dbObjectA = new BasicDBObject();
dbObjectA.put("depton", 13);
WriteResult result = col.remove(dbObjectA);
System.out.println(result.getN());//修改了幾條

    4.5：修改

//修改，修改時必須跟要修改的過濾條件
//設定修還的過濾條件
DBObject dbObjectA = new BasicDBObject();
dbObjectA.put("depton", 13);
//修改內容
DBObject dbObjectB = new BasicDBObject();
dbObjectB.put("$set", new BasicDBObject("dname","修改後的部門"));
//開始修改
WriteResult result = col.update(dbObjectA, dbObjectB);
 

 五：關閉資料庫連結

 client.close();