[ElasticSearch]Java API 之 索引文档 (Index API)

Index API 允许我们存储一个JSON格式的文档，使数据可以被搜索。文档通过index、type、id唯一确定。我们可以自己提供一个id，或者也使用Index API 为我们自动生成一个。

这里有几种不同的方式来产生JSON格式的文档(document)：

（1）手动方式，使用原生的byte[]或者String

（2）使用Map方式，会自动转换成与之等价的JSON

（3）使用第三方库来序列化beans，如Jackson

（4）使用内置的帮助类 XContentFactory.jsonBuilder()

1. 手动方式

1.    /**
2.     *  手动方式 产生JSON 索引文档
3.     * @param client
4.     * @param index
5.     * @param type
6.     * @param id
7.     * @param json
8.     */
9.    public static boolean indexDocByJSON(Client client, String index, String type, String id, String json) {
11.        // Index
12.        IndexRequestBuilder indexRequestBuilder = client.prepareIndex();
13.        indexRequestBuilder.setIndex(index);
14.        indexRequestBuilder.setType(type);
15.        indexRequestBuilder.setId(id);
16.        indexRequestBuilder.setSource(json);
17.        indexRequestBuilder.setTTL(8000);
19.        // 执行
20.        IndexResponse indexResponse = indexRequestBuilder.get();
21.        return indexResponse.isCreated();
23.    }

测试，下面代码存储梅西信息到索引为football-index，类型为football-type，id为1的文档中：

1.    @Test
2.    public void indexDocByJSON() throws Exception {
3.        String index = "football-index";
4.        String type = "football-type";
5.        String id = "1";
6.        String json = "{" +
7.                "\"club\":\"巴萨罗那\"," +
8.                "\"country\":\"阿根廷\"," +
9.                "\"name\":\"梅西\"" +
10.                "}";
11.        boolean result = IndexDocAPI.indexDocByJSON(client, index, type , id,  json);
12.        logger.info("--------- indexDocByJSON {}", result);
13.    }

2. Map方式

1.    /**
2.     *  使用Map 产生JSON 索引文档
3.     * @param client
4.     * @param index
5.     * @param type
6.     * @param id
7.     */
8.    public static boolean indexDocByMap(Client client, String index, String type, String id, Map<String, Object> map) {
10.        // Index
11.        IndexRequestBuilder indexRequestBuilder = client.prepareIndex();
12.        indexRequestBuilder.setIndex(index);
13.        indexRequestBuilder.setType(type);
14.        indexRequestBuilder.setId(id);
15.        indexRequestBuilder.setSource(map);
16.        indexRequestBuilder.setTTL(8000);
18.        // 执行
19.        IndexResponse indexResponse = indexRequestBuilder.get();
20.        return indexResponse.isCreated();
22.    }

测试，下面代码存储穆勒信息到索引为football-index，类型为football-type，id为2的文档中：

1.    @Test
2.    public void indexDocByMap() throws Exception {
3.        String index = "football-index";
4.        String type = "football-type";
5.        String id = "2";
7.        Map<String, Object> map = Maps.newHashMap();
8.        map.put("name", "穆勒");
9.        map.put("club", "拜仁慕尼黑俱乐部");
10.        map.put("country", "德国");
12.        boolean result = IndexDocAPI.indexDocByMap(client, index, type , id,  map);
13.        logger.info("--------- indexDocByMap {}", result);
15.    }

3.  序列化方式

1.    /**
2.     * 利用Json序列化 产生JSON 索引文档
3.     *
4.     * @param client
5.     * @param index
6.     * @param type
7.     * @param id
8.     */
9.    public static boolean indexDocByBean(Client client, String index, String type, String id, Object bean) {
11.        // Bean转换为字节
12.        ObjectMapper mapper = new ObjectMapper();
13.        byte[] json;
14.        try {
15.            json = mapper.writeValueAsBytes(bean);
16.        } catch (JsonProcessingException e) {
17.            logger.error("---------- json 转换失败 Bean:{}", bean.toString());
18.            return false;
19.        }
21.        // Index
22.        IndexRequestBuilder indexRequestBuilder = client.prepareIndex();
23.        indexRequestBuilder.setIndex(index);
24.        indexRequestBuilder.setType(type);
25.        indexRequestBuilder.setId(id);
26.        indexRequestBuilder.setSource(json);
27.        indexRequestBuilder.setTTL(8000);
29.        // 执行
30.        IndexResponse response = indexRequestBuilder.get();
31.        return response.isCreated();
32.    }

测试，下面代码存储卡卡信息到索引为football-index，类型为football-type，id为3的文档中：

4.  XContentBuilder帮助类方式

ElasticSearch提供了一个内置的帮助类XContentBuilder来产生JSON文档

1.    /**
2.     * 使用帮助类XContentBuilder 产生JSON 索引文档
3.     * @param client
4.     * @param index
5.     * @param type
6.     * @param id
7.     * @param xContentBuilder
8.     * @return
9.     */
10.    public static boolean indexDocByXContentBuilder(Client client, String index, String type, String id, XContentBuilder xContentBuilder) {
12.        // Index
13.        IndexRequestBuilder indexRequestBuilder = client.prepareIndex();
14.        indexRequestBuilder.setIndex(index);
15.        indexRequestBuilder.setType(type);
16.        indexRequestBuilder.setId(id);
17.        indexRequestBuilder.setSource(xContentBuilder);
18.        indexRequestBuilder.setTTL(8000);
20.        // 执行
21.        IndexResponse response = indexRequestBuilder.get();
22.        return response.isCreated();
24.    }

测试，下面代码存储托雷斯信息到索引为football-index，类型为football-type，id为4的文档中：

你还可以通过startArray(string)和endArray()方法添加数组。.field()方法可以接受多种对象类型。你可以给它传递数字、日期、甚至其他XContentBuilder对象。

参考：https://www.elastic.co/guide/en/elasticsearch/client/java-api/current/java-docs-index.html#java-docs-index-generate