Opret dit lagergrænseflade med @NoRepositoryBean
, vi kobler det op selv:
@NoRepositoryBean
public interface ModelMongoRepository extends MongoRepository<Model, String> {
}
Derefter i en @Configuration
klasse, instansierer de 2 repository beans ved hjælp af MongoRepositoryFactoryBean
. Begge depoter returnerer den samme Spring Data Repository-grænseflade, men vi tildeler dem forskellige MongoOperations
(dvs.:databasedetaljer):
@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());
}
}
Du har nu 2 bønner med distinkte @Qualifier
navne, som hver er konfigureret til forskellige databaser og bruger den samme model.
Du kan injicere dem ved hjælp af @Qualifier
:
@Autowired
@Qualifier("one")
private ModelMongoRepository mongoRepositoryOne;
@Autowired
@Qualifier("two")
private ModelMongoRepository mongoRepositoryTwo;
For nemheds skyld har jeg hårdkodet værdierne i konfigurationsklassen, men du kan indsætte dem fra egenskaber i application.properties/yml.
Her er ændringen, hvis du vil oprette en tilpasset implementering uden at miste fordelene ved forårsdatagrænsefladelagre. specifikationerne siger dette:
Opret en ny grænseflade, som teknisk set ikke har noget med fjederdata at gøre, gode gamle grænseflade:
public interface CustomMethodsRepository {
public void getById(Model model){
}
Få dit lagergrænseflade til at udvide denne nye grænseflade:
@NoRepositoryBean
public interface ModelMongoRepository extends MongoRepository<Model, String>, CustomMethodsRepository {
}
Opret derefter din implementeringsklasse, som kun implementerer din ikke-forårsdata-grænseflade:
public class ModelMongoRepositoryImpl implements CustomModelMongoRepository {
private MongoOperations mongoOperations;
public ModelMongoRepositoryImpl(MongoOperations mongoOperations) {
this.mongoOperations = mongoOperations;
}
public void getById(Model model){
System.out.println("test");
}
}
Skift Java-konfigurationen for at tilføje 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();
}
Hvis du ikke koblede lageret manuelt gennem Java-konfiguration, skulle denne implementering hedde ModelMongoRepositoryImpl
for at matche grænsefladen ModelMongoRepository +"Impl"
. Og det ville blive håndteret automatisk til foråret.