SpringBoot集成MongoDB实现两种CRUD

深藏阁楼爱情的钟 2023-01-13 10:26 125阅读 0赞

![获取脑图公众号回复：MongoDB][MongoDB]

### SpringBoot集成MongoDB实现CRUD ###

*  一、MongoDB介绍
 *   *  MongoDB是什么
     *  MongoDB的特点
     *  MongoDB适用场景
 *  二、准备工作
 *   *  步骤1：引入依赖
     *  步骤2：添加配置
     *  步骤3：添加实体类
 *  三、基于MongoTemplate实现CRUD
 *   *  添加记录
     *  查询记录
     *  修改记录
     *  删除记录
 *  四、基于MongoRepository实现CRUD
 *   *  添加记录
     *  查询记录
     *  修改记录
     *  删除记录

--------------------

# 一、MongoDB介绍 #

## MongoDB是什么 ##

MongoDB 是一个基于分布式文件存储的数据库。由 C++ 语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案。MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。

## MongoDB的特点 ##

*  MongoDB是一个独立的服务器
 *  MongoDB是基于文档的，而非基于表格
 *  MongoDB是非结构化的
 *  使用MongoDB不必去学习另一种查询语言，学习曲线平滑
 *  MongoDB具有强大的主流开发语言支持，如C\#/++、JAVA、PHP、Python等

## MongoDB适用场景 ##

*  网站数据：由于具备高度伸缩性，适合实时的插入，更新与查询。
 *  缓存：由于性能高，适合作为信息基础设施的缓存层。系统重启之后持久化缓存层以避免下层的数据源过载。
 *  大尺寸，低价值的数据：使用传统的关系型数据库存储一些数据时可能会比较昂贵。
 *  高伸缩性的场景：适合由数十或数百台服务器组成的数据库。
 *  用于对象及 JSON数据的存储：Mongo的BSON数据格式适合文档化格式的存储及查询。

# 二、准备工作 #

## 步骤1：引入依赖 ##

使用MongoDDB主要引入spring-boot-starter-data-mongodb。

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-mongodb</artifactId>
            </dependency>

## 步骤2：添加配置 ##

spring.data.mongodb.uri=mongodb://[ip地址]:27017/[数据库名]

## 步骤3：添加实体类 ##

@Data
     @Document("User")
     public class User { 
     
      @Id
      private String id;
    
      private String name;
    
      private Integer age;
    
      private String email;
    
      private String createDate;
     }

# 三、基于MongoTemplate实现CRUD #

基于MongoTemplate实现CRUD，首先需要将mongoTemplate组件加入Bean。

// 注入mongoTemplate
        @Autowired
        private MongoTemplate mongoTemplate;

## 添加记录 ##

// 添加记录
        @Test
        public void create() { 
            User user = new User();
            user.setAge(21);
            user.setName("Hudie");
            user.setEmail("Hudie@qq.com");
            User user1 = mongoTemplate.insert(user);
            System.out.println(user1);
        }

## 查询记录 ##

（1）查询所有

// 查询所有记录
        @Test
        public void findAll() { 
            List<User> list = mongoTemplate.findAll(User.class);
            System.out.println(list);
        }

（2）根据id查询

// 根据id查询
        @Test
        public void findId() { 
            User user = mongoTemplate.findById("607b7469ef30607aa5bb9a1b", User.class);
            System.out.println(user);
        }

（3）条件查询

// 条件查询
        @Test
        public void findUserList() { 
            Query query = new Query(Criteria.where("name").is("Hudie")
                    .and("age").is(21));
    
            List<User> list = mongoTemplate.find(query, User.class);
            System.out.println(list);
        }

（4）模糊查询

// 模糊查询
        @Test
        public void findLikeUserList() { 
            String name = "di";
            String regex = String.format("%s%s%s", "^.*", name, ".*$");
            Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);
            Query query = new Query(
                    Criteria.where("name").regex(pattern));
            List<User> userList = mongoTemplate.find(query, User.class);
            System.out.println(userList);
        }

（5）分页查询

