EJB3 + JPA - Propagando Transação

Olá meus jovens amigos, já é tarde e estou com um problema, gostaria de vossas opiniões! ahIUAHuiahIUAHuiahIUAh

Bom, vamos lá estou brincando aqui; construindo um brinquedo com as seguintes camadas Action -> BusinessDelegate -> SessionFacade(EJB3) -> ApplicationService -> BusinessObject -> DAO (JPA)

Porém não estou conseguindo persistir dados com um bean CMT e esta arquitetura.... consigo apenas se estiver persistindo no proprio CMT!!!!

Bean

o AS

ai vem o BO somente efetuando as chamadas e no DAO esta assim

so que no flush recebo um

javax.persistence.TransactionRequiredException: no transaction is in progress

Viram???

Somente estou conseguindo persistir por enquanto da seguinte forma

Outro método do mesmo Bean

poderia fazer o metodo com a anotação @TransactionManagement(TransactionManagementType.CONTAINER)

mas não importa...

Agora vejam o AS como ficou

onde AbstractApplicationService é

public abstract class AbstractApplicationService {

private static Logger logger = Logger.getLogger(AbstractApplicationService.class);

/**
	 * Atributo <code>manager</code> utilizado para gerenciar o EntityManager
	 * para transação.
	 */

private EntityManager manager;

/**
	 * Atributo <code>transaction</code> utilizado para gerenciar a transação
	 */
	private EntityTransaction transaction;

protected final void beginEntityManager() {
		logger.debug("Inicio " + this.getClass().getName() + ".beginEntityManager()");
		manager = PersistenceUtil.currentEntityManager();
		logger.debug("Fim " + this.getClass().getName() + ".beginEntityManager()");
	}

/**
	 * Iniciar uma Transação.
	 */
	protected final void beginTransaction() {
		logger.debug("Inicio " + this.getClass().getName() + ".beginTransaction()");
		transaction = PersistenceUtil.currentEntityManager().getTransaction();
		transaction.begin();
		logger.debug("Fim " + this.getClass().getName() + ".beginTransaction()");
	}

/**
	 * Commit de uma Transação.
	 */
	protected final void commitTransaction() {
		logger.debug("Inicio " + this.getClass().getName() + ".commitTransaction()");
		if (transaction.isActive()) {
			transaction.commit();
		} else {
			logger.debug(this.getClass().getName() + "Transaction não Ativa");
		}
		logger.debug("Fim " + this.getClass().getName() + ".commitTransaction()");
	}

/**
	 * Realizar rollback de uma Transação.
	 * 
	 * @param nomeMetodo
	 *            
	 */
	protected final void rollbackTransaction(final String nomeMetodo) {
		try {
			if (transaction.isActive()) {
				logger.debug(this.getClass().getName() + "." + nomeMetodo + "()  - rollbackTransaction");
				transaction.rollback();
			}
		} catch (final Throwable e) {
			logger.error(this.getClass().getName() + ".rollbackTransaction()");
		}
	}

protected final void closeSession() {
		logger.debug("Inicio " + this.getClass().getName() + ".closeSession()");
		try {
			PersistenceUtil.closeEntityManager();
		} catch (Exception e) {
			logger.error(this.getClass().getName() + ".closeSession()");
		} catch (Throwable e) {
			logger.error(this.getClass().getName() + ".closeSession()");
		} finally {
			logger.debug("Fim " + this.getClass().getName() + ".closeSession()");
		}

}

e a PersistenceUtil é

no meu dao agora tenho a mesma coisa de antes

pra completar a minha entity

@Entity
@Table(name="CLIENTE")
public class Cliente extends AbstractEntity {
	
	private Integer codigo;
	
	private String nome;
	
	private String sobrenome;
	
	private String rg;
	
	private String email;
	
	private String telefone;
	
	private String sexo;
	
