ElasticSearch6.x 基于SpringBoot 实现ElasticSearch匹配查询

Dear 丶 2023-10-18 22:24 121阅读 0赞

官方文档地址：[https://www.elastic.co/guide/en/elasticsearch/client/java-api/6.1/java-term-level-queries.html][https_www.elastic.co_guide_en_elasticsearch_client_java-api_6.1_java-term-level-queries.html]

**SpringBoot 功能封装涉及ElasticSearch文档匹配查询，约定方法如下：**

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

/**
    	 * 功能描述：匹配检索之term query
    	 * 
    	 * @param indexs
    	 *            索引数组
    	 * @param types
    	 *            类型数组
    	 * @param fieldNames
    	 *            文档属性数组
    	 * @param text
    	 *            文档属性值
    	 * @return
    	 * @throws InterruptedException
    	 * @throws ExecutionException
    	 */
    	public SearchResponse searchTermQuery(String[] indexs, String[] types, String name, Object value)
    			throws InterruptedException, ExecutionException {
    		TermQueryBuilder termQuery = QueryBuilders.termQuery(name, value);
    		SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(termQuery).execute().get();
    		return response;
    	}
    
    	/**
    	 * 功能描述：匹配检索之terms query
    	 * 
    	 * @param indexs
    	 *            索引数组
    	 * @param types
    	 *            类型数组
    	 * @param name
    	 *            文档属性
    	 * @param values
    	 *            文档属性值数组
    	 * @return
    	 * @throws InterruptedException
    	 * @throws ExecutionException
    	 */
    	public SearchResponse searchTermsQuery(String[] indexs, String[] types, String name, Object[] values)
    			throws InterruptedException, ExecutionException {
    		TermsQueryBuilder termsQuery = QueryBuilders.termsQuery(name, values);
    		SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(termsQuery).execute().get();
    		return response;
    	}
    
    	/**
    	 * 功能描述：匹配检索之range query(基于时间类型)
    	 * 
    	 * @param indexs
    	 *            索引数组
    	 * @param types
    	 *            类型数组
    	 * @param name
    	 *            文档属性
    	 * @param from
    	 *            文档属性值大于指定值
    	 * @param to
    	 *            文档属性值小于指定值
    	 * @return
    	 * @throws InterruptedException
    	 * @throws ExecutionException
    	 */
    	public SearchResponse searchRangeQueryDate(String[] indexs, String[] types, String name, Object from, Object to)
    			throws InterruptedException, ExecutionException {
    		RangeQueryBuilder rangeQuery = QueryBuilders.rangeQuery(name).from(from).to(to).includeLower(true)
    				.includeUpper(true);
    		SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(rangeQuery).execute().get();
    		return response;
    	}
    
    	/**
    	 * 功能描述：匹配检索之range query(基于整数类型)
    	 * 
    	 * @param indexs
    	 *            索引数组
    	 * @param types
    	 *            类型数组
    	 * @param name
    	 *            文档属性
    	 * @param from
    	 *            文档属性值大于指定值
    	 * @param to
    	 *            文档属性值小于指定值
    	 * @return
    	 * @throws InterruptedException
    	 * @throws ExecutionException
    	 */
    	public SearchResponse searchRangeQueryInteger(String[] indexs, String[] types, String name, Object from, Object to)
    			throws InterruptedException, ExecutionException {
    		RangeQueryBuilder rangeQuery = QueryBuilders.rangeQuery(name).gte(from).lt(to);
    		SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(rangeQuery).execute().get();
    		return response;
    	}
    	
    	/**
    	 * 功能描述：匹配检索之exists query
    	 * 
    	 * @param indexs
    	 *            索引数组
    	 * @param types
    	 *            类型数组
    	 * @param name
    	 *            文档属性
    	 * @return
    	 * @throws InterruptedException
    	 * @throws ExecutionException
    	 */
    	public SearchResponse searchExistsQuery(String[] indexs, String[] types, String name)
    			throws InterruptedException, ExecutionException {
    		ExistsQueryBuilder existsQuery = QueryBuilders.existsQuery(name);
    		SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(existsQuery).execute().get();
    		return response;
    	}
    	
    	
    	/**
    	 * 功能描述：匹配检索之prefix query
    	 * 
    	 * @param indexs
    	 *            索引数组
    	 * @param types
    	 *            类型数组
    	 * @param name
    	 *            文档属性
    	 * @param prefix
    	 *            文档属性值前缀
    	 * @return
    	 * @throws InterruptedException
    	 * @throws ExecutionException
    	 */
    	public SearchResponse searchPrefixQuery(String[] indexs, String[] types, String name, String prefix)
    			throws InterruptedException, ExecutionException {
    		PrefixQueryBuilder prefixQuery = QueryBuilders.prefixQuery(name, prefix);
    		SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(prefixQuery).execute().get();
    		return response;
    	}
    	
    	
    	/**
    	 * 功能描述：匹配检索之wildcard query
    	 * 
    	 * @param indexs
    	 *            索引数组
    	 * @param types
    	 *            类型数组
    	 * @param name
    	 *            文档属性
    	 * @param query
    	 *            文档通配符属性值
    	 * @return
    	 * @throws InterruptedException
    	 * @throws ExecutionException
    	 */
    	public SearchResponse searchWildcardQuery(String[] indexs, String[] types, String name, String query)
    			throws InterruptedException, ExecutionException {
    		WildcardQueryBuilder wildcardQuery = QueryBuilders.wildcardQuery(name, query);
    		SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(wildcardQuery).execute().get();
    		return response;
    	}
    	
    	
    	/**
    	 * 功能描述：匹配检索之regexp query
    	 * 
    	 * @param indexs
    	 *            索引数组
    	 * @param types
    	 *            类型数组
    	 * @param name
    	 *            文档属性
    	 * @param regexp
    	 *            文档属性正则表达式
    	 * @return
    	 * @throws InterruptedException
    	 * @throws ExecutionException
    	 */
    	public SearchResponse searchRegexpQuery(String[] indexs, String[] types, String name, String regexp)
    			throws InterruptedException, ExecutionException {
    		RegexpQueryBuilder regexpQuery = QueryBuilders.regexpQuery(name, regexp);
    		SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(regexpQuery).execute().get();
    		return response;
    	}
    	
    	
    	/**
    	 * 功能描述：匹配检索之fuzzy query
    	 * 
    	 * @param indexs
    	 *            索引数组
    	 * @param types
    	 *            类型数组
    	 * @param name
    	 *            文档属性
    	 * @param value
    	 *            文档属性值
    	 * @return
    	 * @throws InterruptedException
    	 * @throws ExecutionException
    	 */
    	public SearchResponse searchFuzzyQuery(String[] indexs, String[] types, String name, Object value)
    			throws InterruptedException, ExecutionException {
    		FuzzyQueryBuilder fuzzyQuery = QueryBuilders.fuzzyQuery(name, value);
    		SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(fuzzyQuery).execute().get();
    		return response;
    	}
    	
    	
    	/**
    	 * 功能描述：匹配检索之ids query
    	 * 
    	 * @param indexs
    	 *            索引数组
    	 * @param types
    	 *            类型数组
    	 * @param ids
    	 *            文档id数组
    	 * @return
    	 * @throws InterruptedException
    	 * @throws ExecutionException
    	 */
    	public SearchResponse searchTypeQuery(String[] indexs, String[] types, String[] ids)
    			throws InterruptedException, ExecutionException {
    		IdsQueryBuilder idsQuery = QueryBuilders.idsQuery(ids);
    		SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(idsQuery).execute().get();
    		return response;
    	}
    	
    	
    	/**
    	 * 功能描述：匹配检索之type query
    	 * 
    	 * @param indexs
    	 *            索引数组
    	 * @param types
    	 *            类型数组
    	 * @param fieldNames
    	 *            文档属性数组
    	 * @param text
    	 *            文档属性值
    	 * @return
    	 * @throws InterruptedException
    	 * @throws ExecutionException
    	 */
    	public SearchResponse searchTypeQuery(String[] indexs, String[] types, String type)
    			throws InterruptedException, ExecutionException {
    		TypeQueryBuilder fuzzyQuery = QueryBuilders.typeQuery(type);
    		SearchResponse response = client.prepareSearch(indexs).setTypes(types).setQuery(fuzzyQuery).execute().get();
    		return response;
    	}

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