Spring boot集成mongodb

雨点打透心脏的1/2处 2022-08-30 00:41 273阅读 0赞

### 文章目录 ###

*  准备数据库
 *   *   *  切换/创建数据库
         *  创建一个集合（table)
         *  得到指定名称的集合（table )
         *  插入
 *  准备环境
 *  一、基于MongoTemplate 开发CRUD
 *   *   *  添加、查询所有
         *  其他查询
         *  修改
         *  删除
 *  二、基于MongoRepository开发CRUD
 *   *   *  添加
         *  查询
         *  修改
         *  删除

# 准备数据库 #

### 切换/创建数据库 ###

use test

如果数据库不存在，则创建数据库，否则切换到指定数据库  
![在这里插入图片描述][20210717172150788.png]

### 创建一个集合（table) ###

db.createCollection( "collName");

### 得到指定名称的集合（table ) ###

db.getCollection("user");

![在这里插入图片描述][20210717172345291.png]

### 插入 ###

> db.User.save(\{name:‘zhangsan’,age:21,sex:true\})  
> db.User.find()  
> \{"\_id": Objectld(“4f69e680c9106ee2ec95da66”), “name”: “zhangsan”, “age”: 21,  
> “sex”: true\}

# 准备环境 #

引入依赖  
添加配置  
实体类

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

# 一、基于MongoTemplate 开发CRUD #

### 添加、查询所有 ###

@SpringBootTest
    class MongodbApplicationTests {
        
    
        @Autowired
        private MongoTemplate mongoTemplate;
    
        //添加
        @Test
        public void createUser() {
        
            User user = new User();
            user.setAge(20);
            user.setName("test");
            user.setEmail("4932200@qq.com");
            User user1 = mongoTemplate.insert(user);
            System.out.println(user1);
        }
    
        //查询所有
        @Test
        public void findUser() {
        
            List<User> userList = mongoTemplate.findAll(User.class);
            System.out.println(userList);
        }
    
    
    }

结果  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ2NjcyNzQ2_size_16_color_FFFFFF_t_70]

### 其他查询 ###

//根据id查询
        @Test
        public void getById() {
        
            User user = 
    mongoTemplate.findById("5ffbfa2ac290f356edf9b5aa", User.class);
            System.out.println(user);
        }
    
        //条件查询
        @Test
        public void findUserList() {
        
            Query query = new Query(Criteria
                    .where("name").is("test")
                    .and("age").is(20));
            List<User> userList = mongoTemplate.find(query, User.class);
            System.out.println(userList);
        }
    
        //模糊查询
        @Test
        public void findUsersLikeName() {
        
            String name = "est";
            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);
        }
    
        //分页查询
        @Test
        public void findUsersPage() {
        
            String name = "est";
            int pageNo = 1;
            int pageSize = 10;
    
            Query query = new Query();
            String regex = String.format("%s%s%s", "^.*", name, ".*$");
            Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);
            query.addCriteria(Criteria.where("name").regex(pattern));
            int totalCount = (int) mongoTemplate.count(query, User.class);
            List<User> userList = mongoTemplate.find(query.skip((pageNo - 1) * pageSize).limit(pageSize), User.class);
    
            Map<String, Object> pageMap = new HashMap<>();
            pageMap.put("list", userList);
            pageMap.put("totalCount",totalCount);
            System.out.println(pageMap);
        }

### 修改 ###

//修改
        @Test
        public void updateUser() {
        
            User user = mongoTemplate.findById("5ffbfa2ac290f356edf9b5aa", User.class);
            user.setName("test_1");
            user.setAge(25);
            user.setEmail("493220990@qq.com");
            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 delete() {
        
            Query query = 
    new Query(Criteria.where("_id").is("5ffbfa2ac290f356edf9b5aa"));
            DeleteResult result = mongoTemplate.remove(query, User.class);
            long count = result.getDeletedCount();
            System.out.println(count);
        }

# 二、基于MongoRepository开发CRUD #

### 添加 ###

//添加
        @Test
        public void createUser() {
        
            User user = new User();
            user.setAge(20);
            user.setName("张三");
            user.setEmail("3332200@qq.com");
            User user1 = userRepository.save(user);
        }

### 查询 ###

//查询所有
        @Test
        public void findUser() {
        
            List<User> userList = userRepository.findAll();
            System.out.println(userList);
        }
    
        //id查询
        @Test
        public void getById() {
        
            User user = userRepository.findById("5ffbfe8197f24a07007bd6ce").get();
            System.out.println(user);
        }
    
        //条件查询
        @Test
        public void findUserList() {
        
            User user = new User();
            user.setName("张三");
            user.setAge(20);
            Example<User> userExample = Example.of(user);
            List<User> userList = userRepository.findAll(userExample);
            System.out.println(userList);
        }
    
        //模糊查询
        @Test
        public void findUsersLikeName() {
        
            //创建匹配器，即如何使用查询条件
            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);
        }
    
        //分页查询
        @Test
        public void findUsersPage() {
        
            Sort sort = Sort.by(Sort.Direction.DESC, "age");
    //0为第一页
            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);
    //创建实例
            Example<User> example = Example.of(user, matcher);
            Page<User> pages = userRepository.findAll(example, pageable);
            System.out.println(pages);
        }

### 修改 ###

//修改
        @Test
        public void updateUser() {
        
            User user = userRepository.findById("5ffbfe8197f24a07007bd6ce").get();
            user.setName("张三_1");
            user.setAge(25);
            user.setEmail("883220990@qq.com");
            User save = userRepository.save(user);
            System.out.println(save);
        }

### 删除 ###

//删除
        @Test
        public void delete() {
        
            userRepository.deleteById("5ffbfe8197f24a07007bd6ce");
        }

[20210717172150788.png]: /images/20220829/7af5e41d8ab2473d99240a4073a09213.png
[20210717172345291.png]: /images/20220829/143db7a8821748478c37f8f8bd4c43d9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ2NjcyNzQ2_size_16_color_FFFFFF_t_70]: /images/20220829/ebc235aff00a411898db8efcfa24cd17.png