Java/EJB3/Entity Persist

Persist Enum

File: Employee.java
import java.io.Serializable;
import java.util.Date;
import javax.persistence.Basic;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.EnumType;
import javax.persistence.Enumerated;
import javax.persistence.FetchType;
import javax.persistence.Id;
import javax.persistence.Lob;
import javax.persistence.Table;
import javax.persistence.Temporal;
import javax.persistence.TemporalType;
@Entity
//@Table(name="EMP", schema="HR")
@Table(name="EMP")
public class Employee implements Serializable {
  @Id
  @Column(name = "EMP_ID")
  private int id;
  @Column(name = "COMM")
  private String name;
  @Column(name = "SAL")
  private long salary;
  private CustomerType customerType;
  private Date timeCreated = new Date();
  private MyImage picture;
  
  public Employee() {
  }
  public Employee(int id) {
    this.id = id;
  }
  public int getId() {
    return id;
  }
  public void setId(int id) {
    this.id = id;
  }
  public String getName() {
    return name;
  }
  public void setName(String name) {
    this.name = name;
  }
  public long getSalary() {
    return salary;
  }
  public void setSalary(long salary) {
    this.salary = salary;
  }
  @Enumerated(EnumType.STRING)
  public CustomerType getCustomerType() { return customerType; }
  public void setCustomerType(CustomerType type) { customerType = type; }
  @Temporal(TemporalType.TIME)
  public Date getTimeCreated() { return timeCreated; }
  public void setTimeCreated(Date time) { timeCreated = time; }
  @Lob @Basic(fetch=FetchType.LAZY)
  public MyImage getPicture() { return picture; }
  public void setPicture(MyImage jpeg) { picture = jpeg; }
  public String toString() {
    return "Employee id: " + getId() + " name: " + getName() + " salary: " + getSalary();
  }
}

File: EmployeeService.java

import java.util.Collection;
import javax.ejb.Remove;
import javax.ejb.Stateless;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.Query;
@Stateless
public class EmployeeService implements EmployeeServiceLocal, EmployeeServiceRemote {
  @PersistenceContext(unitName="EmployeeService")
  EntityManager em;
  
  public EmployeeService() {
  }
  public Employee createEmployee(Employee emp) {
    em.persist(emp);
    em.flush();
    return emp;
  }
  public Employee createEmployee(int id, String name, long salary) {
    Employee emp = new Employee(id);
    emp.setName(name);
    emp.setSalary(salary);
    
    em.persist(emp);
    em.flush();
    return emp;
  }
  public void removeEmployee(int id) {
    Employee emp = findEmployee(id);
    if (emp != null) {
      em.remove(emp);
    }
  }
  public Employee raiseEmployeeSalary(int id, long raise) {
    Employee emp = em.find(Employee.class, id);
    if (emp != null) {
      emp.setSalary(emp.getSalary() + raise);
    }
    return emp;
  }
  public Employee findEmployee(int id) {
    return em.find(Employee.class, id);
  }
  public Collection<Employee> findAllEmployees() {
    Query query = em.createQuery("SELECT e FROM Employee e");
    return (Collection<Employee>) query.getResultList();
  }
  
  public void doAction(){
  }
  @Remove
  public void remove()
  {
    System.out.println("removed");
  }
}
    

File: EmployeeServiceLocal.java

import java.util.Collection;
import javax.ejb.Local;
@Local
public interface EmployeeServiceLocal {
    public void doAction();
    public Employee createEmployee(int id, String name, long salary) ;
    public Employee createEmployee(Employee emp) ;
    public void removeEmployee(int id);
    public Employee raiseEmployeeSalary(int id, long raise) ;
    public Employee findEmployee(int id);
    public Collection<Employee> findAllEmployees() ;
}

File: EmployeeServiceRemote.java


import java.util.Collection;
import javax.ejb.Remote;
@Remote
public interface EmployeeServiceRemote{
  public void doAction();  
  public Employee createEmployee(int id, String name, long salary) ;
  public Employee createEmployee(Employee emp) ;
  public void removeEmployee(int id);
  public Employee raiseEmployeeSalary(int id, long raise) ;
  public Employee findEmployee(int id);
  public Collection<Employee> findAllEmployees() ;  
}

File: MyImage.java
public class MyImage implements java.io.Serializable
{
   public MyImage() {}
}

File: CustomerType.java

public enum CustomerType
{
   UNREGISTERED,
   REGISTERED,
   BIG_SPENDAH
}
   

File: Main.java
import java.util.Collection;
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("EmployeeService/remote");
    
    
    
    service.createEmployee(158, "AAA", 45000);
    service.createEmployee(159, "AAA", 45000);
    
    Employee emp = new Employee();
    emp.setId(160);
    emp.setCustomerType(CustomerType.BIG_SPENDAH);
    MyImage oneUglyDude = new MyImage();
    emp.setPicture(oneUglyDude);
    
    service.createEmployee(emp);
    Employee emp1 = service.findEmployee(160);
    System.out.println(emp1);
    
    Collection<Employee> list = service.findAllEmployees();
    
    System.out.println(list);
  }
}

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