走进大数据丨 ElasticSearch6.X的JavaAPI使用二

ゝ一纸荒年。 2023-06-29 10:45 88阅读 0赞

接续上篇[走进大数据丨ElasticSearch6.X的JavaAPI使用一][ElasticSearch6.X_JavaAPI]

**查看数据**

public static void getIndex() throws Exception {
            GetResponse documentFields = getConnection().prepareGet("blog", "article", "1").get();
            System.out.println(documentFields.getSourceAsString());
            getConnection().close();
        }

**查看多条数据**

public static void getMultiData() throws Exception {
            MultiGetResponse documentFields = getConnection().prepareMultiGet()
                    .add("blog", "article", "1")
                    .add("blog", "article", "1","2","Yaad1m4Be1-QAfKzsqjh").get();
            for(MultiGetItemResponse multidata : documentFields) {
                GetResponse response = multidata.getResponse();
                if(response.isExists()) {
                    System.out.println(response.getSourceAsString());
                }
            }
            getConnection().close();
        }

**更新数据**

public static void update() throws Exception {
            IndexRequest indexRequest = new IndexRequest("blog", "article", "10").source(
                    XContentFactory.jsonBuilder()
                            .startObject()
                            .field("id", "10")
                            .field("content", "ElasticSearch是基于Lucene的搜索服务器")
                            .field("createdate", "2019-12-05")
                            .endObject()
            );
    
    
            /*--------------------------------------------*/
            UpdateRequest updateRequest = new UpdateRequest("blog", "article", "10");
            updateRequest.doc(XContentFactory.jsonBuilder()
                    .startObject()
                    .field("id","10")
                    .field("content","ElasticSearch是基于Lucene的搜索服务器")
                    .field("createdate","2019-12-05")
                    .endObject()).upsert(indexRequest);
            UpdateResponse updateResponse = getConnection().update(updateRequest).get();
            //打印返回结果
            System.out.println("index: "+updateResponse.getIndex());
            System.out.println("Type: "+updateResponse.getType());
            System.out.println("ID: "+updateResponse.getId());
            System.out.println("version: "+updateResponse.getVersion());
            System.out.println("Result: "+updateResponse.getResult());
            getConnection().close();
        }

**删除数据**

public static void deleteData() throws Exception {
            getConnection().prepareDelete("blog", "article", "10").get();
            getConnection().close();
        }

查询数据：like的方式,对所有字段进行like匹配

public static void likeData() throws Exception {
            SearchResponse searchResponse = getConnection().prepareSearch("blog").setTypes("article").setQuery(QueryBuilders.queryStringQuery("基于")).get();
            SearchHits hits = searchResponse.getHits();
            System.out.println("查询结果有"+hits.totalHits+"条");
            for (SearchHit searchHits:hits
                 ) {
                System.out.println(searchHits.getSourceAsString());
            }
    
    
            getConnection().close();
        }

**通配符查询，可以指定字段**

public static void tpdata() throws Exception {
            SearchResponse searchResponse = getConnection().prepareSearch("blog").setTypes("article").setQuery(QueryBuilders.wildcardQuery("content","*服务器*")).get();
            SearchHits hits = searchResponse.getHits();
            System.out.println("查询结果有"+hits.totalHits+"条");
            for (SearchHit searchHits:hits
            ) {
                System.out.println(searchHits.getSourceAsString());
            }
    
    
            getConnection().close();
        }

termQuery查询，类似于等于

public static void treamdata() throws Exception {
            SearchResponse searchResponse = getConnection().prepareSearch("blog").setTypes("article").setQuery(QueryBuilders.termQuery("content","web")).get();
            SearchHits hits = searchResponse.getHits();
            System.out.println("查询结果有"+hits.totalHits+"条");
            for (SearchHit searchHits:hits
            ) {
                System.out.println(searchHits.getSourceAsString());
            }
    
    
            getConnection().close();
        }

fuzzyQuery查询，类似于模糊查询，需要分词

public static void fuzzymdata() throws Exception {
            SearchResponse searchResponse = getConnection().prepareSearch("blog").setTypes("article").setQuery(QueryBuilders.fuzzyQuery("content","接口")).get();
            SearchHits hits = searchResponse.getHits();
            System.out.println("查询结果有"+hits.totalHits+"条");
            for (SearchHit searchHits:hits
            ) {
                System.out.println(searchHits.getSourceAsString());
            }
    
    
            getConnection().close();
        }

**注意：****以上查询使用ES自带的分词中文容易分不出来，需要添加分词器，如IK，结巴等对中文支持比较好。**

![format_png][]

[ElasticSearch6.X_JavaAPI]: http://mp.weixin.qq.com/s?__biz=MzU2MjE1MTgyOQ%3D%3D&chksm=fc6cb077cb1b3961781fe3ce4ffa8adf78b7a602d6b8e03a140721db7c8ce7c22651fa8f53c8&idx=1&mid=2247489677&scene=21&sn=02a89cc8e0d03edb7ad850293ced85cd#wechat_redirect
[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X2pwZy9sR2x2b0tIblJVSjA2Qk1oaEIyRG05REptTG5JZmdtU2RMYmttTmw3M0FoSVgwajlxMURORVlFSFJ0MW54TFZma0F5RkxVSUdwcTY3ajV3aHJiNjBidy82NDA?x-oss-process=image/format,png