Estou com um problema meio incomum, mas busco uma solução.
Tenho um cenário onde tenho várias bases de banco de dados(postgresql) alocadas em vários clientes, todas as bases tem a mesma estrutura, mas com registos diferentes.
Tenho uma aplicação em java com jpa
, ecliselink
e ejb 3
, já pronta e em funcionamento, hoje nela eu utilizo o EntityManager deixando o container gerenciar as transações para mim (CMT - Container Managed Transaction), então não preciso ficar dando begin e commit, ele resolve quando executar da melhor maneira.
Bom, tendo isso em mente, preciso continuar a utilizar essa estrutura e não posso mudar para o modo manual (BTM - Bean Managed Transaction), preciso continuar utilizando o CMT (por motivos maiores). Pesquisando e estudando bastante o conceito consegui realizar a funcionalidade de conectar em várias bases com JTA, só que dessa maneira não consegui que ela seja gerenciada pelo container(CMT), eu teria que dar o begin e commit. Vou postar o código que consegui realizar essa função, se alguém souber como deixar a transação como CMT seguindo essa base de raciocínio eu agradeceria.
O código abaixo funciona, mas não esta executando como CMT, só persiste se ter o begin e commit:
@Stateless
@TransactionManagement(TransactionManagementType.CONTAINER)
public class TestEntDAO {
private EntityManager em;
private EntityManagerFactory emf;
@PostConstruct
public void init() {
em = getEntityManager();
}
public EntityManager getEntityManager() {
Map props = new HashMap();
props.put(PersistenceUnitProperties.TRANSACTION_TYPE, "JTA");
props.put(PersistenceUnitProperties.JTA_DATASOURCE, dataSourceName()); // <- Aqui será injetado o cliente que está logado, pegando a base dele.
emf = Persistence.createEntityManagerFactory("testePU", props);
em = emf.createEntityManager();
return em;
}
public String dataSourceName(){
if(someCondition){
return "db1";
}else{
return "db2";
}
}
public salvar(Tabela tab){
em.persist(tab);
} //<-- quando termia esse método era para dar o commit automatico (CMT), mais não esta sincronizando as transações.
}
Alguém que entenda bem de JPA poderia me ajudar?
Observação: Se alguém falar para usar varios @PersistenceContext(unitName = "db1")
, não posso usar dessa maneira, por que se caso algum IP sair fora ou der problema em alguma base a aplicação não sobe, dando uma dor de cabeça, também já tentei utilizar o Multitenancy não se encaixou nesse caso.
@PersistenceContext(unitName = "db1")
. Se você precisa subir teu aplicativo mesmo com um servidor de banco de dados indisponível, talvez fosse melhor pesquisar por este recurso em vez de outra técnica de usar conexões com múltiplos servidores de bancos de dados. Qual servidor de aplicativos você usa? Talvez o próprio servidor de aplicativos disponibilize uma configuração para isso.