RestHighLevelClient實(shí)現(xiàn)ElasticSearch關(guān)聯(lián)查詢之父子文檔今天分享，承接上一篇內(nèi)容：

DSL操作關(guān)聯(lián)查詢

這篇我們通過(guò)javaAPI的方式實(shí)現(xiàn)：

一、springboot 配置

1、pom文件引用：

      <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-high-level-client</artifactId>
            <version>7.9.3</version>
            <exclusions>
                <exclusion>
                    <groupId>org.elasticsearch</groupId>
                    <artifactId>elasticsearch</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.elasticsearch.client</groupId>
                    <artifactId>elasticsearch-rest-client</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-client</artifactId>
            <version>7.9.3</version>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch</artifactId>
            <version>7.9.3</version>
        </dependency>

        <!-- elasticsearch 新版本官方sdk，版本號(hào)需與使用的es版本一致 -->
        <dependency>
            <groupId>co.elastic.clients</groupId>
            <artifactId>elasticsearch-java</artifactId>
            <version>7.17.0</version>
        </dependency>

2、初始化配置es操作類

import org.apache.http.HttpHost;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.client.CredentialsProvider;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class ElasticSearchConfig {

    @Bean
    public RestHighLevelClient restHighLevelClient(){
 
        RestClientBuilder builder=RestClient.builder(
               // new HttpHost("116.204.80.158", 9200, "http"),
                new HttpHost("116.204.80.155", 9200, "http"));
        CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
        credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "123456"));
        builder.setHttpClientConfigCallback(f -> f.setDefaultCredentialsProvider(credentialsProvider));
        RestHighLevelClient client = new RestHighLevelClient( builder);
        return client;
    }
}

3、業(yè)務(wù)層引用

    @Qualifier("restHighLevelClient")
    @Autowired
    private RestHighLevelClient client;

    private static final String indexName = "test_nandao_index";

    private static final String tableName = "UserInfo";
    private static final String workTableName = "WorkInfo";
    private static final String schoolTableName = "SchoolInfo";
    private static final String UserWorkRelation = tableName+"_"+workTableName+"_relation";

二、核心偽代碼

1、創(chuàng)建父子索引

@Override
    public boolean createIndex(String index) throws IOException {
        //創(chuàng)建json數(shù)

        XContentBuilder mapping = XContentFactory.jsonBuilder()
                .startObject()

                .startObject("properties")

                .startObject("content")
                .field("type","text")
                .endObject()

                .startObject("title")
                .field("type","text")
                .endObject()

                .startObject(tableName+"_"+workTableName+"_relation")
                .field("type","join")
                .startObject("relations")
               // .field("blog","comment")
                .field(tableName,workTableName)
                .endObject()
                .endObject()

                .endObject()

                .endObject();

        CreateIndexRequest request = new CreateIndexRequest(index)
                .settings(Settings.builder()
                        .put("number_of_shards", 2)
                        .put("number_of_replicas", 1)
                        .build())
                .mapping(mapping)
                ;

        //1.創(chuàng)建索引請(qǐng)求
      //  CreateIndexRequest request = new CreateIndexRequest(index);
        String string = request.aliases().toString();
        //2.客戶端執(zhí)行請(qǐng)求IndicesClient,請(qǐng)求后獲得相應(yīng)
        log.info("請(qǐng)求:{}", JSONObject.toJSONString(request));
        log.info("請(qǐng)求:{}",request.toString());
        CreateIndexResponse response = client.indices().create(request, RequestOptions.DEFAULT);
        log.info("返回:{}", JSON.toJSONString(response));
        return response.isAcknowledged();
    }

kibana查看

GET /nandao_parent_sub_index/_mapping

2、判斷索引是否存在

   @Override
    public boolean isExit(String index) throws IOException {
        GetIndexRequest request = new GetIndexRequest(index);
        boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);
        return exists;
    }

3、刪除索引

    @Override
    public boolean delete(String index) throws IOException {
        DeleteIndexRequest request = new DeleteIndexRequest(index);
        AcknowledgedResponse delete = client.indices().delete(request, RequestOptions.DEFAULT);
        return delete.isAcknowledged();
    }

