對索引庫作: 增、刪、改

與之對應的DSL語句

Insert

創建索引庫 (沒有建立映射)

創建指定名稱的索引庫

@Test public void createIndexTest() throws Exception {// 若是對索引庫的增刪改 都需要創建indicesClient對象， 這個就是一個操作數據庫的客戶端對象IndicesClient indicesObject = highLevelClient.indices();// 新建索引庫創建請求: 創建一個索引庫, 并指定名稱CreateIndexRequest createIndexRequest = new CreateIndexRequest("hotel");// 發出索引庫創建請求, 并接收索引庫創建請求的響應CreateIndexResponse createIndexResponse = indicesObject.create(createIndexRequest, RequestOptions.DEFAULT);// 是否創建成功log.info("\n索引庫是否創建成功: {}", createIndexResponse.isAcknowledged());log.info("\n響應結果: {}", createIndexResponse); }

創建索引庫, 并創建映射

在索引庫存在時, 創建映射會失敗, 原因: 索引庫已存在

// 給指定索引庫創建映射樹 @Test public void createMappingTest() throws Exception {// 獲取索引庫增刪改操作對象IndicesClient indicesObject = highLevelClient.indices();// 新建索引庫創建請求: 創建一個指定名稱的索引庫, 并創建映射樹CreateIndexRequest createIndexRequest = new CreateIndexRequest("hotel");// 新建映射樹createIndexRequest.mapping("{\n" +" \"properties\": {\n" +" \"id\": {\n" +" \"type\": \"keyword\"\n" +" },\n" +" \"name\": {\n" +" \"type\": \"text\",\n" +" \"analyzer\": \"ik_smart\",\n" +" \"copy_to\": \"all\"\n" +" },\n" +" \"address\": {\n" +" \"type\": \"text\",\n" +" \"analyzer\": \"ik_smart\"\n" +" },\n" +" \"price\": {\n" +" \"type\": \"integer\"\n" +" },\n" +" \"score\": {\n" +" \"type\": \"integer\"\n" +" },\n" +" \"brand\": {\n" +" \"type\": \"text\",\n" +" \"analyzer\": \"ik_smart\",\n" +" \"copy_to\": \"all\"\n" +" },\n" +" \"city\": {\n" +" \"type\": \"keyword\"\n" +" },\n" +" \"starName\": {\n" +" \"type\": \"keyword\"\n" +" },\n" +" \"business\": {\n" +" \"type\": \"keyword\",\n" +" \"copy_to\": \"all\"\n" +" },\n" +" \"location\": {\n" +" \"type\": \"geo_point\"\n" +" },\n" +" \"pic\": {\n" +" \"type\": \"keyword\",\n" +" \"index\": false\n" +" }, \n" +" \"isAD\": {\n" +" \"type\": \"boolean\"\n" +" },\n" +" \"all\": {\n" +" \"type\": \"text\",\n" +" \"analyzer\": \"ik_smart\"\n" +" }\n" +" }\n" +" }", XContentType.JSON);// 發送創建帶有映射樹的索引庫請求, 并接收創建索引庫請求的響應CreateIndexResponse createIndexResponse = indicesObject.create(createIndexRequest, RequestOptions.DEFAULT);// 是否創建成功log.info("\n索引庫是否創建成功: {}", createIndexResponse.isAcknowledged());log.info("\n響應結果: {}", createIndexResponse); }

Delete

刪除指定的索引庫

刪除指定索引庫

@Test public void deleteIndexTest() throws Exception {// 獲取刪除索引庫對象IndicesClient indicesObject = highLevelClient.indices();// 新建刪除索引庫請求: 刪除一個指定名稱的索引庫DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest("hotel");// 發出刪除索引庫請求, 并接受刪除索引庫請求的響應AcknowledgedResponse deleteIndexResponse = indicesObject.delete(deleteIndexRequest, RequestOptions.DEFAULT);// 判斷是否刪除成功log.info("\n Hotel索引庫是否刪除成功: {}", deleteIndexResponse.isAcknowledged());log.info("\n響應結果: {}", deleteIndexResponse); }

對文檔作: 增、刪、改、查

Insert / Update (ES處理修改時, 是作覆蓋式修改)

批量添加 (方案一)

導入數據庫中的數據到ES中 (批量導入)

public void createIndexWithMappingWithImportData() throws Exception {// 獲取索引庫操作對象IndicesClient indicesObject = highLevelClient.indices();// 創建索引庫CreateIndexRequest createIndexRequest = new CreateIndexRequest("hotel");// 創建映射createIndexRequest.mapping("{\n" +" \"properties\": {\n" +" \"id\": {\n" +" \"type\": \"keyword\"\n" +" },\n" +" \"name\": {\n" +" \"type\": \"text\",\n" +" \"analyzer\": \"ik_max_word\",\n" +" \"copy_to\": \"all\"\n" +" },\n" +" \"address\": {\n" +" \"type\": \"text\",\n" +" \"analyzer\": \"ik_max_word\"\n" +" },\n" +" \"price\": {\n" +" \"type\": \"integer\"\n" +" },\n" +" \"score\": {\n" +" \"type\": \"integer\"\n" +" },\n" +" \"brand\": {\n" +" \"type\": \"text\",\n" +" \"analyzer\": \"ik_max_word\",\n" +" \"copy_to\": \"all\"\n" +" },\n" +" \"city\": {\n" +" \"type\": \"keyword\"\n" +" },\n" +" \"starName\": {\n" +" \"type\": \"keyword\"\n" +" },\n" +" \"business\": {\n" +" \"type\": \"keyword\",\n" +" \"copy_to\": \"all\"\n" +" },\n" +" \"location\": {\n" +" \"type\": \"geo_point\"\n" +" },\n" +" \"pic\": {\n" +" \"type\": \"keyword\",\n" +" \"index\": false\n" +" }, \n" +" \"isAD\": {\n" +" \"type\": \"boolean\"\n" +" },\n" +" \"all\": {\n" +" \"type\": \"text\",\n" +" \"analyzer\": \"ik_max_word\"\n" +" }\n" +" }\n" +" }",XContentType.JSON);// 發送索引庫創建請求CreateIndexResponse createIndexResponse = indicesObject.create(createIndexRequest, RequestOptions.DEFAULT);log.info("\n索引庫創建結果: {}", createIndexResponse.isAcknowledged());log.info("\n響應結果: {}", createIndexResponse);// 查詢數據庫List<Hotel> hotels = hotelMapper.selectList(null);// Copy 到 HotelDochotels.forEach(hotel -> {try {// 將Hotel Copy To HotelDoc 中HotelDoc hotelDoc = new HotelDoc(hotel);// 創建文檔IndexRequest hotelIndex = new IndexRequest("hotel").id(hotel.getId().toString());// 將HotelDoc轉換為JsonString hotelDocToJson = objectMapper.writeValueAsString(hotelDoc);// 填充內容hotelIndex.source(hotelDocToJson, XContentType.JSON);// 發送文檔創建請求IndexResponse indexResponse = highLevelClient.index(hotelIndex, RequestOptions.DEFAULT);// 獲取創建后的文檔idlog.info("ES文檔, id: {}",indexResponse.getId());} catch (Exception e) {throw new RuntimeException(e);}});}

批量添加 (方案二)

批量添加 (方案二)

@Test public void BulkSearchDocument() throws Exception {// 查詢數據庫中的所有數據List<Hotel> hotels = hotelMapper.selectList(null);// 獲取批量添加對象BulkRequest bulkRequest = new BulkRequest();// 遍歷所有數據hotels.forEach(hotel -> {try {// 查詢所有數據HotelDoc hotelDoc = new HotelDoc(hotel);// 將查詢的結果轉換為JsonString hotelDocToJson = objectMapper.writeValueAsString(hotelDoc);// 設定指定索引庫 及 文檔idIndexRequest indexRequest = new IndexRequest("hotel").id(hotel.getId().toString());// 將Json添加到IndexRequest請求中indexRequest.source(hotelDocToJson, XContentType.JSON);// 添加請求bulkRequest.add(indexRequest);}catch (Exception e) {throw new RuntimeException(e.getMessage());}});// 發送批量添加請求BulkResponse bulkResponse = highLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);log.info("批量添加結果: {}", bulkResponse.status()); }

Query

查詢指定文檔id

指定文檔id, 查詢文檔

public void queryDocument() throws Exception {// 指定索引庫民初, 獲取查詢文檔的請求對象GetRequest hotel = new GetRequest("hotel").id("36934");// 發送查詢請求GetResponse getResponse = highLevelClient.get(hotel, RequestOptions.DEFAULT);// 獲取查詢結果String sourceAsString = getResponse.getSourceAsString();// 將Json轉換為HotelDoc實體類HotelDoc hotelDoc = objectMapper.readValue(sourceAsString, HotelDoc.class);log.info("hotelDoc: {}", hotelDoc); }

Delete

刪除指定文檔id

刪除指定文檔id

public void deleteDocument() throws Exception {// 獲取指定索引庫, 且指定文檔id的刪除文檔對象var deleteRequest = new DeleteRequest("hotel").id("36934");// 發送刪除文檔請求DeleteResponse deleteResponse = highLevelClient.delete(deleteRequest, RequestOptions.DEFAULT);log.info("deleteResponse: {}", deleteResponse.getId()); }

條件查詢

查詢所有 (沒有特定條件)

public void queryAllDocument() throws Exception {// 獲取查詢對象SearchRequest searchRequest = new SearchRequest("hotel");// 構建查詢條件: 查詢所有SearchSourceBuilder matchAllQuery = searchRequest.source().query(QueryBuilders.matchAllQuery());// 設置展示的條目searchRequest.source().size(1000);// 發送查詢請求SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 處理查詢結果ArrayList<HotelDoc> hotelDocs = new ArrayList<>();// 獲取查詢結果集SearchHits hits = searchResponse.getHits();// 遍歷結果集for (SearchHit hit : hits) {// 獲取文檔內容JsonString searchResult = hit.getSourceAsString();// 將Json轉換為JavaBeanHotelDoc hotelDoc = objectMapper.readValue(searchResult, HotelDoc.class);// 添加到集合中hotelDocs.add(hotelDoc);}// 全文查詢狀態log.info("\n查詢全部狀態: {}", searchResponse.status());// 輸出所有查詢結果hotelDocs.forEach(hotelDoc -> log.info("\n查詢全部結果: {}", hotelDoc)); }

單字段查詢

public void queryOneDocument() throws Exception {// 獲取查詢對象SearchRequest searchRequest = new SearchRequest("hotel");// 構建查詢條件: 單字段查詢searchRequest.source().query(QueryBuilders.matchQuery("all", "如家"));// 設置展示條目searchRequest.source().size(1000);// 發送查詢請求SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 收集結果ArrayList<HotelDoc> hotelDocs = new ArrayList<>();// 處理查詢結果SearchHits hits = searchResponse.getHits();// 遍歷結果集for (SearchHit hit : hits) {// 獲取查詢的結果String searchResult = hit.getSourceAsString();// 將結果(Json串) 轉換為 JavaBeanHotelDoc hotelDoc = objectMapper.readValue(searchResult, HotelDoc.class);hotelDocs.add(hotelDoc);}// 單字段查詢狀態log.info("\n單字段查詢狀態: {}", searchResponse.status());// 輸出所有查詢結果hotelDocs.forEach(hotelDoc -> log.info("\n單字段查詢結果: {}", hotelDoc)); }

多字段查詢

public void queryManyDocuments() throws Exception {// 獲取查詢請求對象SearchRequest searchRequest = new SearchRequest("hotel");// 構建查詢條件: 多字段查詢searchRequest.source().query(QueryBuilders.multiMatchQuery("如家", "name", "brand"));// 設置展示條目searchRequest.source().size(1000);// 發送查詢請求SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 收集結果ArrayList<HotelDoc> hotelDocs = new ArrayList<>();// 處理查詢結果SearchHits hits = searchResponse.getHits();// 遍歷結果集for (SearchHit hit : hits) {// 獲取結果String searchResult = hit.getSourceAsString();// 將查詢結果轉換為JavaBeanHotelDoc hotelDoc = objectMapper.readValue(searchResult, HotelDoc.class);hotelDocs.add(hotelDoc);}// 多字段查詢狀態log.info("\n多字段查詢狀態: {}", searchResponse.status());// 輸出所有查詢結果hotelDocs.forEach(hotelDoc -> log.info("\n多字段查詢結果: {}", hotelDoc)); }

精準查詢 (不會對查詢條件分詞)

Term (精準值查詢)

@Test public void termSearch() throws Exception {// 獲取查詢對象SearchRequest searchRequest = new SearchRequest("hotel");// 構建查詢條件TermQueryBuilder queryBuilder = QueryBuilders.termQuery("name", "如家");searchRequest.source().query(queryBuilder);// 設置頁面大小searchRequest.source().size(1000);// 發送查詢請求SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 收集查詢結果ArrayList<HotelDoc> hotelDocs = new ArrayList<>();// 處理查詢結果SearchHits hits = searchResponse.getHits();// 遍歷結果集for (SearchHit hit : hits) {// 獲取查詢結果String searchResult = hit.getSourceAsString();// Json轉換為JavaBeanHotelDoc hotelDoc = objectMapper.readValue(searchResult, HotelDoc.class);hotelDocs.add(hotelDoc);}// 精確查詢狀態log.info("\n精確查詢狀態: {}", searchResponse.status());// 輸出所有查詢結果hotelDocs.forEach(hotelDoc -> log.info("\n精確查詢結果: {}", hotelDoc)); }

Range (范圍查詢)

@Test public void rangeSearch() throws Exception {// 獲取查詢對象SearchRequest searchRequest = new SearchRequest("hotel");// 構建查詢條件: gte: 大于等于, lte: 小于等于searchRequest.source().query(QueryBuilders.rangeQuery("price").gte(99).lte(199));searchRequest.source().size(1000);// 發送查詢請求SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 收集查詢結果ArrayList<HotelDoc> hotelDocs = new ArrayList<>();// 處理查詢結果SearchHits hits = searchResponse.getHits();// 遍歷結果集for (SearchHit hit : hits) {// 獲取查詢結果String searchResult = hit.getSourceAsString();// Json轉換為JavaBeanHotelDoc hotelDoc = objectMapper.readValue(searchResult, HotelDoc.class);hotelDocs.add(hotelDoc);}// 范圍查詢狀態log.info("\n范圍查詢狀態: {}", searchResponse.status());// 輸出所有查詢結果hotelDocs.forEach(hotelDoc -> log.info("\n范圍查詢結果: {}", hotelDoc)); }

地理位置查詢

圓形

public void geoDistanceSearch() throws Exception {// 獲取查詢對象SearchRequest searchRequest = new SearchRequest("hotel");// 構建查詢條件searchRequest.source().query(QueryBuilders.geoDistanceQuery("location").point(new GeoPoint(31.21, 121.5)).distance("15km")).size(1000);// 發送查詢條件SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 收集查詢結果ArrayList<HotelDoc> hotelDocs = new ArrayList<>();// 處理查詢結果SearchHits hits = searchResponse.getHits();// 遍歷結果集for (SearchHit hit : hits) {// 獲取查詢結果String searchResult = hit.getSourceAsString();// Json轉換JavaBeanHotelDoc hotelDoc = objectMapper.readValue(searchResult, HotelDoc.class);// 添加到集合hotelDocs.add(hotelDoc);}// 地理坐標查詢狀態log.info("\n地理坐標查詢狀態: {}", searchResponse.status());// 輸出所有查詢結果hotelDocs.forEach(hotelDoc -> log.info("\n地理坐標查詢結果: {}", hotelDoc)); }

矩形

public void geoBoundingBoxSearch() throws Exception {// 獲取查詢對象SearchRequest searchRequest = new SearchRequest("hotel");// 構建查詢條件searchRequest.source().query(QueryBuilders.geoBoundingBoxQuery("location").setCorners(new GeoPoint(31.1, 121.5),new GeoPoint(30.9, 121.7))).size(1000);// 發送查詢請求SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 接收結果ArrayList<HotelDoc> hotelDocs = new ArrayList<>();// 處理查詢結果SearchHits hits = searchResponse.getHits();// 遍歷結果集for (SearchHit hit : hits) {// 獲取查詢結果String searchResult = hit.getSourceAsString();// Json轉換為JavaBeanHotelDoc hotelDoc = objectMapper.readValue(searchResult, HotelDoc.class);// 添加到集合hotelDocs.add(hotelDoc);}// 地理坐標查詢狀態log.info("\n地理坐標查詢狀態: {}", searchResponse.status());// 輸出所有查詢結果hotelDocs.forEach(hotelDoc -> log.info("\n地理坐標查詢結果: {}", hotelDoc)); }

組合條件查詢

查詢全國的酒店名稱不為七天的上海的所有酒店, 價格范圍大于等于99, 小于等于199, 而且查詢的地址位置是31,21, 121.5, 范圍半徑20km

@Test public void boolSearch() throws Exception {// 獲取查詢對象SearchRequest searchRequest = new SearchRequest("hotel");// 構建查詢條件searchRequest.source().query(QueryBuilders.boolQuery().must(QueryBuilders.rangeQuery("price").gte(99).lte(199)).mustNot(QueryBuilders.termQuery("name", "七天")).filter(QueryBuilders.geoDistanceQuery("location").point(31.21, 121.5).distance("20km")).should(QueryBuilders.termQuery("city", "上海"))).size(1000);// 發送查詢請求SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 接收查詢結果ArrayList<HotelDoc> hotelDocs = new ArrayList<>();// 處理查詢結果for (SearchHit hit : searchResponse.getHits()) {// 獲取查詢結果String searchResult = hit.getSourceAsString();// Json 轉換為 JavaBeanHotelDoc hotelDoc = objectMapper.readValue(searchResult, HotelDoc.class);// 添加查詢結果hotelDocs.add(hotelDoc);}// 組合條件查詢狀態log.info("\n組合條件查詢狀態: {}", searchResponse.status());// 輸出所有查詢結果hotelDocs.forEach(hotelDoc -> log.info("\n組合條件查詢結果: {}", hotelDoc)); }

算分查詢

查詢如家酒店， 對于深圳的如家進行+10分

public void addScoreSearch() throws Exception {// 獲取查詢對象SearchRequest searchRequest = new SearchRequest("hotel");// 構建查詢條件searchRequest.source().query(QueryBuilders.functionScoreQuery(QueryBuilders.matchQuery("all", "如家"),new FunctionScoreQueryBuilder.FilterFunctionBuilder[]{new FunctionScoreQueryBuilder.FilterFunctionBuilder(QueryBuilders.termQuery("city", "深圳"),ScoreFunctionBuilders.weightFactorFunction(10f))}).boostMode(CombineFunction.SUM)).size(1000);// 發送查詢請求SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 接收查詢結果ArrayList<HotelDoc> hotelDocs = new ArrayList<>();// 處理查詢結果for (SearchHit hit : searchResponse.getHits()) {// 獲取查詢結果String searchResult = hit.getSourceAsString();// Json 轉換為 JavaBeanHotelDoc hotelDoc = objectMapper.readValue(searchResult, HotelDoc.class);// 添加查詢結果hotelDocs.add(hotelDoc);}// 算分查詢狀態log.info("\n算分查詢狀態: {}", searchResponse.status());// 輸出所有查詢結果hotelDocs.forEach(hotelDoc -> log.info("\n算分查詢結果: {}", hotelDoc)); }

排序查詢

地理位置排序查詢

查找離設定經緯度坐標最近的如家酒店

@Test public void orderSearch() throws Exception {// 獲取查詢對象SearchRequest searchRequest = new SearchRequest("hotel");// 構建查詢條件searchRequest.source().query(QueryBuilders.matchQuery("all", "如家")).sort(SortBuilders.geoDistanceSort("location", new GeoPoint(39.76, 116.33)) // SortBuilders.geoDistanceSort("location", 39.76, 116.33) 兩者結果一致.order(SortOrder.ASC).unit(DistanceUnit.KILOMETERS)).size(1000).from(0) // 從第一頁開始查詢.size(7) // 每次查詢7條, 類似于mysql中的limit, 使用了這個, 就會覆蓋query下的size, DSL語句會報錯, 但JavaCode不會;// 發送查詢請求SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 處理查詢結果SearchHits hits = searchResponse.getHits();// 地理位置排序查詢狀態log.info("\n地理位置排序查詢狀態: {}", searchResponse.status());// 地理位置排序查詢總條目log.error("\n地址位置排序查詢總條目: {}", hits.getTotalHits().value);// 遍歷結果集for (SearchHit hit : hits) {// 獲取查詢結果String searchResult = hit.getSourceAsString();// 獲取查詢出的酒店位置距離設定的位置有多遠Object[] sortValues = hit.getSortValues();// 若不是經緯度查詢, 則距離值則為空, 直接Json轉換為JavaBeanHotelDoc hotelDoc = objectMapper.readValue(searchResult, HotelDoc.class);// 輸出查詢結果log.info("\n查詢結果: {}", hotelDoc);log.info("距離設定的位置有: {}km", sortValues[0]);} }

指定字段排序查詢

倒序查詢全國所有如家品牌酒店的價格

@Test public void sortSearchAll() throws Exception {// 獲取查詢對象SearchRequest searchRequest = new SearchRequest("hotel");// 構建查詢條件searchRequest.source().query(QueryBuilders.matchQuery("all", "如家")).sort(SortBuilders.fieldSort("price").order(SortOrder.DESC)).size(1000);// 發送查詢請求SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 收集查詢結果ArrayList<HotelDoc> hotelDocs = new ArrayList<>();// 處理查詢結果SearchHits hits = searchResponse.getHits();// 遍歷結果集for (SearchHit hit : hits) {// 獲取查詢結果String searchResult = hit.getSourceAsString();// Json轉換為JavaBeanHotelDoc hotelDoc = objectMapper.readValue(searchResult, HotelDoc.class);// 添加到集合hotelDocs.add(hotelDoc);}// 指定字段排序查詢狀態log.info("\n地理位置排序查詢狀態: {}", searchResponse.status());// 指定字段排序查詢總條目log.error("\n指定字段排序查詢總條目: {}", hits.getTotalHits().value);// 輸出所有查詢結果hotelDocs.forEach(hotelDoc -> log.info("\n指定字段排序查詢結果: {}", hotelDoc)); }

高亮顯示

查詢如家酒店, 并高亮顯示為粉色

@Test public void highlightSearch() throws Exception {// 獲取查詢對象SearchRequest searchRequest = new SearchRequest("hotel");// 構建查詢條件searchRequest.source().query(QueryBuilders.matchQuery("all", "如家")).from(6) // 顯示第2頁數據.size(7) // 只顯示7條.highlighter(SearchSourceBuilder.highlight().field("name").requireFieldMatch(false).preTags("<font color = 'pink'>").postTags("</font>"));// 發送查詢請求SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 收集查詢結果ArrayList<HotelDoc> hotelDocs = new ArrayList<>();// 處理查詢結果SearchHits hits = searchResponse.getHits();// 遍歷結果集for (SearchHit hit : hits) {// 獲取查詢結果String searchResult = hit.getSourceAsString();// Json轉換為JavaBeanHotelDoc hotelDoc = objectMapper.readValue(searchResult, HotelDoc.class);// 處理高亮結果: 獲取需要高亮的字段HighlightField nameHighlightField = hit.getHighlightFields().get("name");// 判斷HighlightField對象不為空, ObjectUtil是MyBatisPlus的工具類if (ObjectUtils.isEmpty(nameHighlightField)) {// 獲取第一個元素內容Text newValue = nameHighlightField.getFragments()[0];// 將Json轉換后的JavaBean中指定的屬性替換為新的值hotelDoc.setName(newValue.toString());}// 添加到集合hotelDocs.add(hotelDoc);}// 指定字段高亮顯示查詢狀態log.info("\n指定字段高亮顯示查詢狀態: {}", searchResponse.status());// 指定字段高亮顯示查詢總條目log.error("\n指定字段高亮顯示查詢總條目: {}", hits.getTotalHits().value);// 輸出所有查詢結果hotelDocs.forEach(hotelDoc -> log.info("\n指定字段高亮顯示查詢結果: {}", hotelDoc)); }

聚合查詢

Bucket (桶查詢)

聚合查詢: 桶聚合, 查詢全國每個城市的酒店數量

@Test public void bucketSearch() throws Exception {// 獲取查詢對象SearchRequest searchRequest = new SearchRequest("hotel");// 構建查詢條件searchRequest.source().size(0).aggregation(AggregationBuilders.terms("cityCountAgg") // 桶名稱.field("city") // 統計字段.order(BucketOrder.count(true) // true = asc, false = desc).size(7) // 只展示7條數據);// 發送查詢請求SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 處理查詢結果: 接收結果必須使用Terms, 并且是ElasticSearch包中的Terms cityCountAgg = searchResponse.getAggregations().get("cityCountAgg");// 獲取桶List<? extends Terms.Bucket> cityBuckets = cityCountAgg.getBuckets();// 遍歷結果集for (Terms.Bucket cityBucket : cityBuckets) {// 獲取統計到的城市名稱String cityName = cityBucket.getKeyAsString();// 獲取統計到的城市的所有酒店數量long cityCount = cityBucket.getDocCount();log.info("統計到的城市名稱: {}", cityName);log.info("獲取統計到的城市的所有酒店數量: {}", cityCount);} }

自動補全

@Test public void autoCompletionSearch() throws Exception {// 獲取查詢對象SearchRequest searchRequest = new SearchRequest("hotel");//添加自動補全的查詢條件searchRequest.source().suggest(new SuggestBuilder().addSuggestion("searchSuggetion",SuggestBuilders.completionSuggestion("suggestion").prefix("如").skipDuplicates(true).size(33)));//發出請求SearchResponse searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 處理結果集CompletionSuggestion searchSuggetion = searchResponse.getSuggest().getSuggestion("searchSuggetion");List<CompletionSuggestion.Entry.Option> options = searchSuggetion.getOptions();List<String> result = new ArrayList<>();//遍歷options取出所有的提示內容存儲到集合中，返回for (CompletionSuggestion.Entry.Option option : options) {result.add(option.getText().toString());}log.info("\n自動補全查詢結果: {}", result); }

總結

以上是生活随笔為你收集整理的ElasticSearch: 使用Java Api 操作 ES的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。