---

环境：
jdk1.8
springboot: 2.7.0

spring elastisearch官方文档

一、依赖配置

1、引入es依赖

        <!-- spring data es --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId></dependency><!-- https://mvnrepository.com/artifact/jakarta.json/jakarta.json-api --><dependency><groupId>jakarta.json</groupId><artifactId>jakarta.json-api</artifactId><version>2.0.1</version></dependency>

2、配置文件application.yaml

spring:elasticsearch:uris: http://1.13.152.218:9200username:password:connection-timeout: 10sjackson:date-format: "yyyy-MM-dd HH:mm:ss"

二、使用Repository对es增删改查

1、定义实体类 Book

package com.zhuang.es.entity;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.DateFormat;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;import java.util.Date;
import java.util.List;
import java.util.Map;@Data
@AllArgsConstructor
@NoArgsConstructor
@Document(indexName="books")
public class Book {@Idprivate Long id;@Field(type = FieldType.Text)private String name;@Field(type = FieldType.Text)private String summary;@Field(type = FieldType.Double)private Double price;@Field(type = FieldType.Text)private String parent;private List<Long> list;private Map<Long, String> map;@Field(type = FieldType.Date, format = DateFormat.custom, pattern = "yyyy-MM-dd HH:mm:ss")private Date create;
}

2、注解：

@Document

作用：标识要持久化到Elasticsearch的域对象， 如定义索引名
@Document(indexName="books")

@Id

作用：定义标识符 -> 文档id
@Id private Long id;

@Field

作用：对持久化到Elasticsearch域的属性设置， 比如设置对应es中字段的属性类型

type属性类型:

1、如果没有定义属性的type或者type = FieldType.Auto ，会动态映射 type，会在第一次插入数据时动态设置属性类型。如 private String name; 或 如 @Field(type = FieldType.Auto) private String name;

2、如果显示定义了type的类型，那么在项目启动的时候，就会在es中创建定义的类型
如 @Field(type = FieldType.Text) private String name; 那么name属性在es中的属性类型为text

format日期格式：

1.使用自带的日期格式：format
如 @Field(type = FieldType.Date, format = DateFormat.date_hour_minute_second) private Date create DateFormat是枚举类型;
2.自定义时间类型：pattern
设置format = DateFormat.custom或 format = DateFormat.none,
如： @Field(type = FieldType.Date, format = DateFormat.custom, pattern = "yyyy-MM-dd HH:mm:ss") private Date create;

3、创建接口 BookRepository

继承 ElasticsearchRepository<T, ID>， T为映射的实体类， ID为标记的id类型

package com.zhuang.es.service;import com.zhuang.es.entity.Book;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;public interface BookRepository extends ElasticsearchRepository<Book, Long> {}

4、创建 BookController

注入BookRepository bean，调用封装好的增删改查接口

