休眠注释中的多个数据源抛出 No Session found for current thread 错误

Question

我在我的网络应用程序中使用 spring 4 和休眠注释。一切都适用于单个数据源。当我添加第二个数据源时，我收到 No session for current thread 错误。

这是代码。

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(); 时，在主数据源工作正常的情况下，我没有收到当前线程错误的会话。我做错了什么？

Answer 1

在你的休眠配置文件里面应该是..

@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 注解指定你要使用的事务管理器的名称。