java 中 mongodb的各种操作模糊查询精确查询等等

傷城~ 2022-06-07 10:54 205阅读 0赞

from:http://blog.csdn.net/qq\_27093465/article/details/51578369

本意是想查查mongo数据库的int类型的like怎么查，但是好像没 解决这个问题。

精确查询；模糊查询；分页查询，每页多少：按某个字段排序(或升或降)：查询数量：大于，小于，等于；且，或，某个字段不为空，某个字段不存在，查询在某个范围内，删除等等查询。

**一. 常用查询:**

1. 查询一条数据:(多用于保存时判断db中是否已有当前数据,这里 **is**  精确匹配,模糊匹配 使用**regex**...)

**\[javascript\]**  [view plain][]   [copy][view plain]

1.  **public** PageUrl getByUrl(String url) \{  
2.          **return** findOne(**new** Query(Criteria.where("url").is(url)),PageUrl.**class**);  
3.      \}

2. 查询多条数据:linkUrl.id 属于**分级查询**

**\[javascript\]**  [view plain][]   [copy][view plain]

1.  **public** List<PageUrl> getPageUrlsByUrl(**int** begin, **int** end,String linkUrlid) \{          
2.          Query query = **new** Query();  
3.          query.addCriteria(Criteria.where("linkUrl.id").is(linkUrlid));  
4.          **return** find(query.limit(end - begin).skip(begin), PageUrl.**class**);          
5.      \}

3.**模糊查询**:\-----关键字---**regex**

**\[javascript\]**  [view plain][]   [copy][view plain]

1.  **public** **long** getProcessLandLogsCount(List<Condition> conditions)  
2.      \{  
3.          Query query = **new** Query();  
4.          **if** (conditions != **null** && conditions.size() > 0) \{  
5.              **for** (Condition condition : conditions) \{  
6.                  query.addCriteria(Criteria.where(condition.getKey()).regex(".\*?\\\\" +condition.getValue().toString()+ ".\*"));  
7.              \}  
8.          \}  
9.          **return** count(query, ProcessLandLog.**class**);  
10.     \}

最下面，我在代码亲自实践过的模糊查询，只支持字段属性是字符串的查询，你要是查字段属性是int的模糊查询，还真没辙。

4.**gte:** 大于等于,**lte**小于等于...注意查询的时候各个字段的类型要和mongodb中数据类型一致

**\[javascript\]**  [view plain][]   [copy][view plain]

1.  **public** List<ProcessLandLog> getProcessLandLogs(**int** begin,**int** end,List<Condition> conditions,String orderField,Direction direction)  
2.      \{  
3.          Query query = **new** Query();  
4.          **if** (conditions != **null** && conditions.size() > 0) \{  
5.              **for** (Condition condition : conditions) \{  
6.                  **if**(condition.getKey().equals("time"))\{  
7.                      query.addCriteria(Criteria.where("time").gte(condition.getValue())); //gte: 大于等于  
8.                  \}**else** **if**(condition.getKey().equals("insertTime"))\{  
9.                      query.addCriteria(Criteria.where("insertTime").gte(condition.getValue()));  
10.                 \}**else**\{  
11.                     query.addCriteria(Criteria.where(condition.getKey()).is(condition.getValue()));  
12.                 \}  
13.             \}  
14.         \}  
15.         **return** find(query.limit(end - begin).skip(begin).**with**(**new** Sort(**new** Sort.Order(direction, orderField))), ProcessLandLog.**class**);  
16.     \}  
17.   
18. **public** List<DpsLand> getDpsLandsByTime(**int** begin, **int** end, Date beginDate,Date endDate) \{  
19.   **return** find(**new** Query(Criteria.where("updateTime").gte(beginDate).lte(endDate)).limit(end - begin).skip(begin),  
20.     DpsLand.**class**);  
21.  \}

查询**字段不存在**的数据 -----关键字---**not**

**\[javascript\]**  [view plain][]   [copy][view plain]

