Refactor for blog post

Author: marcosbarbero

pom.xml

@@ -3,7 +3,7 @@
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
 
-    <groupId>com.example</groupId>
+    <groupId>com.marcosbarbero.wd</groupId>
     <artifactId>multiple-mongo-connectors</artifactId>
     <version>0.0.1-SNAPSHOT</version>
     <packaging>jar</packaging>
@@ -14,7 +14,7 @@
     <parent>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-parent</artifactId>
-        <version>1.4.0.RELEASE</version>
+        <version>1.5.10.RELEASE</version>
         <relativePath/>
         <!-- lookup parent from repository -->
     </parent>
@@ -31,6 +31,12 @@
             <artifactId>spring-boot-starter-data-mongodb</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-configuration-processor</artifactId>
+            <optional>true</optional>
+        </dependency>
+
         <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>

src/main/java/com/example/Application.java

@@ -0,0 +1,57 @@
+package com.marcosbarbero.wd.multiplemongo;
+
+import com.marcosbarbero.wd.multiplemongo.repository.primary.PrimaryModel;
+import com.marcosbarbero.wd.multiplemongo.repository.primary.PrimaryRepository;
+import com.marcosbarbero.wd.multiplemongo.repository.secondary.SecondaryModel;
+import com.marcosbarbero.wd.multiplemongo.repository.secondary.SecondaryRepository;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+import java.util.List;
+
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@SpringBootApplication
+public class Application implements CommandLineRunner {
+
+    @Autowired
+    private PrimaryRepository primaryRepository;
+
+    @Autowired
+    private SecondaryRepository secondaryRepository;
+
+    public static void main(String[] args) {
+        SpringApplication.run(Application.class, args);
+    }
+
+    @Override
+    public void run(String... args) throws Exception {
+        log.info("************************************************************");
+        log.info("Start printing mongo objects");
+        log.info("************************************************************");
+        this.primaryRepository.save(new PrimaryModel(null, "Primary database plain object"));
+
+        this.secondaryRepository.save(new SecondaryModel(null, "Secondary database plain object"));
+
+        List<PrimaryModel> primaries = this.primaryRepository.findAll();
+        for (PrimaryModel primary : primaries) {
+            log.info(primary.toString());
+        }
+
+        List<SecondaryModel> secondaries = this.secondaryRepository.findAll();
+
+        for (SecondaryModel secondary : secondaries) {
+            log.info(secondary.toString());
+        }
+
+        log.info("************************************************************");
+        log.info("Ended printing mongo objects");
+        log.info("************************************************************");
+
+    }
+}
+

src/main/java/com/example/config/MultipleMongoConfig.java

@@ -0,0 +1,51 @@
+package com.marcosbarbero.wd.multiplemongo.config;
+
+import com.mongodb.MongoClient;
+
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.boot.autoconfigure.mongo.MongoProperties;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+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 lombok.RequiredArgsConstructor;
+
+/**
+ * @author Marcos Barbero
+ */
+@Configuration
+@RequiredArgsConstructor
+@EnableConfigurationProperties(MultipleMongoProperties.class)
+public class MultipleMongoConfig {
+
+    private final MultipleMongoProperties mongoProperties;
+
+    @Primary
+    @Bean(name = PrimaryMongoConfig.MONGO_TEMPLATE)
+    public MongoTemplate primaryMongoTemplate() throws Exception {
+        return new MongoTemplate(primaryFactory(this.mongoProperties.getPrimary()));
+    }
+
+    @Bean(name = SecondaryMongoConfig.MONGO_TEMPLATE)
+    public MongoTemplate secondaryMongoTemplate() throws Exception {
+        return new MongoTemplate(secondaryFactory(this.mongoProperties.getSecondary()));
+    }
+
+    @Bean
+    @Primary
+    public MongoDbFactory primaryFactory(final MongoProperties mongo) throws Exception {
+        return new SimpleMongoDbFactory(new MongoClient(mongo.getHost(), mongo.getPort()),
+                mongo.getDatabase());
+    }
+
+    @Bean
+    public MongoDbFactory secondaryFactory(final MongoProperties mongo) throws Exception {
+        return new SimpleMongoDbFactory(new MongoClient(mongo.getHost(), mongo.getPort()),
+                mongo.getDatabase());
+    }
+
+}

