（1）建立連接

建立一個(gè)mongodb的連接，至少應(yīng)該知道數(shù)據(jù)庫(kù)實(shí)例的名稱（不一定存在。如果不存在，會(huì)創(chuàng)建一個(gè)新的）

此外，可以指定mongodb服務(wù)器的ip和端口，下面的代碼展現(xiàn)了三種不同的連接方式連接到mydb的數(shù)據(jù)庫(kù)實(shí)例上

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;

import java.util.Arrays;

// 方式一：直接連接單一mongodb服務(wù)器（注意這種方式不會(huì)自動(dòng)發(fā)現(xiàn)mongodb集群中的主服務(wù)器）
MongoClient mongoClient = new MongoClient();
// 方式二（指定ip）：
MongoClient mongoClient = new MongoClient( "localhost" );
// 方式二（指定ip、端口）：
MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
// 方式三：連接到mongodb服務(wù)器集群（會(huì)自動(dòng)發(fā)現(xiàn)主服務(wù)器）
MongoClient mongoClient = new MongoClient(Arrays.asList(new ServerAddress("localhost", 27017),
                                      new ServerAddress("localhost", 27018),
                                      new ServerAddress("localhost", 27019)));

DB db = mongoClient.getDB( "mydb" );

注：MongoClient的實(shí)例代表數(shù)據(jù)庫(kù)連接池，客戶端在多線程環(huán)境下也只需要一個(gè)實(shí)例，請(qǐng)?jiān)L問http://docs./ecosystem/drivers/java-concurrency/#java-driver-concurrency獲取更多信息

MongoClient被設(shè)計(jì)成線程安全、可以被多線程共享的。通常訪問數(shù)據(jù)庫(kù)集群的應(yīng)用只需要一個(gè)實(shí)例。如果出于某些原因，你決定使用多個(gè)實(shí)例，請(qǐng)注意：

所有資源使用限制（最大連接數(shù)等等）對(duì)每個(gè)MongoClient都適用

銷毀一個(gè)實(shí)例時(shí)，請(qǐng)確認(rèn)調(diào)用MongoClient.close()方法來(lái)清理資源

MongoClient類最早從2.10.0版本引入，先前的版本請(qǐng)使用Mongo類

注：mongodb安裝、啟動(dòng)可以參考http://www.cnblogs.com/huangxincheng/archive/2012/02/18/2356595.html

(2)認(rèn)證（可選）

MongoDB可以運(yùn)行在安全模式上。當(dāng)運(yùn)行在這個(gè)模式下時(shí)，任何客戶端應(yīng)用在執(zhí)行任何操作前必須提供用戶名、密碼。java客戶端示例代碼如下：

MongoClient mongoClient = new MongoClient();
DB db = mongoClient.getDB("test");
boolean auth = db.authenticate(myUserName, myPassword);

(3)獲取所有集合（集合類似于mysql中的表）

每個(gè)數(shù)據(jù)庫(kù)實(shí)例有0個(gè)或者多個(gè)集合，通過db可以獲取到。

Set<String> colls = db.getCollectionNames();

for (String s : colls) {
    System.out.println(s);
}

name
address

調(diào)用db的getCollection（String collectionName）方法獲得單一集合

DBCollection coll = db.getCollection("testCollection");

(5)設(shè)置 write concern

2.10.0及以后版本，默認(rèn)的write concern是WriteConcern.ACKNOWLEDGED?？梢愿淖兡J(rèn)模式：

mongoClient.setWriteConcern(WriteConcern.JOURNALED);

2.10.0以前的版本，默認(rèn)值是WriteConcern.NORMAL。一般情況，客戶端會(huì)改變這個(gè)值來(lái)保證寫入數(shù)據(jù)庫(kù)如果有問題可以被通知到。

(6)增加文檔（類似向數(shù)據(jù)庫(kù)中增加一條記錄）

一旦獲取集合對(duì)象coll，就可以插入一條文檔了。例如：插入下面json格式的文檔

{
   "name" : "MongoDB",
   "type" : "database",
   "count" : 1,
   "info" : {
               x : 203,
               y : 102
             }
}