1.  **public** List<GoodsDetail> getGoodsDetails2(**int** begin, **int** end) \{  
2.          Query query = **new** Query();  
3.          query.addCriteria(Criteria.where("goodsSummary").not());  
4.          **return** find(query.limit(end - begin).skip(begin),GoodsDetail.**class**);  
5.      \}

查询**字段不为空**的数据     -----关键字---**ne**

**\[java\]**  [view plain][]   [copy][view plain]

1.  Criteria.where("key1").ne("").ne(**null**)

查询或语句：**a || b**     ----- 关键字---**orOperator**

**\[java\]**  [view plain][]   [copy][view plain]

1.  Criteria criteria = **new** Criteria();  
2.  criteria.orOperator(Criteria.where("key1").is("0"),Criteria.where("key1").is(**null**));

查询且语句： a && b      ----- 关键字--- and

**\[java\]**  [view plain][]   [copy][view plain]

1.  Criteria criteria = **new** Criteria();  
2.  criteria.and("key1").is(**false**);  
3.  criteria.and("key2").is(type);  
4.  Query query = **new** Query(criteria);  
5.  **long** totalCount = **this**.mongoTemplate.count(query, Xxx.**class**);

查询一个**属性的子属性**，例如：查下面数据的key2.keyA的语句

**\[java\]**  [view plain][]   [copy][view plain]

1.     var s = \{  
2.         key1: value1,  
3.         key2: \{  
4.             keyA: valueA,  
5.             keyB: valueB  
6.         \}  
7.     \};  
8.    
9.  @Query("\{'key2.keyA':?0\}")  
10. List<Asset> findAllBykeyA(String keyA);

5. 查询数量:----- 关键字---**count**

**\[javascript\]**  [view plain][]   [copy][view plain]

1.  **public** **long** getPageInfosCount(List<Condition> conditions) \{  
2.          Query query = **new** Query();  
3.          **if** (conditions != **null** && conditions.size() > 0) \{  
4.              **for** (Condition condition : conditions) \{  
5.                  query.addCriteria(Criteria.where(condition.getKey()).is(condition.getValue()));  
6.              \}  
7.          \}  
8.          **return** count(query, PageInfo.**class**);  
9.      \}

查找包含在某个集合范围：\----- 关键字---**in**

**\[java\]**  [view plain][]   [copy][view plain]

1.  Criteria criteria = **new** Criteria();  
2.  Object \[\] o = **new** Object\[\]\{ 0, 1, 2\}; //包含所有  
3.  criteria.and("type").in(o);  
4.  Query query = **new** Query(criteria);  
5.  query.with(**new** Sort(**new** Sort.Order(Direction.ASC, "type"))).with(**new** Sort(**new** Sort.Order(Direction.ASC, "title")));  
6.  List<WidgetMonitor> list = **this**.mongoTemplate.find(query, WidgetMonitor.**class**);

6. 更新一条数据的一个字段:

**\[javascript\]**  [view plain][]   [copy][view plain]

1.  **public** WriteResult updateTime(PageUrl pageUrl) \{  
2.          String id = pageUrl.getId();  
3.          **return** updateFirst(**new** Query(Criteria.where("id").is(id)),Update.update("updateTime", pageUrl.getUpdateTime()), PageUrl.**class**);  
4.      \}

7. 更新一条数据的多个字段:

**\[javascript\]**  [view plain][]   [copy][view plain]

1.  //调用更新  
2.  **private** **void** updateProcessLandLog(ProcessLandLog processLandLog,  
3.              **int** crawlResult) \{  
4.          List<String> fields = **new** ArrayList<String>();  
5.          List<Object> values = **new** ArrayList<Object>();  
6.          fields.add("state");  
7.          fields.add("result");  
8.          fields.add("time");  
9.          values.add("1");  
10.         values.add(crawlResult);  
11.         values.add(Calendar.getInstance().getTime());  
12.         processLandLogReposity.updateProcessLandLog(processLandLog, fields,  
13.                 values);  
14.     \}  
15. //更新  
16. **public** **void** updateProcessLandLog(ProcessLandLog land, List<String> fields,List<Object> values) \{  
17.         Update update = **new** Update();  
18.         **int** size = fields.size();  
19.         **for**(**int** i = 0 ; i < size; i++)\{  
20.             String field = fields.get(i);  
21.             Object value = values.get(i);  
22.             update.set(field, value);  
23.         \}  
24.         updateFirst(**new** Query(Criteria.where("id").is(land.getId())), update,ProcessLandLog.**class**);  
25.     \}

