Elasticsearch5.X Jest API 典型代码实现(安全连接、创建索引、逻辑条件检索)

笔者在进行Elasticsearch开发过程中，通过API的不同比较，选择了Rest API：Jest。然后在墙内百度Jest的示例代码时，发现很多博客的示例都是最简单的例子，无法满足真正生产环境的应用。基于此，笔者写这篇博客，将通过Jest实现的ES交互典型示例总结如下：

1 创建索引

通过百度获取的Jest API示例中，对于索引创建的代码，都是不带settings和mappings的，生产环境开发时，不满足条件，下面是对于带具体settings和mappings的代码示例：

    /**
     * 创建索引
     * @param client
     * @throws IOException
     */
    public JestResult createIndex(JestClient client) throws IOException {
        String index = "stringyone";
        String expectedType1Maping =
                ""_source":{"enabled":false},"properties":{"field1":{"type":"keyword"}}";
        String settingsJson = "{
" +
                "    "settings" : {
" +
                "        "number_of_shards" : 8
" +
                "    },
" +
                "    "mappings" : {"type1": {" + expectedType1Maping + "}}" +
                "}";

        //此处settingsJson字符串就是settings 和 mappings
        CreateIndex createIndex = new CreateIndex.Builder(index)
                .settings(settingsJson)
                .build();

        JestResult result = client.execute(createIndex);
        return result;
    }

2 带安全认证的ES连接创建

    /**
     * 获取JestClient对象
     * @return
     */
    private static JestClient getJestClient() {
        JestClientFactory factory = new JestClientFactory();
        factory.setHttpClientConfig(new HttpClientConfig
                .Builder("http://127.0.0.1:9200")
                .defaultCredentials(username,password)
                .gson(new GsonBuilder().setDateFormat("yyyy-MM-dd'T'HH:mm:ss").create())
                .multiThreaded(true)
                .readTimeout(10000)
                .build());
        JestClient client = factory.getObject();
        return client;
    }

3 条件查询

    /**
     * 带条件检索
     * 实现类似  select * from table where filed = queryString AND (... or条件字段 ...)
     * @param indexName   索引名
     * @param typeName    类型名
     * @param queryString 查询内容
     * @param field       字段对象，包括查询字段及查询字段的值
     * @param fieldForOrs 查询条件 or区分
     * @param client
     * @param pageNumber  页码
     * @param pageSize    页数
     * @return
     */
    public JestResult index(String indexName, String typeName, String queryString, String field, List<Field> fieldForOrs, JestClient client, int pageNumber, int pageSize) {
        //声明一个SearchSourceBuilder对象，构造检索请求体
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();

        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();

        //构造查询哪个字段
        if(StringUtils.isEmpty(field)) {
            //没有检索条件，则全字段查询
            boolQueryBuilder = boolQueryBuilder.must(QueryBuilders.queryStringQuery(queryString));
        } else {
            boolQueryBuilder = boolQueryBuilder.must(QueryBuilders.matchQuery(field,queryString));
        }

        BoolQueryBuilder innerQueryBuilder = QueryBuilders.boolQuery();
        for(Field fieldValue : fieldForOrs) {
            innerQueryBuilder = innerQueryBuilder.should(QueryBuilders.termQuery(fieldValue.getFieldName(),fieldValue.getFieldValue()));
        }
        boolQueryBuilder = boolQueryBuilder.filter(innerQueryBuilder);

        searchSourceBuilder.query(boolQueryBuilder);

        //设置高亮字段
        HighlightBuilder highlightBuilder = new HighlightBuilder();
        highlightBuilder.field(field);
        highlightBuilder.preTags("<em>").postTags("</em>");
        highlightBuilder.fragmentSize(200);
        searchSourceBuilder.highlight(highlightBuilder);

        //设置分页
        searchSourceBuilder.from((pageNumber - 1) * pageSize);
        searchSourceBuilder.size(pageSize);

        //构建Search对象
        Search search =  new Search.Builder(searchSourceBuilder.toString())
                .addIndex(indexName)
                .addType(typeName)
                .build();

        SearchResult searchResult = null;
        try {
            searchResult = client.execute(search);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return searchResult;
    }

4 总结建议

 笔者上面的代码采用的jar包时 jest-2.0.0.jar，对于不同版本的jar包，上述代码中具体一些方法可能出现不同，这个需要读者自己注意。

另外，强烈建议FORK下载Github上的Jest项目，可能不需要关注其源码，但项目自带的单元测试代码，几乎涵盖了Jest对于ES的各类操作

Github地址：https://github.com/searchbox-io/Jest