当前位置：移动技术网 > IT编程>开发语言>Java > SpringBoot工程下MongoDB增删改查，以及复杂查询和更新

SpringBoot工程下MongoDB增删改查，以及复杂查询和更新

2020年07月09日 | 移动技术网IT编程 | 我要评论

1.数据库设计结构

{
    "_id": ObjectId("5f05ab4484cd013081699682"),
    "name": "小明",
    "age": 29,
    "gender": "男",
    "phone": "15914922663",
    "friends": [
        {
            "name": "小白",
            "age": NumberInt("27"),
            "gender": "女",
            "phone": "16620055669",
            "hobby": [
                "画画",
                "旅行",
                "弹钢琴",
                "古筝"
            ]
        },
        {
            "name": "隔壁老王",
            "age": NumberInt("98"),
            "gender": "男",
            "phone": "19920066447",
            "hobby": [
                "王者农药",
                "吃鸡",
                "射击",
                "看书",
                "格斗",
                "动画制作后期处理"
            ]
        },
        {
            "name": "张三",
            "age": NumberInt("28"),
            "gender": "男",
            "phone": "17266989541",
            "hobby": [
                "听音乐",
                "唱歌",
                "羽毛球",
                "ewgsd"
            ]
        }
    ]
}

小明有name,age,gender,phone这些属性，他的朋友有3个，分别是小白、隔壁老王、张三，他的朋友也有name,age,gender,phone这些属性，并且有hobby这个属性

2.创建SpringBoot工程，并开始编写代码

在pom.xml中添加这两个依赖

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.8</version>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
        </dependency>

配置application.yml文件

server:
  port: 9999

###username是用户名，password是密码，databasename是数据库名，最重要的是authdatabase，这是验证数据库名称，必须填
spring:
  data:
    mongodb:
      uri: mongodb://username:password@47.101.102.103:27017/databasename?authSource=authdatabase

创建bean包，在此包创建Person类和Friend类

Person类：

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;

import java.util.List;


@Data    //自动生成getter，setter方法
@NoArgsConstructor    //无参构造器
@AllArgsConstructor    //全参构造器
@Document(collection = "Person")    //指定mongodb的哪个collection
public class Person {
    @Id    //指定主键
    private String id;
    private String name;
    private Integer age;
    private String gender;
    private String phone;
    private List<Friend> friends;

}

Friend类：

import lombok.Data;
import java.util.List;

@Data
public class Friend {
    //注意，下面的属性名必须要和数据库的字段一致
    private String name;
    private Integer age;
    private String gender;
    private String phone;
    private List<String> hobby;
}

创建controller包，在此包下创建FriendMongoDBController类，里面包含了所有增删改查的方法，以及复杂查询更新的方法

import com.example.springcloud_mongodb_test1.bean.Friend;
import com.example.springcloud_mongodb_test1.bean.Person;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.web.bind.annotation.*;
import java.util.ArrayList;
import java.util.List;


@RestController
public class FriendMongoDBController {
    @Autowired
    MongoTemplate mongoTemplate;
    //查询所有记录
    //测试地址http://127.0.0.1:9999/findAllPerson
    @GetMapping("/findAllPerson")
    public List<Person> getAllPerson(){
        return mongoTemplate.findAll(Person.class);
    }

    //根据id查询记录
    //测试地址http://127.0.0.1:9999/findPersonById/xxxxxid
    @GetMapping("/findPersonById/{id}")
    public List<Person> getPersonById(@PathVariable("id")String id){
        Query query = new Query();
        query.addCriteria(Criteria.where("id").is(id));
        return mongoTemplate.find(query,Person.class);

    }

    //根据id查询一个Person的朋友
    //测试地址http://127.0.0.1:9999/findFriendsById/xxxxxid
    @GetMapping("/findFriendsById/{id}")
    public List<Friend> getFriendsById(@PathVariable("id")String id){
        Query query = new Query();
        query.addCriteria(Criteria.where("id").is(id));
        List<Person> personList = mongoTemplate.find(query,Person.class);
        List<Friend> friendList = personList.get(0).getFriends();
        return friendList;
    }

