Elasticsearch_API操作

<dependencies>
              <dependency>
                     <groupId>junit</groupId>
                     <artifactId>junit</artifactId>
                     <version>3.8.1</version>
                     <scope>test</scope>
              </dependency>
              <dependency>
                     <groupId>org.elasticsearch</groupId>
                     <artifactId>elasticsearch</artifactId>
                     <version>5.2.2</version>
              </dependency>
 
              <dependency>
                     <groupId>org.elasticsearch.client</groupId>
                     <artifactId>transport</artifactId>
                     <version>5.2.2</version>
              </dependency>
 
              <dependency>
                     <groupId>org.apache.logging.log4j</groupId>
                     <artifactId>log4j-core</artifactId>
                     <version>2.9.0</version>
              </dependency>
       </dependencies>

private TransportClient client;
 
       @SuppressWarnings("unchecked")
       @Before
       public void getClient() throws Exception {
 
              // 1 设置连接的集群名称
              Settings settings = Settings.builder().put("cluster.name", "my-application").build();
 
              // 2 连接集群
              client = new PreBuiltTransportClient(settings);
              client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("hadoop102"), 9300));
 
              // 3 打印集群名称
              System.out.println(client.toString());
       }

@Test
       publicvoid createIndex_blog(){
              // 1 创建索引
              client.admin().indices().prepareCreate("blog2").get();
             
              // 2 关闭连接
              client.close();
       }

@Test
       publicvoid deleteIndex(){
              // 1 删除索引
              client.admin().indices().prepareDelete("blog2").get();
             
              // 2 关闭连接
              client.close();
       }

@Test
       public void createIndexByJson() throws UnknownHostException {
 
              // 1 文档数据准备
              String json = "{" + "\"id\":\"1\"," + "\"title\":\"基于Lucene的搜索服务器\","
                            + "\"content\":\"它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口\"" + "}";
 
              // 2 创建文档
              IndexResponse indexResponse = client.prepareIndex("blog", "article", "1").setSource(json).execute().actionGet();
 
              // 3 打印返回的结果
              System.out.println("index:" + indexResponse.getIndex());
              System.out.println("type:" + indexResponse.getType());
              System.out.println("id:" + indexResponse.getId());
              System.out.println("version:" + indexResponse.getVersion());
              System.out.println("result:" + indexResponse.getResult());
 
              // 4 关闭连接
              client.close();
       }

@Test
       public void createIndex() throws Exception {
 
              // 1 通过es自带的帮助类，构建json数据
              XContentBuilder builder = XContentFactory.jsonBuilder().startObject().field("id", 3)
                            .field("title", "基于Lucene的搜索服务器").field("content", "它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口。")
                            .endObject();
 
              // 2 创建文档
              IndexResponse indexResponse = client.prepareIndex("blog", "article", "3").setSource(builder).get();
 
              // 3 打印返回的结果
              System.out.println("index:" + indexResponse.getIndex());
              System.out.println("type:" + indexResponse.getType());
              System.out.println("id:" + indexResponse.getId());
              System.out.println("version:" + indexResponse.getVersion());
              System.out.println("result:" + indexResponse.getResult());
 
              // 4 关闭连接
              client.close();
       }

@Test
       publicvoid getData() throws Exception {
             
              // 1 查询文档
              GetResponse response = client.prepareGet("blog", "article", "1").get();
             
              // 2 打印搜索的结果
              System.out.println(response.getSourceAsString());
             
              // 3 关闭连接
              client.close();
       }

@Test
       publicvoid getMultiData() {
             
              // 1 查询多个文档
              MultiGetResponse response = client.prepareMultiGet().add("blog", "article", "1").add("blog", "article", "2", "3")
                            .add("blog", "article", "2").get();
             
              // 2 遍历返回的结果
              for(MultiGetItemResponse itemResponse:response){
                     GetResponse getResponse = itemResponse.getResponse();
                    
                     // 如果获取到查询结果
                     if (getResponse.isExists()) {
                            String sourceAsString = getResponse.getSourceAsString();
                            System.out.println(sourceAsString);
                     }
              }
             
              // 3 关闭资源
              client.close();
       }

@Test
       publicvoid updateData() throws Throwable {
 
              // 1 创建更新数据的请求对象
              UpdateRequest updateRequest = new UpdateRequest();
              updateRequest.index("blog");
              updateRequest.type("article");
              updateRequest.id("3");
 
              updateRequest.doc(XContentFactory.jsonBuilder().startObject()
                            // 对没有的字段添加, 对已有的字段替换
                            .field("title", "基于Lucene的搜索服务器")
                            .field("content",
大数据前景无限")
.field("createDate", "2017-8-22").endObject());
 
              // 2 获取更新后的值
              UpdateResponse indexResponse = client.update(updateRequest).get();
             
              // 3 打印返回的结果
              System.out.println("index:" + indexResponse.getIndex());
              System.out.println("type:" + indexResponse.getType());
              System.out.println("id:" + indexResponse.getId());
              System.out.println("version:" + indexResponse.getVersion());
              System.out.println("create:" + indexResponse.getResult());
 
              // 4 关闭连接
              client.close();
       }

@Test
       publicvoid testUpsert() throws Exception {
 
              // 设置查询条件, 查找不到则添加
              IndexRequest indexRequest = new IndexRequest("blog", "article", "5")
                            .source(XContentFactory.jsonBuilder().startObject().field("title", "搜索服务器").field("content","它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口。Elasticsearch是用Java开发的，并作为Apache许可条款下的开放源码发布，是当前流行的企业级搜索引擎。设计用于云计算中，能够达到实时搜索，稳定，可靠，快速，安装使用方便。").endObject());
             
              // 设置更新, 查找到更新下面的设置
              UpdateRequest upsert = new UpdateRequest("blog", "article", "5")
                            .doc(XContentFactory.jsonBuilder().startObject().field("user", "李四").endObject()).upsert(indexRequest);
 
              client.update(upsert).get();
              client.close();
       }

@Test
       publicvoid deleteData() {
             
              // 1 删除文档数据
              DeleteResponse indexResponse = client.prepareDelete("blog", "article", "5").get();
 
              // 2 打印返回的结果
              System.out.println("index:" + indexResponse.getIndex());
              System.out.println("type:" + indexResponse.getType());
              System.out.println("id:" + indexResponse.getId());
              System.out.println("version:" + indexResponse.getVersion());
              System.out.println("found:" + indexResponse.getResult());
 
              // 3 关闭连接
              client.close();
       }