package com.zhuang.es.controller;import com.zhuang.es.entity.Book;
import com.zhuang.es.service.BookRepository;
import com.zhuang.es.vo.BookVo;
import com.zhuang.es.vo.ResponseVo;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.bind.annotation.*;import javax.annotation.Resource;
import java.util.List;
import java.util.Optional;/*** @program: mybatis-plus* @description:* @author: mrzhuang* @create: 2022-12-23 21:14**/@RestController
@RequestMapping("/book")
public class BookController {@ResourceBookRepository bookRepository;/*** 查询全部** @return /*/@GetMapping("/findAll")public ResponseVo<Iterable<Book>> findAll() {Iterable<Book> books = bookRepository.findAll();return new ResponseVo<>(books);}/*** 向es中增加book** @param book /* @return /*/@PostMapping("/add")public ResponseVo<Book> addBook(@RequestBody Book book) {Book save = bookRepository.save(book);return new ResponseVo<>(save);}/*** 根据id查询** @param id /* @return /*/@GetMapping("/findById")public ResponseVo<Optional<Book>> findById(@RequestParam("id") Long id) {Optional<Book> bookOptional = bookRepository.findById(id);return new ResponseVo<>(bookOptional);}/*** 通过传入实体删除** @param book /* @return /*/@PostMapping("/delete")public ResponseVo<Boolean> delete(@RequestBody Book book) {bookRepository.delete(book);return new ResponseVo<>(true);}/*** 通过id删除** @param id /* @return /*/@GetMapping("/deleteById")public ResponseVo<Boolean> delete(@RequestParam("id") Long id) {bookRepository.deleteById(id);return new ResponseVo<>(true);}/*** 更新某个属性值(如：name)* @param bookVo /*/@PostMapping("/update")public ResponseVo<Book> update(@RequestBody BookVo bookVo) {//获取需要更新的文档idLong id = bookVo.getId();Optional<Book> option = bookRepository.findById(id);if (option.isPresent()) {Book book = option.get();if (StringUtils.isNotEmpty(bookVo.getName())) {book.setName(bookVo.getName());}Book save = bookRepository.save(book);return new ResponseVo<>(book);}return new ResponseVo<>(CodeEnum.FAILUIRE.code, "更新失败！");}/*** 统计数量** @return /*/@GetMapping("/count")public ResponseVo<Long> count() {long count = bookRepository.count();return new ResponseVo<>(count);}/*** 查看id是否存在* @param id /* @return /*/@GetMapping("/existsById")public ResponseVo<Boolean> update(@RequestParam("id") Long id) {boolean exists = bookRepository.existsById(id);return new ResponseVo<>(exists);}/*** 根据name和price查询* @param name /* @param price /* @return /*/@GetMapping("/findByNameAndPrice")public ResponseVo<List<Book>> findByNameAndPrice(@RequestParam("name") String name, @RequestParam("price") Double price) {List<Book> books = bookRepository.findByNameAndPrice(name, price);return new ResponseVo<>(books);}/*** 根据summary和parent查询* @param summary /* @param parent /* @return /*/@GetMapping("/findBySummaryAndParent")public ResponseVo<List<Book>> findBySummaryAndParent(@RequestParam("summary") String summary, @RequestParam("parent") String parent) {List<Book> books = bookRepository.findBySummaryAndParent(summary, parent);return new ResponseVo<>(books);}}

5、Es创建查询机制

通常，Elasticsearch 的查询创建机制按照查询方法中的描述工作。

以下是 Elasticsearch 查询方法转换成的简短示例：
增加方法： List<Book> findByNameAndPrice(String name, Double price);
上面的方法名会被翻译成下面的 Elasticsearch json 查询：

{"query": {"bool" : {"must" : [{ "query_string" : { "query" : "?", "fields" : [ "name" ] } },{ "query_string" : { "query" : "?", "fields" : [ "price" ] } }]}}
}

package com.zhuang.es.service;import com.zhuang.es.entity.Book;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;import java.util.List;public interface BookRepository extends ElasticsearchRepository<Book, Long> {List<Book> findByNameAndPrice(String name, Double price);
}

controller层中调用

    @PostMapping("/findByNameAndPrice")public ResponseVo<List<Book>> findByNameAndPrice(@RequestParam("name") String name, @RequestParam("price") Double price){List<Book> books = bookRepository.findByNameAndPrice(name, price);return new ResponseVo<>(books);}

6、查询创建机制关键词

And

关键词	样本
And	findByNameAndPrice

Es 查询字符串：

"bool" : {"must" : [
{ "query_string" : { "query" : "?", "fields" : [ "name" ] } },
{ "query_string" : { "query" : "?", "fields" : [ "price" ] } }
]
}
}}

Or

关键词	样本
Or	findByNameOrPrice

Es 查询字符串：

{ "query" : {"bool" : {"should" : [
{ "query_string" : { "query" : "?", "fields" : [ "name" ] } },
{ "query_string" : { "query" : "?", "fields" : [ "price" ] } }
]
}
}}

