Java連接MongoDB

一、MongoDB簡介

MongoDB是一個基於分布式文件存儲的開源數據庫。它的數據存儲方式是以BSON（一種二進制的JSON格式）為中心的，可以存儲對象和數組數據類型。MongoDB是一個面向文檔的數據庫，而非關係型數據庫，在使用上有着比較大的不同。

二、Java連接MongoDB

Java可以通過maven依賴的方式引用MongoDB官方提供的Java Driver。

<dependency>
    <groupId>org.mongodb</groupId>
    <artifactId>mongodb-driver</artifactId>
    <version>3.12.7</version>
</dependency>

然後在Java代碼中使用MongoClient連接MongoDB服務器。以下為示例代碼：

import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoDatabase;

public class MongoConnectivity {
    public static void main( String args[] ) {
        try {
            // 連接到MongoDB
            MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
            MongoClient client = new MongoClient(uri);
            
            // 獲取數據庫
            MongoDatabase database = client.getDatabase("mydb");
            
            // 打印數據庫名稱
            System.out.println("MongoDB database name: " + database.getName());
            
            // 關閉連接
            client.close();
        } catch (Exception e) {
            System.err.println(e.getClass().getName() + ": " + e.getMessage());
        }
    }
}

上述代碼連接了本地MongoDB服務器，並指定了要使用的數據庫。然後獲取該數據庫對象，並打印出數據庫的名稱。最後，關閉MongoClient連接。

三、MongoDB操作

1. 插入數據

使用MongoDB的Java Driver通過以下代碼來向指定的集合中插入一條數據：

import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;

public class InsertData {
    public static void main( String args[] ) {
        try {
            // 連接到MongoDB
            MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
            MongoClient client = new MongoClient(uri);

            // 獲取數據庫
            MongoDatabase database = client.getDatabase("mydb");

            // 獲取集合
            MongoCollection collection = database.getCollection("mycollection");

            // 插入數據
            Document doc = new Document("name", "MongoDB")
                    .append("type", "database")
                    .append("count", 1);
            collection.insertOne(doc);

            // 關閉連接
            client.close();
        } catch (Exception e) {
            System.err.println(e.getClass().getName() + ": " + e.getMessage());
        }
    }    
}

2. 查詢數據

查詢MongoDB中的數據可以使用以下代碼段：

import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;

public class QueryData {
    public static void main( String args[] ) {
        try {
            // 連接到MongoDB
            MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
            MongoClient client = new MongoClient(uri);
            
            // 獲取數據庫
            MongoDatabase database = client.getDatabase("mydb");
            
            // 獲取集合
            MongoCollection collection = database.getCollection("mycollection");
          
            // 查詢數據
            FindIterable cursor = collection.find(Filters.eq("name", "MongoDB"));
            for (Document doc : cursor) {
               System.out.println(doc.toJson());
            }
            
            // 關閉連接
            client.close();
        } catch (Exception e) {
            System.err.println(e.getClass().getName() + ": " + e.getMessage());
        }
    }    
}

3. 更新數據

使用以下代碼段可以更新符合條件的數據：

import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;
import com.mongodb.client.model.Updates;

public class UpdateData {
    public static void main( String args[] ) {
        try {
            // 連接到MongoDB
            MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
            MongoClient client = new MongoClient(uri);

            // 獲取數據庫
            MongoDatabase database = client.getDatabase("mydb");

            // 獲取集合
            MongoCollection collection = database.getCollection("mycollection");

            // 更新數據
            collection.updateMany(Filters.eq("name", "MongoDB"), Updates.set("count", 2));

            // 關閉連接
            client.close();
        } catch (Exception e) {
            System.err.println(e.getClass().getName() + ": " + e.getMessage());
        }
    }    
}

4. 刪除數據

使用以下代碼段可以刪除符合條件的數據：

import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;

public class DeleteData {
    public static void main( String args[] ) {
        try {
            // 連接到MongoDB
            MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
            MongoClient client = new MongoClient(uri);

            // 獲取數據庫
            MongoDatabase database = client.getDatabase("mydb");

            // 獲取集合
            MongoCollection collection = database.getCollection("mycollection");

            // 刪除數據
            collection.deleteMany(Filters.eq("name", "MongoDB"));

            // 關閉連接
            client.close();
        } catch (Exception e) {
            System.err.println(e.getClass().getName() + ": " + e.getMessage());
        }
    }    
}

四、小結

本文介紹了Java連接MongoDB的基本方法，以及如何進行增刪改查操作。MongoDB是一個非常靈活的數據庫，可以根據應用情況選擇不同的存儲方式和查詢方式，能夠更好地滿足應用的需求。