Java操作MongoDB：CRUD与聚合实战

MongoDB作为一款高性能的NoSQL数据库，以其灵活的文档存储和强大的查询功能广受欢迎。在Java开发中，如何高效地操作MongoDB进行CRUD（创建、读取、更新、删除）以及聚合操作，是每个开发者必须掌握的技能。本文将带你一步步探索Java操作MongoDB的奥秘。

环境搭建

首先，确保你已经安装了MongoDB服务器，并且它正在运行。接下来，我们需要在Java项目中引入MongoDB的驱动库。通过Maven添加依赖：

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

连接MongoDB

在Java中连接MongoDB非常简单，使用MongoClients类创建一个MongoClient实例：

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

public class MongoDBConnection {
    public static void main(String[] args) {
        MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");
        MongoDatabase database = mongoClient.getDatabase("testDB");
        System.out.println("Connected to the database successfully");
    }
}

CRUD操作

创建文档

使用insertOne方法插入单个文档：

import org.bson.Document;

public class CreateDocument {
    public static void main(String[] args) {
        MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");
        MongoDatabase database = mongoClient.getDatabase("testDB");
        MongoCollection<Document> collection = database.getCollection("users");

        Document doc = new Document("name", "John Doe")
                .append("age", 30)
                .append("city", "New York");

        collection.insertOne(doc);
        System.out.println("Document inserted successfully");
    }
}

读取文档

使用find方法查询文档：

public class ReadDocument {
    public static void main(String[] args) {
        MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");
        MongoDatabase database = mongoClient.getDatabase("testDB");
        MongoCollection<Document> collection = database.getCollection("users");

        Document query = new Document("name", "John Doe");
        FindIterable<Document> iterable = collection.find(query);

        for (Document doc : iterable) {
            System.out.println(doc.toJson());
        }
    }
}

更新文档

使用updateOne方法更新文档：

public class UpdateDocument {
    public static void main(String[] args) {
        MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");
        MongoDatabase database = mongoClient.getDatabase("testDB");
        MongoCollection<Document> collection = database.getCollection("users");

        Document query = new Document("name", "John Doe");
        Document newDoc = new Document("$set", new Document("age", 35));

        collection.updateOne(query, newDoc);
        System.out.println("Document updated successfully");
    }
}

删除文档

使用deleteOne方法删除文档：

public class DeleteDocument {
    public static void main(String[] args) {
        MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");
        MongoDatabase database = mongoClient.getDatabase("testDB");
        MongoCollection<Document> collection = database.getCollection("users");

        Document query = new Document("name", "John Doe");
        collection.deleteOne(query);
        System.out.println("Document deleted successfully");
    }
}

聚合操作

聚合操作用于处理数据，如分组、过滤、投影等。以下是一个简单的聚合示例，计算每个城市的用户数量：

import com.mongodb.client.AggregateIterable;

public class AggregateDocuments {
    public static void main(String[] args) {
        MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");
        MongoDatabase database = mongoClient.getDatabase("testDB");
        MongoCollection<Document> collection = database.getCollection("users");

        List<Document> pipeline = Arrays.asList(
                new Document("$group", new Document("_id", "$city")
                        .append("count", new Document("$sum", 1)))
        );

        AggregateIterable<Document> result = collection.aggregate(pipeline);

        for (Document doc : result) {
            System.out.println(doc.toJson());
        }
    }
}