Is

关键词	样本
Is	findByName

Es 查询字符串：

{ "query" : {"bool" : {"must" : [
{ "query_string" : { "query" : "?", "fields" : [ "name" ] } }
]
}
}}

Not

关键词	样本
Not	findByNameNot

Es 查询字符串：

{ "query" : {"bool" : {"must_not" : [
{ "query_string" : { "query" : "?", "fields" : [ "name" ] } }
]
}
}}

Between

关键词	样本
Between	findByPriceBetween

Es 查询字符串：

{ "query" : {"bool" : {"must" : [
{"range" : {"price" : {"from" : ?, "to" : ?, "include_lower" : true, "include_upper" : true } } }
]
}
}}

LessThan

关键词	样本
LessThan	findByPriceLessThan

Es 查询字符串：

{ "query" : {"bool" : {"must" : [
{"range" : {"price" : {"from" : null, "to" : ?, "include_lower" : true, "include_upper" : false } } }
]
}
}}

LessThanEqual

关键词	样本
LessThanEqual	findByPriceLessThanEqual

Es 查询字符串：

{ "query" : {"bool" : {"must" : [
{"range" : {"price" : {"from" : null, "to" : ?, "include_lower" : true, "include_upper" : true } } }
]
}
}}

GreaterThan

关键词	样本
GreaterThan	findByPriceGreaterThan

Es 查询字符串：

{ "query" : {"bool" : {"must" : [
{"range" : {"price" : {"from" : ?, "to" : null, "include_lower" : false, "include_upper" : true } } }
]
}
}}

GreaterThanEqual

关键词	样本
GreaterThanEqual	findByPriceGreaterThan

Es查询字符串：

{ "query" : {"bool" : {"must" : [
{"range" : {"price" : {"from" : ?, "to" : null, "include_lower" : true, "include_upper" : true } } }
]
}
}}

Before

关键词	样本
Before	findByPriceBefore

Es 查询字符串：

{ "query" : {"bool" : {"must" : [
{"range" : {"price" : {"from" : null, "to" : ?, "include_lower" : true, "include_upper" : true } } }
]
}
}}

After

关键词	样本
After	findByPriceAfter

Es 查询字符串：

{ "query" : {"bool" : {"must" : [
{"range" : {"price" : {"from" : ?, "to" : null, "include_lower" : true, "include_upper" : true } } }
]
}
}}

Like

关键词	样本
Like	findByNameLike

Es查询字符串

{ "query" : {"bool" : {"must" : [
{ "query_string" : { "query" : "?*", "fields" : [ "name" ] }, "analyze_wildcard": true }
]
}
}}

StartingWith

关键词	样本
StartingWith	findByNameStartingWith

Es 查询字符串：

{ "query" : {"bool" : {"must" : [
{ "query_string" : { "query" : "?*", "fields" : [ "name" ] }, "analyze_wildcard": true }
]
}
}}

EndingWith

关键词	样本
EndingWith	findByNameEndingWith

Es查询字符串

{ "query" : {"bool" : {"must" : [
{ "query_string" : { "query" : "*?", "fields" : [ "name" ] }, "analyze_wildcard": true }
]
}
}}

Contanins/Containing

关键词	样本
Contains/Containing	findByNameContaining

Es 查询字符串：

{ "query" : {"bool" : {"must" : [
{ "query_string" : { "query" : "*?*", "fields" : [ "name" ] }, "analyze_wildcard": true }
]
}
}}

In（当注释为 FieldType.Keyword 时)

关键词	样本
In（当注释为 FieldType.Keyword 时）	findByNameIn(Collectionnames)

Es 查询字符串：

{ "query" : {"bool" : {"must" : [
{"bool" : {"must" : [
{"terms" : {"name" : ["?","?"]}}
]
}
}
]
}
}}

In

关键词	样本
In	findByNameIn(Collectionnames)

Es 查询字符串：

