在elasticsearch 2.x版本中,如果我们想指定查询返回的字段,可以使用fields字段设置,代码如下:
-
String index = xxx;
-
String type = xxx;
-
// 指定要返回的字段
-
String[] fields = new String[2];
-
fields[0] = "field1"; // 字段1名称
-
fields[1] = "filed2"; // 字段2名称
-
// 构造query
-
SearchRequestBuilder requestBuilder = client.prepareSearch(index);
-
requestBuilder .setFrom(0).setSize(100)
-
.setTimeout(TimeValue.timeValueMillis(300))
扫描二维码关注公众号,回复: 4206261 查看本文章 -
.setTypes(type)
-
.addFields(fields);
-
// bool 条件
-
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
-
TermQueryBuilder tqb = QueryBuilders.termQuery("field1", "val1");
-
boolQueryBuilder.must(tqb);
-
// set query
-
requestBuilder.setQuery(boolQueryBuilder);
-
// get response
-
SearchResponse response = requestBuilder.execute().actionGet();
-
// 遍历返回的字段
-
SearchHits searchHits = response.getHits();
-
for (SearchHit hit : searchHits) {
-
System.out.println(hit.getFields().get("filed1").getValue().toString());
-
}
但是在5.x中,setFileds函数已经不存在了,那在5.x中通过什么来指定返回的字段呢,答案是Source字段,通过setFetchSource函数来指定要返回的字段,可以指定单个filed或者一个filed数组,通过getSource来获取返回的字段值,其中setFetchSource有三个版本,说明如下:
1. setFetchSource(boolean fetch)
用于指定是否返回字段,默认为true,如果为false,则getSource返回null。
2. setFetchSource(String include, String exclude)
用于指定包含的一个字段和排除的一个字段,实际会返回include字段及其对应的值。
3. setFetchSource(String[] includes, String[] excludes)
用于指定包含的多个字段和排除的多个字段。
下面以具体代码来说明如何获取:
-
String index = xxx;
-
String type = xxx;
-
// 指定要返回的字段
-
String[] fields = new String[2];
-
fields[0] = "field1"; // 字段1名称
-
fields[1] = "filed2"; // 字段2名称
-
// 构造query
-
SearchRequestBuilder requestBuilder = client.prepareSearch(index);
-
requestBuilder .setFrom(0).setSize(100)
-
.setTimeout(TimeValue.timeValueMillis(300))
-
.setTypes(type)
-
// 指定返回的字段,排除字段设为null
-
.setFetchSource(fields, null);
-
// bool 条件
-
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
-
TermQueryBuilder tqb = QueryBuilders.termQuery("field1", "val1");
-
boolQueryBuilder.must(tqb);
-
// set query
-
requestBuilder.setQuery(boolQueryBuilder);
-
// get response
-
SearchResponse response = requestBuilder.execute().actionGet();
-
// 遍历返回的字段
-
SearchHits searchHits = response.getHits();
-
for (SearchHit hit : searchHits) {
-
// 注意这里和2.x不同的是使用getSource函数
-
System.out.println(hit.getSource().get("filed1"));
-
}