Java/EJB3/Entity Blob

EJB Tutorial from JBoss: Entity with Blob data

   <source lang="java">

File: BlobEntity.java /*

* JBoss, Home of Professional Open Source.
* Copyright 2006, Red Hat Middleware LLC, and individual contributors
* as indicated by the @author tags. See the copyright.txt file in the
* distribution for a full listing of individual contributors.
*
* This is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This software is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this software; if not, write to the Free
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/

package org.jboss.tutorial.blob.bean; import java.io.Serializable; import java.sql.Blob; import java.sql.Clob; import javax.persistence.Basic; import javax.persistence.Entity; import javax.persistence.FetchType; import javax.persistence.GeneratedValue; import javax.persistence.GenerationType; import javax.persistence.Id; import javax.persistence.Lob; /**

* Comment
*
* @author 

Save Binary Data Through Ejb

   <source lang="java">

File: CustomerType.java

public enum CustomerType {

  UNREGISTERED,
  REGISTERED,
  BIG_SPENDAH

}

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

      </source>