0
0

java操作 elasticsearch8.0 doc文档＜二＞

java操作 elasticsearch8.0 doc文档＜二＞

本文所有代码在文章最后

本文所有代码在文章最后

创建doc文档

如何连接请看上一篇文章

https://blog.csdn.net/u013979493/article/details/123122242?spm=1001.2014.3001.5502

User user =newUser("10002","lisi",20,"男");IndexResponse indexResponse = client.index(
              x -> x.index("user").id(user.getId()).document(user));

修改doc自定义属性

User user =newUser();//修改什么属性就set什么值
user.setAge(101);UpdateResponse<User> userUpdateResponse = client.update(
                     x -> x.index("user").id("10002").doc(user),User.class);

获取doc信息

GetResponse<User> getResponse = client.get(x -> x
    .index("user").id("10002"),User.class);

删除doc

client.delete(x -> x.index("user").id("10002"));

批量添加doc

//创建user列表List<User> users =newArrayList<>();
users.add(newUser("15","张三",10,"女"));
users.add(newUser("16","张四",10,"女"));
users.add(newUser("17","张五六",11,"女"));
users.add(newUser("18","张三四",12,"女"));
users.add(newUser("19","张三五",13,"女"));
users.add(newUser("20","张三六七",14,"女"));
users.add(newUser("21","张三1",15,"女"));//创建BulkOperation列表准备批量插入docList<BulkOperation> bulkOperations =newArrayList<>();//将user中id作为es id，也可不指定id es会自动生成id
users.forEach(a -> bulkOperations.add(BulkOperation.of(b -> b.index(c -> c.id(a.getId()).document(a)))));
client.bulk(x ->x.index("user").operations(bulkOperations));

批量删除doc

List<String> strings =newArrayList<>();
strings.add("1");
strings.add("2");
strings.add("3");
strings.add("4");
strings.add("5");
strings.add("6");
strings.add("7");List<BulkOperation> bulkOperations =newArrayList<>();
strings.forEach(a -> bulkOperations.add(BulkOperation.of(b -> b.delete(c -> c.id(a)))));
client.bulk(x ->x.index("user").operations(bulkOperations));

批量更新doc

与添加删除同理

查询user索引所有数据

SearchResponse<User> searchResponse = client.search(a -> a.index("user"),User.class);
searchResponse.hits().hits().forEach(x ->System.out.println(x.source()));

条件查询 查询age为15的数据

earchResponse<User> searchResponse = client
                    .search(a -> a
                            .index("user").query(b -> b
                                    .term(c -> c
                                            .field("age").value(d -> d
                                                    .longValue(15)))),User.class);
searchResponse.hits().hits().forEach(x ->System.out.println(x.source()));

分页查询 排序 过滤字段

