SpringBoot整合之SpringBoot整合MongoDB的详细步骤

第SpringBoot整合之SpringBoot整合MongoDB的详细步骤六、创建dao层，这里的dao层有两种写法

（一）dao层写法一

1.编码部分

packagecn.byuan.dao;

importcn.byuan.entity.Student;

importorg.springframework.data.mongodb.repository.MongoRepository;

*dao层写法一

*这里的用法其实和SpringDataJPA相似,可根据需要来自定义方法

*这种写法不需要写实现类

*MongoRepository行对应的对象类型,主键列类型

publicinterfaceStudentDaoTypeOneextendsMongoRepositoryStudent,String{

//可根据需求自己定义方法,无需对方法进行实现

StudentgetAllByStudentName(StringstudentName);

}

2.测试部分

在进行测试之前，我们先查询一下数据库，此时不存在db_student的库

开始测试

packagecn.byuan;

importcn.byuan.dao.StudentDaoTypeOne;

importcn.byuan.entity.Student;

importorg.junit.jupiter.api.Test;

importorg.springframework.beans.factory.annotation.Autowired;

importorg.springframework.boot.test.context.SpringBootTest;

importjava.util.Date;

importjava.util.List;

@SpringBootTest

classStudentDaoTypeOneTests{

@Autowired

privateStudentDaoTypeOnestudentDaoTypeOne;

@Test

voidaddOneStudent(){

//插入10行

for(Integercount=0;countcount++){

Studentstudent=newStudent()

.setStudentId("student_"+count)//如果自己不去设置id则系统会分配给一个id

.setStudentName("Godfery"+count)

.setStudentAge(count)

.setStudentScore(98.5-count)

.setStudentBirthday(newDate());

studentDaoTypeOne.save(student);

@Test

voiddeleteOneStudentByStudentId(){

//删除id为student_0的学生

studentDaoTypeOne.deleteById("student_0");

@Test

voidupdateOneStudent(){

//修改姓名为Godfery1的Student年龄为22

Studentstudent=studentDaoTypeOne.getAllByStudentName("Godfery1");

student.setStudentAge(22);

studentDaoTypeOne.save(student);

@Test

voidgetOneStudentByStudentId(){

System.out.println(studentDaoTypeOne.findById("student_1"));

@Test

voidgetAllStudent(){

ListStudentstudentList=studentDaoTypeOne.findAll();

studentList.forEach(System.out::println);

我们先来查看一下数据库

进入数据库查看一下数据

（二）dao层写法二

1.编码部分

接口部分

packagecn.byuan.dao;

importcn.byuan.entity.Student;

importjava.util.List;

*dao层写法二

*写法二需要进行实现

publicinterfaceStudentDaoTypeTwo{

//增加一位学生

voidaddOneStudent(Studentstudent);

//根据id删除一位学生

voiddeleteOneStudentByStudentId(StringstudentId);

//修改一位学生的信息

voidupdateOneStudent(Studentstudent);

//根据主键id获取一名学生

StudentgetOneStudentByStudentId(StringstudentId);

//获取全部学生

ListStudentgetAllStudent();

}

实现类

packagecn.byuan.dao.imp;

importcn.byuan.dao.StudentDaoTypeTwo;

importcn.byuan.entity.Student;

importorg.springframework.beans.factory.annotation.Autowired;

importorg.springframework.data.mongodb.core.MongoTemplate;

importorg.springframework.stereotype.Repository;

importjava.util.List;

@Repository

publicclassStudentDaoTypeTwoImpimplementsStudentDaoTypeTwo{

//使用MongoTemplate模板类实现数据库操作

@Autowired

privateMongoTemplatemongoTemplate;

//增加一位学生

publicvoidaddOneStudent(Studentstudent){

mongoTemplate.save(student);

//根据id删除一位学生

publicvoiddeleteOneStudentByStudentId(StringstudentId){

Studentstudent=mongoTemplate.findById(studentId,Student.class);

if(student!=null){

mongoTemplate.remove(student);

//修改一位学生的信息

publicvoidupdateOneStudent(Studentstudent){

mongoTemplate.save(student);

//根据主键id获取一名学生

publicStudentgetOneStudentByStudentId(StringstudentId){

returnmongoTemplate.findById(studentId,Student.class);

//获取全部学生

publicListStudentgetAllStudent(){

returnmongoTemplate.findAll(Student.class);

2.测试部分

packagecn.byuan;

importcn.byuan.dao.StudentDaoTypeOne;

importcn.byuan.dao.StudentDaoTypeTwo;

importcn.byuan.entity.Student;

importorg.junit.jupiter.api.Test;

importorg.springframework.beans.factory.annotation.Autowired;

importorg.springframework.boot.test.context.SpringBootTest;

importjava.util.Date;

importjava.util.List;

@SpringBootTest

classStudentDaoTypeTwoTests{

@Autowired

privateStudentDaoTypeTwostudentDaoTypeTwo;

@Test

voidaddOneStudent(){

//插入10行

for(Integercount=0;countcount++){

Studentstudent=newStudent()

.setStudentId("study_"+count)//如果自己不去设置id则系统会分配给一个id

.setStudentName("Echo"+count)

.setStudentAge(count)

.setStudentScore(98.5-count)

.setStudentBirthday(newDate());

studentDaoTypeTwo.addOneStudent(student);

@Test

voiddeleteOneStudentByStudentId(){

//删除id为study_0的学生

studentDaoTypeTwo.deleteOneStudentByStudentId("study_0");

@Test

voidupdateOneStudent(){

//修改id为study_1的Student年龄为21

Studentstudent=studentDaoTypeTwo.getOneStudentByStudentId("study_1");

student.setStudentAge(21);

studentDaoTypeTwo.updateOneStudent(student);

@Test

voidgetOneStudentByStudentId(){

System.out.println(studentDaoTypeTwo.getOneStudentByStudentId("study_1"));