spring-data-jpa 如何使用多个数据源？ [复制]

Question

我阅读了所有相关问题并尝试了所有问题，但仍然无法正确配置。

我有两个数据库，我想将它们用作我的应用程序中的数据源。

这是我的上下文文件：

<jee:jndi-lookup id="firstDataSource" jndi-name="java:/comp/env/jdbc/firstDS"   expected-type="javax.sql.DataSource" />
<jee:jndi-lookup id="secondDataSource" jndi-name="java:/comp/env/jdbc/secondDS" expected-type="javax.sql.DataSource" />

<bean name="persistenceProvider" class="org.hibernate.jpa.HibernatePersistenceProvider"></bean>

<bean class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean" id="thisEntityManagerFactory">
    <property name="dataSource" ref="firstDataSource"/>
    <property name="packagesToScan" value="com.a.b.first.model"/>
    <property name="jpaVendorAdapter">
        <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
            <property name="generateDdl" value="false" />
            <property name="showSql" value="true"/>
            <property name="databasePlatform" value= "org.hibernate.dialect.Oracle10gDialect"/>
            <property name="database" value="ORACLE"/>
        </bean>
    </property>
    <property name="persistenceUnitName" value="firstPersistenceUnit" />
    <property name="persistenceProvider" ref="persistenceProvider"></property>
    <property name="jpaProperties">
        <value>
            hibernate.generate_statistics = true
            hibernate.cache.use_second_level_cache = true
            hibernate.cache.region.factory_class = org.hibernate.cache.ehcache.SingletonEhCacheRegionFactory
            hibernate.cache.use_query_cache = true
            <!--hibernate.hbm2ddl.auto=create-->
        </value>
    </property>
</bean>

<bean class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean" id="otherEntityManagerFactory">
    <property name="dataSource" ref="secondDataSource"/>
    <property name="packagesToScan" value="com.a.b.second.model"/>
    <property name="jpaVendorAdapter">
        <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
            <property name="generateDdl" value="false" />
            <property name="showSql" value="true"/>
            <property name="databasePlatform" value= "org.hibernate.dialect.Oracle10gDialect"/>
            <property name="database" value="ORACLE"/>
        </bean>
    </property>
    <property name="persistenceUnitName" value="secondPersistenceUnit" />
    <property name="persistenceProvider" ref="persistenceProvider"></property>
    <property name="jpaProperties">
        <value>
            hibernate.generate_statistics = true
            hibernate.cache.use_second_level_cache = true
            hibernate.cache.region.factory_class = org.hibernate.cache.ehcache.SingletonEhCacheRegionFactory
            hibernate.cache.use_query_cache = true
            <!--hibernate.hbm2ddl.auto=create-->
        </value>
    </property>
</bean>

<bean class="org.springframework.orm.jpa.JpaTransactionManager" id="thisTransactionManager">
    <property name="entityManagerFactory" ref="thisEntityManagerFactory"/>
    <property name="jpaDialect">
        <bean class="org.springframework.orm.jpa.vendor.HibernateJpaDialect" />
    </property>
</bean>

<bean class="org.springframework.orm.jpa.JpaTransactionManager" id="otherTransactionManager">
    <property name="entityManagerFactory" ref="otherEntityManagerFactory"/>
    <property name="jpaDialect">
        <bean class="org.springframework.orm.jpa.vendor.HibernateJpaDialect" />
    </property>
</bean>

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

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

<jpa:repositories base-package="com.a.b.first.intf" entity-manager-factory-ref="thisEntityManagerFactory" transaction-manager-ref="transactionManager"/>
<jpa:repositories base-package="com.a.b.second.intf" entity-manager-factory-ref="otherEntityManagerFactory" transaction-manager-ref="otherTransactionManager" />

问题是当我尝试使用位于包 com.absecond.intf 下的存储库接口时，它会转到 firstDataSource 并抛出带有消息“的 SQLSyntaxErrorException” ORA-00942: 表或视图不存在”。因为第一个数据库中没有这样的表。

每个EntityManagerFactory的日志中都有一行，说

为持久化单元构建 JPA 容器 EntityManagerFactory '默认'

在下一行中，它为这个 EntityManagerFactory 打印 PersistenceUnitInfo。 PersistenceUnitInfo 的“非 JTA 数据源”属性对于两个 EntityManagerFactories 是相同的。我猜这意味着两个持久性单元使用相同的数据源。

我错过了什么？

谢谢。

Answer 1

在你的服务层你应该有这样的东西：

@Service
@Transactional("thisTransactionManager")
public class ThisService{

   @Autowired
   private com.a.b.first.intf.Repo1 repo1;
}

@Service
@Transactional("otherEntityManagerFactory")
public class OtherService{

   @Autowired
   private com.a.b.second.intf.Repo1 repo1;
}

这样，当您调用服务方法时，TransactionInterceptor 可以加载相应的事务管理器，关联到您要操作的EntityManagerFactory。