SpringBoot 集成mongodb（2）多数据源配置

钓鱼岛哨兵 發表於 2019-7-1 23:14:00

SpringBoot 集成mongodb（2）多数据源配置

github:https://github.com/xiaozhuanfeng/mongoProj
现MongoDB有两个数据库：
<img src="https://img2018.cnblogs.com/blog/1480413/201907/1480413-20190701230121587-836712090.png" alt="">
pom.xml:
<div class="cnblogs_code">
<pre>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-data-mongodb</artifactId>
 </dependency>

 <dependency>
 <groupId>org.projectlombok</groupId>
 <artifactId>lombok</artifactId>
 </dependency>

 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-autoconfigure</artifactId>
 <version>RELEASE</version>
 </dependency>

 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-configuration-processor</artifactId>
 <optional>true</optional>
 </dependency></pre>
</div>
<ul>
<li>
Lombok - 是一个可以通过简单的注解形式来帮助我们简化消除一些必须有但显得很臃肿的Java代码的工具，通过使用对应的注解，可以在编译源码的时候生成对应的方法。简单试了以下这个工具还挺好玩的，加上注解我们就不用手动写 getter\setter、构建方式类似的代码了。
</li>
<li>
spring-boot-autoconfigure - 就是spring boot的自动化配置
</li>
</ul>
注意这里Idea还可以设置Lombok插件：
https://blog.csdn.net/qq_37433657/article/details/83275051
配置文件：
<div class="cnblogs_code">
<pre>#primary 数据源
mongodb.primary.host=192.168.0.102
mongodb.primary.port=27017
mongodb.primary.database=long

mongodb.secondary.host=192.168.0.102
mongodb.secondary.port=27017
mongodb.secondary.database=jianghu</pre>
</div>
1、配置两个数据库的数据源
<div class="cnblogs_code">
<pre>package com.example.demo.config;

import lombok.Data;
import org.springframework.boot.autoconfigure.mongo.MongoProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

@Component
@Data
@ConfigurationProperties(prefix = "mongodb")
public class MultipleMongoProperties {
private MongoProperties primary = new MongoProperties();
private MongoProperties secondary = new MongoProperties();

//安装Lombok插件，@Data
/* public MongoProperties getPrimary() {
 return primary;
}

public MongoProperties getSecondary() {
 return secondary;
}*/
}</pre>
</div>
2、配置不同包路径下使用不同的数据源
<div class="cnblogs_code">
<pre>package com.example.demo.config;

import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;

@Configuration
@EnableMongoRepositories(basePackages = "com.example.demo.repository.primary", mongoTemplateRef = PrimaryMongoConfig.MONGO_TEMPLATE)
public class PrimaryMongoConfig {
protected static final String MONGO_TEMPLATE = "primaryMongoTemplate";
}</pre>
</div>
<div class="cnblogs_code">
<pre>package com.example.demo.config;

import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;

@Configuration
@EnableMongoRepositories(basePackages = "com.example.demo.repository.secondary",
 mongoTemplateRef = SecondaryMongoConfig.MONGO_TEMPLATE)
public class SecondaryMongoConfig {
protected static final String MONGO_TEMPLATE = "secondaryMongoTemplate";
}</pre>
</div>
3、读取对应的配置信息并且构造对应的MongoTemplate
<div class="cnblogs_code">
<pre>package com.example.demo.config;

import com.mongodb.MongoClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.mongo.MongoProperties;
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;

@Configuration
public class MultipleMongoConfig {

@Autowired
private MultipleMongoProperties mongoProperties;

@Primary
@Bean(name = PrimaryMongoConfig.MONGO_TEMPLATE)
public MongoTemplate primaryMongoTemplate() throws Exception {
 return new MongoTemplate(primaryFactory(this.mongoProperties.getPrimary()));
}

@Bean
@Qualifier(SecondaryMongoConfig.MONGO_TEMPLATE)
public MongoTemplate secondaryMongoTemplate() throws Exception {
 return new MongoTemplate(secondaryFactory(this.mongoProperties.getSecondary()));
}

@Bean
@Primary
public MongoDbFactory primaryFactory(MongoProperties mongo) throws Exception {
 return new SimpleMongoDbFactory(new MongoClient(mongo.getHost(), mongo.getPort()),
 mongo.getDatabase());
}

@Bean
public MongoDbFactory secondaryFactory(MongoProperties mongo) throws Exception {
 return new SimpleMongoDbFactory(new MongoClient(mongo.getHost(), mongo.getPort()),
 mongo.getDatabase());
}
}</pre>
</div>
4、新增实体类
对应DB=long的col集合
<div class="cnblogs_code">
<pre>package com.example.demo.dto;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.mongodb.core.mapping.Document;

@Data
@AllArgsConstructor
@NoArgsConstructor
@Document(collection = "col")
public class Human {
private String name;

private int age;

private String gender;

@Override
public String toString() {
 return "Human{" +
 "name='" + name + '\'' +
 ", age=" + age +
 ", gender='" + gender + '\'' +
 '}';
}
}</pre>
</div>
对应DB=jianghu 的wuxia集合
<div class="cnblogs_code">
<pre>package com.example.demo.dto;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.mongodb.core.mapping.Document;

@Data
@AllArgsConstructor
@NoArgsConstructor
@Document(collection = "wuxia")
public class Swordsman {

private String name;

private String age;

private String skill;

@Override
public String toString() {
 return "Swordsman{" +
 "name='" + name + '\'' +
 ", age='" + age + '\'' +
 ", skill='" + skill + '\'' +
 '}';
}
}</pre>
</div>
5、对应的Repository
<div class="cnblogs_code">
<pre>package com.example.demo.repository.primary;

import com.example.demo.dto.Human;
import org.springframework.data.mongodb.repository.MongoRepository;

public interface PrimaryRepository extends MongoRepository<Human, String> {
}</pre>
</div>
<div class="cnblogs_code">
<pre>package com.example.demo.repository.secondary;

import com.example.demo.dto.Swordsman;
import org.springframework.data.mongodb.repository.MongoRepository;

public interface SecondaryRepository extends MongoRepository<Swordsman, String> {
}</pre>
</div>
测试类：
<div class="cnblogs_code">
<pre>package com.example.demo;

import com.example.demo.dto.Human;
import com.example.demo.dto.Swordsman;
import com.example.demo.repository.primary.PrimaryRepository;
import com.example.demo.repository.secondary.SecondaryRepository;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.List;

@RunWith(SpringRunner.class)
@SpringBootTest
public class MultipleMongoTest {

@Autowired
private PrimaryRepository primaryRepository;

@Autowired
private SecondaryRepository secondaryRepository;

@Test
public void test1(){
 List<Human> primaries = this.primaryRepository.findAll();
 for (Human primary : primaries) {
 System.out.println(primary.toString());
 }

 List<Swordsman> secondaries = this.secondaryRepository.findAll();

 for (Swordsman secondary : secondaries) {
 System.out.println(secondary.toString());
 }
}
}</pre>
</div>
测试结果：
<img src="https://img2018.cnblogs.com/blog/1480413/201907/1480413-20190701231342855-1805715867.png" alt="">
  
来源：https://www.cnblogs.com/xiaozhuanfeng/p/11117466.html

頁: [1]

琼殿技术论坛's Archiver

SpringBoot 集成mongodb（2）多数据源配置