MongoDB入门指南:springboot整合MongoDB

1.环境配置

1.1 创建springboot项目

创建方式有2种,一种是直接使用开发工具创建,我这里使用官网的方式来创建,登陆创建的网页(这种方式非适合工具连不上网络的在别处创建好在导入)
主要的配置:

  • Project:Maven
  • Language:Java
  • Spring Boot:2.7.12 (SNAPSHOT) (aliyun的maven没有就在导入后改为2.2.2.RELEASE)
  • Packaging:Jar
  • Java:8
    右边依赖可以不选择,关系不大

    在这里插入图片描述

1.2 引入maven依赖

使用开发工具导入1.1创建好的工程,打开pom文件,添加mongodb依赖,完整的项目依赖

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

<dependency>
	<groupId>org.projectlombok</groupId>
	<artifactId>lombok</artifactId>
	<optional>true</optional>
</dependency>
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-test</artifactId>
	<scope>test</scope>
</dependency>

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

1.3 配置连接

详细可以参考官网说明
https://docs.spring.io/springboot/docs/current/reference/html/data.html#data.nosql.mongodb.connecting

方式一:

spring:
  data:
    mongodb:
      uri: mongodb://root:123456@192.168.3.11:27017/mydb?authSource=admin

方式二:

spring:
  data:
    mongodb:
      database: mydb
      host: 192.168.3.11
      port: 27017
      username: root
      password: 123456
      authentication-database: admin

1.4 使用时

通过上面的配置,就可以使用内置的操作模板对象

import org.springframework.data.mongodb.core.MongoTemplate;
    
    @Autowired
    private MongoTemplate mongoTemplate;

1.5 测试例子

可以利用springboot的单元测试进行编写例子

package com.example.mongodb;

import com.mongodb.client.MongoCollection;
import org.bson.Document;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.mongodb.core.MongoTemplate;

@SpringBootTest
class MongodbDemoApplicationTests {
    @Autowired
    private MongoTemplate mongoTemplate;
    @Test
    void contextLoads() {
    }
    @Test
    void collectionExists() {
        String collectionName = "springboot";
        boolean collectionExists = mongoTemplate.collectionExists(collectionName);
        if (!collectionExists) {
            MongoCollection<Document> collection = mongoTemplate.createCollection(collectionName);
            System.out.println(collection.toString());
        } else {
            System.out.println(collectionName + "is exists");
        }
    }
}

运行结果

...
2023-05-14 16:09:00.389  INFO 17800 --- [           main] org.mongodb.driver.connection            : Opened connection [connectionId{localValue:2,serverValue:11}] to 192.168.3.11:27017
com.mongodb.client.internal.MongoCollectionImpl@43fd77d8
2023-05-14 16:09:00.454  INFO 17800 --- [extShutdownHook] org.mongodb.driver.connection            : Closed connection [connectionId{localValue:2,serverValue:11}] to 192.168.3.11:27017 because the pool has been closed.
2023-05-14 16:09:00.457  INFO 17800 --- [extShutdownHook] o.s.s.concurrent.ThreadPoolTaskExecutor  : Shutting down ExecutorService 'applicationTaskExecutor'

Process finished with exit code 0

上面的结果显示我们已经使用了内置的模板创建了一张表,我们去到客户端验证一下

mydb> show tables
springboot
mydb> 

