ES的各种查询构建(部分Java代码)
    		       		warning:
    		            这篇文章距离上次修改已过435天,其中的内容可能已经有所变动。
    		        
        		                
                
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"),
              
评论已关闭