Nome unità di persistenza dinamica JPA

Question

Ho bisogno di un modo per specificare dinamicamente l'unità di persistenza in un EJB.

esempio semplificato:

Ho un'applicazione che utilizza più database come archivi di dati. Ciascuno degli archivi dati è strutturalmente uguale. A seconda del client che si connette all'applicazione ho bisogno di accedere ai dati da un archivio dati specifico.

Pertanto, vorrei utilizzare lo stesso EJB in modo che la logica aziendale non sia duplicata, , ma è sufficiente selezionare l'unità di persistenza corretta in base al client.

Fino a questo punto ho solo iniettato direttamente il gestore di entità con il nome dell'unità di persistenza codificato. Esiste un modo per iniettare dinamicamente il gestore di entità con l'unità di persistenza richiesta collegata all'EJB? Inoltre, le unità di persistenza possono essere aggiunte dinamicamente durante il runtime? Attualmente devo specificare l'unità di persistenza nel file persistence.xml. Idealmente mi piacerebbe creare pool sul server jdbc/db1, jdbc/db2 etc come richiesto mentre il sistema è in esecuzione. Quindi aggiungili al database del client centrale e collegalo a un client, in modo che quando il client si connette, controllerà il nome del pool e lo userà quando chiamerà l'EJB per ottenere l'unità di persistenza.

Sono ancora molto nuovo nello sviluppo di Java EE. Qualsiasi aiuto sarebbe molto apprezzato.

Answer 1

Nella versione JPA corrente, sfortunatamente non è possibile creare unità di persistenza in modo dinamico. Se questa funzionalità è importante per voi, si potrebbe prendere in considerazione la creazione di un problema di JIRA per essa al JPA issue tracker: http://java.net/jira/browse/JPA_SPEC

Utilizzando la @PersistenceContext annotazione, non è anche possibile selezionare dinamicamente un'unità di persistenza specifica. Questo è in realtà il dominio di sharding, che Hibernate ha provato una volta ad affrontare ma poi improvvisamente interrotto. Vedi http://www.hibernate.org/subprojects/shards.html

Ci sono comunque alcune cose che potresti fare per ottenere un effetto simile.

Un approccio consiste nel creare un bean factory EJB/CDI stateless, da iniettare con tutti i gestori di entità. Il costo di questo è marginale, dal momento che tali bean saranno raggruppati e i gestori di entità non sono così costosi da creare in primo luogo.

Se si desidera iniettarli in base a qualche condizione, questa condizione dovrà essere disponibile dal contesto o deve essere specificata nel punto di iniezione (ma se lo si farebbe, si potrebbe anche iniettare il giusto gestore di entità direttamente).

Un esempio di kickoff:

@Stateless 
@TransactionAttribute(SUPPORTS) 
public class ShardingEntityManagerFactory { 

    @Resource 
    private SessionContext sessionContext; 

    @PersistenceContext(unitName = "pu1") 
    private EntityManager entityManager1; 

    @PersistenceContext(unitName = "pu2") 
    private EntityManager entityManager2; 

    @Produces @TransactionScoped @ShardedPersistenceContext 
    public EntityManager getEntityManager() { 
     if (sessionContext.isCallerInRole("FOO")) { 
      return entityManager1; 
     } else { 
      return entityManager2; 
     } 
    } 
} 

E poi nel vostro fagioli:

@Stateless 
public class SomeBean { 

    @Inject @ShardedPersistenceContext 
    private EntityManager entityManager; 

    // ... 
} 

Nota che si avrebbe bisogno Seam Persistenza qui per la @TransactionScoped annotazione. Potrebbe anche essere più semplice, ma un po 'più prolisso, dimenticare di iniettare il gestore di entità in modo trasparente e iniettare lo ShardingEntityManagerFactory invece e ottenere quello giusto da esso manualmente.

Answer 2

Questo probabilmente non è di alcun aiuto per risolvere il problema, ma come si può sapere che questo tipo di problemi è in discussione per l'attuazione del JPA 2.1

Questo suona come uno di quei casi di multi-tenancy:

Proposal for Multitenancy Support in JPA 2.1 JSR-338

Answer 3

Solo un'idea, non è sicuro se ti aiuto: si può aprire un inputStream di leggere il file persistence.xml e sostituire queste righe:

<property name="javax.persistence.jdbc.url" value="jdbc:mysql://localhost:3306/agendasccv2?zeroDateTimeBehavior=convertToNull"/> 
<property name="javax.persistence.jdbc.password" value="btxbtxbtx"/> 
<property name="javax.persistence.jdbc.driver" value="com.mysql.jdbc.Driver"/> 
<property name="javax.persistence.jdbc.user" value="root"/> 

Poi splash Uno schermo di configurazione di connessione in cui l'utente accede al sistema, e impostare la connessione in base ai privilegi utente su quel file, quindi avviare l'applicazione principale

Non sono sicuro se questo aiuterà, è solo e idea. Dipende dall'applicazione e dalla logica aziendale.

Answer 4

È possibile utilizzare la stessa unità di persistenza per questo. È sufficiente fornire una proprietà Map quando si chiama createEntityManagerFactory() con l'url/datasource che si desidera utilizzare.