ElasticSearch（三）原生Java操作

创建项目，添加对应的依赖，该依赖的版本与ES的版本要一致（我使用的是window的ES，避免了linux的连接问题，仅用于学习ES操作）

<!--  原生JAVA操作ElasticSearch依赖  -->
<dependency>
    <groupId>org.elasticsearch</groupId>
    <artifactId>elasticsearch</artifactId>
    <version>7.7.1</version>
</dependency>
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.7.1</version>
</dependency>

创建一个空索引

/**
 * 创建一个空索引
 */
@Test
public void createNullIndex() {
    RestHighLevelClient client = null;
    try {
        // 1、创建客户端请求，连接ElasticSearch
        client = new RestHighLevelClient(RestClient.builder(new HttpHost("127.0.0.1", 9200, "http")));
        // 2、创建请求对象
        CreateIndexRequest request = new CreateIndexRequest("student");
        // 3、发起请求
        CreateIndexResponse response = client.indices().create(request, RequestOptions.DEFAULT);
        // 4、操作响应结果
        System.out.println(response.index());
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        // 5、关闭客户端
        if (client != null) {
            try {
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

创建一个有结构的索引

/**
 * 创建一个有结构的索引
 */
@Test
public void createMappingsIndex() {
    RestHighLevelClient client = null;
    try {
        // 1、创建一个客户端对象用于连接ES
        client = new RestHighLevelClient(RestClient.builder(new HttpHost("127.0.0.1", 9200, "http")));
        // 2、创建一个请求对象
        CreateIndexRequest request = new CreateIndexRequest("teacher");
        request.source("{\n" +
                "  \"mappings\": {\n" +
                "    \"properties\": {\n" +
                "      \"id\":{\n" +
                "        \"type\": \"integer\"\n" +
                "      },\n" +
                "      \"name\":{\n" +
                "        \"type\": \"text\"\n" +
                "      },\n" +
                "      \"desc\":{\n" +
                "        \"type\": \"text\"\n" +
                "      }\n" +
                "    }\n" +
                "  }\n" +
                "}", XContentType.JSON);
        // 3、发起请求
        CreateIndexResponse response = client.indices().create(request, RequestOptions.DEFAULT);
        // 4、输出相应结果
        System.out.println(response.index());
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        // 5、关闭客户端
        if (client != null) {
            try {
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

删除索引操作

@Test
public void deleteIndex() {
    RestHighLevelClient client = null;
    try {
        // 1、创建客户端对象
        client = new RestHighLevelClient(RestClient.builder(new HttpHost("127.0.0.1", 9200, "http")));
        // 2、创建请求对象
        DeleteIndexRequest request = new DeleteIndexRequest("student");
        // 3、发起请求
        AcknowledgedResponse response = client.indices().delete(request, RequestOptions.DEFAULT);
        // 4、输出响应结果
        System.out.println(response.isAcknowledged());
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        // 5、关闭客户端
        if (client != null) {
            try {
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

新增文档操作

/**
 * 新增文档
 */
@Test
public void addDocument() {
    RestHighLevelClient client = null;
    try {
        // 1、创建客户端对象连接Es
        client = new RestHighLevelClient(RestClient.builder(new HttpHost("127.0.0.1", 9200, "http")));
        // 2、创建请求对象
        IndexRequest request = new IndexRequest("teacher").id("4");
        // 3、添加文档的内容
        request.source(XContentFactory.jsonBuilder().startObject()
                .field("id",4)
                .field("name","懒羊羊")
                .field("desc","懒羊羊喜欢吃，还会骂美羊羊")
                .endObject()
        );
        // 4、发送请求
        IndexResponse response = client.index(request, RequestOptions.DEFAULT);
        // 5、输出响应结果
        System.out.println(response.status());
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        // 6、关闭客户端
        if (client != null) {
            try {
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

修改文档操作

/**
 * 修改文档：对于已存在的文档id进行保存就是修改
 */
@Test
public void updateDocument() {
    RestHighLevelClient client = null;
    try {
        // 1、创建客户端对象连接Es
        client = new RestHighLevelClient(RestClient.builder(new HttpHost("127.0.0.1", 9200, "http")));
        // 2、创建请求对象
        IndexRequest request = new IndexRequest("teacher").id("1");
        // 3、添加文档的内容
        request.source(XContentFactory.jsonBuilder().startObject()
                .field("id",1)
                .field("name","update")
                .field("desc","updatemiaoshuxinxiupdate")
                .endObject()
        );
        // 4、发送请求
        IndexResponse response = client.index(request, RequestOptions.DEFAULT);
        // 5、输出响应结果
        System.out.println(response.status());
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        // 6、关闭客户端
        if (client != null) {
            try {
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

根据文档ID查询文档信息

/**
 * 根据文档ID查询文档信息
 */
@Test
public void findDocumentByID() {
    RestHighLevelClient client = null;
    try {
        // 1、创建客户端对象连接Es
        client = new RestHighLevelClient(RestClient.builder(new HttpHost("127.0.0.1", 9200, "http")));
        // 2、创建请求对象
        GetRequest request = new GetRequest("teacher", "1");
        // 3、发送请求
        GetResponse response = client.get(request, RequestOptions.DEFAULT);
        // 4、输出文档信息
        System.out.println(response.getSourceAsString());
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        // 5、关闭客户端
        if (client != null) {
            try {
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

删除文档信息

/**
 * 删除文档
 */
@Test
public void deleteDocumentByID() {
    RestHighLevelClient client = null;
    try {
        // 1、创建客户端对象连接Es
        client = new RestHighLevelClient(RestClient.builder(new HttpHost("127.0.0.1", 9200, "http")));
        // 2、创建请求对象
        DeleteRequest request = new DeleteRequest("teacher", "1");
        // 3、发送请求
        DeleteResponse response = client.delete(request, RequestOptions.DEFAULT);
        // 4、输出文档信息
        System.out.println(response.status());
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        // 5、关闭客户端
        if (client != null) {
            try {
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

搜索所有文档

/**
 * 搜索所有文档
 * 前提先多添加几个文档信息
 */
@Test
public void findAllDocument() {
    RestHighLevelClient client = null;
    try {
        // 1、创建客户端对象连接Es
        client = new RestHighLevelClient(RestClient.builder(new HttpHost("127.0.0.1", 9200, "http")));
        // 2、创建搜索条件
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        searchSourceBuilder.query(QueryBuilders.matchAllQuery());
        // 3、创建请求对象
        SearchRequest request = new SearchRequest("teacher").source(searchSourceBuilder);
        // 4、发送请求
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        // 5、输出查询结果
        SearchHits hits = response.getHits();
        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        // 5、关闭客户端
        if (client != null) {
            try {
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

根据关键字搜索文档

/**
 * 根据关键子搜索文档
 */
@Test
public void findDocumentByKeywords() {
    RestHighLevelClient client = null;
    try {
        // 1、创建客户端对象连接Es
        client = new RestHighLevelClient(RestClient.builder(new HttpHost("127.0.0.1", 9200, "http")));
        // 2、创建请求条件
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        searchSourceBuilder.query(QueryBuilders.termQuery("desc","懒"));
        // 3、创建请求对象
        SearchRequest request = new SearchRequest("teacher").source(searchSourceBuilder);
        // 4、发送请求
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        // 5、输出查询结果
        SearchHits hits = response.getHits();
        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        // 5、关闭客户端
        if (client != null) {
            try {
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

全部评论

推荐最新楼层

11-27 11:29

小红书_社区技术部_前端开发(实习员工)

10.30字节一面

【再再再再再再再战字节，摆烂了，这次一面都没过（手撕做出来了前面还有几轮字节面试忘记录音了，就不记录了。1.自我介绍2.主要技术栈是3.是否了解react4.做题【建议下次做这种题目拿个草稿纸！！】 console.log('start'); setTimeout(() => { console.log('children2'); setTimeout(function() { console.log('children8'); }, 0) ; Promise.resolve().then(() => { console.log('chil...

查看16道真题和解析面经烤面筋

点赞评论收藏

11-27 13:07

腾讯_解决方案架构师

知乎数仓开发一面

除了少量八股外，其他的按照简历写的技术栈提问1、接口和抽象类的区别？2、final关键字的各种用法，简要讲解下3、说一下flink的checkpoint4、checkpoint 中barrier的两种对齐方式5、interval join操作知道吗，概述下6、窗口函数 Sliding Time Window 为什么不设置很长的窗口时间7、checkpoint 和 kafka offset的关联8、offset的提交是自己写还是用flink框架9、非Barrier对齐可以保证精准一致性吗10、flink的状态后端知道吗？ 通常使用哪种状态后端，优势分别是什么？11、MemoryStateBack...

查看11道真题和解析软件开发笔面经

点赞评论收藏

11-09 14:54

已编辑

华南农业大学产品经理

请赐教😭😭

25届应届生，目前0 offer，焦虑坏了😭😭

大拿老师：这个简历，连手机号码和照片都没打码，那为什么关键要素求职职位就不写呢？从上往下看，都没看出自己到底是产品经理的简历，还是电子硬件的简历？这是一个大问题，当然，更大的问题是实习经历的描述是不对的不要只是去写实习流程，陈平，怎么去开会？怎么去讨论？面试问的是你的产品功能点，是怎么设计的？也就是要写项目的亮点，有什么功能？这个功能有什么难处？怎么去解决的？实习流程大家都一样，没什么优势，也没有提问点，没有提问，你就不得分另外，你要明确你投的是什么职位，如果投的是产品职位，你的项目经历写的全都是跟产品无关的，那你的简历就没用你的面试官必然是一个资深的产品经理，他不会去问那些计算机类的编程项目所以这种四不像的简历，在校招是大忌

点赞评论收藏