Springboot 集成MongoDB

编程入门行业动态更新时间:2024-10-27 19:22:44

Springboot 集成MongoDB

提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档

文章目录

前言
一、Springboot 集成 MongoDB
二、使用步骤
- 1.引入库
- 2.读入数据
总结

前言

本文介绍的内容是Springboot如何集成MongoDB，以及对MongoDB进行基本的增加、查询数据的操作。

一、MongoDB是什么？

MongoDB是一个基于分布式文件存储的数据库。由C++语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案。MongoDB 是一个高性能，开源，无模式的文档型数据库，是当前 NoSql 数据库中比较热门的一种。MongoDB 中的一条记录就是一个文档，与JSON类似。

二、使用步骤

1.引入库

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

2.配置Mongodb

spring.data.mongodb.uri=mongodb://127.0.0.1:27017/admin

3.增加、查询数据

方式一：创建自己的Repository接口类并实现 MongoRepository 接口。

1.创建实体类：

package com.hjxmongodb.mongdb.entity;import org.springframework.data.mongodb.core.mapping.Document;import lombok.Data;/**
* 包名称：com.hjxmongodb.mongdb.entity
* @author 作者：HuangJinXin  
* @Email : hjx_soft@126
* @version 创作时间:2023年11月6日上午11:16:04
*
*/
@Document
@Data
public class User {private String id;private String name;private int age;private String gender;private String email;}

2.创建自己的Repository 接口

package com.hjxmongodb.mongdb.repository;import org.springframework.data.mongodb.repository.MongoRepository;import com.hjxmongodb.mongdb.entity.User;/**
* 包名称：com.hjxmongodb.mongdb.repository
* @author 作者：HuangJinXin  
* @Email : hjx_soft@126
* @version 创作时间:2023年11月9日上午10:16:06
*
*/public interface UserRepository extends MongoRepository<User, String> {}

3.增加、查询数据

查询代码如下：

