ElasticSearch Java API 增删改查操作 - HelloWorld开发者社区

1.添加pom.xml依赖

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

API基本操作2.连接到elasticsearch集群

private static TransportClient client;                                                                 static {// 1、获取客户端对象，设置连接的集群名称                                                              Settings settings= Settings.builder().put("cluster.name","elasticsearch").build();        client=new PreBuiltTransportClient(settings);        // 2、连接集群        try {            client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("hadoop-001"), 9300));            System.out.println(client.toString());        } catch (UnknownHostException e) {            e.printStackTrace();        }}

3.创建索引

public static void creatIndex(){

        //1.创建索引（indices指数）        client.admin().indices().prepareCreate("blog").get();        //2.关闭连接        client.close();    }

4.删除索引

  public static void deleteIndex(){        //1.创建索引（indices指数）        client.admin().indices().prepareDelete("blog").get();        //2.关闭连接        client.close();    }

5 新建文档（源数据是手写的 json 串）

public  static  void  creatIndexByJason(){        // 1、文档数据准备        String json = "{" + "\"id\":\"1\"," + "\"title\":\"基于Lucene的搜索服务器\","                + "\"content\":\"它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口\"" + "}";        String jason2="{"+ "\"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();    }

6 新建文档（源数据是以 map 方式添加的键值对）

public  static  void  creatIndexByMap(){        // 1、文档数据准备        Map<String,Object> json=new HashMap<String,Object>();       //2.创建文档        json.put("id", "2");        json.put("title", "基于Lucene的搜索服务器");        json.put("content", "它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口");        IndexResponse indexResponse=client.prepareIndex("blog","article","2").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();    }

7 新建文档（源数据是通过 es 构建器构建的数据）

  public  static  void  creatIndexByBuilder()  {        //1.通过es自带的帮助类，来构建json数据        XContentBuilder builder= null;        try {            builder = XContentFactory.jsonBuilder().startObject()                    .field("id","3")                    .field("title","基于Lucene的搜索服务器")                    .field("content", "它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口")                    .endObject();        } catch (IOException e) {            e.printStackTrace();        }        IndexResponse indexResponse=client.prepareIndex("blog","article","3").setSource(builder).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();    }

8 搜索文档数据（单个索引）

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

9 搜索文档数据（多个索引）

public static  void 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();    }

10 更新文档数据（update）

  public static void updateData()  {        // 1、创建更新数据的请求对象        UpdateRequest updateRequest = new UpdateRequest();        updateRequest.index("blog");        updateRequest.type("article");        updateRequest.id("3");        try {            updateRequest.doc(XContentFactory.jsonBuilder().startObject()                    .field("title", "基于Lucene的搜索服务器") // 对没有的字段进行添加，对已有的字段进行替换                    .field("content", "它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口。大数据前景无限")                    .field("createDate", "2017-8-22").endObject());        } catch (IOException e) {            e.printStackTrace();        }        // 2、获取更新后的值        UpdateResponse indexResponse = null;        try {            indexResponse = client.update(updateRequest).get();        } catch (InterruptedException e) {            e.printStackTrace();        } catch (ExecutionException e) {            e.printStackTrace();        }        // 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();    }

11 更新文档数据（upsert）

public static void upsertData() throws Exception {        // 设置查询条件，查找不到则添加 IndexRequest 内容        IndexRequest indexRequest = new IndexRequest("blog", "article", "5")                .source(XContentFactory.jsonBuilder().startObject()                        .field("title", "搜索服务器")                        .field("content","Elasticsearch是用Java开发的，并作为Apache许可条款下的开放源码发布，是当前流行的企业级搜索引擎。").endObject());        // 设置更新，查找到则按照 UpdateRequest 更新        UpdateRequest upsert = new UpdateRequest("blog", "article", "5")                .doc(XContentFactory.jsonBuilder().startObject().field("user", "李四").endObject()).upsert(indexRequest);        client.update(upsert).get();        client.close();    }

12 删除文档数据（prepareDelete）

 public static void deleteData() {        // 1、删除文档数据        DeleteResponse indexResponse = client.prepareDelete("blog", "article", "2").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("result:" + indexResponse.getResult());        // 3、关闭连接        client.close();    }

条件查询

1 查询所有（matchAllQuery）

public static  void matchAllQuery(){

    //1.执行查询（查询所有）        SearchResponse searchResponse=client.prepareSearch("blog").setTypes("article")                .setQuery(QueryBuilders.matchAllQuery()).get();        // 2、打印查询结果        SearchHits hits=searchResponse.getHits();//获取命中数，查询结果有多少对象        System.out.println("查询结果一共有"+hits.totalHits+"条");        for (SearchHit hit : hits) {            System.out.println(hit.getSourceAsString());        }    }

2 对所有字段分词查询（queryStringQuery）

public static void queryStringQuery() {    // 1、条件查询（对所有字段分词查询）    SearchResponse searchResponse = client.prepareSearch("blog").setTypes("article")            .setQuery(QueryBuilders.queryStringQuery("全文")).get();    // 2、打印查询结果    SearchHits hits = searchResponse.getHits(); // 获取命中次数，查询结果有多少对象    System.out.println("查询结果有：" + hits.getTotalHits() + "条");    Iterator<SearchHit> iterator = hits.iterator();    while (iterator.hasNext()) {        SearchHit searchHit = iterator.next(); // 每个查询对象        System.out.println(searchHit.getSourceAsString()); // 获取字符串格式打印    }    // 3、关闭连接    client.close();}

3 通配符查询（wildcardQuery）

public static  void wildcardQuery() {    // 1、通配符查询    SearchResponse searchResponse = client.prepareSearch("blog").setTypes("article")            .setQuery(QueryBuilders.wildcardQuery("content", "*全*")).get();    // 2、打印查询结果    SearchHits hits = searchResponse.getHits(); // 获取命中次数，查询结果有多少对象    System.out.println("查询结果有：" + hits.getTotalHits() + "条");    Iterator<SearchHit> iterator = hits.iterator();    while (iterator.hasNext()) {        SearchHit searchHit = iterator.next(); // 每个查询对象        System.out.println(searchHit.getSourceAsString()); // 获取字符串格式打印    }    // 3、关闭连接    client.close();}

4 词条查询（TermQuery）

public static void termQuery() {    // 1、词条查询    SearchResponse searchResponse = client.prepareSearch("blog").setTypes("article")            .setQuery(QueryBuilders.termQuery("content", "全")).get(); // 因为没有使用 IK 分词器，所有只能一个字一个字的查    // 2、打印查询结果    SearchHits hits = searchResponse.getHits(); // 获取命中次数，查询结果有多少对象    System.out.println("查询结果有：" + hits.getTotalHits() + "条");    Iterator<SearchHit> iterator = hits.iterator();    while (iterator.hasNext()) {        SearchHit searchHit = iterator.next(); // 每个查询对象        System.out.println(searchHit.getSourceAsString()); // 获取字符串格式打印    }    // 3、关闭连接    client.close();}

5 模糊查询（fuzzy）

public static void fuzzyQuery() {    // 1、模糊查询    SearchResponse searchResponse = client.prepareSearch("blog").setTypes("article")            .setQuery(QueryBuilders.fuzzyQuery("title", "lucene")).get();    // 2、打印查询结果    SearchHits hits = searchResponse.getHits(); // 获取命中次数，查询结果有多少对象    System.out.println("查询结果有：" + hits.getTotalHits() + "条");    Iterator<SearchHit> iterator = hits.iterator();    while (iterator.hasNext()) {        SearchHit searchHit = iterator.next(); // 每个查询对象        System.out.println(searchHit.getSourceAsString()); // 获取字符串格式打印    }    // 3、关闭连接    client.close();}

映射相关操作

public static void createMapping() throws Exception {    // 1、创建索引（indices 指数）    //client.admin().indices().prepareCreate("blog2").get();    // 1、设置 mapping    XContentBuilder builder = XContentFactory.jsonBuilder()            .startObject()                .startObject("article2")                     .startObject("properties")                         .startObject("id2")                         .field("type", "text")                         .field("store", "true")                         .endObject()                         .startObject("title2")                             .field("type", "text")                             .field("store", "false")                         .endObject()                         .startObject("content2")                              .field("type", "text")                              .field("store", "true")                          .endObject()                       .endObject()                .endObject()            .endObject();    // 2、添加 mapping    PutMappingRequest mapping = Requests.putMappingRequest("blog2").type("article2").source(builder);    client.admin().indices().putMapping(mapping).get();    // 3、关闭资源    client.close();}