MongoRepository 基本使用

叁歲伎倆 2023-02-22 03:56 19阅读 0赞

转载自：[https://www.jianshu.com/p/f47621a224a6][https_www.jianshu.com_p_f47621a224a6]

## 叙述 ##

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) 加入多条数据

以下演示方法的使用，实际上方法传参方式就几个，可以举一反三，以上方法都可以自己尝试使用。

//插入文档中嵌入一个文档
        @Test
            public void insertMany() {
            Users users=new Users();
            Info info=new Info();
            String []sport={"run","basketball"};
            String []address={"hunan","beijing"};
            info.setSport(sport);
            info.setAddress(address);
            users.setUsername("xiaohao999");
            users.setPhone("183xxxxxxxxx");
            users.setInfo(info);
            Users insert = usersRepository.insert(users);
            System.out.println(insert);
    
        }
    
        //批量插入
        @Test
        public void insertList() {
            List<Users> list = new ArrayList<>();
            for (int i = 1; i <= 100; i++) {
                Users users = new Users();
                users.setAddress("湖南");
                users.setHeadImg("");
                users.setPassword("xxxxxxx");
                users.setPhone("183xxxxxxx");
                users.setUsername("xiaohao" + i);
                list.add(users);
    
            }
            usersRepository.insert(list);
    
        }
    
        //查询全部
        @Test
        public void findALL() {
            List<Users> all = usersRepository.findAll();
            for (Users users : all) {
                System.out.println(users);
            }
        }
    
        //查询条数
        @Test
        public void count() {
            long count = usersRepository.count();
            System.out.println(count);
        }
    
        //条件统计条数
        @Test
        public void countByExample() {
            Users users = new Users();
            users.setUsername("xiaohao55");
            Example<Users> usersExample = Example.of(users);
            long count = usersRepository.count(usersExample);
            System.out.println(count);
        }
    
        @Test
        public void exists() {
            Users users = new Users();
            users.setUsername("xiaohao");
            Example<Users> usersExample = Example.of(users);
            boolean exists = usersRepository.exists(usersExample);
            System.out.println(exists);
        }
    
        @Test
        public void existsById() {
            String id = "5d36d565bde542361407adfb";
            boolean exists = usersRepository.existsById(id);
            System.out.println(exists);
        }
    
        //查询喜欢运动中有跑步,和篮球的用户
        @Test
        public void findExample(){
            Users users=new Users();
            Info info =new Info();
            info.setSport(new String[]{"run"，"basketball"});
    
            users.setInfo(info);
            Example example=Example.of(users);
            Optional one = usersRepository.findOne(example);
            usersRepository.sa
            Users user = (Users) one.get();
            System.out.println(user);
    
    
        }
    
    
        //排序查询，这里查找姓名按照一个个字段逐一比较
        @Test
        public void findBySort() {
    
            Sort sort = new Sort(Sort.Direction.DESC, "username");
            List<Users> all = usersRepository.findAll(sort);
            for (Users users : all) {
                System.out.println(users);
            }
        }
    
        //获取表中所有的数据,分页查询 pageAble
        @Test
        public void findByPageable() {
            int page = 2;
            int size = 100;
            Pageable pageable = new PageRequest(page, size);
            Page<Users> all = usersRepository.findAll(pageable);
    
            for (Users users : all) {
                System.out.println(users);
            }
    
    
        }
    
        //批量查询
        @Test
        public void findByList() {
    
            List<String> ids = new ArrayList<>();
            ids.add("5d36d565bde542361407adfb");
            ids.add("5d36d7e0bde5420f34116904");
            Iterable<Users> allById = usersRepository.findAllById(ids);
            for (Users users:allById ){
                System.out.println(users);
            }
    
    
        }
    
        //
        //利用save更新
        @Test
        public void save() {
            Users users= new Users();
            users.setId("5d36d565bde542361407adfb");
            users.setUsername("shawn");
            usersRepository.save(users);
    
    
        }
    
        //添加一个新字段，(user其他字段不能传空，否则将只有这个字段)
        @Test
        public void saveNew1() {
            Users users= new Users();
            users.setId("5d36d565bde542361407adfb");
            users.setUsername("shawn");
            users.setAge("22");
            usersRepository.save(users);
    
    
        }
        //添加一个新字段，其他的不修改可以先查询
        @Test
        public void saveNew2() {
            String id="5d36d7e0bde5420f34116904";
            Optional<Users> byId = usersRepository.findById(id);
            Users users = byId.get();
            users.setUsername("shawn");
            System.out.println(users);
            usersRepository.save(users);
    
    
        }

[https_www.jianshu.com_p_f47621a224a6]: https://www.jianshu.com/p/f47621a224a6