Red Hat Application Migration Toolkit
package com.mpdmal.cloudental; import com.mpdmal.cloudental.entities.base.DBEntity; import com.mpdmal.cloudental.util.CloudentUtils; import com.mpdmal.cloudental.util.exception.ValidationException; import java.io.Serializable; import javax.annotation.PreDestroy; import javax.ejb.LocalBean; import javax.ejb.Stateless; import javax.inject.Named; import javax.persistence.EntityManager; import javax.persistence.NoResultException; import javax.persistence.PersistenceContext; import javax.persistence.Query; import javax.validation.ConstraintViolationException; @Stateless @LocalBean @Named public class EaoManager implements Serializable { private static final long serialVersionUID = 1L; @PersistenceContext protected EntityManager _em; public EntityManager getEM() { return this._em; } @PreDestroy public void closeEM() { this._em.close(); } public DBEntity findOrFail(Class clazz, Integer id) { DBEntity e = (DBEntity)this._em.find(clazz, id); return e == null?null:e; } public void update(DBEntity entity) { this._em.merge(entity); } public void persist(DBEntity entity) throws ValidationException { try { this._em.persist(entity); } catch (ConstraintViolationException var3) { throw CloudentUtils.createValidationException(var3); } } public void delete(DBEntity dbe) { this._em.remove(dbe); } public int executeSingleIntQuery(Query q) { try { return ((Integer)q.getSingleResult()).intValue(); } catch (NoResultException var3) { CloudentUtils.logQueryString(q); } catch (Exception var4) { var4.printStackTrace(); } return -1; } public long executeSingleLongQuery(Query q) { try { return ((Long)q.getSingleResult()).longValue(); } catch (NoResultException var3) { CloudentUtils.logQueryString(q); } catch (Exception var4) { var4.printStackTrace(); } return -1L; } public Object executeSingleObjectQuery(Query q) { try { return q.getSingleResult(); } catch (NoResultException var3) { CloudentUtils.logQueryString(q); } catch (Exception var4) { var4.printStackTrace(); } return null; } public Object executeMultipleObjectQuery(Query q) { try { return q.getResultList(); } catch (NoResultException var3) { CloudentUtils.logQueryString(q); } catch (Exception var4) { var4.printStackTrace(); } return null; } public int executeUpdateQuery(Query q) { try { return q.executeUpdate(); } catch (NoResultException var3) { CloudentUtils.logQueryString(q); } catch (Exception var4) { var4.printStackTrace(); } return -1; } }