{ "query": {"bool": {"must": [{"query_string":{"query": "\"?\" \"?\"", "fields": ["name"]}}]}}}

Notln（当注释为 FieldType.Keyword 时）

关键词	样本
NotIn（当注释为 FieldType.Keyword 时）	indByNameNotIn(Collectionnames)

Es 查询字符串：

{ "query" : {"bool" : {"must" : [
{"bool" : {"must_not" : [
{"terms" : {"name" : ["?","?"]}}
]
}
}
]
}
}}

Notln

关键词	样本
NotIn	findByNameNotIn(Collectionnames)

Es 查询字符串：

{"query": {"bool": {"must": [{"query_string": {"query": "NOT(\"?\" \"?\")", "fields": ["name"]}}]}}}
关键词 | 样本
--- | ----
True|findByAvailableTrue{ "query" : {"bool" : {"must" : [
{ "query_string" : { "query" : "true", "fields" : [ "available" ] } }
]
}
}}

False

关键词	样本
False	findByAvailableFalse

Es 查询字符串：

{ "query" : {"bool" : {"must" : [
{ "query_string" : { "query" : "false", "fields" : [ "available" ] } }
]
}
}}

OrderBy

关键词	样本
OrderBy	findByAvailableTrueOrderByNameDesc

Es 查询字符串：

{ "query" : {"bool" : {"must" : [
{ "query_string" : { "query" : "true", "fields" : [ "available" ] } }
]
}
}, "sort":[{"name":{"order":"desc"}}]
}

Exists

关键词	样本
Exists	findByNameExists

Es 查询字符串：

{"query":{"bool":{"must":[{"exists":{"field":"name"}}]}}}

IsNull

关键词	样本
IsNull	findByNameIsNull

Es 查询字符串：

{"query":{"bool":{"must_not":[{"exists":{"field":"name"}}]}}}

IsNotNull

关键词	样本
IsNotNull	findByNameIsNotNull

Es 查询字符串：

{"query":{"bool":{"must":[{"exists":{"field":"name"}}]}}}

IsEmpty

关键词	样本
IsEmpty	findByNameIsEmpty

Es 查询字符串：

{"query":{"bool":{"must":[{"bool":{"must":[{"exists":{"field":"name"}}],"must_not":[{"wildcard":{"name":{"wildcard":"*"}}}]}}]}}}

IsNotEmpty

关键词	样本
IsNotEmpty	findByNameIsNotEmpty

Es 查询字符串：

{"query":{"bool":{"must":[{"wildcard":{"name":{"wildcard":"*"}}}]}}}

7、高级查询

注入 ElasticsearchOperations bean

