跳到主要内容

17、ElasticSearch 实战：ElasticSearch JavaApi 索引操作

JavaApi 索引操作

与RESTful api类似， java api 是采用代码的形式操作索引，也有相同的索引增、改、查操作。下面我们对api 一一进行测试。

创建索引

步骤：

1、 创建HttpHost对象，该对象主要用于链接ES服务器的描述，包含了,host,port,schema；
2、 创建RestClientBuilder对象，该对象由RestClient对象的静态方法build创建，需要带入HttpHost集群应该还可以带入多个HttpHost；
3、 创建关键对象RestHighLevelClient,该对象才是真正链接ES服务发起操作的对象；
4、 创建CreateIndexRequest对象，该对象是创建索引的请求对象，在7.8.0的版本上需要用org.elasticsearch.client.indices包下的，另外有一个同名的类，应该是过期了；
5、 发起创建请求，client.indices().create(req,RequestOptions.DEFAULT);,其中client就是RestHighLevelClient的实例对象；
6、 请求会响应一个CreateIndexResponse对象这个时候其实已经完成了创建操作了；
7、 最后记得关闭链接,client.close();；
代码如下：

package com.maomao.elastic.search.index;

import org.apache.http.HttpHost;
import org.elasticsearch.client.indices.CreateIndexRequest;
import org.elasticsearch.client.indices.CreateIndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;

import java.io.IOException;

/**
 * @author mao.kaiyin
 */
public class IndexCreate {
   
     

    public static void main(String[] args) throws IOException {
   
     
        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);
        //创建索引
        CreateIndexRequest req = new CreateIndexRequest("teacher");
        CreateIndexResponse res = client.indices().create(req, RequestOptions.DEFAULT);

        boolean acknowledged = res.isAcknowledged();
        System.out.println("索引操作: " + acknowledged);
        client.close();
    }

}

查询索引

查询索引的整体步骤其实和创建类似，差异就是第4,5步。

1、 第4步创建的对象是org.elasticsearch.client.indices.GetIndexRequest类的对象.；
2、 第5步不能在是create方法了而是get方法；
3、 最后请求响应的对象也是GetIndexResponse对象；
代码如下：

package com.maomao.elastic.search.index;

import org.apache.http.HttpHost;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.GetIndexRequest;
import org.elasticsearch.client.indices.GetIndexResponse;

import java.io.IOException;

public class IndexSearch {
   
     

    public static void main(String[] args) throws IOException {
   
     

        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        GetIndexRequest query = new GetIndexRequest("teacher");
        GetIndexResponse response = client.indices().get(query, RequestOptions.DEFAULT);

        System.out.println(response.getAliases());
        System.out.println(response.getMappings());
        System.out.println(response.getSettings());

        client.close();
    }

}

删除索引

与两者类似，差异也是在请求对象不一样，响应对象不一样，调用方法不一样。核心差异也就是第4,5步。

1、 第4步创建的对象是org.elasticsearch.client.indices.DeleteIndexRequest类的对象.；
2、 第5步不能在是create方法了而是get方法；
3、 最后请求响应的对象也是AcknowledgedResponse对象，响应不是DeleteIndexResponse,那说明应该是后续有一堆的操作响应的内容体是一致的，所以用了一个通用的响应对象AcknowledgedResponse；
代码如下：

package com.maomao.elastic.search.index;

import org.apache.http.HttpHost;
import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.GetIndexRequest;
import org.elasticsearch.client.indices.GetIndexResponse;

import java.io.IOException;

public class IndexDelete {
   
     

    public static void main(String[] args) throws IOException {
   
     

        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        DeleteIndexRequest query = new DeleteIndexRequest("teacher");
        AcknowledgedResponse delete = client.indices().delete(query, RequestOptions.DEFAULT);

        System.out.println("删除索引:" + delete.isAcknowledged());

        client.close();
    }

}

总结

通过上面的操作，可以总结整体操作的内容：

1、 javaapi的操作流程应该大致都是一致的，需要一个核心的对象RestHighLevelClient；
2、 对索引的操作都是IndicesClient,它是可以通过RestHighLevelClient对象的indices()方法获取到的；
3、 请求对象有差异，但都是XXXIndexRequest,除了delete以外，尽量用包org.elasticsearch.client.indices下的；
4、 响应的内容与restfulapi一致，都是对应内容的数据结构所以要获取什么内容可以从json内容中整体查看；