MongoDB教程（九）：java集成mongoDB

用户11147438

发布于 2024-07-20 16:39:23

950

发布于 2024-07-20 16:39:23

文章被收录于专栏：Linux系列

💝💝💝首先，欢迎各位来到我的博客，很高兴能够在这里和您见面！希望您在这里不仅可以有所收获，同时也能感受到一份轻松欢乐的氛围，祝你生活愉快！

引言

在现代应用程序开发中，MongoDB 作为一种高性能、灵活的 NoSQL 数据库，越来越受到开发者们的青睐。而 Java，作为企业级应用开发的主流语言之一，与 MongoDB 的集成显得尤为重要。本文将详细阐述如何在 Java 应用中引入 MongoDB，包括必要的库添加、连接配置、基本的 CRUD 操作，以及一些高级功能的使用，通过具体案例代码展示每一个步骤。

一、环境准备

1. 安装 MongoDB

确保你的系统中已经安装并运行了 MongoDB。如果尚未安装，可以从 MongoDB 官方网站下载安装包，按照官方文档完成安装步骤。

2. Maven 项目配置

在 Java 项目中使用 MongoDB，需要引入官方提供的 Java 驱动库。如果你的项目使用 Maven，可以在 pom.xml 文件中添加以下依赖：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-mongodb</artifactId>
        <version>2.7.0</version>
    </dependency>
</dependencies>

如果项目不使用 Spring Boot，则直接引入 MongoDB Java Driver：

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

二、连接 MongoDB

1. 配置 MongoDB 连接

在 Spring Boot 项目中，可以通过 application.properties 文件配置 MongoDB 的连接信息：

spring.data.mongodb.uri=mongodb://localhost:27017/testdb

对于非 Spring Boot 的项目，需要在代码中手动创建 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 操作

1. 插入文档

import com.mongodb.client.MongoCollection;
import com.mongodb.client.model.InsertOneOptions;
import org.bson.Document;

public class InsertDocument {
    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 document = new Document("name", "John Doe")
                             .append("email", "john.doe@example.com")
                             .append("age", 30);

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

2. 查询文档

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

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

        FindIterable<Document> iterable = collection.find(Filters.eq("name", "John Doe"));
        for (Document doc : iterable) {
            System.out.println(doc.toJson());
        }
    }
}

3. 更新文档

import com.mongodb.client.MongoCollection;
import com.mongodb.client.model.Filters;
import com.mongodb.client.model.Updates;
import org.bson.Document;

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");

        collection.updateOne(Filters.eq("name", "John Doe"),
                             Updates.set("age", 31));

        System.out.println("Document updated successfully");
    }
}

4. 删除文档

import com.mongodb.client.MongoCollection;
import com.mongodb.client.model.Filters;

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");

        collection.deleteOne(Filters.eq("name", "John Doe"));

        System.out.println("Document deleted successfully");
    }
}

四、高级功能：聚合管道

MongoDB 的聚合框架提供了强大的数据处理能力。下面是一个使用聚合框架的示例：

import com.mongodb.client.MongoCollection;
import com.mongodb.client.AggregateIterable;
import com.mongodb.client.model.Aggregates;
import org.bson.Document;

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

        AggregateIterable<Document> results = collection.aggregate(
                Arrays.asList(
                        Aggregates.match(new Document("status", "A")),
                        Aggregates.group("$customer_id", Accumulators.sum("total", "$amount"))
                )
        );

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