// 分页查询
        @Test
        public void findUsersPage() { 
            String name = "di";
            // 当前页
            int pageNo = 1;
            // 每页显示记录数
            int pageSize = 10;
            // 模糊条件构造
            String regex = String.format("%s%s%s", "^.*", name, ".*$");
            Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);
            Query query = new Query(Criteria.where("name").regex(pattern));
            // 查询记录数
            long count = mongoTemplate.count(query, User.class);
            // 查询开始位置+每页显示记录数
            List<User> users = mongoTemplate.find(
                    query.skip((pageNo - 1) * pageSize).limit(pageSize), User.class);
            System.out.println(count);
            System.out.println(users);
        }

## 修改记录 ##

//修改
        @Test
        public void updateUser() { 
            // 1.根据id查询到记录
            User user = mongoTemplate.findById("607b7469ef30607aa5bb9a1b", User.class);
            // 2.设置修改值
            user.setName("test01");
            user.setAge(23);
            user.setEmail("test@qq.com");
            // 3.调用方法实现修改
            Query query = new Query(Criteria.where("_id").is(user.getId()));
            Update update = new Update();
            update.set("name", user.getName());
            update.set("age", user.getAge());
            update.set("email", user.getEmail());
            UpdateResult result = mongoTemplate.upsert(query, update, User.class);
            // 返回受影响的行数
            long count = result.getModifiedCount();
            System.out.println(count);
        }

## 删除记录 ##

//删除操作
        @Test
        public void deleteUser() { 
            Query query =
                    new Query(Criteria.where("_id").is("607b7469ef30607aa5bb9a1b"));
            DeleteResult result = mongoTemplate.remove(query, User.class);
            // 返回受影响的行数
            long count = result.getDeletedCount();
            System.out.println(count);
        }

# 四、基于MongoRepository实现CRUD #

## 添加记录 ##

// 添加记录
        @Test
        public void create() { 
            User user = new User();
            user.setAge(21);
            user.setName("胡蝶");
            user.setEmail("hudie@163.com");
            User user1 = userRepository.save(user);
            System.out.println(user1);
        }

## 查询记录 ##

（1）查询所有

// 查询所有记录
        @Test
        public void findAll() { 
            List<User> userList = userRepository.findAll();
            System.out.println(userList);
        }

（2）根据id查询

// 根据id查询
        @Test
        public void findId() { 
            User user = userRepository.findById("607b87662f45b658feccd2e7").get();
            System.out.println(user);
        }

（3）条件查询

// 条件查询
        @Test
        public void findUserList() { 
            User user = new User();
            user.setName("胡蝶");
            user.setAge(21);
            Example<User> userExample = Example.of(user);
            List<User> userList = userRepository.findAll(userExample);
            System.out.println(userList);
        }

（4）模糊查询

// 模糊查询
        @Test
        public void findLikeUserList() { 
            //设置模糊查询匹配规则
            ExampleMatcher matcher = ExampleMatcher.matching()
                    // 设置模糊查询,若不加参数是完全匹配
                    .withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING)
                    // 忽略大小写
                    .withIgnoreCase(true);
            User user = new User();
            user.setName("蝶");
            Example<User> userExample = Example.of(user, matcher);
            List<User> userList = userRepository.findAll(userExample);
            System.out.println(userList);
        }

（5）分页查询

// 分页查询
        @Test
        public void findUsersPage() { 
            // 根据年龄降序排列
            Sort sort = Sort.by(Sort.Direction.DESC, "age");
            // 0为第一页,每页10条记录
            Pageable pageable = PageRequest.of(0, 10, sort);
    
            // 设置模糊查询匹配规则
            ExampleMatcher matcher = ExampleMatcher.matching() //构建对象
                    //改变默认字符串匹配方式：模糊查询
                    .withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING)
                    .withIgnoreCase(true); //改变默认大小写忽略方式：忽略大小写
            User user = new User();
            user.setName("蝶");
            Example<User> userExample = Example.of(user, matcher);
            //创建实例
            Page<User> pages = userRepository.findAll(userExample, pageable);
            System.out.println(pages);
        }

## 修改记录 ##

//修改
        @Test
        public void updateUser() { 
            User user = userRepository.findById("607b87662f45b658feccd2e7").get();
            user.setName("胡小蝶");
            user.setAge(21);
            user.setEmail("diedie@qq.com");
            User save = userRepository.save(user);
            System.out.println(save);
        }

## 删除记录 ##

//删除操作
        @Test
        public void deleteUser() { 
            userRepository.deleteById("607b87662f45b658feccd2e7");
        }

[MongoDB]: /images/20221022/aa1cbcbaa8594c9a9c95d42d8eb498aa.png