MongoDB做為NoSQL數據庫，最近幾年持續升溫，越來越多的企業都開始嘗試用MongoDB代替原有Database做一些事情。MongoDB也在集群，分片，復制上也有相當不錯的的表現。我通過將做各種MongoDB的部署實驗進行介紹。

關于作者：

• 鄭云飛, 程序員Java,Javascript，jquery，css，html，springMVC，Struts2，hibernate，oracle，mysql，hadoop，hbase，hive，sqoop，zookeeper，mongodb，redis
• weibo：@zhengyunfei
• blog: zhengyunfei.iteye.com
  
• email: zhengyunfei8@gmail.com ? ?799078779@qq.com

?

前言

MongoDB作為一種文檔型的NoSQL數據庫，使用起來非常靈活，回避了關系型數據庫前期的復雜數據庫設計。MongoDB存儲基于JSON格式，同時用Javascript做為數據庫操作語言，給了使用者無限想象的空間，可以通過編程在MongoDB服務器中解決非常復雜的條件查詢的問題。

目錄

1. Mongodb創建數據庫鏈接
2. java操作mongodb的方法

1 創建數據庫鏈接類

      package com.mongodb.test;

import java.net.UnknownHostException;

import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.util.JSON;

public class DataBase {

	public static void main(String[] args) throws UnknownHostException, MongoException {
		Mongo mg=new Mongo("127.0.0.1:27017");
		//查詢所有DataBase
		for(String name:mg.getDatabaseNames()){
			System.out.println("dbName:"+name);
		}
		//創建相關數據庫的鏈接
		DB db=mg.getDB("");
		//查詢數據庫所有的集合
		for(String name:db.getCollectionNames()){
			System.out.println("collectionName:"+name);
		}
		DBCollection users=db.getCollection("persons");
		//查詢所有的數據
		DBCursor cur=users.find();
		while(cur.hasNext()){
			DBObject object=cur.next();
			System.out.println(object.get("name"));
		}
		System.out.println(cur.count());
		System.out.println(cur.getCursorId());
		System.out.println(JSON.serialize(cur));
	}

}

    

java 操作mongodb的方法

      package com.mongodb.test;

import java.net.UnknownHostException;
import java.util.List;

import org.bson.types.ObjectId;

import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoException;

