休眠注释中的多个数据源抛出 No Session found for current thread 错误
Multiple Data source in hibernate annotation throwing No Session found for current thread error
我在我的网络应用程序中使用 spring 4 和休眠注释。一切都适用于单一数据源。当我添加第二个数据源时,我收到当前线程没有会话错误。
这是代码。
public abstract class PortalAbstractDao<PK extends Serializable, T> {
private final Class<T> persistentClass;
@SuppressWarnings("unchecked")
public PortalAbstractDao() {
this.persistentClass = (Class<T>) ((ParameterizedType) this.getClass().getGenericSuperclass())
.getActualTypeArguments()[1];
}
@Autowired
@Qualifier("eportalSessionFactory")
private SessionFactory sessionFactory;
protected Session getSession() {
return sessionFactory.getCurrentSession();
}
@SuppressWarnings("unchecked")
public T getByKey(PK key) {
return (T) getSession().get(persistentClass, key);
}
public void persist(T entity) {
getSession().persist(entity);
}
public void delete(T entity) {
getSession().delete(entity);
}
protected Criteria createEntityCriteria() {
return getSession().createCriteria(persistentClass);
}
}
DAO 实现
@Repository("portalDao")
public class PortalDaoImpl extends PortalAbstractDao<Integer, PortalAsset> implements PortalDao {
@SuppressWarnings("unchecked")
@Override
public List<PortalAsset> findAllAssets() {
// Query query = getSession().createSQLQuery(
// "select id,CSC_ASSET_TAG,SERIAL_NO,IBM_ASSET_TAG from sgh_assets where CSC_ASSET_TAG like :term");
// query.setString("term", "%gwls1208%");
Criteria criteria = getSession()
.createCriteria(PortalAsset.class)
.setMaxResults(20)
.setProjection(
Projections.projectionList().add(Projections.property("id"), "id")
.add(Projections.property("ctcassettag"), "ctcassettag")
.add(Projections.property("serialno"), "serialno")
.add(Projections.property("ibmassettag"), "ibmassettag")
.add(Projections.property("block"), "block")
.add(Projections.property("level"), "level").add(Projections.property("room"), "room"))
.setResultTransformer(Transformers.aliasToBean(PortalAsset.class));
return (List<PortalAsset>) criteria.list();
}
}
休眠配置
@Configuration
@EnableTransactionManagement
@ComponentScan({ "com.span.vms.configuration" })
@PropertySource(value = { "classpath:application.properties" })
public class HibernateConfiguration {
@Autowired
private Environment environment;
@Bean
@Primary
public LocalSessionFactoryBean sessionFactory() {
LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean();
sessionFactory.setDataSource(dataSource());
sessionFactory.setPackagesToScan(new String[] { "com.span.vms.model" });
sessionFactory.setHibernateProperties(hibernateProperties());
return sessionFactory;
}
@Bean
@Qualifier("eportalSessionFactory")
public LocalSessionFactoryBean eportalSessionFactory() {
LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean();
sessionFactory.setDataSource(eportalDataSource());
sessionFactory.setPackagesToScan(new String[] { "org.ctc.pm.model" });
sessionFactory.setHibernateProperties(hibernateProperties());
return sessionFactory;
}
@Bean
public DataSource dataSource() {
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;
}
@Bean
public DataSource eportalDataSource() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName(environment.getRequiredProperty("jdbc.driverClassName"));
dataSource.setUrl(environment.getRequiredProperty("jdbc.eportal.url"));
dataSource.setUsername(environment.getRequiredProperty("jdbc.eportal.username"));
dataSource.setPassword(environment.getRequiredProperty("jdbc.eportal.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"));
return properties;
}
@Bean
@Autowired
public HibernateTransactionManager transactionManager(SessionFactory s) {
HibernateTransactionManager txManager = new HibernateTransactionManager();
txManager.setSessionFactory(s);
return txManager;
}
}
服务实施
@Service("portalService")
public class PortalServiceImpl implements PortalService {
@Autowired
private PortalDao dao;
@Override
public List<PortalAsset> findAllAssets() {
return dao.findAllAssets();
}
}
服务接口
public interface PortalDao {
List<PortalAsset> findAllAssets();
}
当我 运行 List<PortalAsset> assets = portalService.findAllAssets();
时,我没有得到当前线程错误的会话,而主数据源工作正常。我做错了什么?
在你的休眠配置文件中它应该是..
@Configuration
@EnableTransactionManagement
@ComponentScan({ "com.span.vms.configuration" })
@PropertySource(value = { "classpath:application.properties" })
public class HibernateConfiguration {
@Autowired
private Environment environment;
@Bean
@Primary
public LocalSessionFactoryBean sessionFactory() {
LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean();
sessionFactory.setDataSource(dataSource());
sessionFactory.setPackagesToScan(new String[] { "com.span.vms.model" });
sessionFactory.setHibernateProperties(hibernateProperties());
return sessionFactory;
}
@Bean(name = "eportalSessionFactory")
public LocalSessionFactoryBean eportalSessionFactory() {
LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean();
sessionFactory.setDataSource(eportalDataSource());
sessionFactory.setPackagesToScan(new String[] { "org.ctc.pm.model" });
sessionFactory.setHibernateProperties(hibernateProperties());
return sessionFactory;
}
@Bean
public DataSource dataSource() {
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;
}
@Bean
public DataSource eportalDataSource() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName(environment.getRequiredProperty("jdbc.driverClassName"));
dataSource.setUrl(environment.getRequiredProperty("jdbc.eportal.url"));
dataSource.setUsername(environment.getRequiredProperty("jdbc.eportal.username"));
dataSource.setPassword(environment.getRequiredProperty("jdbc.eportal.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"));
return properties;
}
@Bean(name = "txManager1")
public HibernateTransactionManager transactionManager() {
HibernateTransactionManager txManager = new HibernateTransactionManager();
txManager.setSessionFactory(sessionFactory());
return txManager;
}
@Bean(name = "txManager2")
public HibernateTransactionManager transactionManager() {
HibernateTransactionManager txManager = new HibernateTransactionManager();
txManager.setSessionFactory(eportalSessionFactory());
return txManager;
}
并在服务层中,在@Transactional 注释中指定您要使用的事务管理器的名称。
我在我的网络应用程序中使用 spring 4 和休眠注释。一切都适用于单一数据源。当我添加第二个数据源时,我收到当前线程没有会话错误。
这是代码。
public abstract class PortalAbstractDao<PK extends Serializable, T> {
private final Class<T> persistentClass;
@SuppressWarnings("unchecked")
public PortalAbstractDao() {
this.persistentClass = (Class<T>) ((ParameterizedType) this.getClass().getGenericSuperclass())
.getActualTypeArguments()[1];
}
@Autowired
@Qualifier("eportalSessionFactory")
private SessionFactory sessionFactory;
protected Session getSession() {
return sessionFactory.getCurrentSession();
}
@SuppressWarnings("unchecked")
public T getByKey(PK key) {
return (T) getSession().get(persistentClass, key);
}
public void persist(T entity) {
getSession().persist(entity);
}
public void delete(T entity) {
getSession().delete(entity);
}
protected Criteria createEntityCriteria() {
return getSession().createCriteria(persistentClass);
}
}
DAO 实现
@Repository("portalDao")
public class PortalDaoImpl extends PortalAbstractDao<Integer, PortalAsset> implements PortalDao {
@SuppressWarnings("unchecked")
@Override
public List<PortalAsset> findAllAssets() {
// Query query = getSession().createSQLQuery(
// "select id,CSC_ASSET_TAG,SERIAL_NO,IBM_ASSET_TAG from sgh_assets where CSC_ASSET_TAG like :term");
// query.setString("term", "%gwls1208%");
Criteria criteria = getSession()
.createCriteria(PortalAsset.class)
.setMaxResults(20)
.setProjection(
Projections.projectionList().add(Projections.property("id"), "id")
.add(Projections.property("ctcassettag"), "ctcassettag")
.add(Projections.property("serialno"), "serialno")
.add(Projections.property("ibmassettag"), "ibmassettag")
.add(Projections.property("block"), "block")
.add(Projections.property("level"), "level").add(Projections.property("room"), "room"))
.setResultTransformer(Transformers.aliasToBean(PortalAsset.class));
return (List<PortalAsset>) criteria.list();
}
}
休眠配置
@Configuration
@EnableTransactionManagement
@ComponentScan({ "com.span.vms.configuration" })
@PropertySource(value = { "classpath:application.properties" })
public class HibernateConfiguration {
@Autowired
private Environment environment;
@Bean
@Primary
public LocalSessionFactoryBean sessionFactory() {
LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean();
sessionFactory.setDataSource(dataSource());
sessionFactory.setPackagesToScan(new String[] { "com.span.vms.model" });
sessionFactory.setHibernateProperties(hibernateProperties());
return sessionFactory;
}
@Bean
@Qualifier("eportalSessionFactory")
public LocalSessionFactoryBean eportalSessionFactory() {
LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean();
sessionFactory.setDataSource(eportalDataSource());
sessionFactory.setPackagesToScan(new String[] { "org.ctc.pm.model" });
sessionFactory.setHibernateProperties(hibernateProperties());
return sessionFactory;
}
@Bean
public DataSource dataSource() {
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;
}
@Bean
public DataSource eportalDataSource() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName(environment.getRequiredProperty("jdbc.driverClassName"));
dataSource.setUrl(environment.getRequiredProperty("jdbc.eportal.url"));
dataSource.setUsername(environment.getRequiredProperty("jdbc.eportal.username"));
dataSource.setPassword(environment.getRequiredProperty("jdbc.eportal.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"));
return properties;
}
@Bean
@Autowired
public HibernateTransactionManager transactionManager(SessionFactory s) {
HibernateTransactionManager txManager = new HibernateTransactionManager();
txManager.setSessionFactory(s);
return txManager;
}
}
服务实施
@Service("portalService")
public class PortalServiceImpl implements PortalService {
@Autowired
private PortalDao dao;
@Override
public List<PortalAsset> findAllAssets() {
return dao.findAllAssets();
}
}
服务接口
public interface PortalDao {
List<PortalAsset> findAllAssets();
}
当我 运行 List<PortalAsset> assets = portalService.findAllAssets();
时,我没有得到当前线程错误的会话,而主数据源工作正常。我做错了什么?
在你的休眠配置文件中它应该是..
@Configuration
@EnableTransactionManagement
@ComponentScan({ "com.span.vms.configuration" })
@PropertySource(value = { "classpath:application.properties" })
public class HibernateConfiguration {
@Autowired
private Environment environment;
@Bean
@Primary
public LocalSessionFactoryBean sessionFactory() {
LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean();
sessionFactory.setDataSource(dataSource());
sessionFactory.setPackagesToScan(new String[] { "com.span.vms.model" });
sessionFactory.setHibernateProperties(hibernateProperties());
return sessionFactory;
}
@Bean(name = "eportalSessionFactory")
public LocalSessionFactoryBean eportalSessionFactory() {
LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean();
sessionFactory.setDataSource(eportalDataSource());
sessionFactory.setPackagesToScan(new String[] { "org.ctc.pm.model" });
sessionFactory.setHibernateProperties(hibernateProperties());
return sessionFactory;
}
@Bean
public DataSource dataSource() {
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;
}
@Bean
public DataSource eportalDataSource() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName(environment.getRequiredProperty("jdbc.driverClassName"));
dataSource.setUrl(environment.getRequiredProperty("jdbc.eportal.url"));
dataSource.setUsername(environment.getRequiredProperty("jdbc.eportal.username"));
dataSource.setPassword(environment.getRequiredProperty("jdbc.eportal.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"));
return properties;
}
@Bean(name = "txManager1")
public HibernateTransactionManager transactionManager() {
HibernateTransactionManager txManager = new HibernateTransactionManager();
txManager.setSessionFactory(sessionFactory());
return txManager;
}
@Bean(name = "txManager2")
public HibernateTransactionManager transactionManager() {
HibernateTransactionManager txManager = new HibernateTransactionManager();
txManager.setSessionFactory(eportalSessionFactory());
return txManager;
}
并在服务层中,在@Transactional 注释中指定您要使用的事务管理器的名称。