EJB 3 Persistence in a remote Stateless Session Beans

[Daniel Jabonete]

Greetings!

I am having some problem in inserting some records in MySQL 5 database using EJB 3 Stateless SessionBean with the EntityManager injected in it.

persistence.xml

<?xml version="1.0" encoding="UTF-8"?>
<persistence xmlns="http://java.sun.com/xml/ns/persistence" version="1.0">
    <persistence-unit name="Ejb3BizComp">
        <provider>oracle.toplink.essentials.ejb.cmp3.EntityManagerFactoryProvider</provider>
        <!-- All persistence classes must be listed -->
        <exclude-unlisted-classes>false</exclude-unlisted-classes>
        <properties>
            <!-- Provider-specific connection properties -->
            <property name="toplink.jdbc.driver" value="com.mysql.jdbc.Driver"/>
            <property name="toplink.jdbc.url" value="jdbc:mysql://localhost:2608/Ejb3BizComp"/>
            <property name="toplink.jdbc.user" value="glassfish"/>
            <property name="toplink.jdbc.password" value="glassfish"/>
            <!-- Provider-specific settings -->
            <property name="toplink.logging.level" value="INFO"/>
            <property name="toplink.ddl-generation" value="create-tables"/>
        </properties>
    </persistence-unit>
</persistence>

EmployeeBeanImpl.java

@Stateless(name = "EmployeeBeanImpl", mappedName = "ejb/EmployeeBeanJNDI")
public class EmployeeBeanImpl implements EmployeeBean {

	@PersistenceContext(unitName = "Ejb3StrutsBizComp")
	EntityManager em;

	private static List employees;
	
	public EmployeeBeanImpl() {}

	public List getAllEmployees() {
		System.out.println("em.isOpen() = " + em.isOpen());
		em.getTransaction().begin();
		Query q = em.createQuery("select e from Employee e");
		em.getTransaction().commit();
		employees = q.getResultList();
		if (employees == null) {
			employees = new ArrayList<Employee>();
		}
		System.out.println("employees " + employees.size());
		return employees;
	}

	public void insert(Employee emp) {
		System.out.println("EmployeeBeanImpl insert emp 111 = " + emp.toString());
		try {
			em.getTransaction().begin();
			System.out.println("EmployeeBeanImpl insert emp 222 = " + emp.toString());
			em.persist(emp);
			em.getTransaction().commit();
		} catch (Exception e) {
			System.err.println("Error from insert : "  + e.getMessage() + " " + e.getCause().getStackTrace().toString());
			e.printStackTrace();
		}
	}

	public void delete(Integer id) {
		em.remove(this.getEmployee(id));
	}
}

Test1.java

public class Test1 {

	private static EmployeeBean dao;

	public void runTest() throws Exception {
		Properties props = new Properties();
		props.setProperty("java.naming.factory.initial",
				"com.sun.enterprise.naming.SerialInitContextFactory");
		props.setProperty("java.naming.factory.url.pkgs",
				"com.sun.enterprise.naming");
		props.setProperty("java.naming.factory.state",
				"com.sun.corba.ee.impl.presentation.rmi.JNDIStateFactoryImpl");
		props.setProperty("org.omg.CORBA.ORBInitialHost", "10.186.249.46");
		props.setProperty("org.omg.CORBA.ORBInitialPort", "3701");

		InitialContext ctx;
		try {
			ctx = new InitialContext(props);
			dao = (EmployeeBean) ctx.lookup("ejb/EmployeeBeanJNDI");
			System.out.println("dao is " + dao.getAllEmployees().size());
		} catch (NamingException e) {
			System.err.println("runTest method : " );
			e.printStackTrace();
		}
	}// runTest...

	public static void main(String[] args) {
		try {
			Test1 cli = new Test1();
			cli.runTest();
			
			Employee emp1 = new Employee();
			emp1.setAge(26);
			emp1.setFirstName("Daniel");
			emp1.setLastName("Jabonete");
			dao.insert(emp1);

		} catch (Exception e) {
			System.err.println("Test1 main method : " );
			e.printStackTrace();
		}
	}// main method...
}

When I’d ran the Test1.java it returns the following error below:

[color=red]Test1 main method : 
javax.ejb.EJBException: nested exception is: java.rmi.ServerException: RemoteException occurred in server thread; nested exception is: 
	java.rmi.RemoteException: null; nested exception is: 
	java.lang.IllegalStateException: 
Exception Description: Cannot use an EntityTransaction while using JTA.
java.rmi.ServerException: RemoteException occurred in server thread; nested exception is: 
	java.rmi.RemoteException: null; nested exception is: 
	java.lang.IllegalStateException: 
Exception Description: Cannot use an EntityTransaction while using JTA.
	at com.sun.corba.ee.impl.javax.rmi.CORBA.Util.mapSystemException(Util.java:243)
	at com.sun.corba.ee.impl.presentation.rmi.StubInvocationHandlerImpl.privateInvoke(StubInvocationHandlerImpl.java:205)
	at com.sun.corba.ee.impl.presentation.rmi.StubInvocationHandlerImpl.invoke(StubInvocationHandlerImpl.java:152)
	at com.sun.corba.ee.impl.presentation.rmi.bcel.BCELStubBase.invoke(BCELStubBase.java:225)
	at bizcomp.services.employee.__EmployeeBean_Remote_DynamicStub.getAllEmployees(bizcomp/services/employee/__EmployeeBean_Remote_DynamicStub.java)
	at bizcomp.services.employee._EmployeeBean_Wrapper.getAllEmployees(bizcomp/services/employee/_EmployeeBean_Wrapper.java)
	at tests.ejbs.models.Test1.runTest(Test1.java:34)
	at tests.ejbs.models.Test1.main(Test1.java:44)
