ES如何指定返回的欄位field
在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))
-
.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"));
-
}