Update springboot

.gitignore

@@ -1,4 +1,9 @@
 .DS_Store
 .idea
 /target
-*.iml
+*.iml
+.vscode
+.settings
+.classpath
+.factorypath
+.project

README.md

@@ -1,5 +1,11 @@
-Multiple Mongo Connectors
----
+# Multiple Mongo Connectors
+
 Sample application to connect to multiple `MongoDB` from spring-boot.
 
 http://blog.marcosbarbero.com/multiple-mongodb-connectors-in-spring-boot/
+
+## Addition
+
+* Updated whole project from Spring-Boot 1.5.x to 2.2.x.
+* Therefore the whole MongoDB factory class has changed.
+* Added Credentials for MongoDB

pom.xml

@@ -14,15 +14,15 @@
     <parent>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-parent</artifactId>
-        <version>1.5.10.RELEASE</version>
+        <version>2.2.1.RELEASE</version>
         <relativePath/>
         <!-- lookup parent from repository -->
     </parent>
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
-        <java.version>1.8</java.version>
+        <java.version>11</java.version>
     </properties>
 
     <dependencies>

src/main/java/com/marcosbarbero/wd/multiplemongo/Application.java

@@ -9,13 +9,15 @@
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.data.mongodb.config.EnableMongoAuditing;
 
 import java.util.List;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
 @SpringBootApplication
+@EnableMongoAuditing
 public class Application implements CommandLineRunner {
 
     @Autowired

src/main/java/com/marcosbarbero/wd/multiplemongo/config/MultipleMongoConfig.java

@@ -1,6 +1,6 @@
 package com.marcosbarbero.wd.multiplemongo.config;
 
-import com.mongodb.MongoClient;
+import com.mongodb.ConnectionString;
 
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.boot.autoconfigure.mongo.MongoProperties;
@@ -10,13 +10,15 @@
 import org.springframework.context.annotation.Primary;
 import org.springframework.data.mongodb.MongoDbFactory;
 import org.springframework.data.mongodb.core.MongoTemplate;
-import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
+import org.springframework.data.mongodb.core.SimpleMongoClientDbFactory;
 
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 
 /**
  * @author Marcos Barbero
  */
+@Slf4j
 @Configuration
 @RequiredArgsConstructor
 @EnableConfigurationProperties(MultipleMongoProperties.class)
@@ -38,14 +40,29 @@ public MongoTemplate secondaryMongoTemplate() throws Exception {
     @Bean
     @Primary
     public MongoDbFactory primaryFactory(final MongoProperties mongo) throws Exception {
-        return new SimpleMongoDbFactory(new MongoClient(mongo.getHost(), mongo.getPort()),
-                mongo.getDatabase());
+        ConnectionString conn = new ConnectionString(buildConnectionString(mongo));
+        return new SimpleMongoClientDbFactory(conn);
     }
 
     @Bean
     public MongoDbFactory secondaryFactory(final MongoProperties mongo) throws Exception {
-        return new SimpleMongoDbFactory(new MongoClient(mongo.getHost(), mongo.getPort()),
-                mongo.getDatabase());
+        ConnectionString conn = new ConnectionString(buildConnectionString(mongo));
+        return new SimpleMongoClientDbFactory(conn);
+    }
+
+    /**
+     * Builds connectionString with credentials
+     * 
+     * @param mongo
+     * @return String with the connection information
+     */
+    private String buildConnectionString(MongoProperties mongo) {
+        String prefex = "mongodb://";
+        String con = new StringBuffer(prefex).append(mongo.getUsername()).append(":").append(mongo.getPassword())
+                .append("@").append(mongo.getHost()).append(":").append(mongo.getPort()).append("/")
+                .append(mongo.getDatabase()).toString();
+        log.debug("connection String: " + con);
+        return con;
     }
 
 }

src/main/resources/application.yml

@@ -2,11 +2,15 @@ mongodb:
   primary:
     host: localhost
     port: 27017
-    database: second
+    database: first
+    username: apifirst
+    password: pa55w0rd
   secondary:
     host: localhost
     port: 27017
     database: second
+    username: apisecond
+    password: pa55w0rd
 
 spring:
   autoconfigure: