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

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

elasticsearch6.x 官网文档地址：[https://www.elastic.co/guide/en/elasticsearch/client/java-api/6.1/java-full-text-queries.html][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连接功能封装][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;
    	}
    
    }

功能的测试方法就不进行补充了

[https_www.elastic.co_guide_en_elasticsearch_client_java-api_6.1_java-full-text-queries.html]: https://www.elastic.co/guide/en/elasticsearch/client/java-api/6.1/java-full-text-queries.html
[ElasticSearch6.x _SpringBoot _ElasticSearch]: https://blog.csdn.net/zhouzhiwengang/article/details/97271288