时间戳

首页 > 解决方案 > 多数据源配置问题

spring - 多数据源配置问题

问题描述

在我的项目中，我将两个 Oracle 数据源用于我正在使用的数据源之一，LocalSessionFactoryBean而另一个LocalContainerEntityManagerFactoryBean 我正在相应地映射数据源，但是当我尝试获取LocalSessionFactoryBean数据源详细信息的 sessionFactory 时，是另一个数据源的详细信息。不要我做错了什么。

<tx:annotation-driven transaction-manager="xxxTransactionManager" />

    <bean id="xxxEntityManagerFactoryBean"
        class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
        <property name="dataSource" ref="dataSource" />     
        <property name="persistenceXmlLocation" value="classpath:persistence.xml" />

        <property name="jpaDialect">
            <bean class="org.springframework.orm.jpa.vendor.HibernateJpaDialect" />
        </property>
        <property name="jpaVendorAdapter">
            <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter" />
        </property>
        <property name="jpaProperties">
            <props>
                <prop key="hibernate.dialect">${hibernate.dialect}</prop>
                <prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
                <prop key="hibernate.hbm2ddl.auto">${hibernate.hbm2ddl.auto}</prop>

            </props>
        </property>
    </bean>
    <bean class="org.modelmapper.ModelMapper" id="modelMapper"/>
    <bean id="xxxEntityManager"
        class="org.springframework.orm.jpa.support.SharedEntityManagerBean">
        <property name="entityManagerFactory" ref="xxxEntityManagerFactoryBean" />
    </bean>

    <bean id="xxxTransactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
        <property name="entityManagerFactory" ref="xxxEntityManagerFactoryBean" />
        <property name="nestedTransactionAllowed" value="true" />
        <property name="dataSource" ref="dataSource" />
        <property name="jpaDialect" ref="jpaDialect" />
    </bean>
    <bean id="jpaDialect" class="org.springframework.orm.jpa.vendor.HibernateJpaDialect" />

在另一个导入的 xml 文件中，我有

<bean id="sessionFactoryNew"
    class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
      <property name="dataSource" ref="dataSource1" />
      <property name="packagesToScan" value="com.citi.aml.npa.domain.api" />
      <property name="hibernateProperties">
         <props>
            <prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
            <prop key="hibernate.dialect">${hibernate.dialect}</prop>
         </props>
      </property>
   </bean>
   <bean id="xxxTransactionManagerNew"
    class="org.springframework.orm.hibernate4.HibernateTransactionManager">
      <property name="sessionFactory" ref="sessionFactoryNew" />
      <qualifier value="xxxtransaction"/>
   </bean>

在应用程序 context.xml 我有像这样的数据源

<beans profile="local">
        <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
            destroy-method="close">
            <property name="driverClassName" value="${db.oracle.driverClassName}" />
            <property name="username" value="${db.oracle.username}" />
            <property name="password" value="${db.oracle.password}" />
            <property name="url" value="${db.oracle.url}" />

        </bean>
        <context:property-placeholder location="classpath*:/config/local/yyy.properties" ignore-unresolvable="true"/>
    </beans>
<beans profile="local">
        <bean id="dataSource1" class="org.apache.commons.dbcp.BasicDataSource"
            destroy-method="close">
            <property name="driverClassName" value="${db.oracle.driverClassName}" />
            <property name="username" value="${db.oracle.username}" />
            <property name="password" value="${db.oracle.password}" />
            <property name="url" value="${db.oracle.url}" />

        </bean>
        <context:property-placeholder location="classpath*:/config/local/xxx_db.properties" ignore-unresolvable="true"/>
    </beans>

在 Dao impl calss 我有

@Repository
public class OracledbTestRepository implements TestRepository {
    @Autowired
    @Qualifier(value = "sessionFactoryNew")
    SessionFactory sessionFactory;

    @SuppressWarnings("unchecked")
    @Override
    public List<xxx> getTestData() {
        Session session = sessionFactory.getCurrentSession();
        System.out.println(sessionFactory);
        List<xxx> xxxTestDatas = session.createCriteria(xxx.class).list();
        return xxxTestDatas;
    }
}

任何帮助将不胜感激。

标签： springoraclehibernatejpa

解决方案

你的 bean 配置对我来说有点奇怪。您有两个同名的不同配置文件。如果这两个数据源需要同时运行，将数据库属性合并到一个文件中，并将两个数据源配置放在同一个配置文件元素中会更简单。

因此，对于统一的 database.properties，请执行以下操作：

db1.oracle.url=jdbc:oracle:thin:@server1...
db1.oracle.username=foo
...
db2.oracle.url=jdbc:oracle:thin:@server2...
db2.oracle.username=bar

对于 bean 配置，使用类似：

<beans profile="local">
        <context:property-placeholder location="classpath*:/config/local/database.properties" ignore-unresolvable="true"/>
        <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
            destroy-method="close">
            <property name="driverClassName" value="${db1.oracle.driverClassName}" />
            <property name="username" value="${db1.oracle.username}" />
            <property name="password" value="${db1.oracle.password}" />
            <property name="url" value="${db1.oracle.url}" />

        </bean>
        <bean id="dataSource1" class="org.apache.commons.dbcp.BasicDataSource"
            destroy-method="close">
            <property name="driverClassName" value="${db2.oracle.driverClassName}" />
            <property name="username" value="${db2.oracle.username}" />
            <property name="password" value="${db2.oracle.password}" />
            <property name="url" value="${db2.oracle.url}" />
        </bean>
    </beans>

推荐阅读