From f996a1903f1284308b9a9ee9de523b6e683ab4e8 Mon Sep 17 00:00:00 2001 From: Andrey G Date: Fri, 31 May 2024 22:09:46 +0300 Subject: [PATCH] FMWK-454 Update dependencies and version number (#245) --- pom.xml | 10 +++++----- .../aerospike/AerospikeCommonDataConfiguration.java | 7 +++++++ .../data/aerospike/AerospikeDataConfiguration.java | 8 +++++--- .../aerospike/AerospikeReactiveDataConfiguration.java | 6 ++++-- 4 files changed, 21 insertions(+), 10 deletions(-) diff --git a/pom.xml b/pom.xml index 5190c97..965181a 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ org.springframework.boot spring-boot-dependencies - 3.2.3 + 3.3.0 com.aerospike @@ -31,7 +31,7 @@ - 0.14.0 + 0.15.0 17 ${java.version} ${java.version} @@ -40,12 +40,12 @@ 1.6 1.6.0 - 4.7.1 + 4.8.0 7.1.0 7.2.1 - 3.1.5 + 3.1.6 - 4.1.1 + 4.1.2 diff --git a/spring-boot-autoconfigure-data-aerospike/src/main/java/org/springframework/boot/autoconfigure/data/aerospike/AerospikeCommonDataConfiguration.java b/spring-boot-autoconfigure-data-aerospike/src/main/java/org/springframework/boot/autoconfigure/data/aerospike/AerospikeCommonDataConfiguration.java index d7b0994..63e2faa 100644 --- a/spring-boot-autoconfigure-data-aerospike/src/main/java/org/springframework/boot/autoconfigure/data/aerospike/AerospikeCommonDataConfiguration.java +++ b/spring-boot-autoconfigure-data-aerospike/src/main/java/org/springframework/boot/autoconfigure/data/aerospike/AerospikeCommonDataConfiguration.java @@ -9,6 +9,7 @@ import org.springframework.context.annotation.Bean; import org.springframework.data.aerospike.config.AerospikeConnectionSettings; import org.springframework.data.aerospike.config.AerospikeDataSettings; +import org.springframework.data.aerospike.config.AerospikeSettings; import org.springframework.data.aerospike.convert.AerospikeCustomConversions; import org.springframework.data.aerospike.convert.AerospikeTypeAliasAccessor; import org.springframework.data.aerospike.convert.MappingAerospikeConverter; @@ -110,6 +111,12 @@ public AerospikeConnectionSettings readAerospikeSettings() { return new AerospikeConnectionSettings(); } + @Bean + public AerospikeSettings aerospikeSettings(AerospikeDataSettings dataSettings, + AerospikeConnectionSettings connectionSettings) { + return new AerospikeSettings(connectionSettings, dataSettings); + } + private AerospikeDataSettings aerospikeDataSettings(AerospikeDataProperties aerospikeDataProperties, AerospikeDataSettings dataSettings) { return configureDataSettings(dataSettings, aerospikeDataProperties); diff --git a/spring-boot-autoconfigure-data-aerospike/src/main/java/org/springframework/boot/autoconfigure/data/aerospike/AerospikeDataConfiguration.java b/spring-boot-autoconfigure-data-aerospike/src/main/java/org/springframework/boot/autoconfigure/data/aerospike/AerospikeDataConfiguration.java index 9bbe468..07828f1 100644 --- a/spring-boot-autoconfigure-data-aerospike/src/main/java/org/springframework/boot/autoconfigure/data/aerospike/AerospikeDataConfiguration.java +++ b/spring-boot-autoconfigure-data-aerospike/src/main/java/org/springframework/boot/autoconfigure/data/aerospike/AerospikeDataConfiguration.java @@ -24,6 +24,7 @@ import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Lazy; import org.springframework.data.aerospike.config.AerospikeDataSettings; +import org.springframework.data.aerospike.config.AerospikeSettings; import org.springframework.data.aerospike.convert.MappingAerospikeConverter; import org.springframework.data.aerospike.core.AerospikeExceptionTranslator; import org.springframework.data.aerospike.core.AerospikeTemplate; @@ -71,8 +72,9 @@ public AerospikeTemplate aerospikeTemplate(IAerospikeClient aerospikeClient, public QueryEngine aerospikeQueryEngine(IAerospikeClient aerospikeClient, AerospikeDataProperties aerospikeDataProperties, FilterExpressionsBuilder filterExpressionsBuilder, - StatementBuilder statementBuilder) { - QueryEngine queryEngine = new QueryEngine(aerospikeClient, statementBuilder, filterExpressionsBuilder); + StatementBuilder statementBuilder, AerospikeSettings settings) { + QueryEngine queryEngine = new QueryEngine(aerospikeClient, statementBuilder, filterExpressionsBuilder, + settings.getDataSettings()); queryEngine.setScansEnabled(aerospikeDataProperties.isScansEnabled()); queryEngine.setQueryMaxRecords(aerospikeDataProperties.getQueryMaxRecords()); return queryEngine; @@ -118,7 +120,7 @@ private AerospikeDataSettings aerospikeDataSettings(AerospikeDataProperties aero } private AerospikeDataSettings configureDataSettings(AerospikeDataSettings dataSettings, - AerospikeDataProperties aerospikeDataProperties) { + AerospikeDataProperties aerospikeDataProperties) { dataSettings.setScansEnabled(aerospikeDataProperties.isScansEnabled()); dataSettings.setCreateIndexesOnStartup(aerospikeDataProperties.isCreateIndexesOnStartup()); return dataSettings; diff --git a/spring-boot-autoconfigure-data-aerospike/src/main/java/org/springframework/boot/autoconfigure/data/aerospike/AerospikeReactiveDataConfiguration.java b/spring-boot-autoconfigure-data-aerospike/src/main/java/org/springframework/boot/autoconfigure/data/aerospike/AerospikeReactiveDataConfiguration.java index 470b666..1df8034 100644 --- a/spring-boot-autoconfigure-data-aerospike/src/main/java/org/springframework/boot/autoconfigure/data/aerospike/AerospikeReactiveDataConfiguration.java +++ b/spring-boot-autoconfigure-data-aerospike/src/main/java/org/springframework/boot/autoconfigure/data/aerospike/AerospikeReactiveDataConfiguration.java @@ -22,6 +22,7 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Lazy; +import org.springframework.data.aerospike.config.AerospikeSettings; import org.springframework.data.aerospike.convert.MappingAerospikeConverter; import org.springframework.data.aerospike.core.AerospikeExceptionTranslator; import org.springframework.data.aerospike.core.ReactiveAerospikeTemplate; @@ -66,9 +67,10 @@ public ReactiveAerospikeTemplate reactiveAerospikeTemplate(MappingAerospikeConve public ReactorQueryEngine reactiveAerospikeQueryEngine(AerospikeReactorClient aerospikeReactorClient, AerospikeDataProperties aerospikeDataProperties, FilterExpressionsBuilder filterExpressionsBuilder, - StatementBuilder statementBuilder) { + StatementBuilder statementBuilder, + AerospikeSettings settings) { ReactorQueryEngine queryEngine = new ReactorQueryEngine(aerospikeReactorClient, statementBuilder, - filterExpressionsBuilder); + filterExpressionsBuilder, settings.getDataSettings()); queryEngine.setScansEnabled(aerospikeDataProperties.isScansEnabled()); queryEngine.setQueryMaxRecords(aerospikeDataProperties.getQueryMaxRecords()); return queryEngine;