Mega Code Archive

 
Categories / Java Tutorial / EJB3
 

Bean Managed Transaction

File: EmployeeBean.java import javax.annotation.Resource; import javax.ejb.EJBException; import javax.ejb.Stateless; import javax.ejb.TransactionManagement; import javax.ejb.TransactionManagementType; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; import javax.transaction.UserTransaction; @Stateless @TransactionManagement(TransactionManagementType.BEAN) public class EmployeeBean implements EmployeeServiceLocal, EmployeeServiceRemote {   @PersistenceContext(unitName = "EmployeeService")   private EntityManager manager;   @Resource UserTransaction tx;   public void doAction() {     try {       try {           tx.begin();           // do the work...           System.out.println("Processing...");       } finally {           tx.commit();       }   } catch (Exception e) {       // handle all the tx.begin()/commit() exceptions       throw new EJBException(e);   } } File: EmployeeServiceLocal.java import javax.ejb.Local; @Local public interface EmployeeServiceLocal {   public void doAction(); } File: EmployeeServiceRemote.java import javax.ejb.Remote; @Remote public interface EmployeeServiceRemote {   public void doAction(); } File: jndi.properties java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces java.naming.provider.url=localhost:1099 File: Main.java import javax.ejb.EJB; import javax.naming.InitialContext; public class Main {   public static void main(String[] a) throws Exception {     EmployeeServiceRemote service = null;     // Context compEnv = (Context) new InitialContext().lookup("java:comp/env");     // service = (HelloService)new     // InitialContext().lookup("java:comp/env/ejb/HelloService");     service = (EmployeeServiceRemote) new InitialContext().lookup("EmployeeBean/remote");     service.doAction();        } } File: Customer.java import javax.persistence.Entity; import javax.persistence.EntityListeners; import javax.persistence.Id; import javax.persistence.PostRemove; @Entity public class Customer implements java.io.Serializable {   private String firstName;   private String lastName;   @Id   private long ssn;   public String getFirstName() {     return firstName;   }   public void setFirstName(String firstName) {     this.firstName = firstName;   }   public String getLastName() {     return lastName;   }   public void setLastName(String lastName) {     this.lastName = lastName;   }   public long getSsn() {     return ssn;   }   public void setSsn(long ssn) {     this.ssn = ssn;   } }