4、添加父文檔

 @Override
    public boolean addDocument(String index, String id, Object object) throws IOException {
        IndexRequest request = new IndexRequest(index);
        //規(guī)則 一般的文檔形如 put /index/_doc/1
        //request.id(id);//如果不設(shè)置id的話會(huì)自動(dòng)分配id
        request.timeout("1s");//設(shè)置超時(shí)時(shí)間
        System.out.println("JSON.toJSONString(object):"+ JSON.toJSONString(object));
        //將我們的數(shù)據(jù)放入請(qǐng)求Json中
        JSONObject jsonObject = (JSONObject) JSONObject.toJSON(object);
        //添加join關(guān)聯(lián)索引
        JSONObject relationObject = new JSONObject();
       // relationObject.put(tableName,workTableName);
        relationObject.put("name",tableName);
        jsonObject.put(UserWorkRelation,relationObject);
        request.source(JSON.toJSONString(jsonObject), XContentType.JSON);
        log.info("請(qǐng)求:{}", JSONObject.toJSONString(request));
        log.info("請(qǐng)求1:{}", JSON.toJSONString(request));
        log.info("請(qǐng)求2:{}", JSON.toJSONString(jsonObject));
        //客戶端發(fā)送請(qǐng)求,獲取相應(yīng)的結(jié)果
        IndexResponse response = client.index(request, RequestOptions.DEFAULT);
        return response.getShardInfo().getSuccessful()>0?true:false;
    }

5、更新父文檔

    @Override
    public boolean updateDocument(UserInfoVo user, String index, String id) throws IOException {
        UpdateRequest request = new UpdateRequest(index, id);
        request.timeout("1s");

        //將我們的數(shù)據(jù)放入請(qǐng)求Json中
        JSONObject jsonObject = (JSONObject) JSONObject.toJSON(user);
        //添加join關(guān)聯(lián)索引
        JSONObject relationObject = new JSONObject();
        // relationObject.put(tableName,workTableName);
        relationObject.put("name",tableName);
        jsonObject.put(UserWorkRelation,relationObject);

        request.doc(JSON.toJSONString(jsonObject), XContentType.JSON);
        UpdateResponse update = client.update(request, RequestOptions.DEFAULT);
        return update.getShardInfo().getSuccessful()>0?true:false;
    }

6、添加子文檔

    @Override
    public boolean addDocumentSub(String index, String parentId, Object object) throws IOException {
        IndexRequest request = new IndexRequest(index).routing(parentId);//設(shè)置索引和路由
        //規(guī)則 一般的文檔形如 put /index/_doc/1
        //request.id(id);//如果不設(shè)置id的話會(huì)自動(dòng)分配id
        request.timeout("1s");//設(shè)置超時(shí)時(shí)間
        System.out.println("JSON.toJSONString(object):"+ JSON.toJSONString(object));
        //將我們的數(shù)據(jù)放入請(qǐng)求Json中
        JSONObject jsonObject = (JSONObject) JSONObject.toJSON(object);
        //添加join關(guān)聯(lián)索引
        JSONObject relationObject = new JSONObject();
        relationObject.put("name",workTableName);
        relationObject.put("parent",parentId);
        jsonObject.put(UserWorkRelation,relationObject);
        request.source(JSON.toJSONString(jsonObject), XContentType.JSON);
        log.info("請(qǐng)求:{}", JSONObject.toJSONString(request));
        log.info("請(qǐng)求1:{}", JSON.toJSONString(request));
        log.info("請(qǐng)求2:{}", JSON.toJSONString(jsonObject));
        //客戶端發(fā)送請(qǐng)求,獲取相應(yīng)的結(jié)果
        IndexResponse response = client.index(request, RequestOptions.DEFAULT);
        return response.getShardInfo().getSuccessful()>0?true:false;
    }

