Cree su interfaz de repositorio con @NoRepositoryBean
, lo conectaremos nosotros mismos:
@NoRepositoryBean
public interface ModelMongoRepository extends MongoRepository<Model, String> {
}
Luego, en un @Configuration
class, instancia los 2 beans de repositorio usando MongoRepositoryFactoryBean
. Ambos repositorios devolverán la misma interfaz Spring Data Repository, pero les asignaremos diferentes MongoOperations
(es decir, detalles de la base de datos):
@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());
}
}
Ahora tiene 2 beans con distintos @Qualifier
nombres, cada uno configurado para diferentes bases de datos y usando el mismo modelo.
Puede inyectarlos usando @Qualifier
:
@Autowired
@Qualifier("one")
private ModelMongoRepository mongoRepositoryOne;
@Autowired
@Qualifier("two")
private ModelMongoRepository mongoRepositoryTwo;
Para simplificar, codifiqué los valores en la clase de configuración, pero puede inyectarlos desde propiedades en application.properties/yml.
Aquí está la modificación si desea crear una implementación personalizada sin perder los beneficios de los repositorios de interfaz de datos de Spring. las especificaciones dicen esto:
Cree una nueva interfaz, que técnicamente no tiene nada que ver con los datos de Spring, buena interfaz antigua:
public interface CustomMethodsRepository {
public void getById(Model model){
}
Haga que la interfaz de su repositorio amplíe esta nueva interfaz:
@NoRepositoryBean
public interface ModelMongoRepository extends MongoRepository<Model, String>, CustomMethodsRepository {
}
Luego, cree su clase de implementación, que solo implementa su interfaz de datos que no son de primavera:
public class ModelMongoRepositoryImpl implements CustomModelMongoRepository {
private MongoOperations mongoOperations;
public ModelMongoRepositoryImpl(MongoOperations mongoOperations) {
this.mongoOperations = mongoOperations;
}
public void getById(Model model){
System.out.println("test");
}
}
Cambie la configuración de Java para agregar 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();
}
Si no estuviera conectando el repositorio manualmente a través de la configuración de Java, esta implementación DEBERÍA llamarse ModelMongoRepositoryImpl
para que coincida con la interfaz ModelMongoRepository +"Impl"
. Y sería manejado automáticamente por la primavera.