1. 程式人生 > >ES如何指定返回的欄位field

ES如何指定返回的欄位field

在elasticsearch 2.x版本中,如果我們想指定查詢返回的欄位,可以使用fields欄位設定,程式碼如下:

 
  1. String index = xxx;

  2. String type = xxx;

  3. // 指定要返回的欄位

  4. String[] fields = new String[2];

  5. fields[0] = "field1"; // 欄位1名稱

  6. fields[1] = "filed2"; // 欄位2名稱

  7. // 構造query

  8. SearchRequestBuilder requestBuilder = client.prepareSearch(index);

  9. requestBuilder .setFrom(0).setSize(100)

  10. .setTimeout(TimeValue.timeValueMillis(300))

  11. .setTypes(type)

  12. .addFields(fields);

  13. // bool 條件

  14. BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();

  15. TermQueryBuilder tqb = QueryBuilders.termQuery("field1", "val1");

  16. boolQueryBuilder.must(tqb);

  17. // set query

  18. requestBuilder.setQuery(boolQueryBuilder);

  19. // get response

  20. SearchResponse response = requestBuilder.execute().actionGet();

  21. // 遍歷返回的欄位

  22. SearchHits searchHits = response.getHits();

  23. for (SearchHit hit : searchHits) {

  24. System.out.println(hit.getFields().get("filed1").getValue().toString());

  25. }

但是在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) 
用於指定包含的多個欄位和排除的多個欄位。 
下面以具體程式碼來說明如何獲取:

 
  1. String index = xxx;

  2. String type = xxx;

  3. // 指定要返回的欄位

  4. String[] fields = new String[2];

  5. fields[0] = "field1"; // 欄位1名稱

  6. fields[1] = "filed2"; // 欄位2名稱

  7. // 構造query

  8. SearchRequestBuilder requestBuilder = client.prepareSearch(index);

  9. requestBuilder .setFrom(0).setSize(100)

  10. .setTimeout(TimeValue.timeValueMillis(300))

  11. .setTypes(type)

  12. // 指定返回的欄位,排除欄位設為null

  13. .setFetchSource(fields, null);

  14. // bool 條件

  15. BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();

  16. TermQueryBuilder tqb = QueryBuilders.termQuery("field1", "val1");

  17. boolQueryBuilder.must(tqb);

  18. // set query

  19. requestBuilder.setQuery(boolQueryBuilder);

  20. // get response

  21. SearchResponse response = requestBuilder.execute().actionGet();

  22. // 遍歷返回的欄位

  23. SearchHits searchHits = response.getHits();

  24. for (SearchHit hit : searchHits) {

  25. // 注意這裡和2.x不同的是使用getSource函式

  26. System.out.println(hit.getSource().get("filed1"));

  27. }