SpringBoo中怎么t整合MongoDB

这篇文章给大家介绍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权限介绍

四、定义核心配置文件

# 登录用户所在的数据库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就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。