Switch to MongoDB 5.0 driver

Author: christophstrobl

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/mongo/MongoReactiveAutoConfiguration.java

@@ -16,6 +16,8 @@
 
 package org.springframework.boot.autoconfigure.mongo;
 
+import java.lang.reflect.Method;
+
 import com.mongodb.MongoClientSettings;
 import com.mongodb.MongoClientSettings.Builder;
 import com.mongodb.connection.TransportSettings;
@@ -25,6 +27,9 @@
 import io.netty.channel.socket.SocketChannel;
 import reactor.core.publisher.Flux;
 
+import org.springframework.aot.hint.MemberCategory;
+import org.springframework.aot.hint.RuntimeHints;
+import org.springframework.aot.hint.RuntimeHintsRegistrar;
 import org.springframework.beans.factory.DisposableBean;
 import org.springframework.beans.factory.ObjectProvider;
 import org.springframework.boot.autoconfigure.AutoConfiguration;
@@ -37,13 +42,15 @@
 import org.springframework.context.annotation.Configuration;
 import org.springframework.core.Ordered;
 import org.springframework.core.annotation.Order;
+import org.springframework.util.ReflectionUtils;
 
 /**
  * {@link EnableAutoConfiguration Auto-configuration} for Reactive Mongo.
  *
  * @author Mark Paluch
  * @author Stephane Nicoll
  * @author Scott Frederick
+ * @author Christoph Strobl
  * @since 2.0.0
  */
 @AutoConfiguration
@@ -132,9 +139,36 @@ public void destroy() {
 		@SuppressWarnings("deprecation")
 		private boolean isCustomTransportConfiguration(MongoClientSettings settings) {
 			return settings != null
-					&& (settings.getTransportSettings() != null || settings.getStreamFactoryFactory() != null);
+					&& (settings.getTransportSettings() != null || isMongo4configuredStreamFactorFactory(settings));
 		}
 
+		/**
+		 * The {@code getStreamFactoryFactory} method has been removed from
+		 * {@link MongoClientSettings} in the 5.0 MongoDB driver generation. To remain
+		 * backwards compatible the lookup is now done reflectively.
+		 * @param settings must not be {@literal null}.
+		 * @return {@literal true} if method present and return value is not
+		 * {@literal null}.
+		 * @since 3.3
+		 */
+		boolean isMongo4configuredStreamFactorFactory(MongoClientSettings settings) {
+
+			Method getStreamFactoryFactory = ReflectionUtils.findMethod(MongoClientSettings.class,
+					"getStreamFactoryFactory");
+			if (getStreamFactoryFactory == null) {
+				return false;
+			}
+			return ReflectionUtils.invokeMethod(getStreamFactoryFactory, settings) != null;
+		}
+
+	}
+
+	static class MongoReactiveAutoConfigurationRuntimeHints implements RuntimeHintsRegistrar {
+
+		@Override
+		public void registerHints(RuntimeHints hints, ClassLoader classLoader) {
+			hints.reflection().registerTypeIfPresent(classLoader, "com.mongodb.MongoClientSettings", MemberCategory.INVOKE_PUBLIC_METHODS);
+		}
 	}
 
 }

spring-boot-project/spring-boot-autoconfigure/src/main/resources/META-INF/spring/aot.factories

@@ -2,6 +2,7 @@ org.springframework.aot.hint.RuntimeHintsRegistrar=\
 org.springframework.boot.autoconfigure.freemarker.FreeMarkerTemplateAvailabilityProvider.FreeMarkerTemplateAvailabilityRuntimeHints,\
 org.springframework.boot.autoconfigure.groovy.template.GroovyTemplateAvailabilityProvider.GroovyTemplateAvailabilityRuntimeHints,\
 org.springframework.boot.autoconfigure.jackson.JacksonAutoConfiguration.JacksonAutoConfigurationRuntimeHints,\
+org.springframework.boot.autoconfigure.mongo.MongoReactiveAutoConfiguration.MongoReactiveAutoConfigurationRuntimeHints,\
 org.springframework.boot.autoconfigure.template.TemplateRuntimeHints
 
 org.springframework.beans.factory.aot.BeanFactoryInitializationAotProcessor=\

spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/mongo/MongoReactiveAutoConfigurationTests.java

@@ -230,7 +230,6 @@ void customizerWithTransportSettingsOverridesAutoConfig() {
 				assertThat(settings.getApplicationName()).isEqualTo("custom-transport-settings");
 				assertThat(settings.getTransportSettings())
 					.isSameAs(SimpleTransportSettingsCustomizerConfig.transportSettings);
-				assertThat(settings.getStreamFactoryFactory()).isNull();
 			});
 	}
 

spring-boot-project/spring-boot-dependencies/build.gradle

@@ -1277,7 +1277,7 @@ bom {
 			releaseNotes("https://github.com/mockito/mockito/releases/tag/v{version}")
 		}
 	}
-	library("MongoDB", "4.11.1") {
+	library("MongoDB", "5.0.0") {
 		group("org.mongodb") {
 			modules = [
 				"bson",