創(chuàng)建普通文檔??

    @Override
    public boolean createDocument(String index, Object object) throws IOException {
        IndexRequest request = new IndexRequest(index);
        //規(guī)則 一般的文檔形如 put /index/_doc/1
       // request.id(id);//如果不設(shè)置id的話會(huì)自動(dòng)分配id
        request.timeout("1s");//設(shè)置超時(shí)時(shí)間
        System.out.println("JSON.toJSONString(object):"+ JSON.toJSONString(object));
        //將我們的數(shù)據(jù)放入請(qǐng)求Json中
        request.source(JSON.toJSONString(object), XContentType.JSON);
        //客戶端發(fā)送請(qǐng)求,獲取相應(yīng)的結(jié)果
        IndexResponse response = client.index(request, RequestOptions.DEFAULT);
        return response.getShardInfo().getSuccessful()>0?true:false;
    }

??????7、判斷是否是doc格式

    @Override
    public boolean isdocuexit(String index, String id) throws IOException {
        GetRequest getRequest = new GetRequest(index,id);
        //不獲取返回的_source上下文
        getRequest.fetchSourceContext(new FetchSourceContext(false));
        getRequest.storedFields("_none_");
        return client.exists(getRequest, RequestOptions.DEFAULT);
    }

8、根據(jù)id和索引查詢

    @Override
    public String getDoucumment(String index, String id) throws IOException {
        GetRequest getRequest = new GetRequest(index, id);
        GetResponse response = client.get(getRequest, RequestOptions.DEFAULT);
        return response.getSourceAsString();
    }

9、根據(jù)父id查詢

    @Override
    public String getDoucummentByParentId(String index, TreeMap<String, Object> content,String parentId) throws IOException {
         
        SearchRequest searchRequest = new SearchRequest(index);
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
      
        ParentIdQueryBuilder build = JoinQueryBuilders.parentId("WorkInfo",parentId);
        sourceBuilder.query(build);
        //將查詢條件放入需要查詢中
        searchRequest.source(sourceBuilder);
        System.out.println("dsl===1==="+sourceBuilder.toString());

        //獲取相應(yīng)的數(shù)據(jù)
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        SearchHit[] hits = searchResponse.getHits().getHits();

       // SearchRequest searchRequest = new SearchRequest(index);
        searchResponse.getHits().forEach(hi ->{
            log.info("查詢結(jié)果:{}",hi.getSourceAsString());
        });
        return hits.toString();
    }

對(duì)應(yīng)DSL語(yǔ)句

POST /nandao_parent_sub_index/_search 
{
	"query": {
		"parent_id": {
			"type": "WorkInfo",
			"id": "tYTxYoUBJlO7GBNmNPml"
		}
	}
}

?

10、Has Child 查詢,返回父文檔

    @Override
    public String getDoucummentHasChild(String userName, String index) throws IOException {
        SearchRequest searchRequest = new SearchRequest(index);
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        HasChildQueryBuilder build = JoinQueryBuilders.hasChildQuery("WorkInfo",QueryBuilders.matchQuery("userName", "Jack"), ScoreMode.None);
        sourceBuilder.query(build);
        //將查詢條件放入需要查詢中
        searchRequest.source(sourceBuilder);
        System.out.println("dsl===1==="+sourceBuilder.toString());
        //獲取相應(yīng)的數(shù)據(jù)
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        SearchHit[] hits = searchResponse.getHits().getHits();
        searchResponse.getHits().forEach(hi ->{
            log.info("查詢結(jié)果:{}",hi.getSourceAsString());
        });
        return hits.toString();
    }

對(duì)應(yīng)DSL語(yǔ)句：

POST /nandao_parent_sub_index/_search
{
	"query": {
		"has_child": {
			"type": "WorkInfo",
			"query": {
				"match": {
					"userName": "Jack"
				}
			}
		}
	}
}

?11、Has parent 查詢,返回子文檔

    @Override
    public String getDoucummentHasParent(String userName, String index) throws IOException {
        SearchRequest searchRequest = new SearchRequest(index);
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        HasParentQueryBuilder build= JoinQueryBuilders.hasParentQuery("UserInfo", QueryBuilders.matchQuery("userName", "wangwu"), false);
        sourceBuilder.query(build);
        //將查詢條件放入需要查詢中
        searchRequest.source(sourceBuilder);
        System.out.println("dsl===1==="+sourceBuilder.toString());
        //獲取相應(yīng)的數(shù)據(jù)
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        SearchHit[] hits = searchResponse.getHits().getHits();
        searchResponse.getHits().forEach(hi ->{
            log.info("查詢結(jié)果:{}",hi.getSourceAsString());
        });
        return hits.toString();
    }

