Skip to content

Commit f464f77

Browse files
authored
Remove the integration of the deprecated RestHighLevelClient.
Original Pull Request #2560 Closes #2558
1 parent 73e9a6f commit f464f77

File tree

148 files changed

+142
-23518
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

148 files changed

+142
-23518
lines changed

pom.xml

Lines changed: 10 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -20,17 +20,12 @@
2020
<properties>
2121
<springdata.commons>3.2.0-SNAPSHOT</springdata.commons>
2222

23-
<!-- version of the RestHighLevelClient -->
24-
<elasticsearch-rhlc>7.17.9</elasticsearch-rhlc>
25-
<!-- version of the new ElasticsearchClient -->
23+
<!-- version of the ElasticsearchClient -->
2624
<elasticsearch-java>8.7.1</elasticsearch-java>
2725

28-
<log4j>2.18.0</log4j>
29-
<!-- netty dependency can be removed once the WebClient code is gone -->
30-
<netty>4.1.90.Final</netty>
31-
3226
<blockhound-junit>1.0.8.RELEASE</blockhound-junit>
3327
<hoverfly>0.14.4</hoverfly>
28+
<log4j>2.18.0</log4j>
3429
<jsonassert>1.5.1</jsonassert>
3530
<testcontainers>1.18.0</testcontainers>
3631
<wiremock>2.35.0</wiremock>
@@ -93,18 +88,6 @@
9388
<url>https://github.com/spring-projects/spring-data-elasticsearch/issues</url>
9489
</issueManagement>
9590

96-
<dependencyManagement>
97-
<dependencies>
98-
<dependency>
99-
<groupId>io.netty</groupId>
100-
<artifactId>netty-bom</artifactId>
101-
<version>${netty}</version>
102-
<type>pom</type>
103-
<scope>import</scope>
104-
</dependency>
105-
</dependencies>
106-
</dependencyManagement>
107-
10891
<dependencies>
10992

11093
<!-- Spring -->
@@ -132,33 +115,12 @@
132115
<optional>true</optional>
133116
</dependency>
134117

135-
<dependency>
136-
<groupId>io.projectreactor.netty</groupId>
137-
<artifactId>reactor-netty-http</artifactId>
138-
<optional>true</optional>
139-
</dependency>
140-
141118
<dependency>
142119
<groupId>io.projectreactor</groupId>
143120
<artifactId>reactor-test</artifactId>
144121
<scope>test</scope>
145122
</dependency>
146123

147-
<!-- optional Elasticsearch RestHighLevelClient, deprecated in SDE 5.0 -->
148-
<dependency>
149-
<groupId>org.elasticsearch.client</groupId>
150-
<artifactId>elasticsearch-rest-high-level-client</artifactId>
151-
<version>${elasticsearch-rhlc}</version>
152-
<optional>true</optional>
153-
<exclusions>
154-
<exclusion>
155-
<groupId>commons-logging</groupId>
156-
<artifactId>commons-logging</artifactId>
157-
</exclusion>
158-
</exclusions>
159-
</dependency>
160-
161-
<!-- new Elasticsearch client, needs the low-level rest client and json api -->
162124
<dependency>
163125
<groupId>co.elastic.clients</groupId>
164126
<artifactId>elasticsearch-java</artifactId>
@@ -340,6 +302,14 @@
340302
<scope>test</scope>
341303
</dependency>
342304

305+
<!--we need Murmur3Hash in a test, before 5.2 we had it from the old Elasticsearch dependency -->
306+
<dependency>
307+
<groupId>commons-codec</groupId>
308+
<artifactId>commons-codec</artifactId>
309+
<version>1.15</version>
310+
<scope>test</scope>
311+
</dependency>
312+
343313
</dependencies>
344314

345315
<build>

src/main/java/org/springframework/data/elasticsearch/client/elc/ElasticsearchTemplate.java

Lines changed: 9 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
*/
1616
package org.springframework.data.elasticsearch.client.elc;
1717

18-
import static org.springframework.data.elasticsearch.client.elc.TypeUtils.*;
18+
import static org.springframework.data.elasticsearch.client.elc.TypeUtils.result;
1919

2020
import co.elastic.clients.elasticsearch.ElasticsearchClient;
2121
import co.elastic.clients.elasticsearch._types.Time;
@@ -28,35 +28,20 @@
2828

2929
import java.io.IOException;
3030
import java.time.Duration;
31-
import java.util.ArrayList;
32-
import java.util.HashMap;
33-
import java.util.Iterator;
34-
import java.util.List;
35-
import java.util.Map;
31+
import java.util.*;
3632
import java.util.stream.Collectors;
3733

3834
import org.apache.commons.logging.Log;
3935
import org.apache.commons.logging.LogFactory;
4036
import org.springframework.data.elasticsearch.BulkFailureException;
4137
import org.springframework.data.elasticsearch.client.UnsupportedBackendOperation;
42-
import org.springframework.data.elasticsearch.core.AbstractElasticsearchTemplate;
43-
import org.springframework.data.elasticsearch.core.IndexOperations;
44-
import org.springframework.data.elasticsearch.core.IndexedObjectInformation;
45-
import org.springframework.data.elasticsearch.core.MultiGetItem;
46-
import org.springframework.data.elasticsearch.core.SearchHits;
47-
import org.springframework.data.elasticsearch.core.SearchScrollHits;
38+
import org.springframework.data.elasticsearch.core.*;
4839
import org.springframework.data.elasticsearch.core.cluster.ClusterOperations;
4940
import org.springframework.data.elasticsearch.core.convert.ElasticsearchConverter;
5041
import org.springframework.data.elasticsearch.core.document.Document;
5142
import org.springframework.data.elasticsearch.core.document.SearchDocumentResponse;
5243
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
53-
import org.springframework.data.elasticsearch.core.query.BulkOptions;
54-
import org.springframework.data.elasticsearch.core.query.ByQueryResponse;
55-
import org.springframework.data.elasticsearch.core.query.IndexQuery;
56-
import org.springframework.data.elasticsearch.core.query.MoreLikeThisQuery;
57-
import org.springframework.data.elasticsearch.core.query.Query;
58-
import org.springframework.data.elasticsearch.core.query.SearchTemplateQuery;
59-
import org.springframework.data.elasticsearch.core.query.UpdateQuery;
44+
import org.springframework.data.elasticsearch.core.query.*;
6045
import org.springframework.data.elasticsearch.core.query.UpdateResponse;
6146
import org.springframework.data.elasticsearch.core.reindex.ReindexRequest;
6247
import org.springframework.data.elasticsearch.core.reindex.ReindexResponse;
@@ -638,6 +623,11 @@ public Query idsQuery(List<String> ids) {
638623
return NativeQuery.builder().withQuery(qb -> qb.ids(iq -> iq.values(ids))).build();
639624
}
640625

626+
@Override
627+
public BaseQueryBuilder queryBuilderWithIds(List<String> ids) {
628+
return NativeQuery.builder().withIds(ids);
629+
}
630+
641631
/**
642632
* extract the list of {@link IndexedObjectInformation} from a {@link BulkResponse}.
643633
*

0 commit comments

Comments
 (0)