如何在Spring启动应用程序中使用多个mongoDB数据库？[重复]

Question

在我的应用程序中，我需要使用两个MongoDB数据库。我不知道如何在应用程序中添加2个MongoDB数据库。spring应用程序中的属性文件。

这是申请表。我的项目的属性文件，

spring.data.mongodb.database=DB1
spring.data.mongodb.authentication-database=DB1
spring.data.mongodb.host=dev-ng-mongo1.domain.com
spring.data.mongodb.password=9876512
spring.data.mongodb.port=27017 
spring.data.mongodb.username=pavan

但是我想为同一个项目使用另一个MongoDB数据库。如何在应用程序中添加新数据库。属性文件。

Answer 1

请按照以下步骤设置多个mongodb数据源。

>

定义您的主要和次要mongob属性，如下面application.properties，请用它们替换您的数据库详细信息：

######Primary Mongo DB########################
spring.data.mongodb.host=localhost
spring.data.mongodb.database=primary
spring.data.mongodb.port=27017
spring.data.mongodb.password=*******
spring.data.mongodb.username=*******

###########Secondary MongoDB#####################
mongodb.host=localhost
mongodb.port=27017
mongodb.database=secondary
mongodb.username=******
mongodb.password=******

现在添加多个Mongo Db配置...

@Configuration
public class MultipleMongoConfig {

@Primary
@Bean(name = "primary")
@ConfigurationProperties(prefix = "spring.data.mongodb")
public MongoProperties getPrimary() {
    return new MongoProperties();
}

@Bean(name = "secondary")
@ConfigurationProperties(prefix = "mongodb")
public MongoProperties getSecondary() {
    return new MongoProperties();
}

@Primary
@Bean(name = "primaryMongoTemplate")
public MongoTemplate primaryMongoTemplate() throws Exception {
    return new MongoTemplate(primaryFactory(getPrimary()));
}

@Bean(name = "secondaryMongoTemplate")
public MongoTemplate secondaryMongoTemplate() throws Exception {
    return new MongoTemplate(secondaryFactory(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());
}

}

现在为您的主secondary.please启用EnableMongoRepository，确保您在此处更改basPackages="com.example.springbootmultipledatasource.primary.repository"您的存储库包

@Configuration
@EnableMongoRepositories(basePackages = 
"com.example.springbootmultipledatasource.primary.repository",
    mongoTemplateRef = "primaryMongoTemplate")
 public class PrimaryMongoConfig {

 }

次要Mongo模板：请确保在此处更改次要存储库包basePackages=“com.example.springbootmultipledatasource.Secondary.repository

    @Configuration
    @EnableMongoRepositories(basePackages = "com.example.springbootmultipledatasource.secondary.repository",
        mongoTemplateRef = "secondaryMongoTemplate")
   public class SecondaryMongoConfig {
   }

现在，您可以创建您的文档、存储库、服务和控制器，您就可以开始了。下面是我的项目结构，你可以创建或有不同的。

https://imgs.xnip.cn/cj/n/23/0fdf88ae-8f2a-4c60-b7d9-ce99700a165f.png" width="100%" height="100%" />