對(duì)應(yīng)DSL語(yǔ)句：

GET /nandao_parent_sub_index/_search
{
  "query": {
    "has_parent": {
      "parent_type": "UserInfo",
      "query": {
        "match": {
          "userName": "wangwu"
        }
      }
    }
  }
}

?12、通過(guò)索引查

   @Override
    public String getAllDoucummentByIndex(String index) throws IOException {
        SearchRequest searchRequest = new SearchRequest(index);
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        SearchHit[] hits = searchResponse.getHits().getHits();
        return hits.toString();
    }

13、通過(guò)索引和id刪除文檔

   @Override
    public boolean deleteDocument(String index, String id) throws IOException {
        DeleteRequest request = new DeleteRequest(index,id);
        request.timeout("1s");
        DeleteResponse deleteResponse = client.delete(request, RequestOptions.DEFAULT);
        return deleteResponse.getShardInfo().getSuccessful()>0?true:false;
    }

14、批量添加文檔

    @Override
    public boolean addmoredocument(List<Object> list, String index, String id) throws IOException {
        BulkRequest bulkRequest = new BulkRequest();
        bulkRequest.timeout("1s");
        //批量處理請(qǐng)求
        for (int i=0;i<list.size();i++){
            bulkRequest.add(
                    new IndexRequest(index)
                            //.id(id)
                            .source(JSON.toJSONString(list.get(i)), XContentType.JSON));
        }
        BulkResponse responses = client.bulk(bulkRequest, RequestOptions.DEFAULT);
        //是否失敗 false-沒(méi)有失敗
        return responses.hasFailures()?false:true;
    }

15、termQuery

    @Override
    public List<Map<String, Object>> termQuery(String index, TreeMap<String, Object> content, int size, int from, boolean ishigh) throws IOException {
        SearchRequest searchRequest = new SearchRequest(index);
        //構(gòu)建查詢條件
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        System.out.println(content.firstKey());
        //查詢條件
        TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery(content.firstKey(),content.get(content.firstKey()));
        sourceBuilder.query(termQueryBuilder);
        sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
        //獲取多少條數(shù)據(jù)
        sourceBuilder.size(size);
        //從第幾行開始
        sourceBuilder.from(from);
        //是否要將查詢的結(jié)果中將搜索的關(guān)鍵詞高亮
        if (ishigh){
            HighlightBuilder highlightBuilder = new HighlightBuilder();
            //設(shè)置高亮的屬性
            highlightBuilder.field(content.firstKey());
            //也可以自定義高亮的樣式,這里我使用的是默認(rèn)的方式
            sourceBuilder.highlighter(highlightBuilder);
        }
        System.out.println("dsl===1==="+sourceBuilder.toString());
        //將查詢條件放入需要查詢中
        searchRequest.source(sourceBuilder);
        //獲取相應(yīng)的數(shù)據(jù)
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        SearchHit[] hits = searchResponse.getHits().getHits();

        ArrayList<Map<String, Object>> result = new ArrayList<>();
        for (SearchHit searchHit:hits){
            Map<String, HighlightField> highlightFields = searchHit.getHighlightFields();
            //獲取高亮的信息
            HighlightField property = highlightFields.get(content.firstKey());
            //查詢的元素?cái)?shù)據(jù)(沒(méi)有高亮)
            Map<String, Object> sourceAsMap = searchHit.getSourceAsMap();
            if (ishigh){
                if (property!=null){
                    Text[] fragments = property.fragments();
                    String n_title = "";
                    for (Text text:fragments){
                        n_title += text;
                    }
                    sourceAsMap.put(content.firstKey(),n_title);
                }
            }
            result.add(sourceAsMap);
        }
        System.out.println("result==1===:"+result);
        return result;
    }

16、matchQuery