import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.elasticsearch._types.query_dsl.BoolQuery;
import co.elastic.clients.elasticsearch._types.query_dsl.MatchAllQuery;
import co.elastic.clients.elasticsearch._types.query_dsl.Query;
import co.elastic.clients.elasticsearch._types.query_dsl.TermQuery;
import co.elastic.clients.json.JsonData;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.zhuang.es.EsApplication;
import com.zhuang.es.entity.Book;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.data.elasticsearch.client.elc.ElasticsearchTemplate;
import org.springframework.data.elasticsearch.client.elc.NativeQuery;
import org.springframework.data.elasticsearch.client.elc.NativeQueryBuilder;
import org.springframework.data.elasticsearch.core.ElasticsearchOperations;
import org.springframework.data.elasticsearch.core.SearchHits;import javax.annotation.Resource;/*** @program: mybatis-plus* @description:* @author: mrzhuang* @create: 2022-12-22 21:43**/@Slf4j
@SpringBootTest(classes = EsApplication.class)
public class EsTest {@ResourceElasticsearchOperations operations;@Testpublic void testSearch() {//term查询TermQuery termQuery = new TermQuery.Builder().field("price").value("10.2").build();Query tQuery = new Query.Builder().term(termQuery).build();//等同于lambda表达式Query price2 = new Query.Builder().term(t -> t.field("price").value("10.2")).build();BoolQuery boolQuery = new BoolQuery.Builder()//filter.filter(q -> q.range(r -> r.field("price").gte(JsonData.of(11.0)).lt(JsonData.of(16.0))))//matchAll.must(q -> q.matchAll(new MatchAllQuery.Builder().build())).build();NativeQuery nativeQuery = new NativeQueryBuilder().withQuery(q -> q.bool(boolQuery))//查询结果按照price从小到大排序.withSort(Sort.by(Sort.Direction.ASC, "price"))//第0页开始.withPageable(PageRequest.of(0, 5)).build();SearchHits<Book> search = operations.search(nativeQuery, Book.class);search.stream().forEach(System.out::println);}
}

二、Es客户端elasticsearchClient

1、创建客户端配置类 ElasticSearchConfig

package com.zhuang.es.config;import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.json.jackson.JacksonJsonpMapper;
import co.elastic.clients.transport.ElasticsearchTransport;
import co.elastic.clients.transport.rest_client.RestClientTransport;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.http.Header;
import org.apache.http.HttpHost;
import org.apache.http.HttpResponseInterceptor;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.client.CredentialsProvider;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.apache.http.impl.nio.client.HttpAsyncClientBuilder;
import org.apache.http.message.BasicHeader;
import org.elasticsearch.client.Node;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.elasticsearch.ElasticsearchProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.elasticsearch.client.elc.ElasticsearchTemplate;
import org.springframework.data.elasticsearch.config.ElasticsearchConfigurationSupport;
import org.springframework.data.elasticsearch.core.convert.ElasticsearchConverter;import javax.annotation.Resource;@Configuration
@Slf4j
public class ElasticSearchConfig extends ElasticsearchConfigurationSupport {@Resourceprivate ElasticsearchProperties elasticSearchProperty;@Beanpublic RestClientBuilder restClientBuilder() {return RestClient.builder(elasticSearchProperty.getUris().stream().map(this::getElasticSearchHttpHosts).toArray(HttpHost[]::new)).setRequestConfigCallback(requestConfigBuilder -> {//设置连接超时时间requestConfigBuilder.setConnectTimeout(elasticSearchProperty.getConnectionTimeout().toMillisPart());requestConfigBuilder.setSocketTimeout(elasticSearchProperty.getSocketTimeout().toMillisPart());return requestConfigBuilder;}).setFailureListener(new RestClient.FailureListener() {//某节点失败,这里可以做一些告警@Overridepublic void onFailure(Node node) {log.error("[ ElasticSearchClient ] >>  node :{}, host:{},  fail ", node.getName(), node.getHost());}}).setHttpClientConfigCallback(httpClientBuilder -> {// 设置[X-Elastic-Product] headerhttpClientBuilder.disableAuthCaching().addInterceptorLast((HttpResponseInterceptor)(response, context) -> response.addHeader("X-Elastic-Product", "Elasticsearch"));//设置账密return getHttpAsyncClientBuilder(httpClientBuilder);});}/*** 配置es client*/@Bean(value = "elasticsearchClient")public ElasticsearchClient elasticsearchClient(@Qualifier("restClientBuilder") RestClientBuilder restClientBuilder) {RestClient restClient = restClientBuilder.setDefaultHeaders(new Header[]{new BasicHeader("Content-Type", "application/json")}).build();ElasticsearchTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());return new ElasticsearchClient(transport);}@Bean(value = "elasticsearchTemplate")public ElasticsearchTemplate elasticsearchTemplate(ElasticsearchClient elasticsearchClient, ElasticsearchConverter elasticsearchConverter) {return new ElasticsearchTemplate(elasticsearchClient, elasticsearchConverter);}private HttpHost getElasticSearchHttpHosts(String host) {host = host.replaceAll("http://", "").replaceAll("https://", "");return new HttpHost(host.split(":")[0], Integer.parseInt(host.split(":")[1]), "http");}private HttpAsyncClientBuilder getHttpAsyncClientBuilder(HttpAsyncClientBuilder httpClientBuilder) {if (StringUtils.isEmpty(elasticSearchProperty.getUsername()) || StringUtils.isEmpty(elasticSearchProperty.getPassword())) {return httpClientBuilder;}//设置账号密码CredentialsProvider credentialsProvider = new BasicCredentialsProvider();credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(elasticSearchProperty.getUsername(), elasticSearchProperty.getPassword()));httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);return httpClientBuilder;}
}

2、增删改查、批量操作

注入ElasticsearchClient bean

   @Resource(name = "elasticsearchClient")ElasticsearchClient client;

package com.zhuang;import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.elasticsearch.core.*;
import co.elastic.clients.elasticsearch.core.bulk.BulkOperation;
import co.elastic.clients.elasticsearch.core.bulk.IndexOperation;
import co.elastic.clients.elasticsearch.core.bulk.UpdateOperation;
import co.elastic.clients.elasticsearch.indices.CreateIndexRequest;
import co.elastic.clients.elasticsearch.indices.CreateIndexResponse;
import com.zhuang.es.EsApplication;
import com.zhuang.es.entity.Book;
import com.zhuang.es.service.BookRepository;
import com.zhuang.es.vo.BookVo;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;import javax.annotation.Resource;
import java.io.IOException;
import java.util.*;/*** @program: kafka* @description:* @author: mrzhuang* @create: 2022-12-25 13:04**/
@Slf4j
@SpringBootTest(classes = EsApplication.class)
public class EsClientTest {@ResourceBookRepository repository;@Resource(name = "elasticsearchClient")ElasticsearchClient client;/*** 创建索引* @throws IOException*/@Testvoid testCreateIndex() throws IOException {//client.indices().create(c->c.index("book"));CreateIndexRequest createIndexRequest= new CreateIndexRequest.Builder().index("book").build();CreateIndexResponse indexResponse = client.indices().create(createIndexRequest);log.info("[{}]索引创建[{}]！", indexResponse.index(), indexResponse.shardsAcknowledged());}/*** 增加数据* @throws IOException*/@Testvoid testInsertData() throws IOException {Optional<Book> book = repository.findById(1l);IndexRequest<Book> indexRequest = new IndexRequest.Builder<Book>().index("book").id("1").document(book.isPresent() ? book.get() : Book.builder().name("小刘").id(2l).build()).build();//IndexRequest source = indexRequest.index("book").id("1").source(book.isPresent() ? book.get() : Book.builder().name("小刘"));IndexResponse index = client.index(indexRequest);log.info("向索引[{}]中增加id:[{}]文档:[{}]", index.index(), index.id(), index.result());}/*** 删除数据* @throws IOException /*/@Testvoid testDeleteData() throws IOException {//1.根据id删除DeleteRequest deleteRequest = new DeleteRequest.Builder().index("book").id("gAcXSIUB94FMQr43ryS6").build();DeleteResponse deleteResponse = client.delete(deleteRequest);log.info("根据id删除：{}", deleteResponse.result().jsonValue());//2.根据查询条件删除DeleteByQueryRequest deleteByQueryRequest = new DeleteByQueryRequest.Builder().index(List.of("book")).query(q -> q.term(t -> t.field("name").value("xiaoxiao"))).build();DeleteByQueryResponse deleteByQueryResponse = client.deleteByQuery(deleteByQueryRequest);log.info("根据查询条件删除：{}个", deleteByQueryResponse.total());}/*** 更新数据** @throws IOException*/@Testvoid testUpdateDate() throws IOException {//方法1：创建实体类BookVo对应的实体类的属性和名称与Book相同//会将Book中对应的属性值替换为需要修改的bookVo中的属性值，然后更新es相对应的属性值BookVo bookVo = BookVo.builder().parent("妈").build();UpdateRequest<Book, BookVo> update1 = new UpdateRequest.Builder<Book, BookVo>().index("book").id("1").doc(bookVo).build();//方法2：创建MapMap<String, String > map = new HashMap<>();map.put("parent","爸妈");UpdateRequest<Book, Map<String, String >> update2 = new UpdateRequest.Builder<Book, Map<String, String >>().index("book").id("1").doc(map).build();UpdateResponse<Book> update = client.update(update1, Book.class);log.info("update:{}", update.result());}/*** 查询数据* @throws IOException*/@Testvoid testSearch() throws IOException {TermQuery termQuery = new TermQuery.Builder().field("id").value("11").build();Query query = new Query.Builder().term(termQuery).build();BoolQuery boolQuery = new BoolQuery.Builder().must(query).build();Query build = new Query.Builder().bool(boolQuery).build();SearchRequest searchRequest = new SearchRequest.Builder().query(build).index(Arrays.asList(new String[]{"book"})).build();SearchResponse<Book> response = client.search(searchRequest, Book.class);log.info("查询数据：{}", response.hits().hits().size());}/*** 批量增加* @throws IOException*/@Testvoid testBulkInsert() throws IOException {//批量新增数据//第一个数据IndexOperation<Book> indexOperation1 = new IndexOperation.Builder<Book>().id("2").document(Book.builder().id(2l).name("小庄呀").build()).build();BulkOperation operation1 = new BulkOperation.Builder().index(indexOperation1).build();//第二个数据IndexOperation<Book> indexOperation2 = new IndexOperation.Builder<Book>().id("3").document(Book.builder().id(3l).name("小庄呀").build()).build();BulkOperation operation2 = new BulkOperation.Builder().index(indexOperation1).build();List<BulkOperation> operations = new ArrayList<>();operations.add(operation1);operations.add(operation2);BulkRequest bulkRequest = new BulkRequest.Builder().index("book").operations(operations).build();BulkResponse bulkResponse = client.bulk(bulkRequest);log.info("批量删除：{}, size：{}", !bulkResponse.errors(), bulkResponse.items().size());}/*** 批量更新* @throws IOException*/@Testvoid testBulkUpdate() throws IOException {//批量新增数据//第一个数据UpdateOperation<Book, BookVo> updateOperation1 = new UpdateOperation.Builder<Book, BookVo>().id("2").action(b -> b.doc(BookVo.builder().name("xiaoxiao").build())).build();BulkOperation operation1 = new BulkOperation.Builder().update(updateOperation1).build();//第一个数据UpdateOperation<Book, BookVo> updateOperation2 = new UpdateOperation.Builder<Book, BookVo>().id("3").action(b -> b.doc(BookVo.builder().name("xiao").build())).build();BulkOperation operation2= new BulkOperation.Builder().update(updateOperation2).build();List<BulkOperation> operations = new ArrayList<>();operations.add(operation1);operations.add(operation2);BulkRequest bulkRequest = new BulkRequest.Builder().index("book").operations(operations).build();BulkResponse bulkResponse = client.bulk(bulkRequest);log.info("批量更新：{}, size：{}", !bulkResponse.errors(), bulkResponse.items().size());}
}

springboot集成elasticsearch7.17.3相关推荐

1. SpringBoot集成Elasticsearch7.4 实战（一）

   在网上已经有好多关于Elasticsearch的介绍,就不在翻来覆去讲一些基本概念,大家感兴趣的可以自己去找一些资料巩固下.这次只为了顾及众多首次接触Elasticsearch,案例都讲的很浅显,还有 ...

2. springboot集成elasticsearch7实现全文检索及分页

   springboot集成elasticsearch7实现全文检索及分页 elasticsearch系列文章前面已经更新过三篇(https://blog.csdn.net/lsqingfeng/cate ...

3. springboot集成elasticsearch7.2

   上篇文章我们讲解了elasticsearch的安装,这次我们来搞一下,如何在自己的项目中集成elasticsearch. 正常来讲spring-data中都会提供相应的starter,让我们方便的使用 ...

4. springboot集成mybatis源码分析-启动加载mybatis过程（二）

   springboot集成mybatis源码分析-启动加载mybatis过程(二) 1.springboot项目最核心的就是自动加载配置,该功能则依赖的是一个注解@SpringBootApplicati ...

5. SpringBoot集成Mybatis用法笔记

   今天给大家整理SpringBoot集成Mybatis用法笔记.希望对大家能有所帮助! 搭建一个SpringBoot基础项目. 具体可以参考SpringBoot:搭建第一个Web程序 引入相关依赖 &l ...

6. springboot集成redis使用redis作为session报错ClassNotFoundException类RememberMeServices

   springboot 集成redis使用redis作为缓存,会报错的问题. 错误信息: java.lang.IllegalStateException: Error processing condit ...

7. 项目构建之springboot集成lomback.xml，和log4j基于properties方式的日志配置记录

   文章目录 springboot集成lomback.xml 描述 在yml中定义的一些配置信息 创建logback-spring.xml文件 logback-spring.xml配置如下: **log4 ...

8. SpringBoot集成Actuator监控管理

   1.说明 本文详细介绍Spring Boot集成Actuator监控管理的方法, 基于已经创建好的Spring Boot工程, 然后引入Actuator依赖, 介绍监控管理相关功能的使用. Sprin ...

9. springboot集成swagger2，构建优雅的Restful API

   springboot集成swagger2,构建优雅的Restful API 转载请标明出处: 原文首发于:https://www.fangzhipeng.com/springboot/2017/07/ ...

最新文章

1. Android - could not install *smartsocket* listener
2. 【2016-09-27-DP小练】
3. catia 桥接曲面圆角_4.3.7.1-Catia曲面之多桥接曲面_简单构面
4. sklearn逻辑回归 极大似然 损失_收藏！攻克目标检测难点秘籍二，非极大值抑制与回归损失优化之路...
5. kibana操作elasticsearch：match匹配查询（and关系）
6. Flink Forward Asia 2021 正式启动！议题火热征集中！
7. ORACLE 添加和查看注释
8. 书籍推荐：Machine Learning Yearning
9. 分类算法python程序_分类算法——k最近邻算法（Python实现）（文末附工程源代码）...
10. 拼多多服务端实习生笔试-滑动窗口2018/4/3
11. 【导入篇】Robotics:Perception课程_导入篇、四周课程内容、week 1st Perspective Projection
12. C#中取得汉语拼音首字母
13. 带你啃透深度学习必学“圣经”花书！（附带论文代码精读讲解）
14. 蓝牙耳机哪个牌子好？国庆出游蓝牙耳机推荐
15. WIN10桌面美化（折腾）
16. Hadoop之自定义InputFormat
17. zabbix如何网站监控web
18. oracle从入门到精通视频教程下载,Oracle从入门到精通与实践视频教程
19. EDA 电子设计自动化VHDL系列课程8 – 脉冲信号发生器
20. CSDN日报20170217——《辞职信：写给我的“藤野先生”》

热门文章

1. python 3.10 的新特性用不到，你来打我!!!
2. Feign 原理 （图解）
3. springboot毕设项目大学生心理辅导系统njqlv（java+VUE+Mybatis+Maven+Mysql）
4. 空中三角测量加密原理及4D产品制作流程
5. 2021年终总结之关于我的技术写作
6. 大数加法（C语言）#includestdio.h #includestdlib.h #includestring.h char A[10005]; char B[10005]; int
7. MATLAB一个测心术的小游戏程序
8. “知识付费”三大法律问题如何处理
9. Spring微服务实战第9章 使用Spring Cloud Sleuth和Zipkin进行分布式跟踪
10. SVG颜色、渐变和填充