springboot-mongodb的多数据源配置的方法步骤

2023-08-24 05:59:04 288

在日常工作中，我们可能需要连接多个MongoDB数据源，比如用户库user，日志库log。本章我们来记录连接多个数据源的步骤，以两个数据源为例，多个数据源类推。

1、pom.xml中引入mongodb的依赖


org.springframework.boot
spring-boot-starter-data-mongodb


org.projectlombok
lombok


org.springframework.boot
spring-boot-autoconfigure
RELEASE

Lombok-是一个可以通过简单的注解形式来帮助我们简化消除一些必须有但显得很臃肿的Java代码的工具，通过使用对应的注解，可以在编译源码的时候生成对应的方法。简单试了以下这个工具还挺好玩的，加上注解我们就不用手动写getter\setter、构建方式类似的代码了。

2,yml配置:

mongodb:
primary:
host:192.168.9.60
port:20000
database:test
secondary:
host:192.168.9.60
port:20000
database:test1

3,配置2个库的数据源:

@Data
@ConfigurationProperties(prefix="mongodb")
publicclassMultipleMongoProperties{

privateMongoPropertiesprimary=newMongoProperties();
privateMongoPropertiessecondary=newMongoProperties();
}

3.1)第一个库封装:

@Configuration
@EnableMongoRepositories(basePackages="com.neo.model.repository.primary",
mongoTemplateRef=PrimaryMongoConfig.MONGO_TEMPLATE)
publicclassPrimaryMongoConfig{

protectedstaticfinalStringMONGO_TEMPLATE="primaryMongoTemplate";
}

3.2)第二个库封装:

@Configuration
@EnableMongoRepositories(basePackages="com.neo.model.repository.secondary",
mongoTemplateRef=SecondaryMongoConfig.MONGO_TEMPLATE)
publicclassSecondaryMongoConfig{

protectedstaticfinalStringMONGO_TEMPLATE="secondaryMongoTemplate";
}

3.3)mongoTemplate:

@Configuration
publicclassMultipleMongoConfig{

@Autowired
privateMultipleMongoPropertiesmongoProperties;

@Primary
@Bean(name=PrimaryMongoConfig.MONGO_TEMPLATE)
publicMongoTemplateprimaryMongoTemplate()throwsException{
returnnewMongoTemplate(primaryFactory(this.mongoProperties.getPrimary()));
}

@Bean
@Qualifier(SecondaryMongoConfig.MONGO_TEMPLATE)
publicMongoTemplatesecondaryMongoTemplate()throwsException{
returnnewMongoTemplate(secondaryFactory(this.mongoProperties.getSecondary()));
}

@Bean
@Primary
publicMongoDbFactoryprimaryFactory(MongoPropertiesmongo)throwsException{
returnnewSimpleMongoDbFactory(newMongoClient(mongo.getHost(),mongo.getPort()),
mongo.getDatabase());
}

@Bean
publicMongoDbFactorysecondaryFactory(MongoPropertiesmongo)throwsException{
returnnewSimpleMongoDbFactory(newMongoClient(mongo.getHost(),mongo.getPort()),
mongo.getDatabase());
}
}

4,创建2个库对应的repository:

@Data
@AllArgsConstructor
@NoArgsConstructor
@Document(collection="first_mongo")
publicclassPrimaryMongoObject{

@Id
privateStringid;

privateStringvalue;

@Override
publicStringtoString(){
return"PrimaryMongoObject{"+"id='"+id+'\''+",value='"+value+'\''
+'}';
}
}

publicinterfacePrimaryRepositoryextendsMongoRepository{
}

测试:

@RunWith(SpringRunner.class)
@SpringBootTest
publicclassMuliDatabaseTest{

@Autowired
privatePrimaryRepositoryprimaryRepository;

@Autowired
privateSecondaryRepositorysecondaryRepository;

@Test
publicvoidTestSave(){

System.out.println("************************************************************");
System.out.println("测试开始");
System.out.println("************************************************************");

this.primaryRepository
.save(newPrimaryMongoObject(null,"第一个库的对象"));

this.secondaryRepository
.save(newSecondaryMongoObject(null,"第二个库的对象"));

Listprimaries=this.primaryRepository.findAll();
for(PrimaryMongoObjectprimary:primaries){
System.out.println(primary.toString());
}

Listsecondaries=this.secondaryRepository.findAll();

for(SecondaryMongoObjectsecondary:secondaries){
System.out.println(secondary.toString());
}

System.out.println("************************************************************");
System.out.println("测试完成");
System.out.println("************************************************************");
}

}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

springboot-mongodb的多数据源配置的方法步骤

热门推荐

随机推荐