springboot整合MongoDB常用方法

阳光穿透心脏的1/2处 2023-06-26 11:00 18阅读 0赞

1、查询全部

private List<SysUser> selectUserList() { 
    
            return mongoTemplate.findAll(SysUser.class);
        }

2、保存/修改

public void save(SysUser user) { 
    
            mongoTemplate.save(user);
        }

3、按主键查询

public SysUser getUserById(String id) { 
        
            return mongoTemplate.findById(id, SysUser.class);
        }

4、按主键修改（更新所有的值）

public Object update(SysUser user) { 
            SysUser oldObj = sysUserService.getUserById(user.getId());
            user.setCreateTime(oldObj.getCreateTime());
            user.setCreateName(oldObj.getCreateName());
            user.setModifyTime(new Date());
            sysUserService.save(user);
            return ResultsUtils.success();
        }

5、按条件修改（更新指定字段的值）

public void update(SysUser user) { 
            Query query = new Query();
            query.addCriteria(Criteria.where("_id").is(user.getId()));
            Update update = new Update();
            update.set("loginName", user.getLoginName());
            mongoTemplate.upsert(query, update, "sys_user");
        }

6、按主键删除

public void delete(String id) { 
            Query query=new Query(Criteria.where("id").is(id));
            mongoTemplate.remove(query,SysUser.class);
        }

7、按条件精确查询

public List<SysUser> getUserList(String loginName) { 
            Query query = new Query();
            if(StringUtils.isNotBlank(loginName)){ 
                query.addCriteria(Criteria.where("loginName").is(loginName));
            }
            return mongoTemplate.find(query, SysUser.class);
        }

8、按条件模糊查询

public List<SysUser> getUserList(String loginName){ 
            Query query = new Query();
            query.addCriteria(Criteria.where("loginName").regex(loginName));
            return mongoTemplate.find(query, SysUser.class);
        }

9、按时间段查询并排序

public List<SysUser> getUserList(String startDate, String endDate) throws Exception{ 
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
            Query query = new Query();
            if (StringUtils.isNotBlank(startDate)&&StringUtils.isNotBlank(endDate)) { 
                query.addCriteria(Criteria.where("createTime").gte(sdf.parse(startDate)).lte(sdf.parse(endDate)));
            }else if(StringUtils.isNotBlank(startDate)){ 
                query.addCriteria(Criteria.where("createTime").gte(sdf.parse(startDate)));
            }else if(StringUtils.isNotBlank(endDate)){ 
                query.addCriteria(Criteria.where("createTime").lte(sdf.parse(endDate)));
            }
            query.with(new Sort(Sort.Direction.DESC, "createTime"));
            return mongoTemplate.find(query, SysUser.class);
        }

10、保存关联对象

public Object add(SysUser user) { 
    // SysRole role=sysRoleService.getRoleById(user.getRoleId());
            user.setSysRole(new SysRole(user.getRoleId()));
            user.setCreateTime(new Date());
            user.setCreateName("Jeff");
            sysUserService.save(user);
            return ResultsUtils.success();
        }

11、按关联对象主键查询

public SysUser getUserByRoleId(String roleId) { 
            Query query = new Query();
            query.addCriteria(Criteria.where("sysRole.$id").is(new ObjectId(roleId)));
            return mongoTemplate.findOne(query, SysUser.class);
        }

12、复杂条件查询

public List<SysUser> getUserList(String loginName,String password) { 
            Query query = new Query();
            Criteria criteria = new Criteria();
            Criteria loginNameCri = new Criteria();
            Criteria emailCri = new Criteria();
            loginNameCri.andOperator(Criteria.where("loginName").is(loginName),Criteria.where("password").is(password));
            emailCri.andOperator(Criteria.where("email").is(loginName),Criteria.where("password").is(password));
            criteria.orOperator(loginNameCri,emailCri);
            query.addCriteria(criteria);
            return mongoTemplate.find(query, SysUser.class);
        }