在SpringBoot中使用MongoDB完成数据存储

更新时间：2023年11月19日 09:48:47 作者：Miaow.Y.Hu

本文主要介绍了在SpringBoot中如恶化使用MongoDB完成数据存储,接下来这篇我们将围绕MongoDB进行,MongoDB是一个开源的,面向文档的NoSQL数据库管理系统,使用类似JSON的BSON（二进制JSON）格式来存储数据,具有灵活的数据模型和强大的查询功能,需要的朋友可以参考下

我们在开发中用到的数据存储工具有许多种，我们常见的数据存储工具包括：

关系性数据库：使用表格来存储数据，支持事务和索引。（如：MySQL，Oracle，SQL Server等）。NoSQL数据库：不使用表格来存储数据，而是使用键值对、文档、或者图形等方式来存储数据，适合处理高并发和大规模数据。（Redis，MongoDB，Cassandra等）文件存储：将数据存储在本地或者远程服务器文件中，常用与存储较小的文件。（FTP，SFTP，AWS C3等）云存储：数据存储在云端，方便多人协作和备份。（Google Drive，Dropbox，OneDriver等）内存存储：将数据存储在内存中，提供快速的读写速度，但是不适用存储持久化数据（Redis，Memcache等）。缓存：将数据存储在缓存中，提高访问速度，减少数据库压力。（Apc，Memcache，Redis等）队列：将任务分发到不同的队列中进行处理，提高系统的可靠性和可拓展性。（RabbitMQ，Kafka等）

这篇我们将围绕MongoDB进行，MongoDB是一个开源的，面向文档的NoSQL数据库管理系统，使用类似JSON的BSON（二进制JSON）格式来存储数据，具有灵活的数据模型和强大的查询功能。

与传统的关系型数据库不同的是，MongoDB不使用表和行的结构，而是使用集合和文档进行的，一个集合就相当于关系型数据库里边的表，一个文档就相当于表中的一行数据，每个文档都是一个键值对的集合，可以包含不同类型的数据。

MongoDB的特点：

面向文档：MongoDB使用灵活的文档模型，可以存储不同结构的数据，无需事先定义表结构。
可扩展性：MongoDB支持水平扩展，可以通过添加更多的服务器来处理大规模的数据和高并发访问。
高性能：MongoDB具有快速的读写性能，支持索引和复杂查询。
强大的查询语言：MongoDB支持丰富的查询语言，包括条件查询、范围查询、正则表达式查询等。
数据复制和故障恢复：MongoDB支持数据复制和自动故障恢复，可以提供高可用性和数据安全性。
地理空间索引：MongoDB支持地理空间索引，可以进行地理位置相关的查询和分析。
开源和活跃的社区：MongoDB是开源的，拥有庞大的用户社区和活跃的开发者社区。

首先在我们测试MongoDB之前，我们需要安装MongoDB，MongoDB下载网站：https://www.mongodb.com/try/download/community

在这里插入图片描述

之后安装后，创建一个test数据库：

在这里插入图片描述

引入相关依赖：

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

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

		<dependency>
			<groupId>org.projectlombok</groupId>
			<artifactId>lombok</artifactId>
			<scope>provided</scope>
		</dependency>

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>

在application.properties中配置相关连接：

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

server.port=7723

创建一个实体类User

public class User {

    @Id
    private Long id;

    private String username;
    private Integer age;


    public Long getId() {
        return id;
    }

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

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public Integer getAge() {
        return age;
    }

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

    public User() {
    }

    public User(Long id, String username, Integer age) {
        this.id = id;
        this.username = username;
        this.age = age;
    }
}

实现用户实体User的数据访问对象

public interface UserRepository extends MongoRepository<User, Long> {

    User findByUsername(String username);

}

接下来创建一个单元测试用例：

@SpringBootTest(classes = Application.class)
public class ApplicationTests {

    @Autowired
    private UserRepository userRepository;

    @Test
    public void test() throws Exception {
        userRepository.deleteAll();

        // 创建三个User，并验证User总数
        userRepository.save(new User(1L, "麻衣**", 22));
        userRepository.save(new User(2L, "娜*", 24));
        userRepository.save(new User(3L, "玩偶**", 26));
        Assertions.assertEquals(3, userRepository.findAll().size());

        // 删除一个User，再验证User总数
        User u = userRepository.findById(1L).get();
        userRepository.delete(u);
        Assertions.assertEquals(2, userRepository.findAll().size());

        // 删除一个User，再验证User总数
        u = userRepository.findByUsername("娜*");
        userRepository.delete(u);
        Assertions.assertEquals(1, userRepository.findAll().size());
    }

}

控制台输出

