这篇文章给大家介绍SpringBoo中怎么t整合MongoDB，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。
一、创建项目，选择依赖
仅选择Spring Web、Spring Data MongoDB即可
二、引入相关依赖（非必要）
这里只是为了实体类的创建方便而引入lombok
<!-- 引入lombok --><dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId></dependency>三、如果是第一次使用MongoDB，首先先创建用户
> use adminswitched to db admin> db.createUser({user:"zlfeng", pwd:"123456", roles:[{role:"readWriteAnyDatabase", db:"admin"}]});Successfully added user: {"user" : "zlfeng","roles" : [{"role" : "readWriteAnyDatabase","db" : "admin"}]}MongoDB权限介绍
| 权限 | 说明 |
|---|---|
| read | 允许用户读取指定数据库 |
| readWrite | 允许用户读写指定数据库 |
| dbAdmin | 允许用户在指定数据库中执行管理函数，如索引创建、删除、查看统计或访问system.profile |
| userAdmin | 允许用户向system.users集合写入，可以在指定数据库中创建、删除和管理用户 |
| clusterAdmin | 必须在admin数据库中定义，赋予用户所有分片和复制集相关函数的管理权限 |
| readAnyDatabase | 必须在admin数据库中定义，赋予用户所有数据库的读权限 |
| readWriteAnyDatabase | 必须在admin数据库中定义，赋予用户所有数据库的读写权限 |
| userAdminAnyDatabase | 必须在admin数据库中定义，赋予用户所有数据库的userAdmin权限 |
| dbAdminAnyDatabase | 必须在admin数据库中定义，赋予用户所有数据库的dbAdmin权限 |
| root | 必须在admin数据库中定义，超级账号，超级权限 |
四、定义核心配置文件
# 登录用户所在的数据库spring.data.mongodb.authentication-database=admin# 数据库的ip地址spring.data.mongodb.host=192.168.133.142# MongoDB端口号spring.data.mongodb.port=27017# 用户账号spring.data.mongodb.username=zlfeng# 用户密码spring.data.mongodb.password=123456# 指定使用的数据库# 不必预先创建，不存在该数据库会自动创建spring.data.mongodb.database=db_student五、创建实体类
package cn.byuan.entity;import lombok.AllArgsConstructor;import lombok.Data;import lombok.NoArgsConstructor;import lombok.experimental.Accessors;import org.springframework.data.annotation.Id;import java.io.Serializable;import java.util.Date;@NoArgsConstructor@AllArgsConstructor@Accessors(chain = true)@Datapublic class Student implements Serializable { @Id// 必须指定id列 private String studentId; private String studentName; private Integer studentAge; private Double studentScore; private Date studentBirthday;}六、创建dao层，这里的dao层有两种写法
（一）dao层写法一
编码部分
package cn.byuan.dao;import cn.byuan.entity.Student;import org.springframework.data.mongodb.repository.MongoRepository;public interface StudentDaoTypeOne extends MongoRepository<Student, String> { // 可根据需求自己定义方法, 无需对方法进行实现 Student getAllByStudentName(String studentName); }
测试部分
在进行测试之前，我们先查询一下数据库，此时不存在db_student的库
开始测试
package cn.byuan;import cn.byuan.dao.StudentDaoTypeOne;import cn.byuan.entity.Student;import org.junit.jupiter.api.Test;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import java.util.Date;import java.util.List;@SpringBootTestclass StudentDaoTypeOneTests { @Autowired private StudentDaoTypeOne studentDaoTypeOne; @Test void addOneStudent(){// 插入10行 for (Integer count = 0; count < 10; count++) { Student student = new Student() .setStudentId("student_"+count) //如果自己不去设置id则系统会分配给一个id .setStudentName("Godfery"+count) .setStudentAge(count) .setStudentScore(98.5-count) .setStudentBirthday(new Date()); studentDaoTypeOne.save(student); } } @Test void deleteOneStudentByStudentId(){// 删除id为student_0的学生 studentDaoTypeOne.deleteById("student_0"); } @Test void updateOneStudent(){// 修改姓名为Godfery1的Student年龄为22 Student student = studentDaoTypeOne.getAllByStudentName("Godfery1"); student.setStudentAge(22); studentDaoTypeOne.save(student); } @Test void getOneStudentByStudentId(){ System.out.println(studentDaoTypeOne.findById("student_1")); } @Test void getAllStudent(){ List<Student> studentList = studentDaoTypeOne.findAll(); studentList.forEach(System.out::println); }}
我们先来查看一下数据库
进入数据库查看一下数据
（二）dao层写法二
编码部分
接口部分
package cn.byuan.dao;import cn.byuan.entity.Student;import java.util.List;public interface StudentDaoTypeTwo {// 增加一位学生 void addOneStudent(Student student);// 根据id删除一位学生 void deleteOneStudentByStudentId(String studentId);// 修改一位学生的信息 void updateOneStudent(Student student);// 根据主键id获取一名学生 Student getOneStudentByStudentId(String studentId);// 获取全部学生 List<Student> getAllStudent();}实现类
package cn.byuan.dao.imp;import cn.byuan.dao.StudentDaoTypeTwo;import cn.byuan.entity.Student;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.mongodb.core.MongoTemplate;import org.springframework.stereotype.Repository;import java.util.List;@Repositorypublic class StudentDaoTypeTwoImp implements StudentDaoTypeTwo {// 使用MongoTemplate模板类实现数据库操作 @Autowired private MongoTemplate mongoTemplate;// 增加一位学生 public void addOneStudent(Student student){ mongoTemplate.save(student); }// 根据id删除一位学生 public void deleteOneStudentByStudentId(String studentId){ Student student = mongoTemplate.findById(studentId, Student.class); if(student != null){ mongoTemplate.remove(student); } }// 修改一位学生的信息 public void updateOneStudent(Student student){ mongoTemplate.save(student); }// 根据主键id获取一名学生 public Student getOneStudentByStudentId(String studentId){ return mongoTemplate.findById(studentId, Student.class); }// 获取全部学生 public List<Student> getAllStudent(){ return mongoTemplate.findAll(Student.class); }}测试部分
package cn.byuan;import cn.byuan.dao.StudentDaoTypeOne;import cn.byuan.dao.StudentDaoTypeTwo;import cn.byuan.entity.Student;import org.junit.jupiter.api.Test;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import java.util.Date;import java.util.List;@SpringBootTestclass StudentDaoTypeTwoTests { @Autowired private StudentDaoTypeTwo studentDaoTypeTwo; @Test void addOneStudent(){// 插入10行 for (Integer count = 0; count < 10; count++) { Student student = new Student() .setStudentId("study_"+count) //如果自己不去设置id则系统会分配给一个id .setStudentName("Echo"+count) .setStudentAge(count) .setStudentScore(98.5-count) .setStudentBirthday(new Date()); studentDaoTypeTwo.addOneStudent(student); } } @Test void deleteOneStudentByStudentId(){// 删除id为study_0的学生 studentDaoTypeTwo.deleteOneStudentByStudentId("study_0"); } @Test void updateOneStudent(){// 修改id为study_1的Student年龄为21 Student student = studentDaoTypeTwo.getOneStudentByStudentId("study_1"); student.setStudentAge(21); studentDaoTypeTwo.updateOneStudent(student); } @Test void getOneStudentByStudentId(){ System.out.println(studentDaoTypeTwo.getOneStudentByStudentId("study_1")); } @Test void getAllStudent(){ List<Student> studentList = studentDaoTypeTwo.getAllStudent(); studentList.forEach(System.out::println); }}
进入数据库查看一下数据
关于SpringBoo中怎么t整合MongoDB就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
