基于SpringBoot 框架MongoDB 一些简单的查询方式
添加jar包,mingo数据库是一款分布式文件存储的数据库,不支持事务,不支持表连接。
首先导入依赖
复制代码 org.springframework.boot spring-boot-starter-data-mongodb
jar包提供的 MongoTemplate 模板进行查询
Query : 创建查询对象用来查询复制代码
Criteria是标准查询的接口,可以引用静态的Criteria.where的把多个条件组合在一起,就可以轻松地将多个方法标准和查询连接起来,方便我们操作查询语句。复制代码
查询
根据关键字查询
//查询对象Query query = new Query();// Criteria是标准查询的接口,可以引用静态的Criteria.where的把多个条件组合在一起,就可以轻松地将多个方法标准和查询连接起来,方便我们操作查询语句。query.addCriteria(Criteria.where("name").is(name));mongoTemplate.findOne(query,User.class); // 若是find()这里返回的是一个对象,查询一个用findOne()复制代码
查询多个用and连接起来即可
query.addCriteria(Criteria.where("name").is(name).and("xxx").is(xxx));复制代码
模糊查询
采用正则匹配查询
//正则 name是你需要输入的查询值Pattern pattern = Pattern.compile("^.*"+ name +".*$", Pattern.CASE_INSENSITIVE);//创建查询对象Query query = new Query();//设置模糊查询query.addCriteria(Criteria.where("name").regex(pattern));复制代码
或者
mongoTemplate.find(Query.query(Criteria.where("name").regex("填写匹配字符")),User.class);复制代码
正则源码方法:
//字符串public Criteria regex(String re) { return this.regex(re, (String)null);}public Criteria regex(String re, @Nullable String options) { return this.regex(this.toPattern(re, options));}//正则表达式public Criteria regex(Pattern pattern) { Assert.notNull(pattern, "Pattern must not be null!"); if (this.lastOperatorWasNot()) { return this.not(pattern); } else { this.isValue = pattern; return this; }}public Criteria regex(BsonRegularExpression regex) { if (this.lastOperatorWasNot()) { return this.not(regex); } else { this.isValue = regex; return this; }}复制代码
查询所有
Query query = new Query();mongoTemplate.find(new Query(new Criteria()),User.class);复制代码
Criteria 的源代码 构造方法
public Criteria() { this.isValue = NOT_SET; this.criteriaChain = new ArrayList();}public Criteria(String key) { this.isValue = NOT_SET; this.criteriaChain = new ArrayList(); this.criteriaChain.add(this); this.key = key;}复制代码
new Criteria()无参的方法中没有查询条件key,表示查询全部。
大于小于,大于等于,小于等于 , 非空
大于:gt
Criteria.where("age").gt(age)复制代码
小于:lt
mongoTemplate.find(Query.query(Criteria.where("age").lt(age)),User.class);复制代码
大于等于:gte
Criteria.where("age").gte(age)复制代码
小于等于:lte
Criteria.where("age").lte(age)复制代码
非空查询 ne(不等于)
mongoTemplate.find(Query.query(Criteria.where("age").ne("").ne(null)),User.class);复制代码
排序
单个字段排序
Query query = new Query(); //query.addCriteria(Criteria.where("name").is(name)); query.with(new Sort(Sort.Direction.ASC, "age")); mongoTemplate.find(query,User.class);复制代码
多个不同字段排序
query.with(new Sort(Sort.Direction.ASC, "age").and(new Sort(Sort.Direction.ASC,"xxx")));复制代码
多个字段同时升序或降序
多个字段同时升序或降序
query.with(new Sort(Direction.ASC,"a","b","c"));复制代码
in(nin) 在指定范围内查询
in源码方法(nin 同理)
public Criteria in(Object... o) { if (o.length > 1 && o[1] instanceof Collection) { throw new InvalidMongoDbApiUsageException("You can only pass in one argument of type " + o[1].getClass().getName()); } else { this.criteria.put("$in", Arrays.asList(o)); return this; }}public Criteria in(Collection c) { this.criteria.put("$in", c); return this;}复制代码
可以是一个字符串也可以是一个集合
可以是一个字符串也可以是一个集合mongoTemplate.find(Query.query(Criteria.where("age").in("")),User.class);复制代码
分页查询
利用PageRequest对象查询
调用with方法设置分页参数
public Query with(Pageable pageable) { if (pageable.isUnpaged()) { return this; } else { this.limit = pageable.getPageSize(); this.skip = pageable.getOffset(); return this.with(pageable.getSort()); }}复制代码
利用Query对象设置查询参数
然后查询总数
public PageModelfindUsersByNameLike(String name, int page , int nums) { Pageable pageable = new PageRequest(page, page, Sort.Direction.ASC, name); //正则 Pattern pattern = Pattern.compile("^.*"+name+".*$", Pattern.CASE_INSENSITIVE); //创建查询对象 Query query = new Query(); //设置模糊查询 query.addCriteria(Criteria.where("name").regex(pattern)); //排序 query.with(new Sort(Sort.Direction.ASC, "age")); //设置分页 query.with(pageable); //查询当前页数据集合 List userList = mongoTemplate.find(query, User.class); //查询总记录数 int count=(int) mongoTemplate.count(query,User.class); //创建分页实体对象 PageModel pageModel =new PageModel (); //pageable.getPageNumber(); //pageable.getPageSize(); return new PageModel (userList,count,pageable);}复制代码
分页实体
/** * 分页 * * @author tizzy * @param*/public class PageModel { //结果集 private List datas; //查询总计记录数 private Long rowCount; //包含页码 , 每页多少条数 private Pageable pageable; public PageModel(List datas, Long rowCount, Pageable pageable) { this.datas = datas; this.rowCount = rowCount; this.pageable = pageable; }}复制代码