SpringBoot整合MongoDB

素颜马尾好姑娘i 2022-10-17 01:48 234阅读 0赞

配置文件`application.yml`：

server:
      # 配置访问时的端口号
      port: 8888
      servlet:
        # 配置访问时的项目名
        context-path: /demo
    spring:
      data:
        mongodb:
           # 无密码的写法
          uri: mongodb://localhost:27017/liuyu
          # 有密码的写法
          # uri: mongodb://name:password@localhost:27017/test

## 第一种方式：dao层继承 MongoRepository<实体类，主键类型> ##

**一、创建dao继承MongoRepository**

import com.example.demomongodb.entity.StudentLiu;
    import org.springframework.data.mongodb.repository.MongoRepository;
    import org.springframework.stereotype.Repository;
    
    @Repository
    public interface StudentRepository extends MongoRepository<StudentLiu,String> { 
    }

**二、创建实体类：**

import com.sun.istack.internal.NotNull;
    import org.springframework.data.annotation.Id;
    
    
    import java.io.Serializable;
    
    
    public class StudentLiu implements Serializable { 
        @Id
        private String id;
    
        @NotNull
        private String studentId;
    
        private Integer age;
    
        private String name;
    
        private String gender;
    
        public String getId() { 
            return id;
        }
    
        public void setId(String id) { 
            this.id = id;
        }
    
        public String getStudentId() { 
            return studentId;
        }
    
        public void setStudentId(String studentId) { 
            this.studentId = studentId;
        }
    
        public Integer getAge() { 
            return age;
        }
    
        public void setAge(Integer age) { 
            this.age = age;
        }
    
        public String getName() { 
            return name;
        }
    
        public void setName(String name) { 
            this.name = name;
        }
    
        public String getGender() { 
            return gender;
        }
    
        public void setGender(String gender) { 
            this.gender = gender;
        }
    }

**三、创建接口**

import com.example.demomongodb.entity.StudentLiu;
    
    import java.util.List;
    
    public interface StudentService { 
        StudentLiu addStudent(StudentLiu student);
    
        void deleteStudent(String id);
    
        StudentLiu updateStudent(StudentLiu student);
    
        StudentLiu findStudentById(String id);
    
        List<StudentLiu> findAllStudent();
    
    }

**四、创建接口实现类：**

import com.example.demomongodb.entity.StudentLiu;
    import com.example.demomongodb.mapper.StudentRepository;
    import com.example.demomongodb.server.StudentService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import org.springframework.transaction.annotation.Transactional;
    
    import java.util.List;
    
    @Service
    public class StudentServiceImpl implements StudentService { 
        @Autowired
        private StudentRepository studentRepository;
    
    
        /**
         * 添加学生信息
         * @param student
         * @return
         */
        @Override
        @Transactional(rollbackFor = Exception.class)
        public StudentLiu addStudent(StudentLiu student) { 
            return studentRepository.save(student);
        }
    
        /**
         * 根据 id 删除学生信息
         * @param id
         */
        @Override
        public void deleteStudent(String id) { 
            studentRepository.deleteById(id);
        }
    
        /**
         * 更新学生信息
         * @param student
         * @return
         */
        @Override
        @Transactional(rollbackFor = Exception.class)
        public StudentLiu updateStudent(StudentLiu student) { 
            StudentLiu oldStudent = this.findStudentById(student.getId());
            if (oldStudent != null){ 
                oldStudent.setStudentId(student.getStudentId());
                oldStudent.setAge(student.getAge());
                oldStudent.setName(student.getName());
                oldStudent.setGender(student.getGender());
                return studentRepository.save(oldStudent);
            } else { 
                return null;
            }
        }
    
        /**
         * 根据 id 查询学生信息
         * @param id
         * @return
         */
        @Override
        public StudentLiu findStudentById(String id) { 
            return studentRepository.findById(id).get();
        }
    
        /**
         * 查询学生信息列表
         * @return
         */
        @Override
        public List<StudentLiu> findAllStudent() { 
            return studentRepository.findAll();
        }
    }

## 五、创建controller ##

