From a0b167905e57b2ae7c66521eeb3b71d35146328d Mon Sep 17 00:00:00 2001
From: Soren Mathiasen <sorenm@mymessages.dk>
Date: Mon, 30 Dec 2024 15:14:43 +0100
Subject: [PATCH] override mongodb connection string

---
 pom.xml                                                       | 2 +-
 .../java/com/kapeta/spring/mongo/AbstractMongoDBConfig.java   | 4 ++++
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/pom.xml b/pom.xml
index c0236d4..f189ba2 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>com.kapeta</groupId>
     <artifactId>nosql-mongodb</artifactId>
-    <version>1.1.0</version>
+    <version>1.1.1</version>
 
     <name>${project.groupId}:${project.artifactId}</name>
     <description>MongoDB support for Kapeta Spring Boot SDK</description>
diff --git a/src/main/java/com/kapeta/spring/mongo/AbstractMongoDBConfig.java b/src/main/java/com/kapeta/spring/mongo/AbstractMongoDBConfig.java
index 0f1b394..1b7b079 100644
--- a/src/main/java/com/kapeta/spring/mongo/AbstractMongoDBConfig.java
+++ b/src/main/java/com/kapeta/spring/mongo/AbstractMongoDBConfig.java
@@ -11,6 +11,7 @@
 import com.kapeta.spring.config.providers.KapetaConfigurationProvider;
 import com.kapeta.spring.config.providers.types.ResourceInfo;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.bson.Document;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -91,6 +92,9 @@ private MongoProperties createMongoUriProperties(String databaseName, String dbA
         String password = mongoInfo.getCredentials().getOrDefault("password","");
 
         String uri = String.format("mongodb+srv://%s:%s@%s/%s?ssl=false&authSource=%s", username, password, mongoInfo.getHost(), databaseName, dbAuthDB);
+        if(!StringUtils.isEmpty(System.getenv("SPRING_DATA_MONGODB_URI"))) {
+            uri = System.getenv("SPRING_DATA_MONGODB_URI");
+        }
 
         MongoProperties properties = new MongoProperties();
         properties.setUri(uri);