使用Spring时如何注入多个JPA EntityManager（持久化单元）

Posted 2023-02-26

【中文标题】使用Spring时如何注入多个JPA EntityManager（持久化单元）

【英文标题】：How to inject multiple JPA EntityManager (persistence units) when using Spring

【发布时间】：2015-05-03 05:42:00

【问题描述】：

我需要使用一个数据库进行查询（非修改）和一个用于命令（修改）。我使用的是 Spring Data JPA，所以我有两个配置类：

@Configuration
@EnableJpaRepositories(value = "com.company.read",
        entityManagerFactoryRef = "readingEntityManagerFactory",
        transactionManagerRef = "readingTransactionManager")
@EnableTransactionManagement
public class SpringDataJpaReadingConfiguration 

    @Bean(name = "readingEntityManagerFactory")
    public EntityManagerFactory readingEntityManagerFactory() 
        return Persistence.createEntityManagerFactory("persistence.reading");
    

    @Bean(name = "readingExceptionTranslator")
    public HibernateExceptionTranslator readingHibernateExceptionTranslator() 
        return new HibernateExceptionTranslator();
    

    @Bean(name = "readingTransactionManager")
    public JpaTransactionManager readingTransactionManager() 
        return new JpaTransactionManager();
    



@Configuration
@EnableJpaRepositories(value = "com.company.write",
        entityManagerFactoryRef = "writingEntityManagerFactory",
        transactionManagerRef = "writingTransactionManager")
@EnableTransactionManagement
public class SpringDataJpaWritingConfiguration 

    @Bean(name = "writingEntityManagerFactory")
    public EntityManagerFactory writingEntityManagerFactory() 
        return Persistence.createEntityManagerFactory("persistence.writing");
    

    @Bean(name = "writingExceptionTranslator")
    public HibernateExceptionTranslator writingHibernateExceptionTranslator() 
        return new HibernateExceptionTranslator();
    

    @Bean(name = "writingTransactionManager")
    public JpaTransactionManager writingTransactionManager() 
        return new JpaTransactionManager();
    

在我的存储库中，我有时需要使用 EntityManager 来决定这样使用：

@Repository
public class UserReadingRepository 

    @PersistenceContext(unitName = "persistence.reading")
    private EntityManager em;

    // some useful queries here

我正在使用 persistence.xml 中定义的持久性单元名称：

<persistence xmlns="http://java.sun.com/xml/ns/persistence"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd"
             version="2.0">

    <persistence-unit name="persistence.reading" transaction-type="RESOURCE_LOCAL">
        <provider>org.hibernate.jpa.HibernatePersistenceProvider</provider>
        <non-jta-data-source>ReadingDS</non-jta-data-source>
        <properties>
            <property name="hibernate.dialect" value="org.hibernate.dialect.mysqlDialect" />
            <property name="hibernate.show_sql" value="true" />
        </properties>
    </persistence-unit>

    <persistence-unit name="persistence.writing" transaction-type="RESOURCE_LOCAL">
        <provider>org.hibernate.jpa.HibernatePersistenceProvider</provider>
        <non-jta-data-source>WritingDS</non-jta-data-source>
        <properties>
            <property name="hibernate.dialect" value="org.hibernate.dialect.MySQLDialect" />
            <property name="hibernate.show_sql" value="true" />
        </properties>
    </persistence-unit>

</persistence>

弹簧抛出org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named 'persistence.reading' 已定义。奇怪的是，Spring 似乎试图用持久性单元名称实例化 a bean？我是不是配置错了什么？

更新：当我从 @PersistenceContext 注释中删除 unitName = "persistence.reading" 时，我会收到以下错误： org.springframework.beans.factory.NoUniqueBeanDefinitionException: No qualifying bean of type [javax.persistence.EntityManagerFactory] is defined: expected single matching bean but found 2: readingEntityManagerFactory,writingEntityManagerFactory

更新 2：Rohit 建议（在评论中）改为电汇 EntityManagerFactory。所以我尝试执行以下操作：

@PersistenceUnit(unitName = "persistence.reading")
private EntityManagerFactory emf;

但 Spring 仅报告：org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named 'persistence.reading' is defined

最终修复： 感谢 Vlad 的回答，我能够更新代码以使用以下内容（只需确保您也定义了 dataSource bean）：

@Bean(name = "readingEntityManagerFactory")
public EntityManagerFactory readingEntityManagerFactory() 
    LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
    em.setPersistenceUnitName("persistence.reading");
    em.setDataSource(dataSource());
    em.setPackagesToScan("com.company");
    em.setJpaVendorAdapter(new HibernateJpaVendorAdapter());
    em.afterPropertiesSet();
    return em.getObject();

【问题讨论】：

为什么不设置transactionManager 的entityManagerFactory 属性？你的persistence.xml 文件在哪里？

persistence.xml 位于 META-INF 内的类路径中。我尝试在transactionManager bean 上设置entityManagerFactories，但结果完全一样。

仅供参考，我很确定 persistence.xml 是可见的，如果我回退到只使用一个 entityManager，那么 Spring 会成功组装所有 bean。

这很奇怪。尽管我遵循基于 Java 的配置方法，但我还在我的应用程序中使用了多个 entityManager。它运行良好，具有不同的持久性单元名称。如果它适用于 1，那么它应该没有理由不适用于 2。或者可能是，某处缺少非常微小的东西。我对 PU 的名称略有怀疑。这听起来可能很傻，但是你能在persistence.reading和persistence.writing中用-替换.吗？

呵呵，我已经想到了，我更改了持久性单元名称，但不幸的是没有运气：-/我用另一个有趣的错误更新了原始问题

【参考方案1】：

EntityManageFactory 配置不正确。您应该改用LocalContainerEntityManagerFactoryBean：

@Bean(name = "readingEntityManagerFactory")
public EntityManagerFactory readingEntityManagerFactory() 
    LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
    em.setPersistenceUnitName("persistence.reading");
    em.setDataSource(dataSource());
    em.setPackagesToScan("com.company");
    em.setJpaVendorAdapter(new HibernateJpaVendorAdapter());
    em.afterPropertiesSet();
    return em.getObject();

此外，JpaTransactionManager 也配置错误。它应该是这样的：

@Bean(name = "readingTransactionManager")
public PlatformTransactionManager readingTransactionManager()
    JpaTransactionManager transactionManager = new JpaTransactionManager();
    transactionManager.setEntityManagerFactory(readingEntityManagerFactory());
    return transactionManager;

您需要对 EntityManager 的读取和写入配置执行相同的操作。

【讨论】：

感谢弗拉德，我终于可以让它工作了。如果其他人也遇到此问题，请查看我在原始问题中的更新并修复您的答案（以便至少编译:)）。

点了。我用平板电脑写了这个答案，在编辑的时候我在脑海里玩着编译器的工作。我用你的最终修复更新了答案，以避免任何问答混淆。

我也在尝试使用上述方法创建两个实体管理器工厂，但在我的情况下，dataSource 是相同的，但我仍然遇到相同的问题没有可用的“javax.persistence.EntityManagerFactory”类型的合格 bean：预期单个匹配 bean，但找到 2。任何指针？