package com.example.demomongodb.controller;
    
    import com.example.demomongodb.entity.StudentLiu;
    import com.example.demomongodb.server.StudentService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.*;
    
    import java.util.List;
    
    @RestController
    @RequestMapping("/student")
    public class StudentController { 
        @Autowired
        private StudentService studentService;
    
        @PostMapping("/add")
        public StudentLiu addStudent(@RequestBody StudentLiu student){ 
            return studentService.addStudent(student);
        }
    
        /**
        * @param:
        * @return:
        * @Date: 2021/5/31
        * @author:liuyu
        * 没有做异常处理，修改不存在的id时会报错
        */
        @PostMapping("/update")
        public StudentLiu updateStudent(@RequestBody StudentLiu student){ 
            return studentService.updateStudent(student);
        }
    
        /**
         * @param:
         * @return:
         * @Date: 2021/5/31
         * @author:liuyu
         * 没有做异常处理，查询不存在的id时会报错
         */
        @GetMapping("/{id}")
        public StudentLiu findStudentById(@PathVariable("id") String id){ 
            return studentService.findStudentById(id);
        }
    
    
        @GetMapping("delete/{id}")
        public void deleteStudentById(@PathVariable("id") String id){ 
            studentService.deleteStudent(id);
        }
    
        @GetMapping("/list")
        public List<StudentLiu> findAllStudent(){ 
            return studentService.findAllStudent();
        }
    }

**测试：**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzA4NTc5Nw_size_16_color_FFFFFF_t_70]

用可视化查看数据：可以看到新增加了一个名为studentLiu的集合，名字是跟你Java里面创建的实体类名字一样的。里面有刚新增加的数据（如果没有可以点左边右上角有个刷新图标），

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzA4NTc5Nw_size_16_color_FFFFFF_t_70 1]

**六、实体类指定集合**  
加个`@Document("student")`，之前注解用的是@Document(collection=“xxx”)只需要把spring-data提供的@Document注解中collection去掉就行,换成@Document(“yourCollectionName”)

这样上面的实体类就可以改成：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzA4NTc5Nw_size_16_color_FFFFFF_t_70 2]

指定集合名称的时候，如果新增数据，数据库没有这个集合会自动创建`student2`这个集合，就不会用类名创建集合了，读取的时候也是从指定的集合读取  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzA4NTc5Nw_size_16_color_FFFFFF_t_70 3]

**七、MongoRepository有以下方法**

count（）统计总数
    count（Example< S > example）条件统计总数
    delete（T entities）通过对象信息删除某条数据
    deleteById（ID id）通过id删除某条数据
    deleteALL（Iterable<? extends T> entities）批量删除某条数据
    deleteAll（) 清空表中所有的数据
    existsById（ID id) 判断数据是否存在
    exists（Example< T > example) 判断某特定数据是否存在
    findAll（) 获取表中所有的数据
    findAll（Sort sort) 获取表中所有的数据，按照某特定字段排序
    findAll（Pageable pageAble) 获取表中所有的数据,分页查询
    findAll（Example< T > example) 条件查询
    findAll（Iterable ids) 条件查询
    findAll（Example< T > example,Pageable pageable) 条件分页查询
    findAll（Example< T > example,Sort sort) 条件查询排序
    findOneById（ID id) 通过id查询一条数据
    findOne（Example example) 通过条件查询一条数据
    insert(S entities) 插入一条数据
    insert(Iterable< T > entities) 插入多条数据
    save(S entities) 保存一条数据
    saveAll(Iterable< T > entities)
    save(Iterable< T > iterable) 加入多条数据

## [具体参考地址][Link 1] ##

## [MongoRepository 基本使用][MongoRepository] ##

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzA4NTc5Nw_size_16_color_FFFFFF_t_70]: /images/20221014/6ccff8d5dc984a1b8d2680004b961134.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzA4NTc5Nw_size_16_color_FFFFFF_t_70 1]: /images/20221014/7c19847e264d43149b68991f896e9968.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzA4NTc5Nw_size_16_color_FFFFFF_t_70 2]: /images/20221014/b908292473a34371987cf4eaf74fda95.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzA4NTc5Nw_size_16_color_FFFFFF_t_70 3]: /images/20221014/a663d53baa4242b79e8e09118bc74bf9.png
[Link 1]: https://blog.csdn.net/weixin_39214304/article/details/84791953
[MongoRepository]: https://blog.csdn.net/lizhengyu891231/article/details/107064031/