Elasticsearch添加修改删除索引文档

bboss

本文介绍如何采用bboss es添加/修改/查询/删除/批量删除elasticsearch索引文档，直接看代码。

增删改查操作

  1. 添加/修改文档：
  3. TAgentInfo agentInfo = new TAgentInfo() ;
  4. agentInfo.setIp("192.168.137.1")；//ip属性作为文档唯一标识，根据ip值对应的索引文档存在与否来决定添加或者修改操作
  5. //设置地理位置坐标
  6. agentInfo.setLocation("28.292781,117.238963");
  7. //设置其他属性
  8. 。。。。
  9. ClientInterface clientUtil = ElasticSearchHelper.getRestClientUtil();                
  10. clientUtil.addDocument("agentinfo",//索引名称
  11.                        "agentinfo",//索引类型
  12.                         agentInfo);//索引数据对象
  13. //执行查询操作
  14. ESDatas<TAgentInfo> data //ESDatas为查询结果集对象，封装了返回的当前查询的List<TAgentInfo>结果集和符合条件的总记录数totalSize
  15.             = clientUtil.searchList("trace-*/_search",//查询操作，查询indices trace-*中符合条件的数据
  16.                                 "queryServiceByCondition",//通过名称引用配置文件中的query dsl语句
  17.                                 traceExtraCriteria,//查询条件封装对象
  18.                                 TAgentInfo.class);//指定返回的po对象类型，po对象中的属性与indices表中的文档filed名称保持一致
  19. TAgentInfo的结构如下：
  21. public class TAgentInfo implements java.io.Serializable{
  22.     private String hostname;
  23.     @ESId   //ip属性作为文档唯一标识，根据ip值对应的索引文档存在与否来决定添加或者修改操作
  24.     private String ip;
  25.     private String ports;
  26.     private String agentId;
  27.     private String location;
  28.     private String applicationName;
  29.     private int serviceType;
  30.     private int pid;
  31.     private String agentVersion;
  32.     private String vmVersion;
  33.     //日期类型
  34.     private Date startTimestampDate;
  35.     private Date endTimestampDate;
  36.     private long startTimestamp;
  37.     private long endTimestamp;
  38.     private int endStatus;
  39.     private String serverMetaData;
  40.     private String jvmInfo;    
  41. }
  42. //删除索引文档
  43. clientUtil.deleteDocument("agentinfo",//索引表
  44.       "agentinfo",//索引类型
  45.       "192.168.137.1");//文档id
  47. //批量删除索引文档
  48. clientUtil.deleteDocuments("agentinfo",//索引表
  49.       "agentinfo",//索引类型
  50.       "192.168.137.1","192.168.137.2","192.168.137.3");//文档ids

执行多表查询操作

  1. //执行多表查询操作
  2. ESDatas<TAgentInfo> data //ESDatas为查询结果集对象，封装了返回的当前查询的List<TAgentInfo>结果集和符合条件的总记录数totalSize
  3.             = clientUtil.searchList("trace1,trace2/_search",//查询操作，同时查询trace1,trace2中符合条件的数据
  4.                                 "queryServiceByCondition",//通过名称引用配置文件中的query dsl语句
  5.                                 traceExtraCriteria,//查询条件封装对象
  6.                                 TAgentInfo.class);//指定返回的po对象类型，po对象中的属性与indices表中的文档filed名称保持一致