Skip to content

Commit a0b1679

Browse files
committed
override mongodb connection string
1 parent e3b354b commit a0b1679

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66

77
<groupId>com.kapeta</groupId>
88
<artifactId>nosql-mongodb</artifactId>
9-
<version>1.1.0</version>
9+
<version>1.1.1</version>
1010

1111
<name>${project.groupId}:${project.artifactId}</name>
1212
<description>MongoDB support for Kapeta Spring Boot SDK</description>

src/main/java/com/kapeta/spring/mongo/AbstractMongoDBConfig.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
import com.kapeta.spring.config.providers.KapetaConfigurationProvider;
1212
import com.kapeta.spring.config.providers.types.ResourceInfo;
1313
import lombok.extern.slf4j.Slf4j;
14+
import org.apache.commons.lang3.StringUtils;
1415
import org.bson.Document;
1516
import org.springframework.beans.factory.annotation.Autowired;
1617
import org.springframework.beans.factory.annotation.Value;
@@ -91,6 +92,9 @@ private MongoProperties createMongoUriProperties(String databaseName, String dbA
9192
String password = mongoInfo.getCredentials().getOrDefault("password","");
9293

9394
String uri = String.format("mongodb+srv://%s:%s@%s/%s?ssl=false&authSource=%s", username, password, mongoInfo.getHost(), databaseName, dbAuthDB);
95+
if(!StringUtils.isEmpty(System.getenv("SPRING_DATA_MONGODB_URI"))) {
96+
uri = System.getenv("SPRING_DATA_MONGODB_URI");
97+
}
9498

9599
MongoProperties properties = new MongoProperties();
96100
properties.setUri(uri);

0 commit comments

Comments
 (0)