2.内置的注解

  springboot的整合不仅为我们提供了一个操作的模板,还给我们提供了方便操作的注解,如 @Document@Id@Field@Transient。这些注解可以帮助将 Java 对象映射为 MongoDB 中的文档数据,并且进行不同层次的数据访问和操作。

  • @Document 是用来标识一个类对应 MongoDB 中的一个文档,通常用在类的定义上。这个注解有两个属性,value 和 collection,用来指定操作的数据库和集合名称。通过该注解,可以将一个 Java 类与一个 MongoDB 文档建立映射关系。

  • @Id 是用来标识一个成员变量或方法作为 MongoDB 文档的 _id 属性。该注解可以应用于 Java 对象中的一个成员变量或者 getter 方法上。如果在类中没有标注 @Id 注解,则 MongoDB 会自动为该文档生成一个 _id 属性。标注了 @Id 注解的成员变量或方法必须为 String、ObjectId 或 BigInteger 类型。

  • @Field 是用来标识一个成员变量或方法对应 MongoDB 文档中的一个key-value对。这个注解有两个属性,name 和 value,可以用来指定在文档中 key 的名称。如果没有指定 name 属性,则默认使用成员变量名作为 key 的名称。该注解可以应用于 Java 对象中的一个成员变量或者 getter 方法上。

  • @Transient 是用来指定一个成员变量不参与MongoDB 文档的序列化。这个注解可以应用于 Java 对象中的一个成员变量或者 getter 方法上。被标注了 @Transient 注解的成员变量或方法不会保存到数据库中。

  这些注解可以让我们在使用 MongoDB 数据库时更加方便和灵活。在使用这些注解时,应该需要注意对应的数据类型和注解的属性,以便正确地映射 Java 对象和 MongoDB 文档之间的关系。

2. 综合的例子

这里就不一一例举说明每个api,只提供一个综合的例子进行使用,

2.1 创建一个java实体

创建一个User的对象实体,同时通过@Document("user")会映射到mongodb中的’user’集合中;@Field("uname")将实体的name映射到mongodb的字段时uname;@Transientaddress不持久化到mongodb中

package com.example.mongodb.entity;


import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import org.springframework.data.annotation.Transient;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;

import java.util.Date;

@Document("user")
@Data
@AllArgsConstructor
@NoArgsConstructor
public class User {
    @Id
    private Integer id;

    @Field("uname")
    private String name;

    @Field
    private int age;

    @Field
    private Double height;

    @Field
    private Date entryDay;

    @Transient
    private String address;


}

2.2 添加文档

添加文档有两种,一种时如果id存在则更新的save方法,另外一种时id存在则抛出异常的insert方法,我们应该根据实际情况选择具体的插入方法。

@Test
    void insertOneDocument() {
        String collectionName = "springboot";
        User user = new User();
        user.setId(1);
        user.setName("Tom");
        user.setAge(19);
        user.setHeight(178.50);
        user.setEntryDay(new Date());
        user.setAddress("beijing");
        //save添加文档 - 如果id存在则更新数据
        User save = mongoTemplate.save(user,collectionName);
        System.out.println(save);
        //insert 添加文档 - 如果id存在则失败抛出异常
        //User insert = mongoTemplate.insert(user,collectionName);
        //System.out.println(insert);
    }

插入数据后还发现,内置的操作模板帮我多添加了一个_class字段到mongodb中,参考后面的2.6可以配置除去该内置字段

mydb> db.springboot.find()
[
  {
    _id: 1,uname: 'Tom',age: 19,height: 178.5,entryDay: ISODate("2023-05-14T08:35:01.607Z"),_class: 'com.example.mongodb.entity.User'
  }
]

批量插入见2.3例子

2.3 查询文档

在查询前,先批量插入数据

@Test
    void insertManyDocument() {
        String collectionName = "springboot";
        List<User> users = new ArrayList<>();
        for(int i=0;i<10;i++){
            users.add(new User(10+i,"name-"+i,10+i,172.0+i,new Date(),"beijing-"+i));
        }
        //插入多行数据
        Collection<User> collection = mongoTemplate.insert(users,collectionName);
        System.out.println(collection.size());
    }

2.3.1 查询所有文档

    @Test
    void findAll() {
        String collectionName = "springboot";
        List<User> userList = mongoTemplate.findAll(User.class,collectionName);
        if (userList.size() > 0) {
            userList.forEach(System.out::println);
        }
    }

结果显示

