From 5731afc284262f8a5524f740f1c14fe7d54ecdac Mon Sep 17 00:00:00 2001 From: Peter-Josef Meisch Date: Sat, 13 May 2023 09:05:32 +0200 Subject: [PATCH] Remove the integration of the deprecated RestHighLevelClient. --- pom.xml | 50 +- .../client/elc/ElasticsearchTemplate.java | 28 +- .../elc/ReactiveElasticsearchTemplate.java | 112 +- .../AbstractElasticsearchConfiguration.java | 56 - ...actReactiveElasticsearchConfiguration.java | 81 - .../client/erhlc/CriteriaFilterProcessor.java | 273 --- .../client/erhlc/CriteriaQueryProcessor.java | 294 --- .../erhlc/DefaultClusterOperations.java | 47 - .../DefaultReactiveClusterOperations.java | 45 - .../DefaultReactiveElasticsearchClient.java | 907 --------- .../client/erhlc/DefaultRequestCreator.java | 24 - .../erhlc/DefaultWebClientProvider.java | 193 -- .../client/erhlc/DocumentAdapters.java | 750 ------- .../erhlc/ElasticsearchAggregation.java | 43 - .../erhlc/ElasticsearchAggregations.java | 43 - .../erhlc/ElasticsearchClusterOperations.java | 41 - .../ElasticsearchExceptionTranslator.java | 144 -- .../erhlc/ElasticsearchRestTemplate.java | 698 ------- .../client/erhlc/HighlightQueryBuilder.java | 180 -- .../client/erhlc/HostProvider.java | 179 -- .../client/erhlc/MultiNodeHostProvider.java | 213 -- .../client/erhlc/NamedXContents.java | 176 -- .../client/erhlc/NativeSearchQuery.java | 231 --- .../erhlc/NativeSearchQueryBuilder.java | 328 --- .../client/erhlc/RawActionResponse.java | 87 - .../erhlc/ReactiveElasticsearchClient.java | 1754 ----------------- .../erhlc/ReactiveElasticsearchTemplate.java | 779 -------- .../client/erhlc/ReactiveIndexTemplate.java | 402 ---- .../client/erhlc/ReactiveRestClients.java | 88 - .../erhlc/RequestBodyEncodingException.java | 42 - .../client/erhlc/RequestConverters.java | 1473 -------------- .../client/erhlc/RequestCreator.java | 308 --- .../client/erhlc/RequestFactory.java | 1343 ------------- .../client/erhlc/ResponseConverter.java | 441 ----- .../client/erhlc/RestClients.java | 270 --- ...stHighLevelClientBeanDefinitionParser.java | 48 - .../erhlc/RestHighLevelClientFactoryBean.java | 106 - .../client/erhlc/RestIndexTemplate.java | 281 --- .../client/erhlc/ScriptField.java | 43 - .../erhlc/SearchDocumentResponseBuilder.java | 225 --- .../client/erhlc/SearchHitsUtil.java | 34 - .../client/erhlc/SingleNodeHostProvider.java | 110 -- .../client/erhlc/WebClientProvider.java | 270 --- .../client/erhlc/package-info.java | 25 - .../ElasticsearchConfigurationSupport.java | 5 +- .../core/AbstractIndexTemplate.java | 241 --- .../core/ReactiveElasticsearchOperations.java | 68 - .../core/ReactiveSearchOperations.java | 29 +- .../elasticsearch/core/SearchOperations.java | 10 + .../elasticsearch/core/query/StringQuery.java | 5 + .../JUnit5SampleReactiveERHLCTests.java | 47 - .../JUnit5SampleRestTemplateTests.java | 47 - .../NestedObjectERHLCIntegrationTests.java | 89 - .../client/ClientConfigurationUnitTests.java | 47 - .../elasticsearch/client/RestClientsTest.java | 107 +- .../erhlc/CriteriaQueryMappingUnitTests.java | 521 ----- .../CriteriaQueryProcessorUnitTests.java | 476 ----- ...efaultReactiveElasticsearchClientTest.java | 114 -- .../DefaultWebClientProviderUnitTests.java | 60 - .../ElasticsearchERHLCIntegrationTests.java | 297 --- ...ElasticsearchExceptionTranslatorTests.java | 61 - ...csearchPartQueryERHLCIntegrationTests.java | 47 - .../erhlc/MultiNodeHostProviderUnitTests.java | 159 -- ...veElasticsearchClientIntegrationTests.java | 1132 ----------- .../ReactiveElasticsearchClientUnitTests.java | 731 ------- .../erhlc/ReactiveMockClientTestsUtils.java | 505 ----- .../client/erhlc/RequestConvertersTest.java | 89 - .../client/erhlc/RequestFactoryTests.java | 895 --------- .../SingleNodeHostProviderUnitTests.java | 76 - .../config/AuditingERHLCIntegrationTests.java | 30 - ...AuditingReactiveERHLCIntegrationTests.java | 33 - ...icsearchConfigurationSupportUnitTests.java | 50 - .../ElasticsearchConfigurationERHLCTests.java | 76 - ...iveElasticsearchConfigurationELCTests.java | 3 - ...eElasticsearchConfigurationERHLCTests.java | 78 - ...stedRepositoriesERHLCIntegrationTests.java | 44 - ...ableRepositoriesERHLCIntegrationTests.java | 39 - .../core/ElasticsearchIntegrationTests.java | 56 +- .../core/InnerHitsERHLCIntegrationTests.java | 60 - .../core/LogEntityERHLCIntegrationTests.java | 53 - .../PointInTimeERHLCIntegrationTests.java | 45 - ...iveElasticsearchERHLCIntegrationTests.java | 104 - ...ReactiveElasticsearchIntegrationTests.java | 24 +- ...iveElasticsearchTemplateCallbackTests.java | 507 ----- ...eactiveElasticsearchTemplateUnitTests.java | 338 ---- ...ctivePointInTimeERHLCIntegrationTests.java | 47 - .../ReactiveReindexERHLCIntegrationTests.java | 39 - .../core/ReindexERHLCIntegrationTests.java | 47 - .../RuntimeFieldsERHLCIntegrationTests.java | 39 - .../SearchAsYouTypeERHLCIntegrationTests.java | 51 - .../SourceFilterERHLCIntegrationTests.java | 40 - .../AggregationERHLCIntegrationTests.java | 97 - ...lusterOperationsERHLCIntegrationTests.java | 25 - ...erationsReactiveERHLCIntegrationTests.java | 25 - .../document/DocumentAdaptersUnitTests.java | 276 --- .../event/CallbackERHLCIntegrationTests.java | 41 - ...ReactiveCallbackERHLCIntegrationTests.java | 40 - .../core/geo/GeoERHLCIntegrationTests.java | 56 - .../geo/GeoJsonERHLCIntegrationTests.java | 41 - .../IndexOperationsERHLCIntegrationTests.java | 39 - .../IndexTemplateERHLCIntegrationTests.java | 26 - .../MappingBuilderERHLCIntegrationTests.java | 40 - .../index/MappingBuilderIntegrationTests.java | 25 +- ...eIndexOperationsERHLCIntegrationTests.java | 39 - ...iveIndexTemplateERHLCIntegrationTests.java | 39 - ...CustomConversionERHLCIntegrationTests.java | 51 - ...ldNamingStrategyERHLCIntegrationTests.java | 54 - ...ldNamingStrategyERHLCIntegrationTests.java | 52 - ...ctiveSearchAfterERHLCIntegrationTests.java | 41 - .../SearchAfterERHLCIntegrationTests.java | 42 - .../CriteriaQueryERHLCIntegrationTests.java | 40 - .../query/HighlightQueryBuilderTests.java | 148 -- .../query/NativeSearchQueryBuilderTests.java | 65 - .../core/query/SeqNoPrimaryTermTests.java | 15 +- .../ReactiveRoutingERHLCIntegrationTests.java | 39 - .../routing/RoutingERHLCIntegrationTests.java | 40 - .../core/routing/RoutingIntegrationTests.java | 4 +- .../CompletionERHLCIntegrationTests.java | 57 - ...tionWithContextsERHLCIntegrationTests.java | 74 - .../ReactiveSuggestERHLCIntegrationTests.java | 55 - ...utableRepositoryERHLCIntegrationTests.java | 43 - ...lasticsearchRestTemplateConfiguration.java | 115 -- ...lasticsearchRestTemplateConfiguration.java | 75 - ...MethodRepositoryERHLCIntegrationTests.java | 43 - ...toryManualWiringERHLCIntegrationTests.java | 43 - ...MethodRepositoryERHLCIntegrationTests.java | 50 - ...ubleIDRepositoryERHLCIntegrationTests.java | 41 - ...namicIndexEntityERHLCIntegrationTests.java | 40 - .../GeoRepositoryERHLCIntegrationTests.java | 40 - ...egerIDRepositoryERHLCIntegrationTests.java | 41 - .../InnerObjectERHLCIntegrationTests.java | 41 - ...ngEntityRepositoryELCIntegrationTests.java | 2 +- ...EntityRepositoryERHLCIntegrationTests.java | 43 - ...EntityRepositoryERHLCIntegrationTests.java | 43 - .../spel/SpELEntityERHLCIntegrationTests.java | 41 - ...ynonymRepositoryERHLCIntegrationTests.java | 40 - ...searchRepositoryERHLCIntegrationTests.java | 41 - ...asticsearchRepositoryIntegrationTests.java | 6 - ...asticsearchRepositoriesRegistrarTests.java | 6 +- .../QueryKeywordsERHLCIntegrationTests.java | 43 - ...iveQueryKeywordsERHLCIntegrationTests.java | 43 - ...veValueConverterERHLCIntegrationTests.java | 43 - .../ValueConverterERHLCIntegrationTests.java | 44 - ...searchRepositoryERHLCIntegrationTests.java | 44 - ...asticsearchRepositoryIntegrationTests.java | 6 - ...searchRepositoryERHLCIntegrationTests.java | 43 - ...icsearchExecutorERHLCIntegrationTests.java | 44 - ...icsearchExecutorERHLCIntegrationTests.java | 44 - 148 files changed, 142 insertions(+), 23518 deletions(-) delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/AbstractElasticsearchConfiguration.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/AbstractReactiveElasticsearchConfiguration.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/CriteriaFilterProcessor.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/CriteriaQueryProcessor.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/DefaultClusterOperations.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/DefaultReactiveClusterOperations.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/DefaultReactiveElasticsearchClient.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/DefaultRequestCreator.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/DefaultWebClientProvider.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/DocumentAdapters.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/ElasticsearchAggregation.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/ElasticsearchAggregations.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/ElasticsearchClusterOperations.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/ElasticsearchExceptionTranslator.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/ElasticsearchRestTemplate.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/HighlightQueryBuilder.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/HostProvider.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/MultiNodeHostProvider.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/NamedXContents.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/NativeSearchQuery.java delete mode 100755 src/main/java/org/springframework/data/elasticsearch/client/erhlc/NativeSearchQueryBuilder.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/RawActionResponse.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/ReactiveElasticsearchClient.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/ReactiveElasticsearchTemplate.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/ReactiveIndexTemplate.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/ReactiveRestClients.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/RequestBodyEncodingException.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/RequestConverters.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/RequestCreator.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/RequestFactory.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/ResponseConverter.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/RestClients.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/RestHighLevelClientBeanDefinitionParser.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/RestHighLevelClientFactoryBean.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/RestIndexTemplate.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/ScriptField.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/SearchDocumentResponseBuilder.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/SearchHitsUtil.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/SingleNodeHostProvider.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/WebClientProvider.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/client/erhlc/package-info.java delete mode 100644 src/main/java/org/springframework/data/elasticsearch/core/AbstractIndexTemplate.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/JUnit5SampleReactiveERHLCTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/JUnit5SampleRestTemplateTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/NestedObjectERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/CriteriaQueryMappingUnitTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/CriteriaQueryProcessorUnitTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/DefaultReactiveElasticsearchClientTest.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/DefaultWebClientProviderUnitTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/ElasticsearchERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/ElasticsearchExceptionTranslatorTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/ElasticsearchPartQueryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/MultiNodeHostProviderUnitTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/ReactiveElasticsearchClientIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/ReactiveElasticsearchClientUnitTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/ReactiveMockClientTestsUtils.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/RequestConvertersTest.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/RequestFactoryTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/client/erhlc/SingleNodeHostProviderUnitTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/config/AuditingERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/config/AuditingReactiveERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/config/configuration/ElasticsearchConfigurationERHLCTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/config/configuration/ReactiveElasticsearchConfigurationERHLCTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/config/nested/EnableNestedRepositoriesERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/config/notnested/EnableRepositoriesERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/InnerHitsERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/LogEntityERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/PointInTimeERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/ReactiveElasticsearchERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/ReactiveElasticsearchTemplateCallbackTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/ReactiveElasticsearchTemplateUnitTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/ReactivePointInTimeERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/ReactiveReindexERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/ReindexERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/RuntimeFieldsERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/SearchAsYouTypeERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/SourceFilterERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/aggregation/AggregationERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/cluster/ClusterOperationsERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/cluster/ClusterOperationsReactiveERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/document/DocumentAdaptersUnitTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/event/CallbackERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/event/ReactiveCallbackERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/geo/GeoERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/geo/GeoJsonERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/index/IndexOperationsERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/index/IndexTemplateERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/index/MappingBuilderERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/index/ReactiveIndexOperationsERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/index/ReactiveIndexTemplateERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/mapping/EntityCustomConversionERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/mapping/FieldNamingStrategyERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/mapping/ReactiveFieldNamingStrategyERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/paginating/ReactiveSearchAfterERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/paginating/SearchAfterERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/query/CriteriaQueryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/query/HighlightQueryBuilderTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/query/NativeSearchQueryBuilderTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/routing/ReactiveRoutingERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/routing/RoutingERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/suggest/CompletionERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/suggest/CompletionWithContextsERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/core/suggest/ReactiveSuggestERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/immutable/ImmutableRepositoryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/junit/jupiter/ElasticsearchRestTemplateConfiguration.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/junit/jupiter/ReactiveElasticsearchRestTemplateConfiguration.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repositories/complex/custommethod/autowiring/ComplexCustomMethodRepositoryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repositories/complex/custommethod/manualwiring/ComplexCustomMethodRepositoryManualWiringERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repositories/custommethod/CustomMethodRepositoryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repositories/doubleid/DoubleIDRepositoryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repositories/dynamicindex/DynamicIndexEntityERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repositories/geo/GeoRepositoryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repositories/integer/IntegerIDRepositoryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repositories/nestedobject/InnerObjectERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repositories/setting/dynamic/DynamicSettingAndMappingEntityRepositoryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repositories/setting/fielddynamic/FieldDynamicMappingEntityRepositoryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repositories/spel/SpELEntityERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repositories/synonym/SynonymRepositoryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repositories/uuidkeyed/UUIDElasticsearchRepositoryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repository/query/keywords/QueryKeywordsERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repository/query/keywords/ReactiveQueryKeywordsERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repository/query/valueconverter/ReactiveValueConverterERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repository/query/valueconverter/ValueConverterERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repository/support/ElasticsearchRepositoryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repository/support/SimpleReactiveElasticsearchRepositoryERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repository/support/querybyexample/QueryByExampleElasticsearchExecutorERHLCIntegrationTests.java delete mode 100644 src/test/java/org/springframework/data/elasticsearch/repository/support/querybyexample/ReactiveQueryByExampleElasticsearchExecutorERHLCIntegrationTests.java diff --git a/pom.xml b/pom.xml index 3b308db0cd..8de17af650 100644 --- a/pom.xml +++ b/pom.xml @@ -20,17 +20,12 @@ 3.2.0-SNAPSHOT - - 7.17.9 - + 8.7.1 - 2.18.0 - - 4.1.90.Final - 1.0.8.RELEASE 0.14.4 + 2.18.0 1.5.1 1.18.0 2.35.0 @@ -93,18 +88,6 @@ https://github.com/spring-projects/spring-data-elasticsearch/issues - - - - io.netty - netty-bom - ${netty} - pom - import - - - - @@ -132,33 +115,12 @@ true - - io.projectreactor.netty - reactor-netty-http - true - - io.projectreactor reactor-test test - - - org.elasticsearch.client - elasticsearch-rest-high-level-client - ${elasticsearch-rhlc} - true - - - commons-logging - commons-logging - - - - - co.elastic.clients elasticsearch-java @@ -340,6 +302,14 @@ test + + + commons-codec + commons-codec + 1.15 + test + + diff --git a/src/main/java/org/springframework/data/elasticsearch/client/elc/ElasticsearchTemplate.java b/src/main/java/org/springframework/data/elasticsearch/client/elc/ElasticsearchTemplate.java index b6b57f96a5..663b0ae40d 100644 --- a/src/main/java/org/springframework/data/elasticsearch/client/elc/ElasticsearchTemplate.java +++ b/src/main/java/org/springframework/data/elasticsearch/client/elc/ElasticsearchTemplate.java @@ -15,7 +15,7 @@ */ package org.springframework.data.elasticsearch.client.elc; -import static org.springframework.data.elasticsearch.client.elc.TypeUtils.*; +import static org.springframework.data.elasticsearch.client.elc.TypeUtils.result; import co.elastic.clients.elasticsearch.ElasticsearchClient; import co.elastic.clients.elasticsearch._types.Time; @@ -28,35 +28,20 @@ import java.io.IOException; import java.time.Duration; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.Iterator; -import java.util.List; -import java.util.Map; +import java.util.*; import java.util.stream.Collectors; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.springframework.data.elasticsearch.BulkFailureException; import org.springframework.data.elasticsearch.client.UnsupportedBackendOperation; -import org.springframework.data.elasticsearch.core.AbstractElasticsearchTemplate; -import org.springframework.data.elasticsearch.core.IndexOperations; -import org.springframework.data.elasticsearch.core.IndexedObjectInformation; -import org.springframework.data.elasticsearch.core.MultiGetItem; -import org.springframework.data.elasticsearch.core.SearchHits; -import org.springframework.data.elasticsearch.core.SearchScrollHits; +import org.springframework.data.elasticsearch.core.*; import org.springframework.data.elasticsearch.core.cluster.ClusterOperations; import org.springframework.data.elasticsearch.core.convert.ElasticsearchConverter; import org.springframework.data.elasticsearch.core.document.Document; import org.springframework.data.elasticsearch.core.document.SearchDocumentResponse; import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates; -import org.springframework.data.elasticsearch.core.query.BulkOptions; -import org.springframework.data.elasticsearch.core.query.ByQueryResponse; -import org.springframework.data.elasticsearch.core.query.IndexQuery; -import org.springframework.data.elasticsearch.core.query.MoreLikeThisQuery; -import org.springframework.data.elasticsearch.core.query.Query; -import org.springframework.data.elasticsearch.core.query.SearchTemplateQuery; -import org.springframework.data.elasticsearch.core.query.UpdateQuery; +import org.springframework.data.elasticsearch.core.query.*; import org.springframework.data.elasticsearch.core.query.UpdateResponse; import org.springframework.data.elasticsearch.core.reindex.ReindexRequest; import org.springframework.data.elasticsearch.core.reindex.ReindexResponse; @@ -638,6 +623,11 @@ public Query idsQuery(List ids) { return NativeQuery.builder().withQuery(qb -> qb.ids(iq -> iq.values(ids))).build(); } + @Override + public BaseQueryBuilder queryBuilderWithIds(List ids) { + return NativeQuery.builder().withIds(ids); + } + /** * extract the list of {@link IndexedObjectInformation} from a {@link BulkResponse}. * diff --git a/src/main/java/org/springframework/data/elasticsearch/client/elc/ReactiveElasticsearchTemplate.java b/src/main/java/org/springframework/data/elasticsearch/client/elc/ReactiveElasticsearchTemplate.java index 1fdb0b1166..5cf1bc85f0 100644 --- a/src/main/java/org/springframework/data/elasticsearch/client/elc/ReactiveElasticsearchTemplate.java +++ b/src/main/java/org/springframework/data/elasticsearch/client/elc/ReactiveElasticsearchTemplate.java @@ -100,7 +100,7 @@ protected Mono> doIndex(T entity, IndexCoor getRefreshPolicy()); return Mono.just(entity) // .zipWith(// - Mono.from(execute((ClientCallback>) client -> client.index(indexRequest))) // + Mono.from(execute(client -> client.index(indexRequest))) // .map(indexResponse -> new IndexResponseMetaData(indexResponse.id(), // indexResponse.index(), // indexResponse.seqNo(), // @@ -149,9 +149,7 @@ protected Mono doExists(String id, IndexCoordinates index) { GetRequest getRequest = requestConverter.documentGetRequest(id, routingResolver.getRouting(), index, true); - return Mono.from(execute( - ((ClientCallback>>) client -> client.get(getRequest, EntityAsMap.class)))) - .map(GetResult::found) // + return Mono.from(execute(client -> client.get(getRequest, EntityAsMap.class))).map(GetResult::found) // .onErrorReturn(NoSuchIndexException.class, false); } @@ -162,9 +160,7 @@ public Mono delete(Query query, Class entityType, IndexCoord DeleteByQueryRequest request = requestConverter.documentDeleteByQueryRequest(query, routingResolver.getRouting(), entityType, index, getRefreshPolicy()); - return Mono - .from(execute((ClientCallback>) client -> client.deleteByQuery(request))) - .map(responseConverter::byQueryResponse); + return Mono.from(execute(client -> client.deleteByQuery(request))).map(responseConverter::byQueryResponse); } @Override @@ -176,8 +172,8 @@ public Mono get(String id, Class entityType, IndexCoordinates index) { GetRequest getRequest = requestConverter.documentGetRequest(id, routingResolver.getRouting(), index, false); - Mono> getResponse = Mono.from(execute( - (ClientCallback>>) client -> client.get(getRequest, EntityAsMap.class))); + Mono> getResponse = Mono + .from(execute(client -> client.get(getRequest, EntityAsMap.class))); ReadDocumentCallback callback = new ReadDocumentCallback<>(converter, entityType, index); return getResponse.flatMap(response -> callback.toEntity(DocumentAdapters.from(response))); @@ -192,9 +188,7 @@ public Mono reindex(ReindexRequest reindexRequest) { true); return Mono.from(execute( // - (ClientCallback>) client -> client - .reindex(reindexRequestES))) - .map(responseConverter::reindexResponse); + client -> client.reindex(reindexRequestES))).map(responseConverter::reindexResponse); } @Override @@ -206,8 +200,7 @@ public Mono submitReindex(ReindexRequest reindexRequest) { false); return Mono.from(execute( // - (ClientCallback>) client -> client - .reindex(reindexRequestES))) + client -> client.reindex(reindexRequestES))) .flatMap(response -> (response.task() == null) ? Mono.error( new UnsupportedBackendOperation("ElasticsearchClient did not return a task id on submit request")) @@ -223,13 +216,10 @@ public Mono update(UpdateQuery updateQuery, IndexCoordinates ind UpdateRequest request = requestConverter.documentUpdateRequest(updateQuery, index, getRefreshPolicy(), routingResolver.getRouting()); - return Mono.from(execute( - (ClientCallback>>) client -> client - .update(request, Document.class))) - .flatMap(response -> { - UpdateResponse.Result result = result(response.result()); - return result == null ? Mono.empty() : Mono.just(UpdateResponse.of(result)); - }); + return Mono.from(execute(client -> client.update(request, Document.class))).flatMap(response -> { + UpdateResponse.Result result = result(response.result()); + return result == null ? Mono.empty() : Mono.just(UpdateResponse.of(result)); + }); } @Override @@ -292,7 +282,7 @@ protected Mono doDeleteById(String id, @Nullable String routing, IndexCo private Mono doDelete(DeleteRequest request) { - return Mono.from(execute((ClientCallback>) client -> client.delete(request))) // + return Mono.from(execute(client -> client.delete(request))) // .flatMap(deleteResponse -> { if (deleteResponse.result() == Result.NotFound) { return Mono.empty(); @@ -311,8 +301,7 @@ public Flux> multiGet(Query query, Class clazz, IndexCoor ReadDocumentCallback callback = new ReadDocumentCallback<>(converter, clazz, index); - Publisher> response = execute( - (ClientCallback>>) client -> client.mget(request, EntityAsMap.class)); + Publisher> response = execute(client -> client.mget(request, EntityAsMap.class)); return Mono.from(response)// .flatMapMany(it -> Flux.fromIterable(DocumentAdapters.from(it))) // @@ -364,14 +353,14 @@ private Flux doFindUnbounded(Query query, Class clazz, IndexC BiFunction> asyncError = (psa, ex) -> { if (LOGGER.isErrorEnabled()) { - LOGGER.error(String.format("Error during pit/search_after"), ex); + LOGGER.error("Error during pit/search_after", ex); } return cleanupPit(psa); }; Function> asyncCancel = psa -> { if (LOGGER.isWarnEnabled()) { - LOGGER.warn(String.format("pit/search_after was cancelled")); + LOGGER.warn("pit/search_after was cancelled"); } return cleanupPit(psa); }; @@ -383,8 +372,8 @@ private Flux doFindUnbounded(Query query, Class clazz, IndexC SearchRequest firstSearchRequest = requestConverter.searchRequest(baseQuery, routingResolver.getRouting(), clazz, index, false, true); - return Mono.from(execute((ClientCallback>>) client -> client - .search(firstSearchRequest, EntityAsMap.class))).expand(entityAsMapSearchResponse -> { + return Mono.from(execute(client -> client.search(firstSearchRequest, EntityAsMap.class))) + .expand(entityAsMapSearchResponse -> { var hits = entityAsMapSearchResponse.hits().hits(); if (CollectionUtils.isEmpty(hits)) { @@ -396,8 +385,7 @@ private Flux doFindUnbounded(Query query, Class clazz, IndexC baseQuery.setSearchAfter(sortOptions); SearchRequest followSearchRequest = requestConverter.searchRequest(baseQuery, routingResolver.getRouting(), clazz, index, false, true); - return Mono.from(execute((ClientCallback>>) client -> client - .search(followSearchRequest, EntityAsMap.class))); + return Mono.from(execute(client -> client.search(followSearchRequest, EntityAsMap.class))); }); }; @@ -454,9 +442,7 @@ protected Mono doCount(Query query, Class entityType, IndexCoordinates SearchRequest searchRequest = requestConverter.searchRequest(query, routingResolver.getRouting(), entityType, index, true); - return Mono - .from(execute((ClientCallback>>) client -> client.search(searchRequest, - EntityAsMap.class))) + return Mono.from(execute(client -> client.search(searchRequest, EntityAsMap.class))) .map(searchResponse -> searchResponse.hits().total() != null ? searchResponse.hits().total().value() : 0L); } @@ -465,9 +451,7 @@ private Flux doFindBounded(Query query, Class clazz, IndexCoo SearchRequest searchRequest = requestConverter.searchRequest(query, routingResolver.getRouting(), clazz, index, false, false); - return Mono - .from(execute((ClientCallback>>) client -> client.search(searchRequest, - EntityAsMap.class))) // + return Mono.from(execute(client -> client.search(searchRequest, EntityAsMap.class))) // .flatMapIterable(entityAsMapSearchResponse -> entityAsMapSearchResponse.hits().hits()) // .map(entityAsMapHit -> DocumentAdapters.from(entityAsMapHit, jsonpMapper)); } @@ -476,9 +460,7 @@ private Flux doSearch(SearchTemplateQuery query, Class clazz, var request = requestConverter.searchTemplate(query, routingResolver.getRouting(), index); - return Mono - .from(execute((ClientCallback>>) client -> client - .searchTemplate(request, EntityAsMap.class))) // + return Mono.from(execute(client -> client.searchTemplate(request, EntityAsMap.class))) // .flatMapIterable(entityAsMapSearchResponse -> entityAsMapSearchResponse.hits().hits()) // .map(entityAsMapHit -> DocumentAdapters.from(entityAsMapHit, jsonpMapper)); } @@ -497,9 +479,7 @@ protected Mono doFindForResponse(Query query, Class< SearchDocumentResponse.EntityCreator entityCreator = searchDocument -> callback.toEntity(searchDocument) .toFuture(); - return Mono - .from(execute((ClientCallback>>) client -> client.search(searchRequest, - EntityAsMap.class))) + return Mono.from(execute(client -> client.search(searchRequest, EntityAsMap.class))) .map(searchResponse -> SearchDocumentResponseBuilder.from(searchResponse, entityCreator, jsonpMapper)); } @@ -520,9 +500,7 @@ public Mono openPointInTime(IndexCoordinates index, Duration keepAlive, Assert.notNull(ignoreUnavailable, "ignoreUnavailable must not be null"); var request = requestConverter.searchOpenPointInTimeRequest(index, keepAlive, ignoreUnavailable); - return Mono - .from(execute((ClientCallback>) client -> client.openPointInTime(request))) - .map(OpenPointInTimeResponse::id); + return Mono.from(execute(client -> client.openPointInTime(request))).map(OpenPointInTimeResponse::id); } @Override @@ -531,9 +509,7 @@ public Mono closePointInTime(String pit) { Assert.notNull(pit, "pit must not be null"); ClosePointInTimeRequest request = requestConverter.searchClosePointInTime(pit); - return Mono - .from(execute((ClientCallback>) client -> client.closePointInTime(request))) - .map(ClosePointInTimeResponse::succeeded); + return Mono.from(execute(client -> client.closePointInTime(request))).map(ClosePointInTimeResponse::succeeded); } // endregion @@ -545,8 +521,7 @@ public Mono putScript(Script script) { Assert.notNull(script, "script must not be null"); var request = requestConverter.scriptPut(script); - return Mono.from(execute((ClientCallback>) client -> client.putScript(request))) - .map(PutScriptResponse::acknowledged); + return Mono.from(execute(client -> client.putScript(request))).map(PutScriptResponse::acknowledged); } @Override @@ -555,8 +530,7 @@ public Mono