	private Date data;

@Id
	@GeneratedValue
	@Column(name="CODIGO")
	public Integer getCodigo() {
		return codigo;
	}

public void setCodigo(Integer codigo) {
		this.codigo = codigo;
	}

public String getNome() {
		return nome;
	}

public void setNome(String nome) {
		this.nome = nome;
	}

public String getSobrenome() {
		return sobrenome;
	}

public void setSobrenome(String sobrenome) {
		this.sobrenome = sobrenome;
	}

public String getRg() {
		return rg;
	}

public void setRg(String rg) {
		this.rg = rg;
	}

public String getEmail() {
		return email;
	}

public void setEmail(String email) {
		this.email = email;
	}

public String getTelefone() {
		return telefone;
	}

public void setTelefone(String telefone) {
		this.telefone = telefone;
	}

public String getSexo() {
		return sexo;
	}

public void setSexo(String sexo) {
		this.sexo = sexo;
	}

@Temporal(TemporalType.TIME)
	public Date getData() {
		return data;
	}

public void setData(Date data) {
		this.data = data;
	}

@Override
	public int hashCode() {
		final int prime = 31;
		int result = 1;
		result = prime * result + ((codigo == null) ? 0 : codigo.hashCode());
		return result;
	}

@Override
	public boolean equals(Object obj) {
		if (this == obj)
			return true;
		if (obj == null)
			return false;
		if (getClass() != obj.getClass())
			return false;
		final Cliente other = (Cliente) obj;
		if (codigo == null) {
			if (other.codigo != null)
				return false;
		} else if (!codigo.equals(other.codigo))
			return false;
		return true;
	}

Deu pra entender?

Parece que a transação não é propagada no bean CMT, somente funciona com o BMT, porém assim preciso garantir a Atomicidade da transação na "mão".

Aindo to estudando e brincando com isso, amanhã continua, mas se alguem puder me ajudar... hehehehehehe

Fico grato pela ajuda.

JavaChild Membro desde: 26/03/2006 22:06:12 Mensagens: 100 Offline

nao posso ajudar, mas voce pode me ajudar

eu ia tirar esse fim de semana pra dar uma olhada exatamente nesses conceitos, se voce pudesser compartilhar este seu projetinho

Debugger Membro desde: 20/04/2006 10:32:12 Mensagens: 59 Offline

Maracuja wrote:

Parece que a transação não é propagada no bean CMT, somente funciona com o BMT, porém assim preciso garantir a Atomicidade da transação na "mão".

Olhando seu código da para perceber que você está controlando a gerência do EntityManager manualmente:

Eu ainda não dei uma olhada profunda na especificação do EJB3, mas acho que não mudou neste aspecto para a especificação do EJB 2.1. Ou seja, se deseja que o Transaction Manager controle toda a transação, tem que garantir que todos os seus provedores de serviços podem ser anexados ao JTA. Pode ser que a definição manual possa estar atrapalhando a mesma.

Uma pergunta, não conheço seu projeto mas haveria algum problema se alterrase seu DAO para um Session Bean Stataless e ussase a atribuição do PersistenteContexte por injeção de dependência pelo container assim:

Dai chamaria seu DAO também por Injecção de dependência assim:

Espero que lhe ajude em algo!

Então, é justamente o que estou dizendo, controlando a transação na "mão" em um bean BMT funciona numa boa, o problema é mesmo com o CMT.

Existem dois casos.

Bean BMT com controle de transação feito na mão que eu ja fiz e funciona numa boa.

Bean CMT, sem fazer o controle transacional na mão, ao tentar pesistir, ocorre o erro.

Concerteza, entre minhas brincadeiras ja fiz e funciona perfeitamente se eu injtar o EntityManager no meu Bean, ou até usar no meu DAO um outro
bean... a questão é que queria entender melhor esta situação específica!!!!

Mesmo que eu fizesse isso

ocorre o mesmo erro... pq neste momento parece não haver uma transação em andamento....

GUJ Ranger Membro desde: 02/06/2005 16:28:38 Mensagens: 939 Offline

Maracuja wrote:

Concerteza, entre minhas brincadeiras ja fiz e funciona perfeitamente se eu injtar o EntityManager no meu Bean, ou até usar no meu DAO um outro
bean... a questão é que queria entender melhor esta situação específica!!!!

A questão é: pq vc precisa dessa situação específica, se o AS já injeta o EntityManager para vc!? Ou seja, qual a vantagem dessa abordagem!?

Eu queria que o Container gerencia-se a transação para mim; porém mantendo esta arquitetura....

GUJ Ranger Membro desde: 02/06/2005 16:28:38 Mensagens: 939 Offline

Sim, e qual a vantagem dessa abordagem?

Maracuja wrote:

public void salvar(Cliente cliente) throws DAOException { logger.debug("Entrou ClienteDAOJPA"); EntityManager manager = null; try{ manager = Persistence.createEntityManagerFactory(UNIT_NAME).createEntityManager(); manager.persist(cliente); manager.flush(); }catch(Exception e){ throw new DAOException("Erro salvar Cliente"); } }

Não é mais fácil injetar o EntityManager?

Talvez, se conseguisse injetar aí o EntityManager, mas só consigo injetar isso no meu EJB!!!!

Tentei injetar no DAO, mas recebi um null. Injetando no EJB funciona na boa.

Porém acredito que mesmo que eu injetasse o entity manager, perigava eu ainda receber um

Acho que vou tranformar meus DAO's em EJB's tb e td será resolvido. eu não queria.... bom ainda to avaliando novas abordagens...

GUJ Ranger Membro desde: 02/06/2005 16:28:38 Mensagens: 939 Offline

Maracuja wrote:

Acho que vou tranformar meus DAO's em EJB's tb e td será resolvido. eu não queria.... bom ainda to avaliando novas abordagens...

Mas é isso mesmo, dê uma olhada...

http://www.hibernate.org/328.html

Thread.start() Membro desde: 02/08/2007 09:50:01 Mensagens: 34 Offline

Boa noite Maracuja,

estou participando de um projeto onde desenhamos essa mesma arquitetura de camadas e estamos enfrentando o mesmo problema em relacao a transacao gerenciada pelo container. Voce chegou a alguma conclusao sobre isso? Como propagar a transacao a partir de um session bean(delegate) ate a camada DAO(POJO)?

Obrigado,
Marco.

Bom, cheguei a conclusão que não tem jeito... se vc quiser utilizar uma transação CMT com esta arquitetura vc teria que utilizar um EntityManager injetado pelo container e seta-lo na ThreadLocal de um PersistenceUtil (sic) !!!!!

Só fazendo gambiarra!!!!

na real.... só ... como sugerido pelo Taz

http://www.hibernate.org/328.html

Writing DAOs as managed EJB 3.0 components

Thread.start() Membro desde: 02/08/2007 09:50:01 Mensagens: 34 Offline

Maracuja,

obrigado pelo pronta resposta. Isso e decepcionante, mas vou dar uma olhada com calma no site indicado.

Abracos,
Marco.

Thread.start() Membro desde: 28/12/2006 11:02:18 Mensagens: 41 Offline

Olá a todos....
Tenho uma aplicação EJB3 rodando dentro do Jboss4.0.5GA, onde estou numa situação assim: minha aplicação tem uma rotina que salva um registro numa tabela de um outro banco através de um DBLINK, e nessa tabela tem um trigger que que ao cair registro lê o mesmo. Mas o problema é que quando eu do um flush() na aplicação para salvar o registro é ativada a trigger onde da um erro na trigger e acaba retornando uma excessão para o jboss quebrando toda a sessão dele, assim não cosigo remover esse registro que está dando erro e a aplicação entra num loop infinito. Como faço para capturar essa excessão sem quebrar as transações do jboss? Alguém poderia me ajudar? Lembrando que a trigger nós aqui não mexemos, e o cliente não quer alterar para corrigir esse erro.

Maracuja wrote:Bom, cheguei a conclusão que não tem jeito... se vc quiser utilizar uma transação CMT com esta arquitetura vc teria que utilizar um EntityManager injetado pelo container e seta-lo na ThreadLocal de um PersistenceUtil (sic) !!!!!

Só fazendo gambiarra!!!!

na real.... só ... como sugerido pelo Taz

http://www.hibernate.org/328.html

Writing DAOs as managed EJB 3.0 components

Exato. Estamos usando uma arquitetura parecida aqui... utilizando DAOS como EJBs. Fica estranho mesmo a arquitetura. E até chego a perguntar: Até aonde vale a pena utilizar DAO numa arquitetura dessas?

Galera, olhando este post vejo que tem algo a ver com a questão que estou enfrentando.
No meu caso, todos os objetos envolvidos são EJBs.... Tenho um EJB Statefull que chama vários EJBs Stateless, e gostaria que as transações fossem iniciadas e finalizadas no Stateful... ou seja, as transações deveriam ser propagadas para os Stateless.
Estava fazendo com injeção de dependência e tudo estava beleza, mas um requisito da aplicação me força a mudar parâmetros do EntityManager em tempo de execução, para pegar conexões de acordo com o usuário logado (cada usuário do sistema tem um usuário paralelo no banco).
Desta forma, preciso pegar minhas referências de EntityManager da seguinte forma:

onde props é um Map com as propriedades que tenho que passar para o EntityManager.

dessa forma, preciso criar a transação com entityManager.getTransaction().begin;

a questão é como propagá-la para os demais EJB sem estado.

alguma sugestão?

[]'s

Notícias, artigos e o maior fórum brasileiro sobre Java