View Javadoc

1   package com.service.customer.ejb;
2   
3   import java.rmi.RemoteException;
4   import java.util.Collection;
5   import java.util.Iterator;
6   import java.util.List;
7   
8   import javax.persistence.PersistenceUnit;
9   import javax.ejb.EJBException;
10  import javax.ejb.Stateless;
11  import javax.naming.Context;
12  import javax.naming.InitialContext;
13  import javax.naming.NamingException;
14  import javax.persistence.EntityManager;
15  import javax.persistence.EntityManagerFactory;
16  
17  @Stateless
18  public class ProcessCustomerSessionBean implements ProcessCustomerSessionLocal {
19      @PersistenceUnit
20      protected EntityManagerFactory emf;
21  
22      public ProcessCustomerSessionBean() {
23      
24      }
25  
26      public List<Customer> findAllCustomers() {
27          EntityManager em = emf.createEntityManager();
28          String query = "SELECT * FROM customer";
29          List<Customer> customerList =
30              (List<Customer>)em.createNativeQuery(query, Customer.class).getResultList();
31          em.close();
32          return customerList;
33      }
34  
35      public Customer findCustomer(String key) {
36          EntityManager em = emf.createEntityManager();
37          String query = "SELECT * FROM customer WHERE id='"+key+"'";
38          List<Customer> customerList =
39              (List<Customer>)em.createNativeQuery(query, Customer.class).getResultList();
40          if(customerList.size() == 1) {
41              return (Customer)customerList.get(0);
42          } else {
43              return null;
44          }
45      }
46  }