MongoDB与Spring Boot整合操作全流程

MongoDB是一款面向文档的NoSQL数据库，它灵活、高效，适合存储各种结构化和非结构化的数据。Spring Boot则是一个简化Java开发的框架，能够快速构建独立的、生产级的Spring应用程序。本文将详细介绍如何将MongoDB与Spring Boot整合，并提供代码示例。

1. 环境准备

1.1 Maven依赖

首先，我们需要创建一个Spring Boot项目，并在pom.xml中添加MongoDB的依赖。以下是示例代码：

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

1.2 MongoDB连接设置

在application.properties文件中配置MongoDB的连接信息：

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

其中localhost是MongoDB的地址，27017是默认端口，testdb是数据库名称。

2. 创建文档模型

接下来，我们需要创建一个代表数据库中集合（Collection）的文档模型。例如，我们可以定义一个User类：

import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;

@Document(collection = "users")
public class User {
    @Id
    private String id;
    private String name;
    private String email;

    // getters and setters
    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }
}

3. 创建Repository接口

为了对User文档进行CRUD操作，我们需要创建一个Repository接口，继承MongoRepository：

import org.springframework.data.mongodb.repository.MongoRepository;

public interface UserRepository extends MongoRepository<User, String> {
    User findByName(String name);
}

4. 创建服务层

服务层负责具体的业务逻辑处理，我们可以创建一个UserService类：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class UserService {
    @Autowired
    private UserRepository userRepository;

    public List<User> getAllUsers() {
        return userRepository.findAll();
    }

    public User getUserById(String id) {
        return userRepository.findById(id).orElse(null);
    }

    public User createUser(User user) {
        return userRepository.save(user);
    }

    public void deleteUser(String id) {
        userRepository.deleteById(id);
    }

    public User updateUser(User user) {
        return userRepository.save(user);
    }
}

5. 创建控制层

最后，我们需要创建一个控制器来处理HTTP请求：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@RestController
@RequestMapping("/users")
public class UserController {
    @Autowired
    private UserService userService;

    @GetMapping
    public List<User> getUsers() {
        return userService.getAllUsers();
    }

    @GetMapping("/{id}")
    public ResponseEntity<User> getUser(@PathVariable String id) {
        User user = userService.getUserById(id);
        return user != null ? ResponseEntity.ok(user) : ResponseEntity.notFound().build();
    }

    @PostMapping
    public User createUser(@RequestBody User user) {
        return userService.createUser(user);
    }

    @PutMapping("/{id}")
    public ResponseEntity<User> updateUser(@PathVariable String id, @RequestBody User user) {
        user.setId(id);
        return ResponseEntity.ok(userService.updateUser(user));
    }

    @DeleteMapping("/{id}")
    public ResponseEntity<Void> deleteUser(@PathVariable String id) {
        userService.deleteUser(id);
        return ResponseEntity.noContent().build();
    }
}

6. 启动应用

创建好以上代码后，我们可以通过Spring Boot的启动类来运行应用。通常在Application.java中，会有如下代码：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

7. 测试接口

启动应用后，可以通过Postman或浏览器测试接口。下面是一些常用的HTTP请求示例：

• 查询所有用户: GET /users
• 查询用户: GET /users/{id}
• 创建用户: POST /users （请求体为JSON格式）
• 更新用户: PUT /users/{id} （请求体为JSON格式）
• 删除用户: DELETE /users/{id}

通过以上步骤，我们成功实现了MongoDB与Spring Boot的整合，并完成了基本的CRUD操作。这只是一个简单的示例，实际应用中可以根据需求扩展更多功能。希望这篇文章对你有所帮助！