男孩子怎么做网站赚钱,wordpress 宁皓,网站评论管理怎么做,下载网站的表格要钱如何做一、快速入门 上面的查询文档都是依赖kibana#xff0c;在浏览器页面使用DSL语句去查询es#xff0c;如何用java去查询es里面的文档(数据)呢 我们通过match_all查询来演示基本的API#xff0c;注意下面演示的是 match_all查询#xff0c;也叫基础查询 首先保证你已经做好了…一、快速入门 上面的查询文档都是依赖kibana在浏览器页面使用DSL语句去查询es如何用java去查询es里面的文档(数据)呢 我们通过match_all查询来演示基本的API注意下面演示的是 match_all查询也叫基础查询 首先保证你已经做好了 实用篇-ES-环境搭建 创建了名为gghotel的索引库然后开始下面的操作。如果需要浏览器操作es那就不需要启动kibana容器 在进行下面的操作之前确保你已经看了前面 实用篇-ES-RestClient操作文档 学的 1. RestClient案例准备然后在进行下面的操作 第一步: 在src/test/java/cn.itcast.hotel目录新建HotelSearchTest类写入如下
package cn.itcast.hotel;import cn.itcast.hotel.service.IHotelService;
import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;import java.io.IOException;SpringBootTest
public class HotelIndexTest2 {private RestHighLevelClient client;Autowiredprivate IHotelService hotelService;Testvoid init(){System.out.println(client);}BeforeEachvoid setUp(){this.client new RestHighLevelClient(RestClient.builder(//指定你Centos7部署的es的主机地址HttpHost.create(http://192.168.229.129:9200)));}AfterEachvoid tearDown() throws IOException {this.client.close();}Testvoid testMatchAll() throws IOException {//准备RequestSearchRequest request new SearchRequest(hotel);//组织DSL参数request.source().query(QueryBuilders.matchAllQuery());//发送请求得到响应结果SearchResponse response client.search(request, RequestOptions.DEFAULT);System.out.println(response);}}第二步: 把控制台里面我们需要的数据解析出来。返回的数据很多我们主要是解析hits里面的数据就行了 把HotelSearchTest类修改为如下主要的修改是sout之前做了一次解析拿到我们想要的数据
package cn.itcast.hotel;import cn.itcast.hotel.pojo.HotelDoc;
import cn.itcast.hotel.service.IHotelService;
import com.alibaba.fastjson.JSON;
import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;import java.io.IOException;SpringBootTest
public class HotelIndexTest2 {private RestHighLevelClient client;Autowiredprivate IHotelService hotelService;Testvoid init(){System.out.println(client);}BeforeEachvoid setUp(){this.client new RestHighLevelClient(RestClient.builder(//指定你Centos7部署的es的主机地址HttpHost.create(http://192.168.229.129:9200)));}AfterEachvoid tearDown() throws IOException {this.client.close();}Testvoid testMatchAll() throws IOException {//准备RequestSearchRequest request new SearchRequest(hotel);//组织DSL参数request.source().query(QueryBuilders.matchAllQuery());//发送请求得到响应结果SearchResponse response client.search(request, RequestOptions.DEFAULT);//下面为逐层解析json数据SearchHits searchHits response.getHits();long total searchHits.getTotalHits().value;System.out.println(共有 total 条数据);SearchHit[] hits searchHits.getHits();for (SearchHit hit : hits) {String json hit.getSourceAsString();//反系列化HotelDoc hotelDoc JSON.parseObject(json, HotelDoc.class);System.out.println(hotelDoc hotelDoc);}}}二、match的三种查询 我们刚刚在第一节演示的是 match_all(也叫基本查询) 查询下面将演示 match(也叫单字段查询) 和 multi_match(也叫多字段查询) 查询
【match 查询也叫单字段查询】
在HotelSearchTest类添加如下 Testvoid testMatch() throws IOException {//准备RequestSearchRequest request new SearchRequest(hotel);//组织DSL参数request.source().query(QueryBuilders.matchQuery(name,如家));//发送请求得到响应结果SearchResponse response client.search(request, RequestOptions.DEFAULT);//下面为逐层解析json数据SearchHits searchHits response.getHits();long total searchHits.getTotalHits().value;System.out.println(共有 total 条数据);SearchHit[] hits searchHits.getHits();for (SearchHit hit : hits) {String json hit.getSourceAsString();//反系列化HotelDoc hotelDoc JSON.parseObject(json, HotelDoc.class);System.out.println(hotelDoc hotelDoc);}} 【multi_match 查询也叫多字段查询】
在HotelSearchTest类添加如下 Testvoid testMatch() throws IOException {//准备RequestSearchRequest request new SearchRequest(hotel);//组织DSL参数request.source().query(QueryBuilders.multiMatchQuery(如家,name,business));//发送请求得到响应结果SearchResponse response client.search(request, RequestOptions.DEFAULT);//下面为逐层解析json数据SearchHits searchHits response.getHits();long total searchHits.getTotalHits().value;System.out.println(共有 total 条数据);SearchHit[] hits searchHits.getHits();for (SearchHit hit : hits) {String json hit.getSourceAsString();//反系列化HotelDoc hotelDoc JSON.parseObject(json, HotelDoc.class);System.out.println(hotelDoc hotelDoc);}}总结: 要构建查询条件只要记住一个QueryBuilders类即可
三、解析代码的抽取
我们发现对于 match、multi_match、match_all 查询的解析部分的代码都是相同的所以我们可以对解析部分的代码进行抽取如下
快捷键ctrl alt M private void handleResponse(SearchResponse response) {//下面为逐层解析json数据SearchHits searchHits response.getHits();long total searchHits.getTotalHits().value;System.out.println(共有 total 条数据);SearchHit[] hits searchHits.getHits();for (SearchHit hit : hits) {String json hit.getSourceAsString();//反系列化HotelDoc hotelDoc JSON.parseObject(json, HotelDoc.class);System.out.println(hotelDoc hotelDoc);}}
之后我们在test中只专注于json的获取解析的任务交给这段代码 四、bool和term、rang精确查询
原理同上 我们直接演示bool复合查询 Testvoid testBool() throws IOException {//准备RequestSearchRequest request new SearchRequest(hotel);//组织DSL参数BoolQueryBuilder boolQuery QueryBuilders.boolQuery();boolQuery.must(QueryBuilders.termQuery(city,杭州));boolQuery.filter(QueryBuilders.rangeQuery(price).lte(250));request.source().query(boolQuery);//发送请求得到响应结果SearchResponse response client.search(request, RequestOptions.DEFAULT);handleResponse(response);}
五、排序和分页 Testvoid testPageAndSort() throws IOException {int pageNum 1;int pageSize 5;//准备RequestSearchRequest request new SearchRequest(hotel);//组织DSL参数//查询所有request.source().query(QueryBuilders.matchAllQuery());//排序request.source().sort(price, SortOrder.ASC);//分页request.source().from(pageNum - 1).size(pageSize);//发送请求得到响应结果SearchResponse response client.search(request, RequestOptions.DEFAULT);handleResponse(response);}六、高亮显示 高亮API包括请求DSL构建和结果解析两部分API和对应的DSL语句如下图下图只是构建再下面还有解析高亮必须由构建解析才能实现
解析如下图 Testvoid testHighLight() throws IOException {//准备RequestSearchRequest request new SearchRequest(hotel);//组织DSL参数//查询所有request.source().query(QueryBuilders.matchQuery(name,如家));//设置高亮匹配方式request.source().highlighter(new HighlightBuilder().field(name).requireFieldMatch(false));//发送请求得到响应结果SearchResponse response client.search(request, RequestOptions.DEFAULT);//下面为逐层解析json数据SearchHits searchHits response.getHits();long total searchHits.getTotalHits().value;System.out.println(共有 total 条数据);SearchHit[] hits searchHits.getHits();for (SearchHit hit : hits) {String json hit.getSourceAsString();//反系列化HotelDoc hotelDoc JSON.parseObject(json, HotelDoc.class);//解析获取高亮结果MapString, HighlightField highlightFields hit.getHighlightFields();if(!CollectionUtils.isEmpty(highlightFields)){//根据字段名获取高亮结果HighlightField highlightField highlightFields.get(name);//判断高亮字段不为空if(highlightField!null){//获取高亮值String name highlightField.getFragments()[0].string();//覆盖非高亮结果hotelDoc.setName(name);}}//最终输出System.out.println(hotelDoc hotelDoc);}}
