使用Spring LDAP存储库的多个LDAP存储库
我想用Spring LDAP设置多个LDAP存储库。我的目标是同时创建或更新所有存储库中的对象。使用Spring LDAP存储库的多个LDAP存储库
我使用LdapRepository Spring接口,我认为现在是不可能的。
我在想我是否可以创建自己的LdapRepository来扩展Spring,但我不知道如何开始。
这是我的配置:
@Configuration
@EnableLdapRepositories("com.xxx.repository.ldap")
@PropertySource("classpath:ldap.properties")
public class LdapConfiguration {
@Autowired
Environment ldapProperties;
@Bean
public LdapContextSourceCustom contextSourceTarget() {
LdapContextSourceCustom ldapContextSource = new LdapContextSourceCustom();
ldapContextSource.setUrl(ldapProperties.getProperty("ldap.url"));
ldapContextSource.setBase(ldapProperties.getProperty("ldap.base"));
ldapContextSource.setUserDn(ldapProperties.getProperty("ldap.userDn"));
ldapContextSource.setPassword(ldapProperties.getProperty("ldap.password"));
ldapContextSource.setKeyStoreFile(ldapProperties.getProperty("ldap.truststore"));
return ldapContextSource;
}
@Bean
public LdapTemplate ldapTemplate(){
return new LdapTemplate(contextSourceTarget());
}
}
而且是完整的,一个仓库:
public interface LdapUserRepository extends LdapRepository<LdapUser> {
}
任何想法,该怎么办呢?
在此先感谢您的帮助。
1)可以指定多个LDAP存储库配置。请看下面的例子。 [注意:这取决于春季启动库]
@Configuration
@EnableLdapRepositories("com.xxx.repository.ldap")
@EnableConfigurationProperties(LdapProperties.class)
public class LdapConfiguration {
@Autowired
private Environment environment;
@Bean(name="contextSource1")
public LdapContextSource contextSourceTarget(LdapProperties ldapProperties) {
LdapContextSource source = new LdapContextSource();
source.setUserDn(this.properties.getUsername());
source.setPassword(this.properties.getPassword());
source.setBase(this.properties.getBase());
source.setUrls(this.properties.determineUrls(this.environment));
source.setBaseEnvironmentProperties(Collections.<String,Object>unmodifiableMap(this.properties.getBaseEnvironment()));
return source;
}
@Bean
public LdapTemplate ldapTemplate(@Qualifier("contextSource1") LdapContextSource contextSource){
return new LdapTemplate(contextSource);
}
}
可以使用spring.ldap
前缀application.properties
配置上述LdapConfiguration
。您可以通过检出https://github.com/spring-projects/spring-boot/blob/master/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/ldap/LdapProperties.java来查看可用的属性。
@Configuration
@EnableLdapRepositories(basePackages="com.yyy.repository.ldap", ldapTemplateRef="ldapTemplate2")
public class LdapConfiguration2 {
@Autowired
private Environment environment;
@Bean(name="ldapProperties2")
@ConfigurationProperties(prefix="spring.ldap2")
public LdapProperties ldapProperties() {
return new LdapProperties();
}
@Bean(name="contextSource2")
public LdapContextSource contextSourceTarget(@Qualifier("ldapProperties2") LdapProperties ldapProperties) {
LdapContextSource source = new LdapContextSource();
source.setUserDn(this.properties.getUsername());
source.setPassword(this.properties.getPassword());
source.setBase(this.properties.getBase());
source.setUrls(this.properties.determineUrls(this.environment));
source.setBaseEnvironmentProperties(Collections.<String,Object>unmodifiableMap(this.properties.getBaseEnvironment()));
return source;
}
@Bean(name="ldapTemplate2")
public LdapTemplate ldapTemplate(@Qualifier("contextSource2") LdapContextSource contextSource){
return new LdapTemplate(contextSource);
}
}
LdapConfiguration2
将由spring.ldap2
前缀application.properties
进行配置。
2)我不认为扩展存储库是解决方案。我建议创建一个@Service
方法遍历您的存储库并应用更新。我将在下面提供两种方法。
例1)
@Service
public class UpdateRepositories {
public void updateAllRepositories(LdapUserRepository userRepository1, LdapUserRepository userRepository2) {
// apply updates to userRepository1 and userRepository2
}
}
例2)
@Service
public class UpdateRepositories {
public void updateAllRepositories(ApplicationContext appContext) {
Map<String, LdapRepository> ldapRepositories = appContext.getBeansofType(LdapRepository.class)
// iterate through map and apply updates
}
}
我还没有编译的代码,所以我们还是我知道如果事情是关闭的,如果你需要更多的指导。
,如果我理解正确的,但在这里我不知道的是我们所做的事情:
-
全球配置类
@Bean("odm") public ObjectDirectoryMapper odm() { return new DefaultObjectDirectoryMapper(); };
-
首先LDAP配置类
@Configuration @PropertySource("classpath:ldap-one.properties") public class LdapOneConfiguration { @Autowired Environment ldapProperties; @Bean(name = "contextSourceOne") public LdapContextSourceCustom contextSourceLdapOneTarget() { LdapContextSourceCustom ldapContextSource = new LdapContextSourceCustom(); ldapContextSource.setUrl(ldapProperties.getProperty("ldap-one.url")); ldapContextSource.setBase(ldapProperties.getProperty("ldap-one.base")); ldapContextSource.setUserDn(ldapProperties.getProperty("ldap-one.userDn")); ldapContextSource.setPassword(ldapProperties.getProperty("ldap-one.password")); ldapContextSource.setKeyStoreFile(ldapProperties.getProperty("ldap-one.truststore")); return ldapContextSource; } @Bean(name = "ldapTemplateOne") public LdapTemplate ldapOneTemplate(@Qualifier("contextSourceOne") LdapContextSourceCustom contextSource) { return new LdapTemplate(contextSource); } @Bean(name = "ldapUserRepoOne") public LdapUserRepository ldapUserRepositoryOne(@Qualifier("ldapTemplateOne") LdapTemplate ldapTemplate, @Qualifier("odm") ObjectDirectoryMapper odm) { return new LdapUserRepository(ldapTemplate, odm); } @Bean(name = "ldapFamilyRepoOne") public LdapFamilyRepository ldapFamilyRepositoryOne(@Qualifier("ldapTemplateOne") LdapTemplate ldapTemplate, @Qualifier("odm") ObjectDirectoryMapper odm) { return new LdapFamilyRepository(ldapTemplate, odm); } }
-
第二个LDAP配置类
@Configuration @PropertySource("classpath:ldap-two.properties") public class LdapTwoConfiguration { @Autowired Environment ldapProperties; @Bean(name = "contextSourceTwo") public LdapContextSourceCustom contextSourceLdapTwoTarget() { LdapContextSourceCustom ldapContextSource = new LdapContextSourceCustom(); ldapContextSource.setUrl(ldapProperties.getProperty("ldap-two.url")); ldapContextSource.setBase(ldapProperties.getProperty("ldap-two.base")); ldapContextSource.setUserDn(ldapProperties.getProperty("ldap-two.userDn")); ldapContextSource.setPassword(ldapProperties.getProperty("ldap-two.password")); ldapContextSource.setKeyStoreFile(ldapProperties.getProperty("ldap-two.truststore")); return ldapContextSource; } @Bean(name = "ldapTemplateTwo") public LdapTemplate ldapTwoTemplate(@Qualifier("contextSourceTwo") LdapContextSourceCustom contextSource) { return new LdapTemplate(contextSource); } @Bean(name = "ldapUserRepoTwo") public LdapUserRepository ldapUserRepositoryTwo(@Qualifier("ldapTemplateTwo") LdapTemplate ldapTemplate, @Qualifier("odm") ObjectDirectoryMapper odm) { return new LdapUserRepository(ldapTemplate, odm); } @Bean(name = "ldapFamilyRepoTwo") public LdapFamilyRepository ldapFamilyRepositoryTwo(@Qualifier("ldapTemplateTwo") LdapTemplate ldapTemplate, @Qualifier("odm") ObjectDirectoryMapper odm) { return new LdapFamilyRepository(ldapTemplate, odm); } }
-
LdapUser库
public class LdapUserRepository extends SimpleLdapRepository<LdapUser> { public LdapUserRepository(LdapOperations ldapOperations, ObjectDirectoryMapper odm) { super(ldapOperations, odm, LdapUser.class); } }
-
LdapFamily库
public class LdapFamilyRepository extends SimpleLdapRepository<LdapFamily> { public LdapFamilyRepository(LdapOperations ldapOperations, ObjectDirectoryMapper odm) { super(ldapOperations, odm, LdapFamily.class); } }
-
LdapUser服务(同样为LdapFamily服务)
@Service public class LdapUserServiceImpl implements LdapUserService { @Autowired private ApplicationContext appContext; private LdapUserRepository uniqueLdapUserRepo; private List<LdapUserRepository> ldapUserRepoList; @PostConstruct private void setUniqueRepo() { uniqueLdapUserRepo = appContext.getBeansOfType(LdapUserRepository.class).values().iterator().next(); ldapUserRepoList = new ArrayList<>(appContext.getBeansOfType(LdapUserRepository.class).values()); } @Override public LdapUser getUser(String uid) { return uniqueLdapUserRepo.findOne(query().where("uid").is(uid)); } @Override public void saveUser(LdapUser user) { for(LdapUserRepository repo: ldapUserRepoList){ repo.save(user); } }
}
我们删除LDAP回购的自动配置:
@EnableLdapRepositories(basePackages = "com.afklm.paul.repository.ldap", ldapTemplateRef = "ldapTwoTemplate")
感谢ryan2049您的帮助。
在示例2中,我只获得一个LdapRepository(第一个实例化我认为)。 –
这个例子取决于你有多个LdapRepository的实现。 – ryan2049
我用两个实体的完整示例添加了答案 –