public class MongoDB {
	//1.建立一個mongodb的數據庫鏈接對象
	private static Mongo connection=null;
	//創建相關數據庫的鏈接
	private static DB db=null;
	public MongoDB(String dbName) throws UnknownHostException, MongoException{
		connection=new Mongo("");
		db=connection.getDB(dbName);
	}
	public static void main(String[] args) throws UnknownHostException, MongoException {
		//實例化
		MongoDB mongoDb=new MongoDB("footbar");
		 /** 
	      * 1.創建一個名字叫javadb的數據庫 
	      */ 
	//  mongoDb.createCollection("javadb"); 
	  /** 
	   * 2.為集合javadb添加一條數據 
	   */ 
	//  DBObject dbs = new BasicDBObject(); 
	//  dbs.put("name", "uspcat.com"); 
	//  dbs.put("age", 2); 
	//  List<String>  books = new ArrayList<String>(); 
	//  books.add("EXTJS"); 
	//  books.add("MONGODB"); 
	//  dbs.put("books", books); 
	//  mongoDb.insert(dbs, "javadb"); 
	  /** 
	   * 3.批量插入數據 
	   */ 
	//  List<DBObject> dbObjects = new ArrayList<DBObject>(); 
	//  DBObject jim = new BasicDBObject("name","jim"); 
	//  DBObject lisi = new BasicDBObject("name","lisi"); 
	//  dbObjects.add(jim); 
	//  dbObjects.add(lisi); 
	//  mongoDb.insertBatch(dbObjects, "javadb"); 
	  /** 
	   * 4.根據ID刪除數據 
	   */ 
	//  mongoDb.deleteById("502870dab9c368bf5b151a04", "javadb"); 
	  /** 
	   * 5.根據條件刪除數據 
	   */ 
	//  DBObject lisi = new BasicDBObject(); 
	//  lisi.put("name", "lisi"); 
	//  int count = mongoDb.deleteByDbs(lisi, "javadb"); 
	//  System.out.println("刪除數據的條數是: "+count); 
	  /** 
	   * 6.更新操作,為集合增加email屬性 
	   */ 
	//  DBObject update = new BasicDBObject(); 
	//  update.put("$set", 
//	    new BasicDBObject("eamil","test @126.com ")); 
	//  mongoDb.update(new BasicDBObject(), 
//	    update,false,true,"javadb"); 
	  /** 
	   * 7.查詢出persons集合中的name和age 
	   */ 
	//  DBObject keys = new BasicDBObject(); 
	//  keys.put("_id", false); 
	//  keys.put("name", true); 
	//  keys.put("age", true); 
	//  DBCursor cursor = mongoDb.find(null, keys, "persons"); 
//	     while (cursor.hasNext()) { 
//	      DBObject object = cursor.next(); 
//	      System.out.println(object.get("name")); 
//	     } 
	     /** 
	      * 7.查詢出年齡大于26歲并且英語成績小于80分 
	      */ 
	//  DBObject ref = new BasicDBObject(); 
	//  ref.put("age", new BasicDBObject("$gte",26)); 
	//  ref.put("e", new BasicDBObject("$lte",80)); 
	//  DBCursor cursor = mongoDb.find(ref, null, "persons"); 
//	     while (cursor.hasNext()) { 
//	      DBObject object = cursor.next(); 
//	      System.out.print(object.get("name")+"-->"); 
//	      System.out.print(object.get("age")+"-->"); 
//	      System.out.println(object.get("e")); 
//	     } 
	  /** 
	   * 8.分頁例子 
	   */ 
	  DBCursor cursor = mongoDb.find(null, null, 0, 3, "persons"); 
	     while (cursor.hasNext()) { 
	      DBObject object = cursor.next(); 
	      System.out.print(object.get("name")+"-->"); 
	      System.out.print(object.get("age")+"-->"); 
	      System.out.println(object.get("e")); 
	     }   
	  //關閉連接對象 
	  connection.close(); 
	 } 
	 /** 
	  * 穿件一個數據庫集合 
	  * @param collName 集合名稱 
	  * @param db  數據庫實例 
	  */ 
	 public void createCollection(String collName){ 
	  DBObject dbs = new BasicDBObject(); 
	  db.createCollection("javadb", dbs); 
	 } 
	 /** 
	  * 為相應的集合添加數據 
	  * @param dbs 
	  * @param collName 
	  */ 
	 public void insert(DBObject dbs,String collName){ 
	  //1.得到集合 
	  DBCollection coll = db.getCollection(collName); 
	  //2.插入操作 
	  coll.insert(dbs); 
	 } 
	 /** 
	  * 為集合批量插入數據 
	  * @param dbses 
	  * @param collName 
	  */ 
	 public void insertBatch(List<DBObject> dbses,String collName){ 
	  //1.得到集合 
	  DBCollection coll = db.getCollection(collName); 
	  //2.插入操作 
	  coll.insert(dbses); 
	 } 
	 /** 
	  * 根據id刪除數據 
	  * @param id 
	  * @param collName 
	  * @return 返回影響的數據條數 
	  */ 
	 public int deleteById(String id,String collName){ 
	  //1.得到集合 
	  DBCollection coll = db.getCollection(collName); 
	  DBObject dbs = new BasicDBObject("_id", new ObjectId(id)); 
	  int count = coll.remove(dbs).getN(); 
	  return count; 
	 } 
	 /** 
	  * 根據條件刪除數據 
	  * @param id 
	  * @param collName 
	  * @return 返回影響的數據條數 
	  */  
	 public int deleteByDbs(DBObject dbs,String collName){ 
	  //1.得到集合 
	  DBCollection coll = db.getCollection(collName); 
	  int count = coll.remove(dbs).getN(); 
	  return count; 
	 } 
	 /** 
	  * 更新數據 
	  * @param find 查詢器 
	  * @param update 更新器 
	  * @param upsert 更新或插入 
	  * @param multi 是否批量更新 
	  * @param collName 集合名稱 
	  * @return 返回影響的數據條數 
	  */ 
	 public int update(DBObject find, 
	      DBObject update, 
	      boolean upsert, 
	      boolean multi, 
	      String collName){ 
	  //1.得到集合 
	  DBCollection coll = db.getCollection(collName); 
	  int count = coll.update(find, update, upsert, multi).getN(); 
	  return count; 
	 } 
	 /** 
	  * 查詢器(分頁) 
	  * @param ref 
	  * @param keys 
	  * @param start 
	  * @param limit 
	  * @return 
	  */ 
	 public DBCursor find(DBObject ref, 
	   DBObject keys, 
	   int start, 
	   int limit, 
	   String collName){ 
	  DBCursor cur = find(ref, keys, collName); 
	  return cur.limit(limit).skip(start); 
	 } 
	 /** 
	  * 查詢器(不分頁) 
	  * @param ref 
	  * @param keys 
	  * @param start 
	  * @param limit 
	  * @param collName 
	  * @return 
	  */ 
	 public DBCursor find(DBObject ref, 
	   DBObject keys, 
	   String collName){ 
	  //1.得到集合 
	  DBCollection coll = db.getCollection(collName); 
	  DBCursor cur = coll.find(ref, keys); 
	  return cur; 
	 }  
	
}

    

?