Caused by: java.rmi.RemoteException: null; nested exception is: 
	java.lang.IllegalStateException: 
Exception Description: Cannot use an EntityTransaction while using JTA.
	at com.sun.enterprise.iiop.POAProtocolMgr.mapException(POAProtocolMgr.java:251)
	at com.sun.ejb.containers.BaseContainer.postInvoke(BaseContainer.java:1411)
	at com.sun.ejb.containers.BaseContainer.postInvoke(BaseContainer.java:1316)
	at com.sun.ejb.containers.EJBObjectInvocationHandler.invoke(EJBObjectInvocationHandler.java:210)
	at com.sun.ejb.containers.EJBObjectInvocationHandlerDelegate.invoke(EJBObjectInvocationHandlerDelegate.java:117)
	at $Proxy35.getAllEmployees(Unknown Source)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at com.sun.corba.ee.impl.presentation.rmi.ReflectiveTie._invoke(ReflectiveTie.java:154)
	at com.sun.corba.ee.impl.protocol.CorbaServerRequestDispatcherImpl.dispatchToServant(CorbaServerRequestDispatcherImpl.java:687)
	at com.sun.corba.ee.impl.protocol.CorbaServerRequestDispatcherImpl.dispatch(CorbaServerRequestDispatcherImpl.java:227)
	at com.sun.corba.ee.impl.protocol.CorbaMessageMediatorImpl.handleRequestRequest(CorbaMessageMediatorImpl.java:1846)
	at com.sun.corba.ee.impl.protocol.CorbaMessageMediatorImpl.handleRequest(CorbaMessageMediatorImpl.java:1706)
	at com.sun.corba.ee.impl.protocol.CorbaMessageMediatorImpl.handleInput(CorbaMessageMediatorImpl.java:1088)
	at com.sun.corba.ee.impl.protocol.giopmsgheaders.RequestMessage_1_2.callback(RequestMessage_1_2.java:223)
	at com.sun.corba.ee.impl.protocol.CorbaMessageMediatorImpl.handleRequest(CorbaMessageMediatorImpl.java:806)
	at com.sun.corba.ee.impl.protocol.CorbaMessageMediatorImpl.dispatch(CorbaMessageMediatorImpl.java:563)
	at com.sun.corba.ee.impl.protocol.CorbaMessageMediatorImpl.doWork(CorbaMessageMediatorImpl.java:2567)
	at com.sun.corba.ee.impl.orbutil.threadpool.ThreadPoolImpl$WorkerThread.run(ThreadPoolImpl.java:555)
Caused by: java.lang.IllegalStateException: 
Exception Description: Cannot use an EntityTransaction while using JTA.
	at oracle.toplink.essentials.internal.ejb.cmp3.transaction.JTATransactionWrapper.getTransaction(JTATransactionWrapper.java:66)
	at oracle.toplink.essentials.internal.ejb.cmp3.EntityManagerImpl.getTransaction(EntityManagerImpl.java:340)
	at com.sun.enterprise.util.EntityManagerWrapper.getTransaction(EntityManagerWrapper.java:1094)
	at bizcomp.services.employee.EmployeeBeanImpl.getAllEmployees(EmployeeBeanImpl.java:30)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at com.sun.enterprise.security.application.EJBSecurityManager.runMethod(EJBSecurityManager.java:1011)
	at com.sun.enterprise.security.SecurityUtil.invoke(SecurityUtil.java:175)
	at com.sun.ejb.containers.BaseContainer.invokeTargetBeanMethod(BaseContainer.java:2920)
	at com.sun.ejb.containers.BaseContainer.intercept(BaseContainer.java:4011)
	at com.sun.ejb.containers.EJBObjectInvocationHandler.invoke(EJBObjectInvocationHandler.java:203)
	... 17 more
javax.ejb.EJBException: nested exception is: java.rmi.ServerException: RemoteException occurred in server thread; nested exception is: 
	java.rmi.RemoteException: null; nested exception is: 
	java.lang.IllegalStateException: 
Exception Description: Cannot use an EntityTransaction while using JTA.
	at bizcomp.services.employee._EmployeeBean_Wrapper.getAllEmployees(bizcomp/services/employee/_EmployeeBean_Wrapper.java)
	at tests.ejbs.models.Test1.runTest(Test1.java:34)
	at tests.ejbs.models.Test1.main(Test1.java:44)[/color]

My suspected problem were on the EntityManager, but not perfectly sure about that, and how to persist an entity in a session beans.

Hoping for your help with regards to the stated problems.

Thanks very much. I really appreciated your time.

Cheers!

[bhupesh ravish]

em.getTransaction().commit();

Try removing this line. I feel it should not be there n may be it is creating the problem.

[Leonardo Carreira]

@Daniel Jabonete

sir.. may i know your EJB Container?..

Thanks in advance..

[Daniel Jabonete]

hi guyz,

got it solved.

i am using glassfish, what i did was changed the set-up configuration in Resources> JDBC> JDBC Resources JNDI Name: jdbc/__default to the database schema defined in my pointing persistence.xml file.

thou, i am not sure 'yet in the case if my application would like to access multiple database schemas at the same time.

thanks very much!

cheers!