Crie sua interface de repositório com
@NoRepositoryBean
, vamos ligá-lo nós mesmos:@NoRepositoryBean
public interface ModelMongoRepository extends MongoRepository<Model, String> {
}
Então, em um
@Configuration
class, instancie os 2 beans de repositório usando MongoRepositoryFactoryBean
. Ambos os repositórios retornarão a mesma interface do Spring Data Repository, mas atribuiremos a eles MongoOperations
diferentes (ou seja:detalhes do banco de dados):@Configuration
@EnableMongoRepositories
public class MongoConfiguration {
@Bean
@Qualifier("one")
public ModelMongoRepository modelMongoRepositoryOne() throws DataAccessException, Exception {
MongoRepositoryFactoryBean<ModelMongoRepository, Model, String> myFactory = new MongoRepositoryFactoryBean<ModelMongoRepository, Model, String>();
myFactory.setRepositoryInterface(ModelMongoRepository.class);
myFactory.setMongoOperations(createMongoOperations("hostname1", 21979, "dbName1", "username1", "password1"));
myFactory.afterPropertiesSet();
return myFactory.getObject();
}
@Bean
@Qualifier("two")
public ModelMongoRepository modelMongoRepositoryTwo() throws DataAccessException, Exception {
MongoRepositoryFactoryBean<ModelMongoRepository, Model, String> myFactory = new MongoRepositoryFactoryBean<ModelMongoRepository, Model, String>();
myFactory.setRepositoryInterface(ModelMongoRepository.class);
myFactory.setMongoOperations(createMongoOperations("hostname2", 21990, "dbName2", "username2", "password2"));
myFactory.afterPropertiesSet();
return myFactory.getObject();
}
private MongoOperations createMongoOperations(String hostname, int port, String dbName, String user, String pwd) throws DataAccessException, Exception {
MongoCredential mongoCredentials = MongoCredential.createScramSha1Credential(user, dbName, pwd.toCharArray());
MongoClient mongoClient = new MongoClient(new ServerAddress(hostname, port), Arrays.asList(mongoCredentials));
Mongo mongo = new SimpleMongoDbFactory(mongoClient, dbName).getDb().getMongo();
return new MongoTemplate(mongo, dbName);
}
//or this one if you have a connection string
private MongoOperations createMongoOperations(String dbConnection) throws DataAccessException, Exception {
MongoClientURI mongoClientURI = new MongoClientURI(dbConnection);
MongoClient mongoClient = new MongoClient(mongoClientURI);
Mongo mongo = new SimpleMongoDbFactory(mongoClient, mongoClientURI.getDatabase()).getDb().getMongo();
return new MongoTemplate(mongo, mongoClientURI.getDatabase());
}
}
Agora você tem 2 beans com
@Qualifier
distintos nomes, cada um configurado para diferentes bancos de dados e usando o mesmo modelo. Você pode injetá-los usando
@Qualifier
:@Autowired
@Qualifier("one")
private ModelMongoRepository mongoRepositoryOne;
@Autowired
@Qualifier("two")
private ModelMongoRepository mongoRepositoryTwo;
Para simplificar, codifiquei os valores na classe de configuração, mas você pode injetá-los nas propriedades em application.properties/yml.
Aqui está a modificação se você quiser criar uma implementação personalizada sem perder os benefícios dos repositórios de interface de dados de mola. as especificações dizem isso:
Crie uma nova interface, que tecnicamente não tem nada a ver com dados de mola, boa e velha interface:
public interface CustomMethodsRepository {
public void getById(Model model){
}
Faça com que sua interface de repositório estenda esta nova interface:
@NoRepositoryBean
public interface ModelMongoRepository extends MongoRepository<Model, String>, CustomMethodsRepository {
}
Em seguida, crie sua classe de implementação, que somente implementa sua interface não-spring-data:
public class ModelMongoRepositoryImpl implements CustomModelMongoRepository {
private MongoOperations mongoOperations;
public ModelMongoRepositoryImpl(MongoOperations mongoOperations) {
this.mongoOperations = mongoOperations;
}
public void getById(Model model){
System.out.println("test");
}
}
Altere a configuração Java para adicionar
myFactory.setCustomImplementation(new ModelMongoRepositoryImpl());
:@Bean
@Qualifier("one")
public ModelMongoRepository modelMongoRepositoryOne() throws DataAccessException, Exception {
MongoRepositoryFactoryBean<ModelMongoRepository, Model, String> myFactory = new MongoRepositoryFactoryBean<ModelMongoRepository, Model, String>();
MongoOperations mongoOperations = createMongoOperations("hostname1", 21979, "dbName1", "usdername1", "password1");
myFactory.setCustomImplementation(new ModelMongoRepositoryImpl(mongoOperations));
myFactory.setRepositoryInterface(ModelMongoRepository.class);
myFactory.setMongoOperations(mongoOperations);
myFactory.afterPropertiesSet();
return myFactory.getObject();
}
Se você não estivesse conectando o repositório manualmente através da configuração Java, esta implementação teria que ser nomeada
ModelMongoRepositoryImpl
para corresponder à interface ModelMongoRepository +"Impl"
. E seria tratado automaticamente pela primavera.