java QueryBuilder用法_【转载】Elasticsearch--java操作之QueryBuilders构建搜索Query

雨点打透心脏的1/2处 2022-11-06 08:55 207阅读 0赞

package com.elasticsearch;

import org.elasticsearch.action.ActionListener;

import org.elasticsearch.action.search.SearchResponse;

import org.elasticsearch.index.query.IndicesQueryBuilder;

import org.elasticsearch.index.query.QueryBuilder;

import org.elasticsearch.index.query.QueryBuilders;

/\*\*

\* Created by lw on 14-7-15.

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* elasticsearch以提供了一个完整的Java查询dsl其余查询dsl。

\* QueryBuilders工厂构建

\* API:

\* http://www.elasticsearch.org/guide/en/elasticsearch/client/java-api/current/query-dsl-queries.html

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

public class Es\_QueryBuilders\_DSL \{

/\*\*

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* match query 单个匹配

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder matchQuery() \{

return QueryBuilders.matchQuery("name", "葫芦4032娃");

/\*\*

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* multimatch query

\* 创建一个匹配查询的布尔型提供字段名称和文本。

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder multiMatchQuery() \{

//现住址和家乡在【山西省太原市7429街道】的人

return QueryBuilders.multiMatchQuery(

"山西省太原市7429街道", // Text you are looking for

"home", "now\_home" // Fields you query on

);

/\*\*

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* boolean query and 条件组合查询

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder booleanQuery() \{

return QueryBuilders

.boolQuery()

.must(QueryBuilders.termQuery("name", "葫芦3033娃"))

.must(QueryBuilders.termQuery("home", "山西省太原市7967街道"))

.mustNot(QueryBuilders.termQuery("isRealMen", false))

.should(QueryBuilders.termQuery("now\_home", "山西省太原市"));

/\*\*

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* ids query

\* 构造一个只会匹配的特定数据 id 的查询。

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder idsQuery() \{

return QueryBuilders.idsQuery().ids("CHszwWRURyK08j01p0Mmug", "ojGrYKMEQCCPvh75lHJm3A");

/\*\*

\* TODO NotSolved

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* constant score query

\* 另一个查询和查询,包裹查询只返回一个常数分数等于提高每个文档的查询。

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder constantScoreQuery() \{

/\*return // Using with Filters

QueryBuilders.constantScoreQuery(FilterBuilders.termFilter("name", "kimchy"))

.boost(2.0f);\*/

// With Queries

return QueryBuilders.constantScoreQuery(QueryBuilders.termQuery("name", "葫芦3033娃"))

.boost(2.0f);

/\*\*

\* TODO NotSolved

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* disjunction max query

\* 一个生成的子查询文件产生的联合查询，

\* 而且每个分数的文件具有最高得分文件的任何子查询产生的，

\* 再加上打破平手的增加任何额外的匹配的子查询。

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder disMaxQuery() \{

return QueryBuilders.disMaxQuery()

.add(QueryBuilders.termQuery("name", "kimchy")) // Your queries

.add(QueryBuilders.termQuery("name", "elasticsearch")) // Your queries

.boost(1.2f)

.tieBreaker(0.7f);

/\*\*

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* fuzzy query

\* 使用模糊查询匹配文档查询。

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder fuzzyQuery() \{

return QueryBuilders.fuzzyQuery("name", "葫芦3582");

/\*\*

\* TODO NotSolved

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* has child / has parent

\* 父或者子的文档查询

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder hasChildQuery() \{

return // Has Child

QueryBuilders.hasChildQuery("blog\_tag",

QueryBuilders.termQuery("tag", "something"));

// Has Parent

/\*return QueryBuilders.hasParentQuery("blog",

QueryBuilders.termQuery("tag","something"));\*/

/\*\*

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* matchall query

\* 查询匹配所有文件。

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder matchAllQuery() \{

return QueryBuilders.matchAllQuery();

/\*\*

\* TODO NotSolved

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* more like this (field) query (mlt and mlt\_field)

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder moreLikeThisQuery() \{

// mlt Query

QueryBuilders.moreLikeThisQuery("home", "now\_home") // Fields

.likeText("山西省太原市7429街道") // Text

.minTermFreq(1) // Ignore Threshold

.maxQueryTerms(12); // Max num of Terms

// in generated queries

// mlt\_field Query

return QueryBuilders.moreLikeThisFieldQuery("home") // Only on single field

.likeText("山西省太原市7429街道")

.minTermFreq(1)

.maxQueryTerms(12);

/\*\*

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* prefix query

\* 包含与查询相匹配的文档指定的前缀。

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder prefixQuery() \{

return QueryBuilders.prefixQuery("name", "葫芦31");

/\*\*

\* TODO NotSolved

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* querystring query

\* 　　查询解析查询字符串,并运行它。有两种模式,这种经营。

\* 第一,当没有添加字段(使用\{ @link QueryStringQueryBuilder \#字段(String)\},将运行查询一次,非字段前缀

\* 　　将使用\{ @link QueryStringQueryBuilder \# defaultField(字符串)\}。

\* 第二,当一个或多个字段

\* 　　(使用\{ @link QueryStringQueryBuilder \#字段(字符串)\}),将运行提供的解析查询字段,并结合

\* 　　他们使用DisMax或者一个普通的布尔查询(参见\{ @link QueryStringQueryBuilder \# useDisMax(布尔)\})。

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder queryString() \{

return QueryBuilders.queryString("+kimchy -elasticsearch");

/\*\*

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* range query

\* 查询相匹配的文档在一个范围。

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder rangeQuery() \{

return QueryBuilders

.rangeQuery("name")

.from("葫芦1000娃")

.to("葫芦3000娃")

.includeLower(true) //包括下界

.includeUpper(false); //包括上界

/\*\*

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* span queries (first, near, not, or, term)

\* 跨度查询

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder spanQueries() \{

// Span First

QueryBuilders.spanFirstQuery(

QueryBuilders.spanTermQuery("name", "葫芦580娃"), // Query

// Max查询范围的结束位置

);

// Span Near TODO NotSolved

QueryBuilders.spanNearQuery()

.clause(QueryBuilders.spanTermQuery("name", "葫芦580娃")) // Span Term Queries

.clause(QueryBuilders.spanTermQuery("name", "葫芦3812娃"))

.clause(QueryBuilders.spanTermQuery("name", "葫芦7139娃"))

.slop(30000) // Slop factor

.inOrder(false)

.collectPayloads(false);

// Span Not TODO NotSolved

QueryBuilders.spanNotQuery()

.include(QueryBuilders.spanTermQuery("name", "葫芦580娃"))

.exclude(QueryBuilders.spanTermQuery("home", "山西省太原市2552街道"));

// Span Or TODO NotSolved

return QueryBuilders.spanOrQuery()

.clause(QueryBuilders.spanTermQuery("name", "葫芦580娃"))

.clause(QueryBuilders.spanTermQuery("name", "葫芦3812娃"))

.clause(QueryBuilders.spanTermQuery("name", "葫芦7139娃"));

// Span Term

//return QueryBuilders.spanTermQuery("name", "葫芦580娃");

/\*\*

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* term query

\* 一个查询相匹配的文件包含一个术语。。

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder termQuery() \{

return QueryBuilders.termQuery("name", "葫芦580娃");

/\*\*

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* terms query

\* 一个查询相匹配的多个value

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder termsQuery() \{

return QueryBuilders.termsQuery("name", // field

"葫芦580娃", "葫芦3812娃") // values

.minimumMatch(1); // 设置最小数量的匹配提供了条件。默认为1。

/\*\*

\* TODO NotSolved

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* top children query

\* 构建了一种新的评分的子查询，与子类型和运行在子文档查询。这个查询的结果是，那些子父文档文件匹配。

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder topChildrenQuery() \{

return QueryBuilders.topChildrenQuery(

"blog\_tag", // field

QueryBuilders.termQuery("name", "葫芦3812娃") // Query

)

.score("max") // max, sum or avg

.factor(5)

.incrementalFactor(2);

/\*\*

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* wildcard query

\* 　　实现了通配符搜索查询。支持通配符\* < /tt>,

\* 　　匹配任何字符序列(包括空), ? < /tt>,

\* 　　匹配任何单个的字符。注意该查询可以缓慢,因为它

\* 　　许多方面需要遍历。为了防止WildcardQueries极其缓慢。

\* 　　一个通配符词不应该从一个通配符\* < /tt>或

\* 　　< /tt>  ?。

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder wildcardQuery() \{

return QueryBuilders.wildcardQuery("name", "葫芦\*2娃");

/\*\*

\* TODO NotSolved

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* nested query

\* 嵌套查询

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static QueryBuilder nestedQuery() \{

return QueryBuilders.nestedQuery("location", // Path

QueryBuilders.boolQuery() // Your query

.must(QueryBuilders.matchQuery("location.lat", 0.962590433140581))

.must(QueryBuilders.rangeQuery("location.lon").lt(0.00000000000000000003))

)

.scoreMode("total"); // max, total, avg or none

/\*\*

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\* indices query

\* 索引查询

\* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

\*/

protected static IndicesQueryBuilder indicesQuery() \{

// Using another query when no match for the main one

QueryBuilders.indicesQuery(

QueryBuilders.termQuery("name", "葫芦3812娃"),

Es\_Utils.INDEX\_DEMO\_01, "index2"

) //设置查询索引上执行时使用不匹配指数

.noMatchQuery(QueryBuilders.termQuery("age", "葫芦3812娃"));

// Using all (match all) or none (match no documents)

return QueryBuilders.indicesQuery(

QueryBuilders.termQuery("name", "葫芦3812娃"),

Es\_Utils.INDEX\_DEMO\_01, "index2"

) // 设置不匹配查询,可以是 all 或者 none

.noMatchQuery("none");

public static void main(String\[\] args) \{

Es\_Utils.startupClient();

try \{

searchTest(indicesQuery());

\} catch (Exception e) \{

e.printStackTrace();

\} finally \{

Es\_Utils.shutDownClient();

private static void searchTest(QueryBuilder queryBuilder) \{

//预准备执行搜索

Es\_Utils.client.prepareSearch(Es\_Utils.INDEX\_DEMO\_01)

.setTypes(Es\_Utils.INDEX\_DEMO\_01\_MAPPING)

.setQuery(queryBuilder)

.setFrom(0).setSize(20).setExplain(true)

.execute()

//注册监听事件

.addListener(new ActionListener() \{

@Override

public void onResponse(SearchResponse searchResponse) \{

Es\_Utils.writeSearchResponse(searchResponse);

@Override

public void onFailure(Throwable e) \{

\});

java QueryBuilder用法_【转载】Elasticsearch--java操作之QueryBuilders构建搜索Query

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关使用QueryBuilders、NativeSearchQuery实现复杂查询

相关 elasticsearch基本操作之--使用QueryBuilders进行范围时间组合查询

相关 java QueryBuilder用法_【转载】Elasticsearch--java操作之QueryBuilders构建搜索Query

相关 QueryBuilders.rangeQuery

相关 QueryBuilders的matchQuery

相关 QueryBuilders.termsQuery

相关 QueryBuilder: A Simple Way to Read and Write Query Strings

相关 elasticsearch4java操作之QueryBuilders构建搜索Query

相关 java操作elasticsearch使用QueryBuilders进行数据查询

相关 Spring boot中mongoDB的查询--Query， QueryBuilder、BasicQuery