【发布时间】:2016-12-20 20:38:13
【问题描述】:
我知道这个问题有数十亿个问题,但我无法解决我的问题。我有 Spring + Hibernate 的应用程序。 Hibernate 有 2 个配置(用于客户和管理数据库)。客户的休眠支持使用 DATABASE 方法的多租户。我也使用 Spring Security。
这是我的租户 ID 解析类:
@Component
public class MyTenantIdentifierResolver implements CurrentTenantIdentifierResolver {
@Autowired
private UserService userService;
public String resolveCurrentTenantIdentifier() {
User u = (User) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
com.lspsystem.model.User us = userService.getByLogin(u.getUsername());
return us.getCompany().getTenantId();
}
public boolean validateExistingCurrentSessions() {
return true;
}
}
这是我的用户服务:
@Service
public class UserServiceImpl implements UserService {
@Autowired
private UserDAO userDAO;
public User get(Integer id) {
return userDAO.get(id);
}
public boolean delete(Integer id) {
return userDAO.delete(id);
}
public void update(User u) {
userDAO.update(u);
}
public List<User> getAll(User u) {
return userDAO.getAllUsers();
}
public User getByLogin(String login) {
return userDAO.getByLogin(login);
}
}
我的问题:为什么MyTenantIdResolver 中的UserService 总是null?但是,例如在下一节课中(来自安全),它不会 null。
@Service
public class UserDetailsServiceImpl implements UserDetailsService {
@Autowired
private UserService userService;
public User loadUserByUsername(String s) throws UsernameNotFoundException {
com.lspsystem.model.User u = userService.getByLogin(s);
return new User(u.getEmail(), u.getPassword(), true, true, true, true, getGrantedAuthorities(u));
}
@Autowired
public UserDetailsServiceImpl(UserService userService) {
this.userService = userService;
}
private List<GrantedAuthority> getGrantedAuthorities(com.lspsystem.model.User u) {
List<GrantedAuthority> authorities = new ArrayList<GrantedAuthority>();
return authorities;
}
}
请注意,UserService 和 MyTenantIdResolver 属于不同的休眠配置。
更新
客户休眠配置:
@Configuration
@EnableTransactionManagement
@PropertySource(value = {"classpath:customerHibernate.properties"})
public class RemoteDBHibernateConfig {
@Autowired
private Environment environment;
@Bean(name = "customerSessionFactory")
public SessionFactory sessionFactory() throws IOException{
LocalSessionFactoryBean builder =
new LocalSessionFactoryBean();
builder.setDataSource(dataSource1());
builder.setPackagesToScan("com.lspsystem.model");
builder.setHibernateProperties(hibernateProperties());
builder.afterPropertiesSet();
return builder.getObject();
}
@Bean("defaultDS")
public DataSource dataSource1() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName(environment.getRequiredProperty("jdbc.driverClassName"));
dataSource.setUrl(environment.getRequiredProperty("jdbc.url"));
dataSource.setUsername(environment.getRequiredProperty("jdbc.username"));
dataSource.setPassword(environment.getRequiredProperty("jdbc.password"));
return dataSource;
}
private Properties hibernateProperties() {
Properties properties = new Properties();
properties.put("hibernate.dialect", environment.getRequiredProperty("hibernate.dialect"));
properties.put("hibernate.show_sql", environment.getRequiredProperty("hibernate.show_sql"));
properties.put("hibernate.format_sql", environment.getRequiredProperty("hibernate.format_sql"));
properties.put("hibernate.multiTenancy", environment.getRequiredProperty("hibernate.multiTenancy"));
properties.put("hibernate.multi_tenant_connection_provider", environment.getRequiredProperty("hibernate.multi_tenant_connection_provider"));
properties.put("hibernate.tenant_identifier_resolver", environment.getRequiredProperty("hibernate.tenant_identifier_resolver"));
return properties;
}
@Bean
@Autowired
public HibernateTransactionManager transactionManager() throws IOException{
HibernateTransactionManager txManager = new HibernateTransactionManager();
txManager.setSessionFactory(sessionFactory());
return txManager;
}}
管理员休眠配置:
@Configuration
@EnableTransactionManagement
@PropertySource(value = {"classpath:adminHibernate.properties"})
public class AdminDBHibernateConfig {
@Autowired
private Environment environment;
@Bean(name = "adminSessionFactory")
public SessionFactory sessionFactory() throws IOException {
LocalSessionFactoryBean builder =
new LocalSessionFactoryBean();
builder.setDataSource(dataSource());
builder.setPackagesToScan("com.lspsystem.model");
builder.setHibernateProperties(hibernateProperties());
builder.afterPropertiesSet();
return builder.getObject();
}
@Bean
public DataSource dataSource() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName(environment.getRequiredProperty("admin.jdbc.driverClassName"));
dataSource.setUrl(environment.getRequiredProperty("admin.jdbc.url"));
dataSource.setUsername(environment.getRequiredProperty("admin.jdbc.username"));
dataSource.setPassword(environment.getRequiredProperty("admin.jdbc.password"));
return dataSource;
}
private Properties hibernateProperties() {
Properties properties = new Properties();
properties.put("hibernate.dialect", environment.getRequiredProperty("admin.hibernate.dialect"));
properties.put("hibernate.show_sql", environment.getRequiredProperty("admin.hibernate.show_sql"));
properties.put("hibernate.format_sql", environment.getRequiredProperty("admin.hibernate.format_sql"));
properties.put("hibernate.hbm2dll.auto", environment.getRequiredProperty("admin.hibernate.hbm2ddl.auto"));
return properties;
}
@Bean
@Autowired
public HibernateTransactionManager transactionManager() throws IOException{
HibernateTransactionManager txManager = new HibernateTransactionManager();
txManager.setSessionFactory(sessionFactory());
return txManager;
}}
网络应用配置:
@Configuration
@EnableWebMvc
@Import(SecurityConfiguration.class)
public class WebApplicationConfig extends WebMvcConfigurerAdapter{
@Override
public void addResourceHandlers(ResourceHandlerRegistry registry) {
registry.addResourceHandler("/resources/**").addResourceLocations("/resources/");
}
@Bean
public InternalResourceViewResolver viewResolver(){
InternalResourceViewResolver view = new InternalResourceViewResolver();
view.setViewClass(JstlView.class);
view.setPrefix("/WEB-INF/jsp/");
view.setSuffix(".jsp");
return view;
}}
UserDAO,例如:
@Repository
public class UserDAOImpl implements UserDAO {
@Autowired
@Qualifier("adminSessionFactory")
private SessionFactory sessionFactory;
public com.lspsystem.model.User get(Integer id) {
Session session = sessionFactory.openSession();
User u = (User)session.load(User.class, id);
return u;
}
public User getByLogin(String login) {
Session session = sessionFactory.openSession();
Query q = session.createQuery("SELECT u FROM User u WHERE u.email = :email");
q.setParameter("email", login);
User u = (User)q.list().get(0);
return u;
}}
【问题讨论】:
-
提供您的配置类/文件。
-
是的,请提供您的配置文件。无论如何只是一个想法:单个服务如何同时拥有两个持久性配置? (如果我理解你的情况曝光)
-
我的配置已添加。
-
在这种情况下,Hibernate 自己创建和管理 MyTenantIdResolver 的实例吗?我从未使用过该功能,但鉴于您将类名配置为休眠属性,我高度怀疑是这种情况。
-
我在不使用 UserService 的情况下找到了解决方案,并且一切正常。所以我认为解析器没有问题......
标签: java spring hibernate multi-tenant