BasicDBObject doc = new BasicDBObject("name", "MongoDB").
                              append("type", "database").
                              append("count", 1).
                              append("info", new BasicDBObject("x", 203).append("y", 102));

coll.insert(doc);

通過調(diào)用findOne()方法可以獲得上一步中我們插入的文檔。方法的返回值返回一個(gè)單一的文檔（與DBCurse的find()方法不同）。當(dāng)只存在唯一文檔或者只關(guān)心第一個(gè)文檔時(shí)非常有用。

DBObject myDoc = coll.findOne();
System.out.println(myDoc);

{ "_id" : "49902cde5162504500b45c2c" ,
  "name" : "MongoDB" ,
  "type" : "database" ,
  "count" : 1 ,
  "info" : { "x" : 203 , "y" : 102}}

(8)添加多條文檔

為了方便以后的查詢操作，現(xiàn)在向集合中增加多條文檔

這些文檔的格式為：

{
   "i" : value
}

for (int i=0; i < 100; i++) {
    coll.insert(new BasicDBObject("i", i));
}

(8)查詢集合中文檔總個(gè)數(shù)

目前，已經(jīng)向集合中插入101條文檔（100條是通過循環(huán)添加的，1條是單獨(dú)添加的）?？梢哉{(diào)用getCount()方法查詢總個(gè)數(shù)

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

(9)使用游標(biāo)查詢所有文檔

可以使用find()方法查詢集合中的所有文檔。方法返回一個(gè)DBCursor。這個(gè)對(duì)象可以遍歷查詢出的文檔集合。下面是查詢所有文檔并且輸出到控制臺(tái)的代碼片段

DBCursor cursor = coll.find();
try {
   while(cursor.hasNext()) {
       System.out.println(cursor.next());
   }
} finally {
   cursor.close();
}

(10)查詢單一文檔

通過向find()方法傳遞參數(shù)可以查詢到集合的一部分文檔集合。例如：查找i==71的文檔的代碼片段如下：

BasicDBObject query = new BasicDBObject("i", 71);

cursor = coll.find(query);

try {
   while(cursor.hasNext()) {
       System.out.println(cursor.next());
   }
} finally {
   cursor.close();
}

{ "_id" : "49903677516250c1008d624e" , "i" : 71 }

db.things.find({j: {$ne: 3}, k: {$gt: 10} });

BasicDBObject query = new BasicDBObject("j", new BasicDBObject("$ne", 3)).
                                      append("k", new BasicDBObject("$gt", 10));

cursor = coll.find(query);

try {
   while(cursor.hasNext()) {
       System.out.println(cursor.next());
   }
} finally {
   cursor.close();
}

通過查詢可以獲取集合中的多個(gè)文檔。例如：查詢i>50的文檔：

query = new BasicDBObject("i", new BasicDBObject("$gt", 50));  // e.g. find all where i > 50

cursor = coll.find(query);

try {
   while(cursor.hasNext()) {
       System.out.println(cursor.next());
   }
} finally {
   cursor.close();
}

查詢20<i<=30的文檔：

query = new BasicDBObject("i", new BasicDBObject("$gt", 20).
                                               append("$lte", 30));  // i.e.   20 < i <= 30
cursor = coll.find(query);

try {
   while(cursor.hasNext()) {
       System.out.println(cursor.next());
   }
} finally {
   cursor.close();
}

(12)創(chuàng)建索引

mongodb支持索引并且添加到集合中也非常方便。創(chuàng)建一個(gè)索引，需要指定被索引的字段以及索引方向（1代表升序、2代表降序）。

為字段i添加索引：

coll.createIndex(new BasicDBObject("i", 1));  // create index on "i", 升序

示例代碼：

List<DBObject> list = coll.getIndexInfo();

for (DBObject o : list) {
   System.out.println(o);
}

{ "name" : "i_1" , "ns" : "mydb.testCollection" , "key" : { "i" : 1} }

示例代碼如下：

MongoClient mongoClient = new MongoClient();

for (String s : mongoClient.getDatabaseNames()) {
   System.out.println(s);
}

示例代碼如下：

MongoClient mongoClient = new MongoClient();
mongoClient.dropDatabase("myDatabase");