Elasticsearch中动态滤波器的构建

Question

我正在构建API。我在弹性搜索中有身份证，名字，价格。客户机为我提供输入json和要应用的过滤器。

输入1：下面用户正在筛选ID=1（整数）的记录

{
    "filters": {
        "id":1
    }

}

输入2：用户正在查询带有city=tokyo的记录

{
    "filters": {
        "city":"tokyo"
    }

}

用于处理输入和查询到弹性搜索的Java代码

        filters = ipjson.path("filters");
        Iterator<Entry<String, JsonNode>> ite = filters.fields();

        while (ite.hasNext()) {
            Entry<String, JsonNode> ele = ite.next();
            String key = ele.getKey();
            if (ele.getValue().isInt()) {
                andFilter.add(FilterBuilders.termFilter(key, ele.getValue().asInt()))

            } else if (ele.getValue().isTextual()) {
                andFilter.add(FilterBuilders.termFilter(key, ele.getValue().textValue()));
            }


        }

对于过滤器中接收的每个键，我都在检查输入值的数据类型。

我想支持所有的专栏。我想要一个通用的解决方案，而不检查输入数据类型。

输入3：

{
        "filters": {
            "city":"tokyo",
            "id":3,
            "price":134.45
        }

}

在不对每个字段及其数据类型进行任何处理的情况下，我想用java API在elasticsearch中查询上面的过滤器。我该怎么做？

更新：

试图将所有字符串参数发送到弹性搜索，得到以下异常

SearchParseException[[project][4]: from[-1],size[-1]: Parse Failure [Failed to parse source [{"query":{"filtered":{"filter":{"and":{"filters":[{"term":{"id":"\"1\""}}]}}}}}]]]; nested: NumberFormatException[For input string: ""1""]; }
    at org.elasticsearch.action.search.type.TransportSearchTypeAction$BaseAsyncAction.onFirstPhaseResult(TransportSearchTypeAction.java:233) ~[elasticsearch-1.4.1.jar:na]
    at org.elasticsearch.action.search.type.TransportSearchTypeAction$BaseAsyncAction$1.onFailure(TransportSearchTypeAction.java:179) ~[elasticsearch-1.4.1.jar:na]
    at org.elasticsearch.search.action.SearchServiceTransportAction$23.run(SearchServiceTransportAction.java:565) ~[elasticsearch-1.4.1.jar:na]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) ~[na:1.7.0_60]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) ~[na:1.7.0_60]

Answer 1

在为FilterBuilder使用termFilter时，不需要显式指定值，因为它支持所有基本的基本Java类型，如(float、int、long、string、object)。因此，只需使用FilterBuilders.termFilter(key，ele.getValue())，apache lucene引擎负责处理类型。