Skip to content

Commit a2d41bc

Browse files
committed
allows authentication when use
1 parent 7f40ab3 commit a2d41bc

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

mongodb-driver/src/main/java/org/jnosql/diana/mongodb/document/MongoDBDocumentConfiguration.java

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
package org.jnosql.diana.mongodb.document;
1717

1818
import com.mongodb.MongoClient;
19+
import com.mongodb.MongoCredential;
1920
import com.mongodb.ServerAddress;
2021
import com.mongodb.async.client.MongoClientSettings;
2122
import com.mongodb.async.client.MongoClients;
@@ -31,6 +32,7 @@
3132
import java.util.List;
3233
import java.util.Map;
3334
import java.util.Objects;
35+
import java.util.Optional;
3436
import java.util.stream.Collectors;
3537

3638
import static java.util.Objects.requireNonNull;
@@ -107,8 +109,11 @@ public MongoDBDocumentCollectionManagerFactory get(Settings settings) throws Nul
107109
return new MongoDBDocumentCollectionManagerFactory(new MongoClient());
108110
}
109111

110-
return new MongoDBDocumentCollectionManagerFactory(new MongoClient(servers, MongoAuthentication.of(settings),
111-
null));
112+
Optional<MongoCredential> credential = MongoAuthentication.of(settings);
113+
MongoClient mongoClient = credential.map(c -> new MongoClient(servers, c, null))
114+
.orElseGet(() -> new MongoClient(servers));
115+
116+
return new MongoDBDocumentCollectionManagerFactory(mongoClient);
112117
}
113118

114119
public MongoDBDocumentCollectionManagerFactory get(String pathFileConfig) throws NullPointerException {

0 commit comments

Comments
 (0)