MongoDB
 sql >> Datenbank >  >> NoSQL >> MongoDB

Wie verwende ich mehrere Mongodb-Datenbanken in einer Spring-Boot-Anwendung?

Bitte befolgen Sie die nachstehenden Schritte, um mehrere Mongodb-Datenquellen einzurichten.

  1. Definieren Sie Ihre primären und sekundären mongodb-Eigenschaften wie unten in application.properties, bitte ersetzen Sie damit Ihre db-Details:

    ######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=******
    
  2. Fügen Sie nun Multiple Mongo Db Configuration hinzu..

    @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());
    }
    

    }

  3. Aktivieren Sie nun EnableMongoRepositories Stellen Sie für Ihre primäre und sekundäre Datei sicher, dass Sie basePackages = "com.example.springbootmultipledatasource.primary.repository" ändern Ihr Repository-Paket hier

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

Sekundäre Mongo-Vorlage:Bitte stellen Sie sicher, dass Sie Ihr sekundäres Repository-Paket hier ändern basePackages = "com.example.springbootmultipledatasource.secondary.repository

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

Jetzt können Sie Ihr Dokument, Ihr Repository, Ihren Dienst und Ihren Controller erstellen, und Sie können loslegen. Nachfolgend finden Sie meine Projektstruktur, die Sie erstellen oder anders haben können.