SearchResponse<User> searchResponse = client
                    .search(a -> a
                            .index("user")//从第0条到第4条.from(0).size(5)//按年龄降序排序.sort(b -> b
                                    .field(c -> c
                                            .field("age").order(SortOrder.Desc))).source(c -> c
                                    .filter(d -> d
                                            //不包含字段.excludes("id","age")//包含字段.includes("name"))),User.class);
searchResponse.hits().hits().forEach(x ->System.out.println(x.source()));

组合查询

SearchResponse<User> searchResponse = client
                    .search(a -> a
                            .index("user").query(b -> b
                                    .bool(c -> c
                                            //必须不满足某些条件.mustNot(d -> d.match(e -> e.field("sex").query(f -> f.stringValue("男"))))//可同时满足某些条件.should(d -> d.match(e -> e.field("age").query(f -> f.longValue(10)))).should(d -> d.match(e -> e.field("age").query(f -> f.longValue(12)))))),User.class);
searchResponse.hits().hits().forEach(x ->System.out.println(x.source()));

范围查询

from to查询

SearchResponse<User> searchResponse = client
                    .search(a -> a
                            .index("user").query(b -> b
                                    .range(c -> c.field("age").from("10").to("12"))),User.class);
            searchResponse.hits().hits().forEach(x ->System.out.println(x.source()));

大于小于查询

SearchResponse<User> searchResponse = client
                    .search(a -> a
                            .index("user").query(b -> b
                                    //小于等于//                                    .range(c -> c.field("age").lte(JsonData.of("13")))//小于//                                    .range(c -> c.field("age").lt(JsonData.of("13")))//大于等于//                                    .range(c -> c.field("age").gte(JsonData.of("13")))//大于//                                    .range(c -> c.field("age").gt(JsonData.of("13")))//范围.range(c -> c.field("age").from("10").to("13"))).sort(b -> b.field(c -> c.field("age").order(SortOrder.Asc)))//经测试，若不指定size则只会返回前十条数据，此处这是size是想返回所有数据，如有更好的方法清指教.size(1000),User.class);
searchResponse.hits().hits().forEach(x ->System.out.println(x.source()));

模糊查询 高亮显示

SearchResponse<User> searchResponse = client.search(_0 -> _0
                    .query(_1 -> _1
                            .fuzzy(_2 -> _2
                                    .field("name")//最大偏移量，意为最多有能有几个不符合的.fuzziness("1")//最大查询数量//                                    .maxExpansions(5).value(_3 -> _3
                                            .stringValue("张四"))))//高亮.highlight(_4 -> _4
                            .fields("name", _5 -> _5
                                    .preTags("<font color='red'>").postTags("</font>"))),User.class);
searchResponse.hits().hits().forEach(x ->System.out.println(x.source()));

聚合操作

SearchResponse<Map> search = client
                    .search(_0 -> _0
                            //按年龄进行分组.aggregations("ageGroup", _1 -> _1
                                    .terms(_2 -> _2
                                            .field("age"))),Map.class);System.out.println(search);

本文所有方法本人以测试正常使用，如有错误请指正，一起讨论
以下为本文所有代码

User实体类

publicclassUser{privateString id;privateString name;privateint age;privateString sex;publicUser(){}publicUser(String id,String name,int age,String sex){this.id = id;this.name = name;this.age = age;this.sex = sex;}publicStringgetId(){return id;}publicvoidsetId(String id){this.id = id;}publicStringgetName(){return name;}publicvoidsetName(String name){this.name = name;}publicintgetAge(){return age;}publicvoidsetAge(int age){this.age = age;}publicStringgetSex(){return sex;}publicvoidsetSex(String sex){this.sex = sex;}@OverridepublicStringtoString(){return"User{"+"id='"+ id +'\''+", name='"+ name +'\''+", age="+ age +", sex='"+ sex +'\''+'}';}}

es操作

publicclassESClientDemo{privatestaticfinalString clusterNodes ="127.0.0.1:9201";privatestaticfinalString account ="elastic";privatestaticfinalString passWord ="D4ibOD8mtcItd_p_FGUO";publicstaticElasticsearchClient client;publicstaticRestClientBuilder builder;publicstaticRestClient restClient;publicstaticElasticsearchTransport transport;//有密码登录publicstaticvoidmain(String[] args){try{HttpHost[] httpHosts =Arrays.stream(clusterNodes.split(",")).map(x ->{String[] hostInfo = x.split(":");returnnewHttpHost(hostInfo[0],Integer.parseInt(hostInfo[1]));}).toArray(HttpHost[]::new);finalCredentialsProvider credentialsProvider =newBasicCredentialsProvider();//设置账号密码
            credentialsProvider.setCredentials(AuthScope.ANY,newUsernamePasswordCredentials(account, passWord));

            builder =RestClient.builder(httpHosts).setHttpClientConfigCallback(httpClientBuilder ->
                            httpClientBuilder
                                    .setDefaultCredentialsProvider(credentialsProvider));// Create the low-level client
            restClient = builder.build();// Create the transport with a Jackson mapper
            transport =newRestClientTransport(
                    restClient,newJacksonJsonpMapper());// And create the API client
            client =newElasticsearchClient(transport);//            Boolean acknowledged = client.indices().create(c -> c.index("user")).acknowledged();//            System.out.println("创建索引: " + (Boolean.TRUE.equals(acknowledged) ? "成功" : "失败"));//            GetIndexResponse getIndexResponse = client.indices().get(c -> c.index("user"));//            System.out.println("获取索引 user 响应: " + getIndexResponse);//            DeleteIndexResponse deleteIndexResponse = client.indices().delete(c -> c.index("user"));//            System.out.println("删除索引 user 响应: " + deleteIndexResponse);//创建doc//            User user = new User("lisi", 20, "男");//            IndexResponse indexResponse = client.index(//                            x -> x.index("user").id("10002").document(user));//修改doc部分属性//            User user = new User();//            user.setAge(101);//            UpdateResponse<User> userUpdateResponse = client.update(//                            x -> x.index("user").id("10002").doc(user), User.class);//获取doc信息//            GetResponse<User> getResponse = client.get(x -> x.index("user").id("10002"), User.class);//删除doc//            client.delete(x -> x.index("user").id("10002"));//批量添加doc/*List<User> users = new ArrayList<>();
            users.add(new User("15", "张三", 10, "女"));
            users.add(new User("16", "张四", 10, "女"));
            users.add(new User("17", "张五六", 11, "女"));
            users.add(new User("18", "张三四", 12, "女"));
            users.add(new User("19", "张三五", 13, "女"));
            users.add(new User("20", "张三六七", 14, "女"));
            users.add(new User("21", "张三1", 15, "女"));
            List<BulkOperation> bulkOperations = new ArrayList<>();
            users.forEach(a -> bulkOperations.add(BulkOperation.of(b -> b.index(c -> c.id(a.getId()).document(a)))));
            client.bulk(x ->x.index("user").operations(bulkOperations));*///批量删除doc/*List<String> strings = new ArrayList<>();
            strings.add("1");
            strings.add("2");
            strings.add("3");
            strings.add("4");
            strings.add("5");
            strings.add("6");
            strings.add("7");
            List<BulkOperation> bulkOperations = new ArrayList<>();
            strings.forEach(a -> bulkOperations.add(BulkOperation.of(b -> b.delete(c -> c.id(a)))));
            client.bulk(x ->x.index("user").operations(bulkOperations));*///查询user索引所有数据/*SearchResponse<User> searchResponse = client.search(a -> a.index("user"), User.class);
            searchResponse.hits().hits().forEach(x -> System.out.println(x.source()));*///条件查询/*SearchResponse<User> searchResponse = client
                    .search(a -> a
                            .index("user")
                            .query(b -> b
                                    .term(c -> c
                                            .field("age")
                                            .value(d -> d
                                                    .longValue(15)
                                            )
                                    )
                            ), User.class);
            searchResponse.hits().hits().forEach(x -> System.out.println(x.source()));*///分页查询 排序 过滤字段/*SearchResponse<User> searchResponse = client
                    .search(a -> a
                            .index("user")
                            .from(0)
                            .size(5)
                            .sort(b -> b
                                    .field(c -> c
                                            .field("age")
                                            .order(SortOrder.Desc)
                                    )
                            )
                            .source(c -> c
                                    .filter(d -> d
                                            //不包含字段
                                            .excludes("id", "age")
                                            //包含字段
                                            .includes("name")
                                    )
                            ), User.class);
            searchResponse.hits().hits().forEach(x -> System.out.println(x.source()));*///组合查询/*SearchResponse<User> searchResponse = client
                    .search(a -> a
                            .index("user")
                            .query(b -> b
                                    .bool(c -> c
                                            .mustNot(d -> d.match(e -> e.field("sex").query(f -> f.stringValue("男"))))
                                            .should(d -> d.match(e -> e.field("age").query(f -> f.longValue(10))))
                                            .should(d -> d.match(e -> e.field("age").query(f -> f.longValue(12))))
                                    )
                            ), User.class);
            searchResponse.hits().hits().forEach(x -> System.out.println(x.source()));*///范围查询/*SearchResponse<User> searchResponse = client
                    .search(a -> a
                            .index("user")
                            .query(b -> b
                                    .range(c -> c.field("age").from("10").to("12"))
                            ), User.class);
            searchResponse.hits().hits().forEach(x -> System.out.println(x.source()));*//*SearchResponse<User> searchResponse = client
                    .search(a -> a
                            .index("user")
                            .query(b -> b
                                    //小于等于
//                                    .range(c -> c.field("age").lte(JsonData.of("13")))
                                    //小于
//                                    .range(c -> c.field("age").lt(JsonData.of("13")))
                                    //大于等于
//                                    .range(c -> c.field("age").gte(JsonData.of("13")))
                                    //大于
//                                    .range(c -> c.field("age").gt(JsonData.of("13")))
                                    //范围
                                    .range(c -> c.field("age").from("10").to("13"))

                            )
                            .sort(b -> b.field(c -> c.field("age").order(SortOrder.Asc)))
                            .size(999999999), User.class);
            searchResponse.hits().hits().forEach(x -> System.out.println(x.source()));*///模糊查询 高亮显示/*SearchResponse<User> searchResponse = client.search(_0 -> _0
                    .query(_1 -> _1
                            .fuzzy(_2 -> _2
                                    .field("name")
                                    //最大偏移量
                                    .fuzziness("1")
                                    //最大查询数量
//                                    .maxExpansions(5)
                                    .value(_3 -> _3
                                            .stringValue("张四")
                                    )
                            )
                    )
                    .highlight(_4 -> _4
                            .fields("name", _5 -> _5
                                    .preTags("<font color='red'>")
                                    .postTags("</font>")
                            )
                    ), User.class);
            searchResponse.hits().hits().forEach(x -> System.out.println(x.source()));*///分组操作/*SearchResponse<Map> search = client
                    .search(_0 -> _0
                            .aggregations("ageGroup", _1 -> _1
                                    .terms(_2 -> _2
                                            .field("age")
                                    )
                            ), Map.class);
            System.out.println(search);*/}catch(Exception e){
            e.printStackTrace();}finally{try{
                client.shutdown();
                transport.close();
                restClient.close();}catch(IOException e){
                e.printStackTrace();}}}}

制作不易，请尊重作者的劳动成果

标签： java 开发语言 后端
本文转载自: https://blog.csdn.net/u013979493/article/details/123172320
版权归原作者 amo丶 所有， 如有侵权，请联系我们删除。
登录后发布评论

“java操作 elasticsearch8.0 doc文档＜二＞”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

Postman Pre-request Script

Apifox、Postman进行接口调用时如何携带cookie？

使用IDEA启动项目build时，解决Java编译时内存溢出问题：OutOfMemoryError深入解析

zookeeper实现RMI服务，高可用，HA

Idea 中kafka 生产者无法正常生产消息，SpringBoot编写简单的kafka实例

【NOIP提高组】潜伏者

**探索未来架构：深度学习的自动化设计神器 —— DARTS**

文章导航