elasticsearch java索引的增删改查

本是古典何须时尚 2021-11-02 10:56 487阅读 0赞

1.创建索引并插入数据
    Map<String, Object> json = new HashMap<String, Object>();
    json.put("user", "kimchy5");
    json.put("postDate", new Date());
    json.put("message", "trying out Elasticsearch");
    //参数设置
    //Settings settings = Settings.settingsBuilder().put("cluster.name", "elasticsearch").build();
    //TransportClient client = TransportClient.builder().settings(settings).build();
    Client client = TransportClient.builder().build()
            .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
    // 第一个参数：索引名；第二个参数：索引类型；第三个参数：索引ID(相同的id时修改数据，默认为随机字符串)
    IndexResponse indexResponse = client.prepareIndex("twitter", "json", "1").setSource(json).get();
    System.out.println(indexResponse);
    // 不指定id会随机生成一个
    //client.prepareIndex("twitter", "tweet").setSource(json);
    client.close();
    
    2.索引数据批量插入（插入效率高）
    // 批量插入数据，删除和修改也可以，不举例了
    BulkRequestBuilder bulkRequest = client.prepareBulk();
    IndexRequest request = client.prepareIndex("twitter", "tweet", "1").setSource(json).request();
    IndexRequest request2 = client.prepareIndex("twitter", "tweet", "2").setSource(json2).request();
    bulkRequest.add(request);
    bulkRequest.add(request2);
    bulkRequest.execute().actionGet();
    
    3.判断索引是否存在
    IndicesExistsRequest inExistsRequest = new IndicesExistsRequest("twitter");
    IndicesExistsResponse inExistsResponse = client.admin().indices().exists(inExistsRequest).actionGet();
    System.out.println("索引twitter是否存在："+inExistsResponse.isExists());
    
    4.删除索引
    //删除索引twitter
    client.admin().indices().prepareDelete("twitter").execute().actionGet();
    //删除索引中的某个文档（一条数据）
    client.prepareDelete("twitter", "tweet", "1");
    
    5.查询索引库
    Client client = TransportClient.builder().build()
            .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
     
    // 第一个参数：要查找的内容 第二，三个参数：要查找的字段
    QueryBuilder qb = QueryBuilders.multiMatchQuery("喧嚣", "content","message");
    // twitter：索引名 tweet:索引类型
    SearchResponse response = client.prepareSearch("twitter").setTypes("tweet").setQuery(qb)
    //设置查询类型  SearchType.QUERY_AND_FETCH：全部获取
                    .setSearchType(SearchType.DFS_QUERY_AND_FETCH).execute().actionGet();
     
    SearchHits hits = response.getHits();
    if (hits.totalHits() > 0) {
        for (SearchHit hit : hits) {
            System.out.println("score:" + hit.getScore() + ":\t" + hit.getSource());// .get("title")
        }
    } else {
        System.out.println("搜到0条结果");
    }
    client.close();
    
    6.刷新索引
    //刷新所有
    client.admin().indices().prepareRefresh().get();
    //刷新某一个
    client.admin().indices().prepareRefresh("twitter").get();
    //刷新某个类型
    client.admin().indices().prepareRefresh("twitter","tweet").get();
    
    7.更新索引数据
    //更新索引（根据索引，类型，id）
    UpdateRequest updateRequest = new UpdateRequest();
    updateRequest.index("twitter");
    updateRequest.type("tweet");
    updateRequest.id("1");
    updateRequest.doc(jsonBuilder().startObject().field("content", "如果我说爱我没有如果").endObject());
    client.update(updateRequest).get();
    或
    UpdateRequest updateRequest = new UpdateRequest("twitter", "tweet", "1")
            .doc(jsonBuilder().startObject().field("content", "如果我说爱我没有如果").endObject());
    client.update(updateRequest).get();
    
    8.插入更新
    //插入更新（如果不存在id为3的则插入content为IndexRequest的内容，如果存在则更新content为UpdateRequest的内容）
    IndexRequest indexRequest = new IndexRequest("twitter", "tweet", "3")
            .source(jsonBuilder().startObject()
                .field("content", "每当我迷失在黑夜里")
                .endObject());
    UpdateRequest updateRequest2 = new UpdateRequest("twitter", "tweet", "3")
            .doc(jsonBuilder().startObject()
                    .field("content", "请照亮我前行")
                    .endObject())
            .upsert(indexRequest); 
    client.update(updateRequest2).get();
    client.close();

转载于:https://www.cnblogs.com/gavinYang/p/11199643.html