java 連接 mongodb 及使用


MongoDB是當今非常流行的一款NoSQL數據庫,本文介紹如何使用MongoDB的Java驅動來操作MongoDB。

一、引入MongoDB Java Driver包


 

如果需要操作MongoDB的Java項目是一個Maven項目,可以在依賴中加上以下的配置。

<dependencies>
    <dependency>
        <groupId>org.mongodb</groupId>
        <artifactId>mongo-java-driver</artifactId>
        <version>2.13.2</version>
    </dependency>
</dependencies>

 

或者通過直接下載jar包的方式使用,下載地址:mongo-java-driver-2.13.2.jar。

詳細的如何引入MongoDB jar包的方法可以參考官方文檔。

 

二、連接MongoDB


 

可以使用MongoClient來連接MongoDB,MongoClient的使用方式如下:

MongoClient mongoClient = new MongoClient("localhost", 27017);
DB db = mongoClient.getDB("mydb");

 

上面的代碼連接了localhost:27017上MongoDB服務,並指定使用mydb數據庫。連接后便可以對這個數據庫作進一步的操作。

 

需要指出的是,MongoClient是線程安全的,可以在多程程環境中共享同一個MongoClient。通常來說,一個應用程序中,只需要生成一個全局的MongoClient實例,然后在程序的其他地方使用這個實例即可。

 

三、認證


 

可以使用多種方式對連接進行認證,下面介紹兩種方式。

 

1. 方式一:MongoCredential

 

MongoCredential類的createCredential方法可以指定認證的用戶名,密碼,以及使用的數據庫,並返回一個MongoCredential對象。其方法的聲明如下:

static MongoCredential createCredential(
String userName, String database, char[] password)

 

例如

MongoCredential credential = MongoCredential.createCredential(
"user", "mydb", "password".toCharArray());

 

上面創建了一個用戶名為user,密碼為password,數據庫為mydb的MongoCredential對象。

 

將生成MongoCredential的對象作為MongoClient構造函數的參數。由於MongoClient構造函數的為List<MongoCredential>類型,所以需要先構造成一個List再傳遞。

 

完整的認證的例子如下:

MongoCredential credential = MongoCredential.createCredential(
"user", "mydb", "password".toCharArray());
ServerAddress serverAddress = new ServerAddress("localhost", 27017); MongoClient mongoClient = new MongoClient(serverAddress, Arrays.asList(credential)); DB db = mongoClient.getDB("mydb");

 

2. 方式二:MongoClientURI

 

亦可以使用MongoClientURI完成MongoDB的認證,它代表了一個URI對象。MongoClientURI的構造函數接受一個String類型的字符串,這個字符串的格式如下:

mongodb://[username:password@]
host1[:port1][,host2[:port2],…[,hostN[:portN]]][/[database][?options]]

 

生成的MongoClientURI對象作為MongoClient構造函數的參數,完整的認證例子如下:

String sURI = String.format(
"mongodb://%s:%s@%s:%d/%s", "user", "password", "localhost", 27017, "mydb");
MongoClientURI uri = new MongoClientURI(sURI); MongoClient mongoClient = new MongoClient(uri); DB db = mongoClient.getDB("mydb");

 

四、獲取一個集合


 

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

 

然后可以對指定的集合進行操作,例如,插入,刪除,查找,更新文檔等。

 

五、插入文檔


 

例如,一個文檔以Json來表示如下,

{ “name”: “mongo”, “info”: { “ver”: “3.0” } }

 

現在需要插入到集合mycol中。為了插入到集合中,可以使用BasicDBObject構造一個文檔。

BasicDBObject doc = new BasicDBObject("name", "mongo").append(
"info", new BasicDBObject("ver", "3.0"));
coll.insert(doc);

 

六、查找文檔


 

1. 通過findOne查找一個符合條件文檔

 

通過findOne可以查找一個符合條件的文檔。例如,對於上面的mycol集合,執行以下命令:

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

 

將輸出mycol集合中的第一個文檔。也可以通過指定findOne的查找參數,來查找符合查找條件的一個文檔。

 

2. 通過find查找所有符合條件的文檔

 

find用來查找符合條件的文檔,它返回一個DBCursor對象,通過遍歷DBCursor對象,可以獲得所有符合查找條件的文檔。


為了說明和測試,我們先插入一批以下格式的文檔

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

 

find的使用示例如下:

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

 

會輸出mycol集合中所有的文檔。

 

也可以指定查找的條件,例如:

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

DBCursor cursor = coll.find(query);

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

 

對於查找條件中包括$操作符的情形,例如以下一條mongo shell命令:

db.coll.find({i: {$gte: 50}});

 

可以使用DBObject生成查找條件,

// find all where i >= 50
BasicDBObject query = new BasicDBObject("i", new BasicDBObject("$gte", 50));

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

 

七、更新文檔


 

BasicDBObject query = new BasicDBObject("i", 70);
BasicDBObject up = new BasicDBObject("$set", new BasicDBObject("i", 100));
coll.update(query, up);

 

上面的語句將i為70的文檔更新i的值等於100。

 

與我們常用的更新文檔的mongo語句一樣,DBCollection還包含了save,findAndModify等更新文檔的方法,其使用方法在此不再贅述,可以參考API說明文檔即可。

 

八、刪除文檔


 

可以通過生成一個DBObject對象來刪除指定的文檔,例如:

BasicDBObject query = new BasicDBObject("i", 71);
coll.remove(query);

 

上面的語句刪除i為71的文檔。

 

九、參考資料


 

  • http://mongodb.github.io/mongo-java-driver/2.13/getting-started/installation-guide/

  • http://mongodb.github.io/mongo-java-driver/2.13/getting-started/quick-tour/

  • https://github.com/mongodb/mongo-java-driver/blob/2.13.x/src/examples/example/QuickTour.java

  • http://mongodb.github.io/mongo-java-driver/3.0/driver/reference/connecting/authenticating/

  • http://api.mongodb.org/java/3.0/?com/mongodb/MongoClientURI.html

  • http://api.mongodb.org/java/2.13/

文章地址:http://blog.csdn.net/lihao21/article/details/46939269

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM