Java/EJB3/Entity Embeddable

Entity With Embeddable Key

   <source lang="java">

File: EmployeePK.java import javax.persistence.Column; import javax.persistence.Embeddable; @Embeddable public class EmployeePK implements java.io.Serializable {

 private String lastName;
 private long ssn;
 public EmployeePK() {
 }
 public EmployeePK(String lastName, long ssn) {
   this.lastName = lastName;
   this.ssn = ssn;
 }
 @Column(name="CUSTOMER_LAST_NAME")
 public String getLastName() {
   return this.lastName;
 }
 public void setLastName(String lastName) {
   this.lastName = lastName;
 }
 @Column(name="CUSTOMER_SSN")
 public long getSsn() {
   return ssn;
 }
 public void setSsn(long ssn) {
   this.ssn = ssn;
 }
 public boolean equals(Object obj) {
   if (obj == this)
     return true;
   if (!(obj instanceof EmployeePK))
     return false;
   EmployeePK pk = (EmployeePK) obj;
   if (!lastName.equals(pk.lastName))
     return false;
   if (ssn != pk.ssn)
     return false;
   return true;
 }
 public int hashCode() {
   return lastName.hashCode() + (int) ssn;
 }

}

File: EmployeeService.java

import javax.ejb.Stateless; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; @Stateless public class EmployeeService implements EmployeeServiceLocal, EmployeeServiceRemote {

 @PersistenceContext(unitName="EmployeeService")
 EntityManager em;
 
 public EmployeeService() {
 }
 public void doAction(){
   EmployeePK pk = new EmployeePK("B", 9999999);
   Employee cust = new Employee();
   cust.setPk(pk);
   cust.setFirstName("B");  
   
   em.persist(cust);
   em.flush();
   System.out.println("saved");
   
 }

}

File: EmployeeServiceLocal.java

import java.util.Collection; import javax.ejb.Local; @Local public interface EmployeeServiceLocal {

   public void doAction();

}

File: EmployeeServiceRemote.java

import java.util.Collection; import javax.ejb.Remote; @Remote public interface EmployeeServiceRemote{

 public void doAction();  

}

File: Employee.java import java.io.Serializable; import javax.persistence.AttributeOverride; import javax.persistence.AttributeOverrides; import javax.persistence.Column; import javax.persistence.EmbeddedId; import javax.persistence.Entity; import javax.persistence.Table; import javax.persistence.Transient; @Entity @Table(name="EMP") public class Employee implements Serializable {

 private String firstName;
 private EmployeePK pk;
 public String getFirstName() { return firstName; }
 public void setFirstName(String firstName) { this.firstName = firstName; }
 @EmbeddedId
 @AttributeOverrides({
     @AttributeOverride(name="lastName", column=@Column(name="LAST_NAME")),
     @AttributeOverride(name="ssn", column=@Column(name="SSN"))
 })
 public EmployeePK getPk() { return pk; }
 public void setPk(EmployeePK pk) { this.pk = pk; }
 @Transient
 public String getLastName() { return pk.getLastName(); }
 @Transient
 public long getSsn() { return pk.getSsn(); }

}

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.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

      </source>
   
  
 
  

Entity With Embedded Attribute

   <source lang="java">

File: Employee.java import javax.persistence.AttributeOverride; import javax.persistence.AttributeOverrides; import javax.persistence.Column; import javax.persistence.Embedded; import javax.persistence.Entity; import javax.persistence.GeneratedValue; import javax.persistence.Id; @Entity public class Employee implements java.io.Serializable {

 private long id;
 private String firstName;
 private String lastName;
 private Address address;
 @Id
 @GeneratedValue
 public long getId() {
   return id;
 }
 public void setId(long id) {
   this.id = id;
 }
 public String getFirstName() {
   return firstName;
 }
 public void setFirstName(String first) {
   this.firstName = first;
 }
 public String getLastName() {
   return lastName;
 }
 public void setLastName(String last) {
   this.lastName = last;
 }
 @Embedded
 @AttributeOverrides( { @AttributeOverride(name = "street", column = @Column(name = "STREET")),
     @AttributeOverride(name = "city", column = @Column(name = "CITY")),
     @AttributeOverride(name = "state", column = @Column(name = "STATE")) })
 public Address getAddress() {
   return address;
 }
 public void setAddress(Address address) {
   this.address = address;
 }

}

File: EmployeeService.java