...
User(id=1,name=Tom,age=19,height=178.5,entryDay=Sun May 14 16:35:01 CST 2023,address=null)
User(id=2,name=Jerry,age=20,height=175.5,entryDay=Sun May 14 16:46:41 CST 2023,address=null)
User(id=10,name=name-0,age=10,height=172.0,entryDay=Sun May 14 16:56:17 CST 2023,address=null)
User(id=11,name=name-1,age=11,height=173.0,address=null)
User(id=12,name=name-2,age=12,height=174.0,address=null)
User(id=13,name=name-3,age=13,height=175.0,address=null)
User(id=14,name=name-4,age=14,height=176.0,address=null)
User(id=15,name=name-5,age=15,height=177.0,address=null)
User(id=16,name=name-6,age=16,height=178.0,address=null)
User(id=17,name=name-7,age=17,height=179.0,address=null)
User(id=18,name=name-8,age=18,height=180.0,address=null)
User(id=19,name=name-9,height=181.0,address=null)
Process finished with exit code 0

2.3.2 根据_id查询

    @Test
    void findById() {
        String collectionName = "springboot";
        User user = mongoTemplate.findById(1,User.class,collectionName);
        System.out.println(user);
    }

查询结果

...
User(id=1,address=null)

Process finished with exit code 0

2.3.3 返回匹配的第一个文档

import org.springframework.data.mongodb.core.query.Query;
@Test
    void findFirst() {
        String collectionName = "springboot";
        User user = mongoTemplate.findOne(new Query(),collectionName);
        System.out.println(user);
    }

查询结果

...
User(id=1,address=null)

Process finished with exit code 0

2.3.4 单条件查询

查询年龄大于等于20的数据

import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
    @Test
    void findBySimpleQuery() {
        String collectionName = "springboot";
        Query query = new Query(Criteria.where("age").gte(20));
        User user = mongoTemplate.findOne(query,collectionName);
        System.out.println(user);
    }

查询结果

User(id=2,address=null)

Process finished with exit code 0

后续都会使用内置封装的Criteria对象进行条件查询

2.3.5 多条件查询

查询年龄大于15并且身高大于170的数据

@Test
    void findByAndQuery() {
        String collectionName = "springboot";
        Criteria ageCriteria = Criteria.where("age").gt(15);
        Criteria heightCriteria = Criteria.where("height").gt(170.0);
        //组装两个and条件
        Criteria andCriteria = new Criteria();
        andCriteria.andOperator(ageCriteria,heightCriteria);
        //封装成query
        Query query = new Query(andCriteria);
        List<User> userList = mongoTemplate.find(query,collectionName);
        if (userList.size() > 0) {
            userList.forEach(System.out::println);
        }
    }

查询结果

...
User(id=1,address=null)

Process finished with exit code 0

2.3.6 条件查询加上排序和分页

在2.3.5的基础之上添加排序(age从大到小,height从小到大)和分页(返回第一页,每页2行数据)

import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
@Test
    void findByComplexQuery() {
        String collectionName = "springboot";
        Criteria ageCriteria = Criteria.where("age").gt(15);
        Criteria heightCriteria = Criteria.where("height").gt(170.0);
        //组装两个and条件
        Criteria andCriteria = new Criteria();
        andCriteria.andOperator(ageCriteria,heightCriteria);
        //封装成query
        Query query = new Query(andCriteria);

        //排序 age从大到小,height从小到大
        List<Sort.Order> orders = new ArrayList<>();
        orders.add(Sort.Order.desc("age"));
        orders.add(Sort.Order.asc("height"));
        query.with(Sort.by(orders));
        //分页 第一页,每页2行数据
        query.with(PageRequest.of(0,2));
        List<User> userList = mongoTemplate.find(query,collectionName);
        if (userList.size() > 0) {
            userList.forEach(System.out::println);
        }
    }

查询结果

...
User(id=2,address=null)
User(id=1,address=null)

Process finished with exit code 0

2.3.7 使用json查询

json查询即在客户端执行的语句
客户端查询

