2011-12-14 61 views
0

我想綁定變量dataSourceString(可能的值:HR,FINANCE:我通過jsp動態獲取dataSourceString值)到DataSource。當dataSourceString值爲HR,然後連接到TESTDS,並且當dataSourceString值爲FINANCE時,根據我想要連接到數據源的dataSourceString值連接到TESTDS1.Means。 Enviornment:EJB3,weblogic10.3.3,JPA使用JPA的動態數據源查找

注:還有一兩件事,我不想寫的if-else循環中的SessionBean喜歡當dataSourceString是HR那麼其他連接到該EnityManage不同EntityManager.currently有10 dataSourceString的15個可能的值。我想編寫代碼,如果將來添加新的dataSourceString,那麼只有我必須更改persistence.xml。

研究後,我來到下面的代碼,但得到一些錯誤。

錯誤: -

No persistence unit named 'em' is available in scope test.jar. Available persistence units: [HR, FINANCE] 


    at weblogic.ejb.container.deployer.EJBModule.prepare(EJBModule.java:467) 
    at weblogic.application.internal.flow.ModuleListenerInvoker.prepare(ModuleListenerInvoker.java:199) 
    at weblogic.application.internal.flow.DeploymentCallbackFlow$1.next(DeploymentCallbackFlow.java:507) 
    at weblogic.application.utils.StateMachineDriver.nextState(StateMachineDriver.java:41) 
    at weblogic.application.internal.flow.DeploymentCallbackFlow.prepare(DeploymentCallbackFlow.java:149) 
    Truncated. see log file for complete stacktrace 

     Caused By: java.lang.IllegalArgumentException: No persistence unit named 'em' is available in scope test.jar. Available persistence units: [HR, FINANCE] 
    at weblogic.deployment.ModulePersistenceUnitRegistry.getPersistenceUnit(ModulePersistenceUnitRegistry.java:132) 
    at weblogic.deployment.BasePersistenceContextProxyImpl.<init>(BasePersistenceContextProxyImpl.java:38) 
    at weblogic.deployment.TransactionalEntityManagerProxyImpl.<init>(TransactionalEntityManagerProxyImpl.java:35) 
    at weblogic.deployment.BaseEnvironmentBuilder.createPersistenceContextProxy(BaseEnvironmentBuilder.java:974) 
    at weblogic.deployment.BaseEnvironmentBuilder.addPersistenceContextRefs(BaseEnvironmentBuilder.java:855) 
    Truncated. see log file for complete stacktrace 

錯誤是顯而易見的,沒有持久性單元爲EM是在persistence.xml中 可用,但我如何能實現使用JPA動態數據源的查找。 以下是我的代碼

會話Bean

package entity.library; 
import java.util.Collection; 
import javax.ejb.Stateless; 
import javax.persistence.EntityManager; 
import javax.persistence.EntityManagerFactory; 
import javax.persistence.Persistence; 
import javax.persistence.PersistenceContext; 
import javax.persistence.PersistenceUnit; 
import java.io.Serializable; 
import javax.ejb.*; 

@Remote(TestInterface.class) 
@Stateless(mappedName="ejb3/TestBeans") 

public class TestSessionBean implements Serializable, TestInterface 
{ 
protected TestJPA test; 
protected Collection <TestJPA> list; 

@PersistenceContext 
private EntityManager em; 
@PersistenceUnit 
private EntityManagerFactory emf; 


    public Collection <TestJPA> getAllList(String dataSourceString) { 

emf = Persistence.createEntityManagerFactory(dataSourceString); 
em = emf.createEntityManager(); 

list=em.createQuery("SELECT test FROM TestJPA test").getResultList(); 
    return list; 
    } 
    } 

的persistence.xml

<persistence version="1.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_1_0.xsd"> 

    <persistence-unit name="HR" transaction-type="JTA"> 
    <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider> 
    <jta-data-source>TESTDS</jta-data-source> 
    <non-jta-data-source>TESTDS</non-jta-data-source> 
    <properties> 
    <property name="eclipselink.target-server" value="WebLogic_10"/> 
    <property name="eclipselink.logging.level" value="FINEST"/> 
    </properties> 
    </persistence-unit> 

    <persistence-unit name="FINANCE" transaction-type="JTA"> 
    <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider> 
    <jta-data-source>TESTDS1</jta-data-source> 
    <non-jta-data-source>TESTDS1</non-jta-data-source> 
    <properties> 
    <property name="eclipselink.target-server" value="WebLogic_10"/> 
    <property name="eclipselink.logging.level" value="FINEST"/> 
    </properties> 
    </persistence-unit> 

    </persistence> 

回答

2

如果在persistence.xml中定義一個持久性單元,則默認單位申請&相同是通過註釋注入的。

您可以在運行時手動查找特定的持久化上下文。

javax.persistence.EntityManager entityManager = 
       (javax.persistence.EntityManager)initCtx.lookup(
        "java:comp/env/" + persistenceContext); 
0

更妙的是...

相反的: @PersistenceContext(NAME = 「myPU」)
私人EntityManager的EM;

指定:

@PeristenceContext(的unitName = 「myPU」)
私人EntityManager的EM;