@Override
    public List<Map<String, Object>> matchQuery(String index, TreeMap<String, Object> content, int size, int from, boolean ishigh) throws IOException {
        SearchRequest searchRequest = new SearchRequest(index);
        //構(gòu)建查詢條件
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        //查詢條件
        MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery(content.firstKey(),content.get(content.firstKey()));

        sourceBuilder.query(matchQueryBuilder);
        sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
        //獲取多少條數(shù)據(jù)
        sourceBuilder.size(size);
        //從第幾行開始
        sourceBuilder.from(from);
        //是否要高亮
        if (ishigh){
            HighlightBuilder highlightBuilder = new HighlightBuilder();
            //設(shè)置高亮的屬性
            highlightBuilder.field(content.firstKey());
            //也可以自定義高亮的樣式,這里我使用的是默認(rèn)的方式
            sourceBuilder.highlighter(highlightBuilder);
        }

        System.out.println("dsl===2==="+sourceBuilder.toString());

        //將查詢條件放入需要查詢中
        searchRequest.source(sourceBuilder);
        //獲取相應(yīng)的數(shù)據(jù)
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        SearchHit[] hits = searchResponse.getHits().getHits();

        ArrayList<Map<String, Object>> result = new ArrayList<>();
        for (SearchHit searchHit:hits){
            Map<String, HighlightField> highlightFields = searchHit.getHighlightFields();
            //獲取高亮的信息
            HighlightField property = highlightFields.get(content.firstKey());
            //查詢的元素?cái)?shù)據(jù)(沒(méi)有高亮)
            Map<String, Object> sourceAsMap = searchHit.getSourceAsMap();
            System.out.println("sourceAsMap===2==="+sourceAsMap);
            if (ishigh){
                if (property!=null){
                    Text[] fragments = property.fragments();
                    String n_title = "";
                    for (Text text:fragments){
                        n_title += text;
                    }
                    sourceAsMap.put(content.firstKey(),n_title);
                }
            }
            result.add(sourceAsMap);
        }
        System.out.println("result==2===:"+result);

        return result;
    }

17、boolmustQuery

@Override
    public List<Map<String, Object>> boolmustQuery(String index, TreeMap<String, Object> content, int size, int from, boolean ishigh) throws IOException {
        SearchRequest searchRequest = new SearchRequest(index);
        //構(gòu)建查詢條件
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        //查詢條件
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
        Set keys = content.keySet();
        for (Object key:keys){
            //將要查詢的條件加入
            boolQueryBuilder.must(QueryBuilders.termQuery((String) key,content.get(key)));
        }
        sourceBuilder.query(boolQueryBuilder);
        sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
        //獲取多少條數(shù)據(jù)
        sourceBuilder.size(size);
        //從第幾行開始
        sourceBuilder.from(from);

        System.out.println("dsl===3==="+sourceBuilder.toString());
        //將查詢條件放入需要查詢中
        searchRequest.source(sourceBuilder);
        //獲取相應(yīng)的數(shù)據(jù)
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        SearchHit[] hits = searchResponse.getHits().getHits();
        ArrayList<Map<String, Object>> result = new ArrayList<>();
        for (SearchHit searchHit:hits){
            Map<String, HighlightField> highlightFields = searchHit.getHighlightFields();
            //獲取高亮的信息
            HighlightField property = highlightFields.get(content.firstKey());
            //查詢的元素?cái)?shù)據(jù)(沒(méi)有高亮)
            Map<String, Object> sourceAsMap = searchHit.getSourceAsMap();
            System.out.println("sourceAsMap===2==="+sourceAsMap);
            if (ishigh){
                if (property!=null){
                    Text[] fragments = property.fragments();
                    String n_title = "";
                    for (Text text:fragments){
                        n_title += text;
                    }
                    sourceAsMap.put(content.firstKey(),n_title);
                }
            }
            result.add(sourceAsMap);
        }

        System.out.println("result==3===:"+result);
        return result;
    }

到此關(guān)聯(lián)關(guān)系處理基本分享完畢，同時(shí)也可以參考這篇文章:

es父子查詢處理

下篇我們分析es的理論與架構(gòu)組成敬請(qǐng)期待！文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-690248.html

到了這里，關(guān)于RestHighLevelClient實(shí)現(xiàn)ElasticSearch關(guān)聯(lián)查詢之父子文檔的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！