package com.hjxmongodb.mongdb;import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.Optional;
import java.util.Random;
import java.util.UUID;import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.domain.Example;
import org.springframework.data.domain.ExampleMatcher;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;import com.hjxmongodb.mongdb.entity.User;
import com.hjxmongodb.mongdb.repository.UserRepository;/**
* 包名称：com.hjxmongodb.mongdb
* @author 作者：HuangJinXin  
* @Email : hjx_soft@126
* @version 创作时间:2023年11月9日上午10:58:19
*
*/@SpringBootTest
public class MongoRepositoryTest {@Autowiredprivate UserRepository userRepository;/*** 批量增加数据* 使用MongoRepository 批量插入数据*/@Testvoid createUsers() {Random random = new Random();Collection<User> userList = new ArrayList<User>();for (int i = 0; i < 100000; i++) {User user = new User();user.setId(UUID.randomUUID().toString().replace("-", ""));user.setAge(random.nextInt(22, 50));user.setGender(random.nextInt(0, 2)+"");user.setName("hjx" + random.nextInt(10000));user.setEmail("hjx"+random.nextInt(10000)+"wm@163");userList.add(user);}System.out.println("批量插入数据：" + userList.size());userList = userRepository.insert(userList);System.out.println("保存成功 ： " + userList.size());}@Testvoid findUser() {System.out.println("使用MongoRepository 来查询数据...");//查询所有的数据List<User> userList =userRepository.findAll();for (User user : userList) {System.out.println(user);}//根据ID查询单个数据Optional<User> user = userRepository.findById("f777728d4779450e81c30fcf2c38dfe0");System.out.println(user.get());}@Testvoid findByCondition() {System.out.println("根据条件配置来查询数据...");User user = new User();user.setAge(32);Example<User> example = Example.of(user);List<User> tempUser =userRepository.findAll(example);System.out.println(tempUser.size());}@Testvoid findByConditions() {System.out.println("根据条件模糊查询数据...");ExampleMatcher exampleMatcher = ExampleMatcher.matching().withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING).withIgnoreCase(true);User userExample = new User();userExample.setName("99");userExample.setAge(32);userExample.setGender("1");Example example = Example.of(userExample,exampleMatcher);List<User> resultList =userRepository.findAll(example);System.out.println(resultList.size());}@Testvoid findByPages() {System.out.println("分页查询数据...");for (int i = 0; i < 10; i++) {Pageable pageable =PageRequest.of(i, 10);User userExample = new User();userExample.setAge(32);Example example = Example.of(userExample);Page<User> pages =userRepository.findAll(example, pageable);System.out.println(pages.getContent());System.out.println(pages.getContent().size());System.out.println(pages.getNumber());System.out.println(pages.getSize());System.out.println("------------------------");}}}

方式二：使用MongoTemplate 来操作数据库。

全部代码如下：

package com.hjxmongodb.mongdb;import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.Random;
import java.util.UUID;import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;import com.hjxmongodb.mongdb.entity.User;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.result.DeleteResult;
import com.mongodb.client.result.UpdateResult;/*** 包名称：com.hjxmongodb.mongdb* * @author 作者：HuangJinXin* @Email : hjx_soft@126* @version 创作时间:2023年11月9日上午10:09:09**/@SpringBootTest
public class MongoTemplateTest {@Autowiredprivate MongoTemplate mongoTemplate;static final String collectionName = "user";@Testvoid collectionExists() {System.out.println("创建集合，即数据库");// 判断是否已经存在该集合名称boolean collectionNameExists = mongoTemplate.collectionExists(collectionName);if (!collectionNameExists) {MongoCollection<org.bson.Document> document = mongoTemplate.createCollection(collectionName);System.out.println(document.toString());} else {System.out.println(collectionName + " is exists.");}}@Testvoid create() {System.out.println("批量增加数据...");Random random = new Random();Collection<User> userList = new ArrayList<User>();for (int i = 0; i < 100000; i++) {User user = new User();user.setId(UUID.randomUUID().toString().replace("-", ""));user.setAge(random.nextInt(22, 50));user.setGender(random.nextInt(0, 2) + "");user.setName("hjx" + random.nextInt(10000));user.setEmail("hjx" + random.nextInt(10000) + "wm@163");userList.add(user);}System.out.println("批量插入：" + userList.size() + "条数据。");List<User> t = (List<User>) mongoTemplate.insert(userList, collectionName);System.out.println("保存成功 ： " + t.size());}@Testvoid findUser() {System.out.println("根据条件查找用户信息...");Query query = new Query();Criteria criteria = Criteria.where("age").gte(30); // 年龄等于30Criteria nameCriteria = Criteria.where("name").regex("99"); // 名称中包括99Criteria andCriteria = new Criteria();andCriteria.andOperator(criteria, nameCriteria);query.addCriteria(andCriteria);query.limit(400);List<User> userList = mongoTemplate.find(query, User.class, collectionName);System.out.println(userList.size());userList.forEach(item -> System.out.println(item));}@Testvoid findAll() {System.out.println("分页按条件查询数据....");Query query = new Query();Criteria criteria = Criteria.where("age").gte(30); // 年龄大于等于30Criteria nameCriteria = Criteria.where("name").regex("99"); // 名称中包含有99Criteria andCriteria = new Criteria();andCriteria.andOperator(criteria, nameCriteria);query.addCriteria(andCriteria);for (int i = 0; i < 10; i++) {Pageable pageable = PageRequest.of(i, 10);//每页查询10条数据query.with(pageable);List<User> pages = mongoTemplate.find(query, User.class, collectionName);System.out.println(pages.size());System.out.println(pages);System.out.println("------------------------");}}@Testvoid findallUser() {System.out.println("查询所有数据，循环输出....");List<User> user = mongoTemplate.findAll(User.class, collectionName);// 第一种循环打印数据的方式：user.forEach(item -> System.out.println(item));// 第二种循环打印数据的方式：user.forEach(System.out::println);}@Testvoid update() {System.out.println("更新用户信息...");Criteria updateCriteria = Criteria.where("age").is(22);Update updateItem = new Update();updateItem.set("age", 32);UpdateResult result = mongoTemplate.updateMulti(new Query(updateCriteria), updateItem, User.class,collectionName);System.out.println(result.toString());}@Testvoid delete() {System.out.println("删除用户信息...");Criteria updateCriteria = Criteria.where("age").is(35);DeleteResult result = mongoTemplate.remove(new Query(updateCriteria), User.class, collectionName);System.out.println(result);}//	@Testvoid deleteAll() {System.out.println("删除所有用户信息...");//方式1：删除所有数据
//		DeleteResult result = mongoTemplate.remove(new Query(), collectionName);
//		System.out.println(result);//方式2：删除所有数据,删除集合就可以了。mongoTemplate.dropCollection(collectionName);}}