SpringBoot集成MongoDB

MongoDB是一个开源、高性能、可扩展的文档型数据库系统。与传统关系型数据库相比，MongoDB具有更高的性能和更好的可伸缩性，并且可以存储非结构化数据。SpringBoot是一个基于Spring框架的快速开发框架，它提供了一种方便快捷的方式来构建和部署Web应用程序。SpringBoot可以集成不同种类的数据库，本文章介绍的是SpringBoot集成下的MongoDB的操作。

文章共3,251字 · 阅读需要大约11分钟

一键AI生成摘要，助你高效阅读

问答

努力，努力，在努力！

2819人浏览 · 2023-04-21 14:10:19

努力，努力，在努力！ · 2023-04-21 14:10:19 发布

前言

MongoDB是一个开源、高性能、可扩展的文档型数据库系统。与传统关系型数据库相比，MongoDB具有更高的性能和更好的可伸缩性，并且可以存储非结构化数据。

SpringBoot是一个基于Spring框架的快速开发框架，它提供了一种方便快捷的方式来构建和部署Web应用程序。SpringBoot可以集成不同种类的数据库，本文章介绍的是SpringBoot集成下的MongoDB的操作。

集成SpringBoot和MongoDB的方法如下：

添加MongoDB依赖：在pom.xml文件中添加对MongoDB的依赖。
配置MongoDB：在application.properties文件中添加MongoDB的配置信息。
创建MongoDB Repository：使用Spring Data MongoDB创建MongoDB Repository接口。
集成MongoDB：在SpringBoot主类上添加@EnableMongoRepositories注解，并将MongoDB Repository添加到SpringBoot应用程序中。

SpringBoot集成MongDB的优缺点
优点：

高性能：MongoDB使用内存映射I/O和数据预读取等技术，可以在高负载下保持高性能。
可伸缩性：MongoDB支持分片和复制集等功能，可以轻松地扩展存储和处理能力。
非结构化数据存储：MongoDB支持存储非结构化数据，可以存储复杂的文档和对象。

缺点：

内存占用：MongoDB需要在内存中存储索引和数据，因此对内存的使用较多。
数据一致性：MongoDB的数据一致性可能受到分片和复制集等因素的影响。可能出现数据冲突或数据丢失等问题。

实现

SpringBoot集成MongoDB下的操作包括：连接数据库、新增数据、查询数据、更新数据、删除数据。

创建Maven工程

在开始写代码之前，我们需要准备好一个Maven工程。新建一个Maven工程，添加以下依赖：

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency>
	<groupId>org.mongodb</groupId>
	<artifactId>mongo-java-driver</artifactId>
	<version>.0</version>
</dependency>

配置application.properties

在application.properties中添加以下配置信息：

spring.data.mongodb.host=localhost
spring.data.mongodb.port=27017
spring.data.mongodb.database=test
spring.data.mongodb.username=
spring.data.mongodb.password=

或者用实体类配置

@Configuration
@EnableMongoRepositories(basePackages = "com.example.repository")
public class MongoConfig extends AbstractMongoClientConfiguration {

    @Value("${spring.data.mongodb.host}")
    private String host;

    @Value("${spring.data.mongodb.port}")
    private int port;

    @Value("${spring.data.mongodb.database}")
    private String database;

    @Value("${spring.data.mongodb.username}")
    private String username;

    @Value("${spring.data.mongodb.password}")
    private String password;

    @Override
    protected String getDatabaseName() {
        return database;
    }

    @Override
    public MongoClient mongoClient() {
        return MongoClients.create(ConnectionString.format("mongodb://%s:%d", host, port));
    }

    @Override
    protected boolean autoIndexCreation() {
        return true;
    }

    @Override
    @Bean
    public MongoTemplate mongoTemplate() {
        return new MongoTemplate(mongoClient(), database);
    }

}

创建实体类

在src/main/java/目录下新建一个实体类。本篇文章中的实体类为User，具体代码如下：

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

//Document注解表明对应了MongoDB中的user表。
@Document(collection = "user")
public class User {
    @Id
    private String id;
    private String name;
    private Integer 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 Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }
}

新增数据

@Repository
public class UserRepository {

    @Autowired
    MongoTemplate mongoTemplate;

    @Autowired
    MongoOperations mongoOperations;

    // 可以直接将实体对象插入到指定的集合中
    @Override
    public User save(User user) {
        mongoTemplate.save(user);
        return user;
    }

    // 一次性插入多条数据
    @Override
    public void saveAll(List<User> userList) {
        mongoTemplate.insertAll(userList);
    }

}

查询数据

@Repository
public class UserRepository {

    @Autowired
    MongoTemplate mongoTemplate;

    @Autowired
    MongoOperations mongoOperations;

    // 多条件组合查询，并支持分页查询和排序查询
    @Override
    public List<User> findUser(UserQuery query) {
        Query q = query.buildQuery();
        q.with(query.buildPageable());
        q.with(query.buildSort());
        return mongoTemplate.find(q, User.class);
    }

    // 使用Query和Criteria构造查询条件，使用MongoTemplate的find方法查询符合条件的数据集合
    @Override
    public List<User> findByAge(int minAge, int maxAge) {
        Query query = new Query();
        query.addCriteria(Criteria.where("age").gte(minAge).lte(maxAge));
        return mongoTemplate.find(query, User.class);
    }

}

更新数据

@Repository
public class UserRepository {

    @Autowired
    MongoTemplate mongoTemplate;

    @Autowired
    MongoOperations mongoOperations;

    // 直接更新指定的实体对象
    @Override
    public void update(User user) {
        mongoTemplate.save(user);
    }

    // 使用Query和Update构造更新条件和更新内容
    @Override
    public void updateAge(String id, int age) {
        Query query = new Query(Criteria.where("id").is(id));
        Update update = new Update().set("age", age);
        mongoTemplate.updateFirst(query, update, User.class);
    }

}

删除数据

@Repository
public class UserRepository {

    @Autowired
    MongoTemplate mongoTemplate;

    @Autowired
    MongoOperations mongoOperations;

    // 直接删除指定的实体对象
    @Override
    public void delete(User user) {
        mongoTemplate.remove(user);
    }

    // 使用Query构造删除条件
    @Override
    public void deleteById(String id) {
        Query query = new Query(Criteria.where("id").is(id));
        mongoTemplate.remove(query, User.class);
    }

}