Два Mon go хранилища с разными свойствами

Question

У меня есть два репозитория:

@Repository
public interface SpringLRepository extends MongoRepository<L, String> {
}

@Repository
public interface SpringSRepository extends MongoRepository<S, String> {
}

В properties файле, который я получил:

spring.data.mongodb.authentication-database=admin

spring.data.mongodb.l.host=localhost
spring.data.mongodb.l.port=27017
spring.data.mongodb.l.username=root
spring.data.mongodb.l.password=example
spring.data.mongodb.l.authentication-database=admin
spring.data.mongodb.l.database=l

spring.data.mongodb.s.host=localhost
spring.data.mongodb.s.port=27017
spring.data.mongodb.s.username=root
spring.data.mongodb.s.password=example
spring.data.mongodb.s.authentication-database=admin
spring.data.mongodb.s.database=s

Я хочу иметь отдельные свойства для SpringLRepository и SpringSRepository или измените только часть из них, например spring.data.mongodb.database параметр.

Я попытался выполнить следующие действия: Настройка нескольких хранилищ MongoDB с Spring Data Mon go

Сначала, если я не исключу MongoDataAutoConfiguration.class:

@SpringBootApplication(
        exclude = {
                //MongoDataAutoConfiguration.class
        })

У меня есть:

Parameter 1 of method gridFsTemplate in org.springframework.boot.autoconfigure.data.mongo.MongoDbFactoryDependentConfiguration required a single bean, but 2 were found:
    - mongoLTemplate: defined by method 'mongoLTemplate' in class path resource [...l/core/application/LMongoConfig.class]
    - mongoSTemplate: defined by method 'mongoSTemplate' in class path resource [...s/core/application/SMongoConfig.class]

Что я могу сделать с это?

Теперь я больше не использую @Repository, и я добавил два класса. Первая конфигурация:

@Configuration
@EnableMongoRepositories(
        basePackages = "...s.infrastructure.secondary.persistence",
        mongoTemplateRef = "mongoSTemplate"
)
public class SMongoConfig {
  @Value("${spring.data.mongodb.lead.host}")
  private String mongoHost;
  @Value("${spring.data.mongodb.lead.port}")
  private Integer mongoPort;

    @Bean
    @Qualifier("mongoSTemplate")
    MongoTemplate mongoSTemplate(@Qualifier("mongoSDbFactory") MongoDbFactory mongoDbFactory, MongoConverter converter) {
        MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory, converter);
        mongoTemplate.setWriteConcern(WriteConcern.MAJORITY);
        mongoTemplate.setWriteResultChecking(WriteResultChecking.EXCEPTION);
        return mongoTemplate;
    }

@Bean
@Qualifier("mongoSimulationsDbFactory")
public MongoDbFactory mongoSimulationsDbFactory() {
    MongoClientOptions.Builder mongoOperations = MongoClientOptions.builder();
    mongoOperations.socketTimeout(1000 * 2);
    mongoOperations.connectTimeout(1000 * 2);
    MongoCredential mongoCredential = MongoCredential.createCredential("root", "admin", "example".toCharArray());
    return new SimpleMongoDbFactory(
            new MongoClient(
                    new ServerAddress(mongoHost, mongoPort),
                    Collections.singletonList(mongoCredential)
            ),
            "s");
}
}

Вторая конфигурация:

@Configuration
@EnableMongoRepositories(
        basePackages = "...l.infrastructure.secondary.persistence",
        mongoTemplateRef = "mongoLTemplate"
)
public class LMongoConfig{
    @Value("${spring.data.mongodb.l.host}")
    private String mongoHost;

    @Value("${spring.data.mongodb.l.port}")
    private Integer mongoPort;

    @Value("${spring.data.mongodb.l.database}")
    private String mongoDB;

    @Value("${spring.data.mongodb.l.password}")
    private char[] mongoPassword;

    @Bean
    @Qualifier("mongoLTemplate")
    MongoTemplate mongoLTemplate(@Qualifier("mongoLDbFactory") MongoDbFactory mongoDbFactory, MongoConverter converter) {
        MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory, converter);
        mongoTemplate.setWriteConcern(WriteConcern.MAJORITY);
        mongoTemplate.setWriteResultChecking(WriteResultChecking.EXCEPTION);
        return mongoTemplate;
    }

    @Bean
    @Qualifier("mongoLDbFactory")
    public MongoDbFactory mongoLDbFactory() {
        MongoClientOptions.Builder mongoOperations = MongoClientOptions.builder();
        mongoOperations.socketTimeout(1000 * 2);
        mongoOperations.connectTimeout(1000 * 2);

    MongoCredential mongoCredential = MongoCredential.createCredential("root", "admin", "example".toCharArray());
        return new SimpleMongoDbFactory(
                new MongoClient(
                        new ServerAddress(mongoHost, mongoPort),
                        Collections.singletonList(mongoCredential)
                ),
                "s");
    }
}

Теперь этот код сохраняет s и l для разделения репозиториев, но у меня есть несколько проблем. SimpleMongoDbFactory и MongoClient устарели , и трудно найти более новый пример Mongo, делающего это.

Answer 1

@Bean
public SimpleMongoClientDbFactory metadataFactory(final MongoProperties mongo) throws Exception {
    return new SimpleMongoClientDbFactory(mongo.getUri());
}

@Bean
public MongoConfigurationProperties mongoProperties() {
    return new MongoConfigurationProperties();
}

Я использую это. AFAIK это не устарело. В этом случае mongoProperties - это bean-компонент @ConfigurationProperties, который указывает на URI - необходимо несколько URI, так как в этом приложении я подключаюсь к нескольким базам данных.