8. 删除数据:

**\[javascript\]**  [view plain][]   [copy][view plain]

1.  **public** **void** deleteObject(Class<T> clazz,String id) \{  
2.          remove(**new** Query(Criteria.where("id").is(id)),clazz);  
3.      \}

9.保存数据:

**\[javascript\]**  [view plain][]   [copy][view plain]

1.  //插入一条数据  
2.  **public** **void** saveObject(Object obj) \{  
3.          insert(obj);  
4.      \}  
5.    
6.  //插入多条数据      
7.  **public** **void** saveObjects(List<T> objects) \{  
8.          **for**(T t:objects)\{  
9.              insert(t);  
10.         \}  
11.     \}

**我自己使用的例子：**

**下面例子涉及到：  
精确查询：is；  
模糊查询：regex；  
分页查询，每页多少：skip，limit  
按某个字段排序(或升或降)：new Sort(new Sort.Order(Sort.Direction.ASC, "port"))  
查询数量：count**

**\[java\]**  [view plain][]   [copy][view plain]

1.  **public** Map<String, Object> getAppPortDetailByPage(**int** pageNo, **int** pageSize, String order, String sortBy, String appPortType, String appPortSeacherName) \{  
2.      Criteria criteria = **new** Criteria();  
3.      **if** (!appPortType.equals("")) \{  
4.          **if** (!appPortType.equals("all")) \{  
5.              //DB表里的字段----appmanageType  
6.              //下同 port protocol 也是DB表的字段  
7.              criteria.and("appmanageType").is(appPortType);  
8.          \}  
9.      \}  
10.     **if** (!appPortSeacherName.equals("")) \{  
11.         **try** \{  
12.             criteria.orOperator(Criteria.where("port").is(Integer.parseInt(appPortSeacherName)),  
13.                     Criteria.where("protocol").regex(".\*?" + appPortSeacherName + ".\*"));  
14.         \}**catch** (Exception e)\{  
15.             criteria.orOperator(Criteria.where("protocol").regex(".\*?" + appPortSeacherName + ".\*"));  
16.         \}  
17.     \}  
18.     Map<String, Object> result = Maps.newHashMap();  
19.     Query query = **new** Query(criteria);  
20.     query.skip((pageNo - 1) \* pageSize);  
21.     query.limit(pageSize);  
22.     **if**(order != **null** && sortBy != **null**)\{  
23.         query.with(**new** Sort(**new** Sort.Order(order.equals("asc") ? Sort.Direction.ASC : Sort.Direction.DESC, sortBy)));  
24.     \}**else** \{  
25.         query.with(**new** Sort(**new** Sort.Order(Sort.Direction.ASC, "port")));  
26.     \}  
27.     List<Appportmanage> list = **this**.mongoTemplate.find(query, Appportmanage.**class**);  
28.     **long** count = **this**.mongoTemplate.count(query, Appportmanage.**class**);  
29.     result.put("datas", list);  
30.     result.put("size", count);  
31.     **return** result;  
32. \}

mongo数据库里面像搜索数据类型为int的字段，

然后想使用like语句来着，但是没有实现，

因为我的port端口存的事int属性，

但是在列表页面，要支持字段搜索的话，然后我的int类型的端口字段，就不支持搜索了，

然后就考虑，既然是端口，那就是一个固定的，唯一的，

为什么要支持like语句呢？

你搜索端口号是1的就搜出来的是1的端口号就对了，而不是1，11，21，，，等等都个搜索出来，

所以，

对去其他的字符串 类型的字段，你使用like语句搜索，

我是没意见的，

要是非得 实现int类型的like搜索，

我 也不知道啊。