elasticsearch Insert 插入数据和delete 删除数据（Java），

elasticsearch Insert 插入数据和delete 删除数据（Java），

首先我不赞成再采用一些中间件（jar包）来解决和 Elasticsearch  之间的交互，比如 Spring-data-elasticsearch.jar 系列一样，用就得依赖它。而 Elasticsearch  本身的用法就是很简洁的，也很容易，只要稍微加一下封装，即可解决。下面上我的简单封装的批量处理。

1. package com.sojson.core.elasticsearch.manager;
3. import java.util.ArrayList;
4. import java.util.HashMap;
5. import java.util.List;
6. import java.util.Map;
8. import net.sf.json.JSONObject;
10. import org.elasticsearch.action.bulk.BulkRequestBuilder;
11. import org.elasticsearch.action.bulk.BulkResponse;
12. import org.elasticsearch.action.index.IndexRequestBuilder;
14. import com.sojson.common.utils.StringUtils;
15. import com.sojson.core.elasticsearch.utils.ESTools;
17. public class InsertManager {
19. /**
20. * 添加数据到Elasticsearch
21. * @param index 索引
22. * @param type 类型
23. * @param idName Id字段名称
24. * @param json 存储的JSON，可以接受Map
25. * @return
26. */
27. public static Map save(String index, String type, String idName,JSONObject json) {
28. List list = new ArrayList();
29. list.add(json);
30. return save(index, type, idName, list);
31. }
34. /**
35. * 添加数据到Elasticsearch
36. * @param index 索引
37. * @param type 类型
38. * @param idName Id字段名称
39. * @param listData 一个对象集合
40. * @return
41. */
42. @SuppressWarnings("unchecked")
43. public static Map save(String index, String type, String idName,List listData) {
44. BulkRequestBuilder bulkRequest = ESTools.client.prepareBulk().setRefresh(true);
45. Map resultMap = new HashMap();
48. for (Object object : listData) {
49. JSONObject json = JSONObject.fromObject(object);
50. //没有指定idName 那就让Elasticsearch自动生成
51. if(StringUtils.isBlank(idName)){
52. IndexRequestBuilder lrb = ESTools.client                                                             .prepareIndex(index, type)                                                                 .setSource(json);
53. bulkRequest.add(lrb);
54. }
55. else{
56. String idValue = json.optString(idName);
57. IndexRequestBuilder lrb = ESTools.client                                                                 .prepareIndex(index, type,idValue)                                                                 .setSource(json);
58. bulkRequest.add(lrb);
59. }
61. }
63. BulkResponse bulkResponse = bulkRequest.execute().actionGet();
64. if (bulkResponse.hasFailures()) {
65. // process failures by iterating through each bulk response item
66. System.out.println(bulkResponse.getItems().toString());
67. resultMap.put("500", "保存ES失败!");
68. return resultMap;
69. }
70. bulkRequest = ESTools.client.prepareBulk();
71. resultMap.put("200", "保存ES成功!");
72. return resultMap;
73. }
74. }

Elasticsearch的删除也是很灵活的，下次我再介绍，DeleteByQuery的方式。今天就先介绍一个根据ID删除。上代码。



1. package com.sojson.core.elasticsearch.manager;
3. import org.elasticsearch.action.delete.DeleteResponse;
5. import com.sojson.common.model.SOBanggKey;
6. import com.sojson.core.elasticsearch.utils.ESTools;
8. public class DeleteManager {
9. /**
10. * 根据ID删除
11. * @param key
12. * @return
13. */
14. public static int deleteSOBanggByKey(SOBanggKey key) {
15. //这里可以忽略，组装一个我业务逻辑的ID
16. String prefix = "%sx_x%s";
17. String id = String.format(prefix, key.getId(),key.getGid());
19. DeleteResponse result = ESTools.client.prepareDelete().setRefresh(true).setIndex(MappingManager.INDEX)
20. .setType(MappingManager.B_TYPE)
21. .setId(id)//设置ID
22. .setRefresh(true)//刷新
23. .execute().actionGet();
24. //是否查找并删除
25. boolean isfound = result.isFound();
26. return isfound?1:0;
27. }
29. }