MongoDB 集成 - 配置连接 - 连接 MongoDB 数据库

Java - Web - Spring 《MongoDB 集成 - 配置连接 - 连接 MongoDB 数据库》

在现代的 Web 开发中，数据库是不可或缺的一部分。MongoDB 作为一个流行的 NoSQL 数据库，以其灵活的数据模型和高可扩展性受到广泛关注。在 Java 的 Spring 框架中集成 MongoDB 可以让开发者更方便地操作数据库。本文将详细介绍如何在 Spring 项目中配置并连接 MongoDB 数据库，并给出相应的演示代码。

1. 项目环境准备

在开始之前，确保你已经安装了以下软件：

• Java 开发环境（JDK 8 及以上）
• Maven 或 Gradle 构建工具
• MongoDB 数据库

创建 Spring Boot 项目

你可以使用 Spring Initializr（https://start.spring.io/）来快速创建一个 Spring Boot 项目，添加以下依赖：

• Spring Web
• Spring Data MongoDB

2. 配置 MongoDB 连接

2.1 在 application.properties 或 application.yml 中配置连接信息

使用 application.properties

spring.data.mongodb.host=localhost
spring.data.mongodb.port=27017
spring.data.mongodb.database=testdb

使用 application.yml

spring:
  data:
    mongodb:
      host: localhost
      port: 27017
      database: testdb

上述配置中，host 是 MongoDB 服务器的地址，port 是端口号（默认是 27017），database 是要连接的数据库名称。

2.2 如果 MongoDB 有用户名和密码

使用 application.properties

spring.data.mongodb.host=localhost
spring.data.mongodb.port=27017
spring.data.mongodb.database=testdb
spring.data.mongodb.username=yourUsername
spring.data.mongodb.password=yourPassword

使用 application.yml

spring:
  data:
    mongodb:
      host: localhost
      port: 27017
      database: testdb
      username: yourUsername
      password: yourPassword

3. 演示代码

3.1 创建实体类

首先，创建一个简单的实体类，用于映射 MongoDB 中的文档。

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 int age;
    // 构造函数、Getter 和 Setter 方法
    public User() {}
    public User(String name, int age) {
        this.name = name;
        this.age = age;
    }
    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 int getAge() {
        return age;
    }
    public void setAge(int age) {
        this.age = age;
    }
    @Override
    public String toString() {
        return "User{" +
                "id='" + id + '\'' +
                ", name='" + name + '\'' +
                ", age=" + age +
                '}';
    }
}

3.2 创建 Repository 接口

Spring Data MongoDB 提供了 MongoRepository 接口，我们可以通过继承该接口来实现对 MongoDB 的基本操作。

import org.springframework.data.mongodb.repository.MongoRepository;
public interface UserRepository extends MongoRepository<User, String> {
}

3.3 创建服务类

创建一个服务类，用于调用 Repository 接口的方法。

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 saveUser(User user) {
        return userRepository.save(user);
    }
}

3.4 创建控制器类

创建一个控制器类，用于处理 HTTP 请求。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@RestController
@RequestMapping("/users")
public class UserController {
    @Autowired
    private UserService userService;
    @GetMapping
    public List<User> getAllUsers() {
        return userService.getAllUsers();
    }
    @PostMapping
    public User saveUser(@RequestBody User user) {
        return userService.saveUser(user);
    }
}

4. 测试连接

启动 Spring Boot 项目，使用 Postman 或其他工具进行测试：

• 保存用户信息：发送一个 POST 请求到 http://localhost:8080/users，请求体为：

  {
    "name": "John Doe",
    "age": 30
  }

• 获取所有用户信息：发送一个 GET 请求到 http://localhost:8080/users

总结

通过以上步骤，你就可以在 Spring 项目中成功集成并连接 MongoDB 数据库，实现基本的数据操作。希望本文对你有所帮助，让你在 Java Web 开发中更加得心应手！