    //根据姓名模糊查询
    //测试地址http://127.0.0.1:9999/findBlurByName
    @GetMapping("/findBlurByName")
    public List<Person> getBlurByName(){
        Query query = new Query();
        query.addCriteria(Criteria.where("name").regex(".*小.*"));
        List<Person> personList = mongoTemplate.find(query,Person.class);
        return personList;
    }

    //多条件查询，查询年龄大于90小于120的Person
    //测试地址http://127.0.0.1:9999/findAgeField/90/120
    @GetMapping("/findAgeField/{gt}/{lt}")
    public List<Person> getAgeField(@PathVariable("gt")Integer gt,@PathVariable("lt")Integer lt){
        Query query = new Query();
        Criteria criteria = new Criteria();
        criteria.andOperator(
          Criteria.where("age").gt(gt),
          Criteria.where("age").lt(lt)
        );
        query.addCriteria(criteria);
        List<Person> personList = mongoTemplate.find(query,Person.class);
        return personList;
    }

    //多条件查询，与或条件并存，查询年龄大于90小于120的或者姓名包括有"小"字的Person
    //测试地址http://127.0.0.1:9999/findAgeFieldOrName/90/120/小
    @GetMapping("/findAgeFieldOrName/{gt}/{lt}/{name}")
    public List<Person> getAgeFieldOrName(@PathVariable("gt")Integer gt,@PathVariable("lt")Integer lt,@PathVariable("name")String name){
        Query query = new Query();
        Criteria criteria = new Criteria();

        criteria.orOperator(
                new Criteria().andOperator(
                        Criteria.where("age").gt(gt),
                        Criteria.where("age").lt(lt)
                ),
                Criteria.where("name").regex(".*"+name+".*")
        );
        query.addCriteria(criteria);
        List<Person> personList = mongoTemplate.find(query,Person.class);
        return personList;
    }

    //更新一个Person的某个朋友的信息，例如更新小明的朋友张三的爱好，我们为她添加一个爱好，以更新数据
    //必须先把url粘贴到浏览器，然后复制url，粘贴到postman去发送post请求，我们将会发现postman显示的url的中文部分是一串乱码
    //测试地址http://127.0.0.1:9999/updateFriendHobbyByName/小明/张三/爱好xxx
    @RequestMapping("/updateFriendHobbyByName/{name}/{friend_name}/{hobby}")
    public String updateFriendHobbyByName(@PathVariable("name")String name,@PathVariable("friend_name")String friend_name,@PathVariable("hobby")String hobby){
        Query query = new Query();
        query.addCriteria(Criteria.where("name").is(name));
        List<Person> personList = mongoTemplate.find(query,Person.class);
        List<Friend> friendList = personList.get(0).getFriends();

        for(int i=0;i<friendList.size();i++){
            if(friendList.get(i).getName().equals(friend_name)){
                List<String> hobbyList = friendList.get(i).getHobby();
                hobbyList.add(hobby);
                break;
            }

        }
        Update update = new Update().set("friends",friendList);
        mongoTemplate.updateFirst(query,update,Person.class);


        return null;
    }

    //插入一个新的Person
    //测试地址http://127.0.0.1:9999/addOnePerson
    @RequestMapping("/addOnePerson")
    public Person addOnePerson(){
        Person person = new Person();
        person.setName("星爷");
        person.setAge(92);
        person.setGender("男");
        person.setPhone("16655966754");
        List<Friend> friendList = new ArrayList<>();
        Friend friend = new Friend();
        friend.setName("哈莉");
        friend.setAge(18);
        friend.setGender("女");
        friend.setPhone("66955421563");
        List<String> hobbyList = new ArrayList<>();
        for(int i=1;i<5;i++){
            hobbyList.add("爱好"+Integer.toString(i));
        }
        friend.setHobby(hobbyList);
        friendList.add(friend);
        person.setFriends(friendList);
        mongoTemplate.insert(person);
        return person;
    }

