Добавление модуля сохранения в JNDI для модулей EJB

Question

Я работаю над простым модулем EJB, используя пример кода. Я пытаюсь реализовать операции CURD через веб-сервис SOAP. У меня есть единица постоянства, определенная в persistence.xml.

Вот код для моей реализации. Проблема в том, что я не могу создать экземпляр PersistenceService, потому что имя единицы сохраняемости отсутствует в списках JNDI.

Если вместо внедрения кода я использую

EntityManagerFactory emf = Persistence.createEntityManagerFactory(PU_NAME);
em = emf.createEntityManager();

код выполняется, но затем транзакция управляется контейнером. Я читал некоторые учебные пособия, и они упоминали, что в этом случае, если пользователь хочет откатить транзакцию позже, он не может этого сделать.

Что я могу сделать вместо этого?

класс пользователей

@WebService()
@Stateless()
public class users {
public users()
{

}

/**
 * Web service operation
 */
@WebMethod(operationName = "addUser")
public Integer addUser(
        @WebParam(name = "UserName") final String UserName,
        @WebParam(name = "LastName") final String LastName) {

        DatabaseEntityManager dem = new DatabaseEntityManager();
        Integer result = null;
        try
        {
        result = dem.addUser(UserName, LastName, false);
        dem.commitTx();
        return result;
        } catch(Exception E)
        {
        }
 return new Integer(-1);
 }

Класс DatabaseEntityManager

public class DatabaseEntityManager {
    PersistenceService ps_bck = null;
    public DatabaseEntityManager()
    {

    }

    public SiteUsers addUser(
        String Username,
        String LastName, boolean commit) throws Exception
    {
        AppUser appUser = new appUser(UserName, LastName);
        //AppUser is an entity class 

        PersistenceService ps = PersistenceService.getInstance();
        try
        {
            ps.beginTx();
            EntityManager em = ps.getEntityManager();
            em.persist(appUser);
            if (commit)
                ps.commitTx();
            else
                ps_bck  = ps;
        }
        catch (Exception E)
        {
            ps.rollbackTx();
        }
        finally
        {
            ps.close();
        }

        return appUser.getId();
    }

    void commitTx() throws Exception
    {
        try
        { 
            ps_bck.commitTx();
        }
        catch(Exception E)
        {
            throw E;
        }
        finally
        {
            ps_bck =null;
        }
    }
}

Класс PersistenceService - заимствовано из примера кода, сгенерированного NetBeans

public class PersistenceService {
    private static String DEFAULT_PU = "pers-ejbPU";

    private static ThreadLocal<PersistenceService> instance = new ThreadLocal<PersistenceService>() {
        @Override
        protected PersistenceService initialValue() {
            return new PersistenceService();
        }
    };

    private EntityManager em;
    private UserTransaction utx;

    private PersistenceService() {
        try {
            //This code runs 
            // EntityManagerFactory emf = ersistence.createEntityManagerFactory(DEFAULT_PU);
            // em = emf.createEntityManager();

            //This code throws an exception
            this.em = (EntityManager) new InitialContext().lookup("java:comp/env/persistence/"+ DEFAULT_PU);
            this.utx = (UserTransaction) new InitialContext().lookup("java:comp/UserTransaction");
        } catch (NamingException ex) {
            throw new RuntimeException(ex);
        }
    }

    /**
     * Returns an instance of PersistenceService.
     *
     * @return an instance of PersistenceService
     */
    public static PersistenceService getInstance() {
        return instance.get();
    }

    private static void removeInstance() {
        instance.remove();
    }

    /**
     * Returns an instance of EntityManager.
     *
     * @return an instance of EntityManager
     */
    public EntityManager getEntityManager() {
        return em;
    }

    /**
     * Begins a resource transaction.
     */
    public void beginTx() {
        try {
            utx.begin();
            em.joinTransaction();
        } catch (Exception ex) {
            throw new RuntimeException(ex);
        }
    }

    /**
     * Commits a resource transaction.
     */
    public void commitTx() {
        try {
            utx.commit();
        } catch (Exception ex) {
            throw new RuntimeException(ex);
        }
    }

    /**
     * Rolls back a resource transaction.
     */
    public void rollbackTx() {
        try {
            utx.rollback();
        } catch (Exception ex) {
            throw new RuntimeException(ex);
        }
    }

    /**
     * Closes this instance.
     */
    public void close() {
        removeInstance();
    }
}

Answer 1

Если в вашем файле persistence.xml есть запись

 <persistence-unit name="PU_NAME" transaction-type="JTA">

В вашем классе PersistenceService добавьте аннотацию:

@PersistenceContext (name = "PU_NAME") private EntityManager em;