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 }