在開發中如何實現MongoDB與Java的集成

這篇“在開發中如何實現MongoDB與Java的集成”文章的知識點大部分人都不太理解，所以小編給大家總結了以下內容，內容詳細，步驟清晰，具有一定的借鑒價值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來看看這篇“在開發中如何實現MongoDB與Java的集成”文章吧。

1.什么是MongoDB？

MongoDB 是一種非常流行的 NoSQL 開源數據庫。它適用于集合而不是表和文檔而不是行和列，可提供高性能、高可用性和輕松的可擴展性。

示例文件：

{
   "_id" : ObjectId("5b0d226b31a5f6595a7034de"),
   "firstName" : "Dharam",
   "lastName" : "Rajput"
}

1.1 我們需要什么

• MongoDB 3.6

• MongoDB-Java-Driver 2.10.1

• JDK 1.8

• Maven 3.0.3

1.2 所需的依賴

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

現在讓我們開始用 Java 實現 Mongo 查詢，我們將從 CRUD 操作開始。

2. 與 MongoClient 的連接

如果我們使用低于2.10.0的MongoDB版本，那么我們使用MongoDB服務器，但我們使用的是更高版本，所以我們將使用MongoClient與MongoDB建立連接。

MongoClient mongo = new MongoClient( "localhost" , 27017 );
// If we use older version than
Mongo mongo = new Mongo("localhost", 27017);

3. 與數據庫的連接

現在連接數據庫。如果您的數據庫不存在，那么 Mongo 將創建一個新數據庫。

DB database = mongoClient.getDB("testdb");

如果我們在安全模式下使用 Mongo，則需要身份驗證。

MongoClient mongoClient = new MongoClient();
DB database = mongoClient.getDB("testdb"); // testdb is db name
boolean auth = database.authenticate("username", "password".toCharArray());

使用以下代碼檢查哪個數據庫已經存在。

mongoClient.getDatabaseNames().forEach(System.out::println);

4. 蒙戈收藏

現在，創建一個相當于RDBMS 中的表的集合。我們可以將集合設為：

database.createCollection("users", null);

獲取并打印所選數據庫的所有現有集合。

database.getCollectionNames().forEach(System.out::println);

5. 插入文檔

現在我們將在集合（表）中保存一個文檔（數據）。

DBCollection table = db.getCollection("users");
BasicDBObject document = new BasicDBObject();
document.put("firstName", "Dharam");
document.put("lastName", "Rajput");
table.insert(document);

現在已經在數據庫中插入了一個文檔。

{
   "_id" : ObjectId("5b0d226b31a5f6595a7034de"),
   "firstName" : "Dharam",
   "lastName" : "Rajput"
}

6. 更新文檔

假設我們有以下文檔：

{
   "_id" : ObjectId("5b0d226b31a5f6595a7034de"),
   "firstName" : "Dharam",
   "lastName" : "Rajput"
}

我們想更改此文檔的名字。

首先搜索 name="Dharam" 的文檔并使用新值 "Dharmendra" 更新它

BasicDBObject query = new BasicDBObject();
query.put("firstName", "Dharam");
BasicDBObject newDocument = new BasicDBObject();
newDocument.put("firstName", "Dharmendra");
BasicDBObject updateObj = new BasicDBObject();
updateObj.put("$set", newDocument);

7. 在集合中查找文檔

在用戶集合中搜索“firstName = Dharmendra”的文檔

DBCollection db= db.getCollection("user");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.put("firstName", "Dharmendra");
DBCursor cursor = db.find(searchQuery);
while (cursor.hasNext()) {
System.out.println(cursor.next());
}

8. 刪除文件

刪除“firstName = Dharmendra”的文檔。

DBCollection db= db.getCollection("user");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.put("name", "mkyong");
db.remove(searchQuery);

本教程是 MongoDB 與 Java 的快速介紹。

現在在這里找到 MongoDB 與 Java 集成的完整代碼。

package com.demo.mongodb;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.MongoClient;
public class TestDB {
public static void main(String[] args) {
try {
/**** Connect to MongoDB ****/
// Since 2.10.0, uses MongoClient
MongoClient mongoClient = new MongoClient("localhost", 27017);
/**** Get database ****/
// if database doesn't exists, MongoDB will create it for you
DB db = mongoClient.getDB("testdb");
mongoClient.getDatabaseNames().forEach(System.out::println);
/**** Get collection / table from 'testdb' ****/
// if collection doesn't exists, MongoDB will create it for you
DBCollection collection = db.getCollection("users");
/**** Insert ****/
// create a document to store key and value
BasicDBObject document = new BasicDBObject();
document.put("firstName", "Dharam");
document.put("lastName", "Rajput");
collection.insert(document);
/**** Find and display ****/
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.put("firstName", "Dharam");
DBCursor dbCursor = collection.find(searchQuery);
while (dbCursor.hasNext()) {
System.out.println(dbCursor.next());
}
/**** Update ****/
// search document where name="Dharam" and update it with new values "Dharmendra"
BasicDBObject dbQuery = new BasicDBObject();
dbQuery.put("firstName", "Dharam");
BasicDBObject newDocument = new BasicDBObject();
newDocument.put("firstName", "Dharmendra");
BasicDBObject updateObj = new BasicDBObject();
updateObj.put("$set", newDocument);
collection.update(dbQuery, updateObj);
/**** Find and display ****/
BasicDBObject findQuery
   = new BasicDBObject().append("firstName", "Dharmendra");
DBCursor findCursor = collection.find(findQuery);
while (findCursor.hasNext()) {
System.out.println(findCursor.next());
}
   } catch (Exception e) {
e.printStackTrace();
 }
}
}

以上就是關于“在開發中如何實現MongoDB與Java的集成”這篇文章的內容，相信大家都有了一定的了解，希望小編分享的內容對大家有幫助，若想了解更多相關的知識內容，請關注億速云行業資訊頻道。