ElasticSearch6.x 基于SpringBoot 实现ElasticSearch全文查询-蒲公英云

ElasticSearch6.x 基于SpringBoot 实现ElasticSearch全文查询

Myth丶恋晨 2023-10-18 22:24 214阅读 0赞

elasticsearch6.x 官网文档地址：https://www.elastic.co/guide/en/elasticsearch/client/java-api/6.1/java-full-text-queries.html

SpringBoot 功能封装涉及ElasticSearch的全文检索方法约定如下：

public SearchResponse searchMatchQuery(String[] indexs, String[] types,String name, Object text)

public SearchResponse searchMultiMatchQuery(String[] indexs, String[] types,String[] fieldNames, Object text)

public SearchResponse searchCommonTermsQuery(String[] indexs, String[] types,String fieldName, Object text)

public SearchResponse searchQueryStringQuery(String[] indexs, String[] types,String queryString)

在上一篇文中说到：ElasticSearch6.x 基于SpringBoot 实现ElasticSearch连接功能封装,将约定的方法填充到ElasticSearchIndexUtil.java 工具类中。

@Component
public class ElasticSearchIndexUtil {
    // 引入 Ela 连接实列化对象
    @Autowired
    private TransportClient client;
/**
     * 功能描述：全文检索之match query
     * @param indexs  索引数组
     * @param types   类型数组
     * @param name    文档属性名称
     * @param text    文档属性值
     * @return
     * @throws InterruptedException
     * @throws ExecutionException
     */
    public SearchResponse searchMatchQuery(String[] indexs, String[] types,String name, Object text) throws InterruptedException, ExecutionException{
        MatchQueryBuilder matchQuery = QueryBuilders.matchQuery(name, text);
        SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(matchQuery).execute().get();
        return response;
    }
    /**
     * 功能描述：全文检索之multi_match query
     * @param indexs  索引数组
     * @param types   类型数组
     * @param fieldNames    文档属性数组
     * @param text    文档属性值
     * @return
     * @throws InterruptedException
     * @throws ExecutionException
     */
    public SearchResponse searchMultiMatchQuery(String[] indexs, String[] types,String[] fieldNames, Object text) throws InterruptedException, ExecutionException{
        MultiMatchQueryBuilder multiMatchQuery = QueryBuilders.multiMatchQuery(text, fieldNames);
        SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(multiMatchQuery).execute().get();
        return response;
    }
    /**
     * 功能描述：全文检索之common_terms query
     * @param indexs  索引数组
     * @param types   类型数组
     * @param fieldNames    文档属性数组
     * @param text    文档属性值
     * @return
     * @throws InterruptedException
     * @throws ExecutionException
     */
    public SearchResponse searchCommonTermsQuery(String[] indexs, String[] types,String fieldName, Object text) throws InterruptedException, ExecutionException{
        CommonTermsQueryBuilder commonTermsQuery = QueryBuilders.commonTermsQuery(fieldName, text);
        SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(commonTermsQuery).execute().get();
        return response;
    }
    /**
     * 功能描述：全文检索之query_string query
     * @param indexs  索引数组
     * @param types   类型数组
     * @param fieldNames    文档属性数组
     * @param text    文档属性值
     * @return
     * @throws InterruptedException
     * @throws ExecutionException
     */
    public SearchResponse searchQueryStringQuery(String[] indexs, String[] types,String queryString) throws InterruptedException, ExecutionException{
        QueryStringQueryBuilder queryStringQuery = QueryBuilders.queryStringQuery(queryString);
        SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(queryStringQuery).execute().get();
        return response;
    }
    /**
     * 功能描述：全文检索之simple_query_string
     * @param indexs  索引数组
     * @param types   类型数组
     * @param fieldNames    文档属性数组
     * @param text    文档属性值
     * @return
     * @throws InterruptedException
     * @throws ExecutionException
     */
    public SearchResponse searchSimpleQueryStringQuery(String[] indexs, String[] types,String queryString) throws InterruptedException, ExecutionException{
        SimpleQueryStringBuilder simpleQueryString = QueryBuilders.simpleQueryStringQuery(queryString);
        SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(simpleQueryString).execute().get();
        return response;
    }
}