org.springframework.data.mongodb.core.MongoTemplate
MongoTemplate對MongoDB的CRUD操做
1. 查詢操做mongoTemplate.find (query, entityClass)
參數說明:
entityClass:實體class,也就是要把文檔轉換成對應的實體
query :
query查詢語句的實現方式有兩種
第一種實現方式
mongoTemplate.find (new Query(new Criteria("onumber").is("002")),entityClass)
第二種實現方式
Criteria是標準查詢的接口,能夠引用靜態的Criteria.where的把多個條件組合在一塊兒,
就能夠輕鬆地將多個方法標準和查詢鏈接起來,方便咱們操做查詢語句
mongoTemplate.find (new Query(Criteria.where("onumber").is("002")),entityClass)
即 : 查詢條件onumber="002"
多個條件組合查詢
例如:onumber="002" and cname="zcy"
Query query=new Query()
query.addCriteria(new Criteria("onumber").is("002"));
query.addCriteria(new Criteria("cname").is("zcy1"));
= mongoTemplate.find (query,entityClass);
public static void main(String[] args) {
Query query = new Query();
query.addCriteria(new Criteria("onumber").is("002"));
query.addCriteria(new Criteria("cname").is("zcy1"));
// Query: { "onumber" : "002" , "cname" : "zcy1"}, Fields: null, Sort: null
System.err.println(query.toString());
Query query2 = new Query(Criteria.where("onumber").is("002").and("cname").is("zcy"));
// Query: { "onumber" : "002" , "cname" : "zcy"}, Fields: null, Sort: null
System.out.println(query2.toString());
}
第二種實現方式
mongoTemplate.find (new Query(Criteria.where("onumber").is("002").and("cname").is("zcy")),entityClass)
源碼:
where:
public static Criteria where(String key) {
return new Criteria(key);
}
is:
public Criteria is(Object o) {spring
if (!isValue.equals(NOT_SET)) {
throw new InvalidMongoDbApiUsageException(
"Multiple 'is' values declared. You need to use 'and' with multiple criteria");
}mongodb
if (lastOperatorWasNot()) {
throw new InvalidMongoDbApiUsageException("Invalid query: 'not' can't be used with 'is' - use 'ne' instead.");
}app
this.isValue = o;
return this;
}
and:
public Criteria and(String key) {
return new Criteria(this.criteriaChain, key);
}
public <T> List<T> find(Query query, Class<T> entityClass) {
return find(query, entityClass, determineCollectionName(entityClass));
}
例如:onumber="002" or cname="zcy"ui
@RestController
@Api
@RequestMapping(value = "/v1.0")
public class DemoController {this
@PostMapping(value = "/query")
public Response query(@RequestParam(value = "name", required = false) String name,
@RequestParam(value = "age", required = false) String age) {.net
Response response = new Response();
try {
MLoggerUtils.info("{},{}", name, age);
Query query = new Query();
List<Criteria> list = new ArrayList<Criteria>();
Criteria criteria = new Criteria();
Criteria[] criterias = {};
if (StringUtils.isNotEmpty(name)) {
list.add(new Criteria("name").is(name));
}
if (StringUtils.isNotEmpty(name)) {
list.add(new Criteria("age").is(age));
}
if (CollectionUtils.isNotEmpty(list)) {
criteria.orOperator(list.toArray(criterias));
}接口
query.addCriteria(criteria);
MLoggerUtils.info("param{}", query.toString());
} catch (Exception e) {
// TODO: handle exception
}
return null;
}
public static void main(String[] args) {
Query query = new Query();
query.addCriteria(new Criteria("onumber").is("002"));
query.addCriteria(new Criteria("cname").is("zcy1"));
// Query: { "onumber" : "002" , "cname" : "zcy1"}, Fields: null, Sort:
// null
System.err.println(query.toString());
Query query2 = new Query(Criteria.where("onumber").is("002").and("cname").is("zcy"));
// Query: { "onumber" : "002" , "cname" : "zcy"}, Fields: null, Sort:
// null
System.out.println(query2.toString());ip
Query query3 = new Query(new Criteria().orOperator(Criteria.where("onumber").is("002"), Criteria.where("cname").is("zcy")));
System.out.println(query3.toString());
// Query: { "$or" : [ { "onumber" : "002"} , { "cname" : "zcy"}]},
// Fields: null, Sort: null
}文檔
}
get