ES的各种查询构建(部分Java代码)
warning:
这篇文章距离上次修改已过180天,其中的内容可能已经有所变动。
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.functionscore.FunctionScoreQueryBuilder;
import org.elasticsearch.index.query.functionscore.ScoreFunctionBuilders;
// 创建一个匹配查询
QueryBuilder matchQuery = QueryBuilders.matchQuery("field", "value");
// 创建一个函数得分查询
FunctionScoreQueryBuilder functionScoreQuery = QueryBuilders.functionScoreQuery()
.add(ScoreFunctionBuilders.fieldValueFactorFunction("field")) // 使用字段值因子函数
.scoreMode("sum") // 设置分数模式为求和
.setMinScore(1.0f); // 设置最小分数
// 创建一个布尔查询
QueryBuilder boolQuery = QueryBuilders.boolQuery()
.must(matchQuery) // 必须匹配的查询
.should(QueryBuilders.termQuery("tag", "java")) // 可能匹配的查询
.filter(QueryBuilders.rangeQuery("date").from("2020-01-01")); // 过滤查询
// 创建一个范围查询
QueryBuilder rangeQuery = QueryBuilders.rangeQuery("age")
.from(18)
.to(30)
.includeLower(true)
.includeUpper(false);
// 创建一个前缀查询
QueryBuilder prefixQuery = QueryBuilders.prefixQuery("field", "val");
// 创建一个通配符查询
QueryBuilder wildcardQuery = QueryBuilders.wildcardQuery("field", "val*");
// 创建一个模糊查询
QueryBuilder fuzzyQuery = QueryBuilders.fuzzyQuery("field", "value");
// 创建一个类型查询
QueryBuilder typeQuery = QueryBuilders.typeQuery("_doc");
// 创建一个组合查询
QueryBuilder disMaxQuery = QueryBuilders.disMaxQuery()
.add(QueryBuilders.matchQuery("field1", "value"))
.add(QueryBuilders.matchQuery("field2", "value"));
// 创建一个查询字符串查询
QueryBuilder queryStringQuery = QueryBuilders.queryStringQuery("value");
// 创建一个地理边界查询
QueryBuilder geoBoundingBoxQuery = QueryBuilders.geoBoundingBoxQuery("location")
.setCorners(40, -70, 40, -100); // 设置边界的两个对角点
// 创建一个地理距离查询
QueryBuilder geoDistanceQuery = QueryBuilders.geoDistanceQuery("location")
.point(40, -70)
.distance(100, DistanceUnit.KILOMETERS);
// 创建一个组合查询
CompoundQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery()
.must(QueryBuilders.matchQuery("field", "value"))
.filter(QueryBuilders.termQuery("tag", "java"));
// 创建一个常量查询
QueryBuilder constantScoreQuery = QueryBuilders.constantScoreQuery(QueryBuilders.termQuery("field", "value")).boost(1.2f);
// 创建一个条件查询
QueryBuilder conditionalQuery = QueryBuilders.conditionalQuery(
QueryBuilders.termQuery("field", "value"),
QueryBuilders.termQuery("field", "value2"),
评论已关闭