mydb> db.springboot.find({$and:[{age:{$gte:15}},{height:{$lte:178}}]})
[
  {
    _id: 2,uname: 'Jerry',age: 20,height: 175.5,entryDay: ISODate("2023-05-14T08:46:41.242Z")
  },{
    _id: 15,uname: 'name-5',age: 15,height: 177,entryDay: ISODate("2023-05-14T08:56:17.988Z")
  },{
    _id: 16,uname: 'name-6',age: 16,height: 178,entryDay: ISODate("2023-05-14T08:56:17.988Z")
  }
]
mydb> 

转化成json查询

	@Test
    void findByJsonQuery() {
        String collectionName = "springboot";
        String json = "{$and:[{age:{$gte:15}},{height:{$lte:178}}]}";
        Query query = new BasicQuery(json);
        List<User> userList = mongoTemplate.find(query,address=null)

Process finished with exit code 0

2.4 更新文档

2.4.1 更新匹配到的第一行数据

import com.mongodb.client.result.UpdateResult;
import org.springframework.data.mongodb.core.query.Update;
    @Test
    void updateOneByQuery() {
        String collectionName = "springboot";
        Criteria idCriteria = Criteria.where("id").is(1);
        Update update = new Update();
        update.set("age",20);
        UpdateResult result = mongoTemplate.updateFirst(new Query(idCriteria),update,collectionName);
        System.out.println(result.toString());
    }

更新结果

...
AcknowledgedUpdateResult{matchedCount=1,modifiedCount=1,upsertedId=null}

Process finished with exit code 0

2.4.2 更新匹配到的所有数据

import com.mongodb.client.result.UpdateResult;
import org.springframework.data.mongodb.core.query.Update;
	@Test
    void updateManyByQuery() {
        String collectionName = "springboot";
        Criteria ageCriteria = Criteria.where("age").is(20);
        Update update = new Update();
        update.set("age",25);
        UpdateResult result = mongoTemplate.updateMulti(new Query(ageCriteria),collectionName);
        System.out.println(result.toString());
    }

更新结果

...
AcknowledgedUpdateResult{matchedCount=2,modifiedCount=2,upsertedId=null}

Process finished with exit code 0

2.4.3 匹配更新时查找不到则插入

	@Test
    void updateOrInsertOneByQuery() {
        String collectionName = "springboot";
        Criteria idCriteria = Criteria.where("id").is(666);
        Update update = new Update();
        update.setOnInsert("name","test");
        update.setOnInsert("id",666);
        UpdateResult result = mongoTemplate.upsert(new Query(idCriteria),collectionName);
        System.out.println(result.toString());
    }

匹配结果

...

Process finished with exit code 0

使用客户端查询发现数据被新增了

mydb> db.springboot.find({_id:666})
[ { _id: 666,uname: 'test' } ]
mydb> 

2.5 删除文档

2.5.1 查询并删除

删除id为666的数据

	@Test
    void deleteByQuery() {
        String collectionName = "springboot";
        Criteria idCriteria = Criteria.where("id").is(666);
        DeleteResult deleteResult = mongoTemplate.remove(new Query(idCriteria),collectionName);
        System.out.println(deleteResult.toString());
    }

执行结果

AcknowledgedDeleteResult{deletedCount=1}

Process finished with exit code 0

2.5.2 删除所有

删除所有就是构造一个空的Query对象

	@Test
    void deleteAllQuery() {
        String collectionName = "springboot";
        DeleteResult deleteResult = mongoTemplate.remove(new Query(),collectionName);
        System.out.println(deleteResult.toString());
    }

也可以使用删除集合的方法,更加推荐这种,高效

	@Test
    void dropCollection() {
        String collectionName = "springboot";
        mongoTemplate.dropCollection(collectionName);
    }

2.6 删除内置的_class字段

构造出DefaultMongoTypeMapper,把typeKey设置为null

package com.example.mongodb.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.MongoDatabaseFactory;
import org.springframework.data.mongodb.core.convert.*;
import org.springframework.data.mongodb.core.mapping.MongoMappingContext;

@Configuration
public class ProjectConfig {
    @Bean
    MappingMongoConverter mappingMongoConverter(
            MongoDatabaseFactory mongoDatabaseFactory,MongoMappingContext context,MongoCustomConversions conversions) {
        DbRefResolver dbRefResolver = new DefaultDbRefResolver(mongoDatabaseFactory);
        MappingMongoConverter myMappingMongoConverter =
                new MappingMongoConverter(dbRefResolver,context);
        myMappingMongoConverter.setCustomConversions(conversions);
        //构造出DefaultMongoTypeMapper,把typeKey设置为null
        myMappingMongoConverter.setTypeMapper(new DefaultMongoTypeMapper(null));
        return myMappingMongoConverter;
    }
}

测试添加一行数据

@Test
    void insertOneDocument() {
        String collectionName = "springboot";
        User user = new User();
        user.setId(2);
        user.setName("Jerry");
        user.setAge(20);
        user.setHeight(175.50);
        user.setEntryDay(new Date());
        user.setAddress("beijing");
        //save添加文档 - 如果id存在则更新数据
        User save = mongoTemplate.save(user,collectionName);
        System.out.println(save);
    }

登陆客户端查询

mydb> db.springboot.find()
[
  {
    _id: 1,_class: 'com.example.mongodb.entity.User'
  },{
    _id: 2,entryDay: ISODate("2023-05-14T08:46:41.242Z")
  }
]

3. 总结

  本文介绍了使用Spring Boot整合MongoDB实现数据操作的方法,包括环境准备、连接配置、以及实现数据操作。通过本文的学习,可以熟悉在Spring Boot中使用MongoDB的方法,从而在实际项目中更加灵活和高效地实现数据操作。

原文地址:https://blog.csdn.net/dougsu/article/details/130669868

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


文章浏览阅读552次。com.mongodb.MongoQueryException: Query failed with error code 292 and error message 'Executor error during find command :: caused by :: Sort exceeded memory limit of 104857600 bytes, but did not opt in to external sorting.' on server 11.51.141.63:27017 _mongodb 大文件 下载失败
文章浏览阅读635次,点赞9次,收藏8次。MongoDB 是一种 NoSQL 数据库,它将每个数据存储为一个文档,这里的文档类似于 JSON/BSON 对象,具体数据结构由键值(key/value)对组成。
文章浏览阅读2.1k次。和。_mongodb 日期类型
文章浏览阅读1.7k次。Scalestack等客户期待使用MongoDB Atlas Vector Search和Amazon Bedrock构建下一代应用程序
文章浏览阅读970次。SpringBoot整合中间件mongodb、ES_springboot3 elasticsearch json数据
文章浏览阅读673次。MongoDB 简介_尚医通sql
文章浏览阅读1k次,点赞8次,收藏9次。官网下载MongoDB安装包后进行解压(因了解并不深入,故暂不进行详细说明,自行查找其他安装方法,后期了解深入后将进行该教程的完善)在bin目录下使用命令启动:./mongod --config …/mongodb.conf。该文章任然处于完善中,如果存在错误遗漏的地方,欢迎私信联系。安装相关的nuget包后即可通过以下方法连接数据。YX9010_0@的第二十篇文章。
文章浏览阅读1.2k次,点赞17次,收藏26次。社交场景, 使用 MongoDB 存储存储用户信息, 以及用户发表的朋友圈信息, 通过地理位置索引实现附近的人, 地点等功能.游戏场景, 使用 MongoDB 存储游戏用户信息, 用户的装备, 积分等直接以内嵌文档的形式存储, 方便查询, 高效率存储和访问.物流场景, 使用 MongoDB 存储订单信息, 订单状态在运送过程中会不断更新, 以 MongoDB 内嵌数组的形式来存储, 一次查询就能将订单所有的变更读取出来.物联网场景, 使用 MongoDB 存储所有接入的智能设备信息, 以及设备汇报的日
文章浏览阅读686次。您可以使用 update_one() 方法来更新 MongoDB 中调用的记录或文档。update_one() 方法的第一个参数是 query 对象,用于定义要更新的文档。注释:如果查询找到多个记录,则仅更新第一个匹配项。第二个参数是定义文档新值的对象。_python 更新 mongodb 数据
文章浏览阅读1.3k次。首先来学习一下nosql这里安装就不进行介绍 只记录一下让自己了解mongodb。_nosql注入
文章浏览阅读4.1k次,点赞8次,收藏7次。在data的目录下,创建一个db文件。因为启动MongoDB服务之前必须创建数据库文件的存放文件夹,否则命令不会自动创建,而且不能启动成功。第一步:安装时,Custom是指可以自定义安装路径,然后傻瓜式安装即可(注意:先不要安装图形化工具,否则安装时间会特别长):如果要想连接成功,必须要开服务,即mongod -dbpath C:MongoDBdatadb的cmd要一直开着。然后回车,ctrl+F输入port找到端口号,一般为:27017。打开命令行,然后找到bin文件地址,并输入。_mongodb windows安装
文章浏览阅读5.1k次,点赞3次,收藏43次。详细介绍MongoDB数据库的基本知识,安装方法,基本操作,_mongodb数据库
文章浏览阅读3.2k次。安装教程翻看以往文章。_navicat 连接mongodb
文章浏览阅读426次,点赞9次,收藏12次。win10开放端口:https://blog.csdn.net/m0_43605481/article/details/119255256。我的是阿里云服务器,所以直接在安全组中加入规则,端口范围:27017,授权对象:0.0.0.0。windows在mongodb安装文件夹的bin文件夹中的mongod.cfg。数据库名字是test,打算创建一个用户,账号aaa,密码bbb,权限readWrite。因为该用户是创建在test数据库的,所以在最后要加上test。O了,然后恢复了test的数据。
文章浏览阅读1.1k次。聚合操作主要用于处理数据并返回计算结果。聚合操作将来自多个文档的值组合在一起,按条件分组后,再进行一系列操作(如求和、平均值、最大值、最小值)以返回单个结果。MongoDB的聚合查询​聚合是MongoDB的高级查询语言,它允许我们通过转化合并由多个文档的数据来生成新的在单个文档里不存在的文档信息。MongoDB中聚合(aggregate)主要用于处理数据(例如分组统计平均值、求和、最大值等),并返回计算后的数据结果,有点类似sql语句中的count(*)、groupby。..._如何将几个db的数据统整在一起做查询
文章浏览阅读680次,点赞7次,收藏8次。(2)application.properties配置文件。(4)UserService类。(5)测试和测试结果。
文章浏览阅读1k次,点赞17次,收藏25次。Studio 3T 2023.9 (macOS, Linux, Windows) - MongoDB 的专业 GUI、IDE 和 客户端,支持自然语言查询_mongodb客户端
文章浏览阅读1.1k次,点赞32次,收藏27次。插件式的存储引擎架构可以实现 Server 层和存储引擎层的解耦,可以支持多种存储引擎,如 MySQL 既可以支持 B-Tree 结构的 InnoDB 存储引擎,还可以支持 LSM 结构的 RocksDB 存储引擎。MongoDB 中的记录就是一个 BSON 文档,它是由键值对组成的数据结构,类似于 JSON 对象,是 MongoDB 中的基本数据单元。的简称,是 JSON 文档的二进制表示,支持将文档和数组嵌入到其他文档和数组中,还包含允许表示不属于 JSON 规范的数据类型的扩展。
文章浏览阅读5.1k次,点赞6次,收藏96次。本文设计了一种基于智能室内温度控制的自动调速风扇。以STM32系列单片机为核心主控板,通过程序代码驱动和使用温度传感器模块实现对环境温度的实时监测,并可以实时显示环境温度。同时,可以设置温度检测的上下警告值,根据需求自行调节。_stm32 温控风扇
文章浏览阅读898次,点赞13次,收藏21次。在MongoDB中,我们使用find()和find_one()方法来在集合中查找数据,就像在MySQL数据库中使用SELECT语句来在表中查找数据一样。_pymongo find_one