    //根据删除一个Person
    //测试地址http://127.0.0.1:9999/delOnePerson/xxxid
    @RequestMapping("/delOnePerson/{id}")
    public void delOnePerson(@PathVariable("id")String id){
        Query query = new Query();
        query.addCriteria(Criteria.where("id").is(id));
        mongoTemplate.remove(query, Person.class);
    }


}

创建config包，并创建MongoConfig类（插入数据的时候避免生成_class字段）

import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.NoSuchBeanDefinitionException;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.convert.CustomConversions;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.core.convert.DbRefResolver;
import org.springframework.data.mongodb.core.convert.DefaultDbRefResolver;
import org.springframework.data.mongodb.core.convert.DefaultMongoTypeMapper;
import org.springframework.data.mongodb.core.convert.MappingMongoConverter;
import org.springframework.data.mongodb.core.mapping.MongoMappingContext;

@Configuration
public class MongoConfig {

    @Bean
    public MappingMongoConverter mappingMongoConverter(MongoDbFactory factory, MongoMappingContext context, BeanFactory beanFactory) {
        DbRefResolver dbRefResolver = new DefaultDbRefResolver(factory);
        MappingMongoConverter mappingConverter = new MappingMongoConverter(dbRefResolver, context);
        try {
            mappingConverter.setCustomConversions(beanFactory.getBean(CustomConversions.class));
        } catch (NoSuchBeanDefinitionException ignore) {
        }

        // Don't save _class to mongo
        mappingConverter.setTypeMapper(new DefaultMongoTypeMapper(null));

        return mappingConverter;
    }

}

mongodb最实用的增删改查的方法到此结束，谢谢大家浏览此文章！

本文地址：https://blog.csdn.net/Xeon_CC/article/details/107216249

您可能感兴趣的文章:

如对本文有疑问，点击进行留言回复！！

java线程池源码解析

1.从提交Runnable开始2. 具体流程（简化代码）public void execute(Runnable... [阅读全文]
Mybatis-Plus Sql 注入器

Mybatis+Mybatis-PlusSpring+Mybatis+Mybatis-PlusSpring Bo... [阅读全文]
dockerfile创建一个自己的jdk8镜像步骤

1、官方下载jdk8地址：https://www.oracle.com/java/technologies/ja... [阅读全文]
第十一天-Java继承/多态特性-方法重写/抽象类/适配器/对象运行时的多态/

java不支持多继承，可以通过接口实现。继承后可以调用被继承类里的方法缺省修饰符修饰的方法在子类继承后，只能在同... [阅读全文]
Java面向对象（三）——关键字（this,super,static,final,abstract,interface,implements,throw）

Java面向对象（三）——关键字（this,super,static,final,abstract,interf... [阅读全文]
荐 java基础中的--------构造方法+静态+代码块+主方法解释

构造方法一.概述1.构造方法：构造函数，构造器，Constuctor2.作用：用于给对象的成员变量进行赋值，在创... [阅读全文]
选择排序就是这么简单

选择排序(Selection sort)是一种简单直观的排序算法。它的工作原理是每一次从待排序的数据元素中选出最... [阅读全文]
一维数组及经典应用

一、数组的定义数组是一个变量，存储相同数据类型的一组数据；数组的下标由0开始向上递增。数组的声明,分配空间和赋值... [阅读全文]
java数据结构和算法——数组模拟环形队列（queue）

摘要：由于数组模拟队列，数组无法复用，下面讲解了用数组模拟环形队列的方法，采用取模的方式，使得数组可以重复使用。... [阅读全文]
微服务技术系列教程（46）-SpringBoot整合MongoDB（文章评论案例）

01 引言本文的代码已上传至Github，有兴趣的同学可以Clone下来看看https://github.com... [阅读全文]

网友评论


验证码：