java - 使用多个持久化单元动态处理 EntityManager

Question

我有一个包含多个模式的数据库，所以我有一个包含多个 <persistence-unit /> 的 persistence.xml 文件(命名为 01、02、...)。

有问题的: 我想根据某些用户标准动态创建 EntityManager 函数。

我测试了2个案例。

第一种情况:基本上，我测试了这段代码(在无状态 EJB 中):

String criteria = "01";     
EntityManagerFactory emf = Persistence.createEntityManagerFactory(criteria);
EntityManager em = emf.createEntityManager();

Joueur joueur = new Joueur(); // Joueur is an Entity
joueur.setPseudo("olivier");

em.persist(joueur);

但我收到异常:

Caused by: Exception [EclipseLink-4002] (Eclipse Persistence Services - 2.3.2.v20111125-r10461): org.eclipse.persistence.exceptions.DatabaseException Internal Exception: org.postgresql.util.PSQLException: ERREUR: la transaction est annulée, les commandes sont ignorées jusqu'à la fin du bloc de la transaction

我认为(在一些 Stackoverflow 帖子的帮助下)，我的 EntityManager 没有“链接”到我的事务上下文，因为它不是由容器注入(inject)的。

第二种情况:因此，我使用了注入(inject):

@PersistenceContext(unitName="00")
private EntityManager em00;

@PersistenceContext(unitName="01")
private EntityManager em01;

我函数中的代码:

String criteria = "01";
EntityManager em = getEm(criteria);
...

和 getEm() 方法:

private EntityManager getEm(String criteria){

    if (criteria == "00")
        return em00;
    else if (criteria == "01")
        return em01;

    return null;
}

没问题，它可以工作，但我必须注入(inject)与我拥有持久性单元一样多的 EntityManagers。

• 如果我有 50 个模式，成本是多少...？
• 有没有办法真正动态地管理实体管理器？ (仅 1 个 EntityManger)
• 如果我必须为每个模式创建 1 个 EntityManager，即使我不使用它，我该如何改进我的代码以消耗尽可能少的资源？

感谢您的建议和反馈

编辑:

我的配置文件:

持久性.xml:

<persistence version="2.0"
    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">

    <persistence-unit name="00" transaction-type="JTA">
        <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
        <jta-data-source>jdbc/sim/00</jta-data-source>
        <mapping-file>orm_00_beta.xml</mapping-file>
        <class>com.sim.entities.Joueur</class>      
        <properties>
            <property name="eclipselink.ddl-generation" value="create-tables" />
        </properties>       
    </persistence-unit>

    <persistence-unit name="01" transaction-type="JTA">
        <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
        <jta-data-source>jdbc/sim/01</jta-data-source>
        <mapping-file>orm_01_beta2.xml</mapping-file>
        <class>com.sim.entities.Joueur</class>
        <properties>
            <property name="eclipselink.ddl-generation" value="create-tables" />
        </properties>
    </persistence-unit>

</persistence>

orm_00_beta.xml:

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

<persistence-unit-metadata>
    <persistence-unit-defaults>        
        <schema>beta</schema>
    </persistence-unit-defaults>
</persistence-unit-metadata>   

orm_01_beta2.xml:

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

<persistence-unit-metadata>
    <persistence-unit-defaults>        
        <schema>beta2</schema>
    </persistence-unit-defaults>
</persistence-unit-metadata>   

Answer 1

您需要将“eclipselink.target-server”设置为您在使用应用程序管理的持久性单元时使用的应用程序服务器(一些服务器会自动设置，然后使用容器管理的持久性单元)。然后 EntityManager 将与创建时处于 Activity 状态的 JTA 事务绑定(bind)。如果您在 JTA 事务开始之前创建 EntityManager，那么您可以使用 joinTransaction()。

如果您仍然有问题，请包括您正在使用的服务器以及完整的异常堆栈跟踪。

如果您有很多模式，您可以考虑使用 EclipseLink Multi-Tenancy 支持，它允许每个租户拥有自己的模式。

http://www.eclipse.org/eclipselink/documentation/2.4/jpa/extensions/a_multitenant.htm#BABEGBIJ