2023-11-17 15:39:39.655  INFO 15808 --- [           main] org.mongodb.driver.cluster               : Cluster created with settings {hosts=[localhost:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms'}
2023-11-17 15:39:39.737  INFO 15808 --- [localhost:27017] org.mongodb.driver.connection            : Opened connection [connectionId{localValue:2, serverValue:26}] to localhost:27017
2023-11-17 15:39:39.737  INFO 15808 --- [localhost:27017] org.mongodb.driver.connection            : Opened connection [connectionId{localValue:1, serverValue:27}] to localhost:27017
2023-11-17 15:39:39.737  INFO 15808 --- [localhost:27017] org.mongodb.driver.cluster               : Monitor thread successfully connected to server with description ServerDescription{address=localhost:27017, type=STANDALONE, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=17, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=58204100}
2023-11-17 15:39:39.963  INFO 15808 --- [           main] c.miaow.demo.ApplicationTests   : Started ApplicationTests in 2.079 seconds (JVM running for 2.619)
2023-11-17 15:39:40.106  INFO 15808 --- [           main] org.mongodb.driver.connection            : Opened connection [connectionId{localValue:3, serverValue:28}] to localhost:27017
2023-11-17 15:39:40.184  INFO 15808 --- [extShutdownHook] org.mongodb.driver.connection            : Closed connection [connectionId{localValue:3, serverValue:28}] to localhost:27017 because the pool has been closed.
2023-11-17 15:39:40.184  INFO 15808 --- [extShutdownHook] o.s.s.concurrent.ThreadPoolTaskExecutor  : Shutting down ExecutorService 'applicationTaskExecutor'

注意，MongoDB的语法有所区别，具体的如下：

查询语法：

插入文档：db.collection.insertOne(document) 或 db.collection.insertMany(documents)

查询文档：db.collection.find(query, projection)

更新文档：db.collection.updateOne(filter, update) 或 db.collection.updateMany(filter, update)

删除文档：db.collection.deleteOne(filter) 或db.collection.deleteMany(filter)

条件查询：db.collection.find({ field: value })

范围查询：db.collection.find({ field: { $gt: value1, $lt: value2 } })
正则表达式查询：db.collection.find({ field: /pattern/ })

排序：db.collection.find().sort({ field: 1 })（1表示升序，-1表示降序）

分页：db.collection.find().skip(offset).limit(limit)

聚合查询：db.collection.aggregate(pipeline)

在Java中的相关操作：

连接MongoDB：使用MongoClient类来连接MongoDB数据库。

普通连接方式，如果是Spring Boot中就是配置一下

MongoClient mongoClient = new MongoClient("localhost", 27017);
MongoDatabase database = mongoClient.getDatabase("mydatabase");

获取集合：使用getCollection方法获取集合对象。

MongoCollection<Document> collection = database.getCollection("mycollection");

插入文档:

Document document = new Document("name", "miaow")
    .append("age", 24)
    .append("email", "miaow@example.com");
collection.insertOne(document);

查询文档：

FindIterable<Document> result = collection.find(new Document("name", "miaow"));
for (Document document : result) {
    // 处理查询结果
}

更新文档：

collection.updateOne(eq("name", "miaow"), new Document("$set", new Document("age", 24)));

删除文档：

collection.deleteOne(eq("name", "miaow"));

以上就是在SpringBoot中使用MongoDB完成数据存储的详细内容，更多关于SpringBoot MongoDB数据存储的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

Spring Boot 发送邮件功能案例分析
这篇文章主要介绍了 Spring Boot 发送邮件功能，本文通过代码结合案例分析给大家介绍的非常详细,需要的朋友可以参考下
2017-11-11
Log4j如何屏蔽某个类的日志打印
这篇文章主要介绍了Log4j如何屏蔽某个类的日志打印，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-12-12
OpenFeign如何解决Get请求自动转化成POST的问题
这篇文章主要介绍了OpenFeign如何解决Get请求自动转化成POST的问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2024-04-04
一文详解MVCC的执行原理
MVCC是一种并发控制机制,用于解决数据库并发访问中,数据一致性问题,它通过在读写操作期间保存多个数据版本,以提供并发事务间的隔离性,本文将和大家简单聊聊MVCC的执行原理,需要的朋友可以参考下
2023-12-12
Mybatis 简介与原理
MyBatis 是支持定制化 SQL、存储过程以及高级映射的优秀的持久层框架。MyBatis 避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集
2017-05-05
解决Mybatis-Plus操作分页后数据失效问题
这篇文章主要介绍了解决Mybatis-Plus操作分页后数据失效问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-11-11
带你3分钟带你搞定Spring Boot中Schedule
本文主要围绕Spring scheduled应用实践进行分享,如果是单体应用,使用SpringBoot内置的@scheduled注解可以解决大部分业务需求,对Spring Boot中Schedule 相关知识感兴趣的朋友一起看看吧
2024-07-07
Spring Boot自定义Banner实现代码
这篇文章主要介绍了Spring Boot自定义Banner实现代码,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-01-01
@Value如何获取yml和properties配置参数
这篇文章主要介绍了@Value如何获取yml和properties配置参数的操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-07-07
Java使用延时队列搞定超时订单处理的场景
这篇文章主要介绍了Java使用延时队列搞定超时订单处理,本文通过示例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-08-08

在SpringBoot中使用MongoDB完成数据存储

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具