在SpringBoot下用java操作MongoDB数据库的增删改查

野性酷女 2022-05-31 14:51 169阅读 0赞

首先我们需要建立一个SpringBoot工程，在IDEA中有快捷的创建方式。

new -> project -> Spring Initializr 根据需要一路next下去即可

![2018022717031187][]

第二步，给application.properties添加MongoDB配置

#MongoDB
    #spring.data.mongodb.username=root
    #spring.data.mongodb.password=
    spring.data.mongodb.host=localhost
    spring.data.mongodb.repositories.enabled=true
    spring.data.mongodb.database=
    spring.data.mongodb.port=27017

> 第三步，在工程中创建一个实体类，便于接下来的测试(@Data注解属于lombok插件，用于简化getter,setter方法)

@Data
    @Document(collection="student")    
    class Student{
      @Id
      String _id;
      String name;
      String class_id;
      String sex;
      Integer age;
    }

第四步，创建一个controller类,编写四个接口用于测试

@RestController
    public class MongoTestController {
      
      @Autowired MongoTemplate mongoTemplate;
    
      @RequestMapping(value = "/save", method = RequestMethod.GET)
      public void save(){
        Student student = new Student();
        student.setName("张三");
        student.setAge(18);
        student.setSex("男");
        student.setId(UUID.randomUUID().toString());
        
        mongoTemplate.save(student);
      }
    
      @RequestMapping(value = "/del", method = RequestMethod.GET)
      public void del(){
        // 删除name = 张三的数据
        Criteria criteria = Criteria.where("name").is("张三");
    //    删除年龄 > 17
    //    Criteria.where("age").gt(17);
    //    删除年龄 <= 19
    //    Criteria.where("age").lte(19)
        Query query = Query.query(criteria);
        
        mongoTemplate.remove(query, Student.class);
    //    一样的效果
    //    mongoTemplate.remove(query, "student");
      }
    
      @RequestMapping(value = "/update", method = RequestMethod.GET)
      public void update(){
        // 匹配条件name = 张三
        Criteria criteria = Criteria.where("name").is("张三");
        Query query = Query.query(criteria);
        // 修改年龄 = 20
        Update update = new Update();
        update.set("age", 20);
        
        // updateFirst 修改匹配到的第一个学生
        mongoTemplate.updateFirst(query, update, Student.class);
    //    mongoTemplate.updateFirst(query, update, "student");
        // updateMulti 修改所有 name = 张三 的学生
        mongoTemplate.updateMulti(query, update, Student.class);
      }
      
      @RequestMapping(value = "/query", method = RequestMethod.GET)
      public void query(){
        // 匹配条件sex = 男
        Criteria criteria = Criteria.where("sex").is("男");
        Query query = Query.query(criteria);
    
        // 查询名字为张三的所有学生
        List<Student> students = mongoTemplate.find(query, Student.class);
        
        // 类似的 查询年龄 > 18的学生
        Criteria criteria1 = Criteria.where("age").lt(18);
        Query query1 = Query.query(criteria);
        List<Student> students1 = mongoTemplate.find(query1, Student.class);
      }
      
    }

上面的代码使用了SpringBoot自带的MongoTemplate API实现了对数据库的CRUD操作。

同时，还有第二种实现方式，创建一个实体类的Dao接口，继承MongoRepository接口。MongoRepository第一个泛型里面填入与数据库交互的实体Bean,第二个泛型是该实体Bean的id类型。

public interface StudentDao extends MongoRepository<Student, String>{
    }

这样，我们就可以在需要对该实体Bean和数据库交互的类中自动注入进去，使用该接口的API

@Autowired StudentDao studentDao;

比如一些基本的操作如下:

//根据id查找一条数据
        studentDao.findOne(id);
        
        //查出所有数据
        studentDao.findAll();
        
        //根据id删除一条数据
        studentDao.delete(id);
        
        //保存一个Student对象
        studentDao.save(student);
        
        //没有修改的方法，只需要save一次相同id的Student对象即可修改

[2018022717031187]: /images/20220531/e053955ee3984e01b380bb709ed9c61b.png