src/main/java/com/example/config/PrimaryMongoConfig.java

@@ -1,17 +1,17 @@
-package com.example.config.props;
-
-import lombok.Data;
+package com.marcosbarbero.wd.multiplemongo.config;
 
 import org.springframework.boot.autoconfigure.mongo.MongoProperties;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
+import lombok.Data;
+
 /**
  * @author Marcos Barbero
  */
 @Data
 @ConfigurationProperties(prefix = "mongodb")
 public class MultipleMongoProperties {
 
-	private MongoProperties primary = new MongoProperties();
-	private MongoProperties secondary = new MongoProperties();
+    private MongoProperties primary = new MongoProperties();
+    private MongoProperties secondary = new MongoProperties();
 }

src/main/java/com/example/config/SecondaryMongoConfig.java

@@ -0,0 +1,17 @@
+package com.marcosbarbero.wd.multiplemongo.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
+
+import static com.marcosbarbero.wd.multiplemongo.config.PrimaryMongoConfig.MONGO_TEMPLATE;
+
+/**
+ * @author Marcos Barbero
+ */
+@Configuration
+@EnableMongoRepositories(basePackages = "com.marcosbarbero.wd.multiplemongo.repository.primary",
+        mongoTemplateRef = MONGO_TEMPLATE)
+public class PrimaryMongoConfig {
+
+    protected static final String MONGO_TEMPLATE = "primaryMongoTemplate";
+}

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

@@ -0,0 +1,17 @@
+package com.marcosbarbero.wd.multiplemongo.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
+
+import static com.marcosbarbero.wd.multiplemongo.config.SecondaryMongoConfig.MONGO_TEMPLATE;
+
+/**
+ * @author Marcos Barbero
+ */
+@Configuration
+@EnableMongoRepositories(basePackages = "com.marcosbarbero.wd.multiplemongo.repository.secondary",
+        mongoTemplateRef = MONGO_TEMPLATE)
+public class SecondaryMongoConfig {
+
+    protected static final String MONGO_TEMPLATE = "secondaryMongoTemplate";
+}

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

@@ -1,4 +1,4 @@
-package com.example.model.repository.primary;
+package com.marcosbarbero.wd.multiplemongo.repository.primary;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;
@@ -14,7 +14,7 @@
 @AllArgsConstructor
 @NoArgsConstructor
 @Document(collection = "first_mongo")
-public class PrimaryMongoObject {
+public class PrimaryModel {
 
 	@Id
 	private String id;
@@ -23,7 +23,7 @@ public class PrimaryMongoObject {
 
 	@Override
 	public String toString() {
-        return "PrimaryMongoObject{" + "id='" + id + '\'' + ", value='" + value + '\''
+        return "PrimaryModel{" + "id='" + id + '\'' + ", value='" + value + '\''
 				+ '}';
 	}
 }

src/main/java/com/example/config/props/MultipleMongoProperties.java src/main/java/com/marcosbarbero/wd/multiplemongo/config/MultipleMongoProperties.java

@@ -1,9 +1,9 @@
-package com.example.model.repository.primary;
+package com.marcosbarbero.wd.multiplemongo.repository.primary;
 
 import org.springframework.data.mongodb.repository.MongoRepository;
 
 /**
  * @author Marcos Barbero
  */
-public interface PrimaryRepository extends MongoRepository<PrimaryMongoObject, String> {
+public interface PrimaryRepository extends MongoRepository<PrimaryModel, String> {
 }