Elasticsearch 日期查询详解，Elasticsearch Date 查询Java API

Elasticsearch 日期存储 Java API

存储的时候，我采用的方式是直接存储Date 类型。上部分代码。

1. //Map集合
2. for (Map<String,Object> source : jsonArray) {
3. //直接
4. IndexRequestBuilder lrb = ESTools.client.prepareIndex(index, type,id)
5. //直接set
6. .setSource(source);
7. //TTL
8. if(null != timer && timer.length > 0){
9. lrb.setTTL(timer[0]);
10. }
11. bulkRequest.add(lrb);
12. }

若是有日期查询，大量的日期查询，建议想清楚，是以String ，Date ，仍是Long 类型的毫秒值，怎么存储怎么查询。

Elasticsearch 日期查询 Java API

先来一个完整的业务代码。里面包含时间查询，其实业务很简单，我就须要当天的数据。

1. /**
2. * 浏览记录,分页查询
3. * @param key 用户key
4. * @param pageSize size
5. * @param pageNo no
6. * @param isToday 是否只返回当天数据
7. * @return 分页对象
8. */
9. public static Pagination<HistoryBo> findByHistoryPage(String key, Integer pageSize, Integer pageNo,boolean isToday) {
10. Pagination<HistoryBo> page = new Pagination<HistoryBo>();
11. pageNo = null==pageNo?1:pageNo;
12. page.setPageNo(pageNo);
13. page.setPageSize(pageSize);
14.  
15.  
16. Client client = ESTools.client;
17. SearchRequestBuilder srb = client.prepareSearch(BaseMapping.HISTORY_INDEX);
18. //根据用户key查询
19. srb.setQuery(QueryBuilders.termQuery("key",key) );
20.  
21. /*******************************|日期查询代码 start|***********************************/
22. //是否只查询当天
23. if(isToday){
24. //取到当天凌晨时间
25. Calendar cal = Calendar.getInstance();
26. cal.set(Calendar.HOUR_OF_DAY,0);
27. cal.set(Calendar.MINUTE, 0);
28. cal.set(Calendar.SECOND, 0);
29. cal.add(Calendar.DATE,0);
30. //查询今天的的数据,查询createDate 字段，大于当天0点的时间
31. srb.setQuery(QueryBuilders.rangeQuery("createDate").gt(cal.getTime()));
32. }
33. /*******************************|日期查询代码 end|***********************************/
34.  
35.  
36. /**设置返回version，默认是false**/
37. srb.setVersion(Boolean.TRUE);
38. srb.addSort("createDate", SortOrder.DESC);
39. srb.setFrom((pageNo - 1) * pageSize).setSize(pageSize);
40. //srb.setExplain(Boolean.TRUE)
41. //get() == execute().actionGet(); 新版本把execute().actionGet() 封装成get().
42. SearchResponse response = srb.get();
43. SearchHits hits = response.getHits();
44. //total
45. int total = (int)hits.getTotalHits();
46. page.setTotalCount(total);
47.  
48. List<HistoryBo> list = new ArrayList<HistoryBo>(total);
49. for (SearchHit searchHit : hits) {
50. Map<String, Object> source = searchHit.getSource();
51. String id = searchHit.getId();
52. //获取version，做为count返回
53. long v = searchHit.getVersion();
54. //先建立，防止catch后 null.toString()异常。
55.  
56. Gson gson = new Gson();
57. String json = "";
58. try {
59. json = gson.toJson(source);
60. HistoryBo entity = gson.fromJson(gson.toJson(source), HistoryBo.class);
61. entity.setCount(v);
62. entity.setKey(id);//把ID取出来，给key赋值，方便删除操做
63. list.add(entity);
64. } catch (Exception e) {
65. LoggerUtils.fmtError(SelectManager.class, e, "转换为<HistoryBo>失败，Data[%s]", json);
66. continue;
67. }
68. }
69. page.setList(list);
70. return page;
71.  
72. }

Elasticsearch 时间查询Java API说明

按Date类型查询

查询大于一个给定的时间。

1. //查询大于一个给定的时间
2. QueryBuilders.rangeQuery("date").gt(date);

查询一个区间时间

1. //查询区间时间
2. QueryBuilders.rangeQuery("date").lt(beginDate).gt(endDate);

查询小于给定的时间

1. //查询小于给定时间的数据
2. QueryBuilders.rangeQuery("date").lt(beginDate);

Date 以格式化字符串方式查询。

查询小于给定时间的数据

1. //查询小于给定时间的数据
2. QueryBuilders.rangeQuery("date").format("yyyyMMdd").lt("20170505");

查询区间时间

1. //查询区间时间
2. srb.setQuery(QueryBuilders.rangeQuery("date").format("yyyyMMdd").gt("20170505").lt("20170530"));

查询等于给定时间

1. //查询等于给定时间
2. srb.setQuery(QueryBuilders.rangeQuery("date").format("yyyyMMdd").gte("20170505"));

小插曲：这里我建议格式化话的时候，中间别带“-” ，只是建议。由于我测试把“20170505” 写成 int 类型的 20170505  查询是OK 的。

有问题加群继续沟通。另外上次记得深刻了一次Elasticsearch date 类型存储的博客。

另外存储Date，请认准java.util.Date  ， 切勿用 java.sql.Date 

有时间能够看看：http://www.sojson.com/blog/149.html