import javax.ejb.Stateless; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; @Stateless public class EmployeeService implements EmployeeServiceLocal, EmployeeServiceRemote {

 @PersistenceContext(unitName="EmployeeService")
 EntityManager em;
 
 public EmployeeService() {
 }
 public void doAction(){
   Employee cust = new Employee();
   cust.setFirstName("B");
   cust.setLastName("B");
   Address address = new Address();
   address.setStreet("Street");
   address.setCity("Boston");
   address.setState("MA");
   cust.setAddress(address);
   
   em.persist(cust);
   em.flush();
   System.out.println("saved");
   
 }

}

File: EmployeeServiceLocal.java

import java.util.Collection; import javax.ejb.Local; @Local public interface EmployeeServiceLocal {

   public void doAction();

}

File: EmployeeServiceRemote.java

import java.util.Collection; import javax.ejb.Remote; @Remote public interface EmployeeServiceRemote{

 public void doAction();  

}

File: Address.java

import javax.persistence.Column; import javax.persistence.Embeddable; @Embeddable public class Address implements java.io.Serializable {

  private String street;
  private String city;
  private String state;
  @Column(name="STREET")
  public String getStreet() { return street; }
  public void setStreet(String street) { this.street = street; }
  @Column(name="CITY")
  public String getCity() { return city; }
  public void setCity(String city) { this.city = city; }
  @Column(name="STATE")
  public String getState() { return state; }
  public void setState(String state) { this.state = state; }

}

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.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

      </source>
   
  
 
  

Mark Embedded Id

   <source lang="java">

File: EmployeePK.java import javax.persistence.Column; import javax.persistence.Embeddable; @Embeddable public class EmployeePK implements java.io.Serializable {

 private String lastName;
 private long ssn;
 public EmployeePK() {
 }
 public EmployeePK(String lastName, long ssn) {
   this.lastName = lastName;
   this.ssn = ssn;
 }
 @Column(name="CUSTOMER_LAST_NAME")
 public String getLastName() {
   return this.lastName;
 }
 public void setLastName(String lastName) {
   this.lastName = lastName;
 }
 @Column(name="CUSTOMER_SSN")
 public long getSsn() {
   return ssn;
 }
 public void setSsn(long ssn) {
   this.ssn = ssn;
 }
 public boolean equals(Object obj) {
   if (obj == this)
     return true;
   if (!(obj instanceof EmployeePK))
     return false;
   EmployeePK pk = (EmployeePK) obj;
   if (!lastName.equals(pk.lastName))
     return false;
   if (ssn != pk.ssn)
     return false;
   return true;
 }
 public int hashCode() {
   return lastName.hashCode() + (int) ssn;
 }

}

File: EmployeeService.java

import javax.ejb.Stateless; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; @Stateless public class EmployeeService implements EmployeeServiceLocal, EmployeeServiceRemote {

 @PersistenceContext(unitName="EmployeeService")
 EntityManager em;
 
 public EmployeeService() {
 }
 public void doAction(){
   EmployeePK pk = new EmployeePK("B", 9999999);
   Employee cust = new Employee();
   cust.setPk(pk);
   cust.setFirstName("B");  
   
   em.persist(cust);
   em.flush();
   System.out.println("saved");
   
 }

}

File: EmployeeServiceLocal.java

import java.util.Collection; import javax.ejb.Local; @Local public interface EmployeeServiceLocal {

   public void doAction();

}

File: EmployeeServiceRemote.java

import java.util.Collection; import javax.ejb.Remote; @Remote public interface EmployeeServiceRemote{

 public void doAction();  

}

File: Employee.java import java.io.Serializable; import javax.persistence.AttributeOverride; import javax.persistence.AttributeOverrides; import javax.persistence.Column; import javax.persistence.EmbeddedId; import javax.persistence.Entity; import javax.persistence.Table; import javax.persistence.Transient; @Entity @Table(name="EMP") public class Employee implements Serializable {

 private String firstName;
 private EmployeePK pk;
 public String getFirstName() { return firstName; }
 public void setFirstName(String firstName) { this.firstName = firstName; }
 @EmbeddedId
 @AttributeOverrides({
     @AttributeOverride(name="lastName", column=@Column(name="LAST_NAME")),
     @AttributeOverride(name="ssn", column=@Column(name="SSN"))
 })
 public EmployeePK getPk() { return pk; }
 public void setPk(EmployeePK pk) { this.pk = pk; }
 @Transient
 public String getLastName() { return pk.getLastName(); }
 @Transient
 public long getSsn() { return pk.getSsn(); }

}

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 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.doAction();
 }

}

      </source>