Stateful Session Bean Lifecycle: PrePassivate

August 9, 2009 at 11:01 pm (JBoss) (, )

File: Employee.java

import javax.persistence.Entity;
import javax.persistence.EntityListeners;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.PostRemove;

@Entity

public class Employee implements java.io.Serializable {
private int id;

private String firstName;

private String lastName;

@Id
@GeneratedValue
public int getId() {
return id;
}

@PostRemove
public void postRemove()
{
System.out.println(“@PostRemove”);
}

public void setId(int 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;
}
}

File: EmployeeBean.java

import javax.ejb.PrePassivate;
import javax.ejb.Stateful;

@Stateful
public class EmployeeBean implements EmployeeServiceLocal, EmployeeServiceRemote {

public EmployeeBean() {
}
public void doAction(){
System.out.println(“doAction”);

}

@PrePassivate
public void PrePassivate() {
System.out.println(“PrePassivate”);
}
}

File: EmployeeServiceLocal.java

import java.util.Map;

import javax.ejb.Local;

@Local
public interface EmployeeServiceLocal {
public void doAction();
}

File: EmployeeServiceRemote.java

import javax.ejb.Remote;

@Remote
public interface EmployeeServiceRemote {
public void 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

File: Main.java

import javax.ejb.EJB;
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(“EmployeeBean/remote”);

service.doAction();

}

}

Permalink Leave a Comment

EJB Tutorial from JBoss: Stateful Session Bean

August 7, 2009 at 12:09 am (JBoss, Programs) (, )

File: ShoppingCart.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.stateful.bean;

import java.util.HashMap;
import javax.ejb.Remove;

public interface ShoppingCart
{
void buy(String product, int quantity);

HashMap<String, Integer> getCartContents();

@Remove void checkout();
}

File: ShoppingCartBean.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.stateful.bean;

import java.io.Serializable;
import java.util.HashMap;
import javax.ejb.Remove;
import javax.ejb.Stateful;
import javax.ejb.Remote;

@Stateful
@Remote(ShoppingCart.class)
public class ShoppingCartBean implements ShoppingCart, Serializable
{
private HashMap<String, Integer> cart = new HashMap<String, Integer>();

public void buy(String product, int quantity)
{
if (cart.containsKey(product))
{
int currq = cart.get(product);
currq += quantity;
cart.put(product, currq);
}
else
{
cart.put(product, quantity);
}
}

public HashMap<String, Integer> getCartContents()
{
return cart;
}

@Remove
public void checkout()
{
System.out.println(“To be implemented”);
}
}

File: Client.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.stateful.client;

import java.util.HashMap;
import javax.naming.InitialContext;
import org.jboss.tutorial.stateful.bean.ShoppingCart;

/**
* Comment
*
* @author <a href=”mailto:bill@jboss.org”>Bill Burke</a>
* @version $Revision: 57207 $
*/
public class Client
{
public static void main(String[] args) throws Exception
{
InitialContext ctx = new InitialContext();
ShoppingCart cart = (ShoppingCart) ctx.lookup(“ShoppingCartBean/remote”);

System.out.println(“Buying 1 memory stick”);
cart.buy(“Memory stick”, 1);
System.out.println(“Buying another memory stick”);
cart.buy(“Memory stick”, 1);

System.out.println(“Buying a laptop”);
cart.buy(“Laptop”, 1);

System.out.println(“Print cart:”);
HashMap<String, Integer> fullCart = cart.getCartContents();
for (String product : fullCart.keySet())
{
System.out.println(fullCart.get(product) + “     ” + product);
}

System.out.println(“Checkout”);
cart.checkout();

System.out.println(“Should throw an object not found exception by invoking on cart after @Remove method”);
try
{
cart.getCartContents();
}
catch (javax.ejb.EJBNoSuchObjectException e)
{
System.out.println(“Successfully caught no such object exception.”);
}

}
}

Permalink Leave a Comment

EJB Tutorial from JBoss: Entity with Blob data

August 5, 2009 at 9:18 am (JBoss, Programs) (, )

Entity Bean with Blob Data

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 <a href=”mailto:bill@jboss.org”>Bill Burke</a>
* @version $Revision: 57207 $
*/
@Entity
public class BlobEntity implements Serializable
{
private long id;
private Blob blobby;
private Clob clobby;

@Id @GeneratedValue(strategy=GenerationType.IDENTITY)
public long getId()
{
return id;
}

public void setId(long id)
{
this.id = id;
}

@Lob @Basic(fetch = FetchType.EAGER)
public Blob getBlobby()
{
return blobby;
}

public void setBlobby(Blob blobby)
{
this.blobby = blobby;
}

@Lob @Basic(fetch = FetchType.EAGER)
public Clob getClobby()
{
return clobby;
}

public void setClobby(Clob clobby)
{
this.clobby = clobby;
}

}

File: LobTester.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.util.HashMap;

/**
* Comment
*
* @author <a href=”mailto:bill@jboss.org”>Bill Burke</a>
* @version $Revision: 57207 $
*/
public interface LobTester
{
long create();

HashMap findBlob(long id) throws Exception;

String findClob(long id) throws Exception;

long create2();

BlobEntity2 findBlob2(long id) throws Exception;
}

File: LobTesterBean.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.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.HashMap;
import javax.ejb.Remote;
import javax.ejb.Stateless;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.PersistenceContext;
import org.hibernate.Hibernate;

/**
* Comment
*
* @author <a href=”mailto:bill@jboss.org”>Bill Burke</a>
* @version $Revision: 57207 $
*/
@Stateless
@Remote(LobTester.class)
public class LobTesterBean implements LobTester
{

@PersistenceContext EntityManager manager;

public long create()
{
BlobEntity blob = new BlobEntity();

HashMap map = new HashMap();
map.put(“hello”, “world”);
ByteArrayOutputStream baos = new ByteArrayOutputStream();
try
{
ObjectOutputStream oos = new ObjectOutputStream(baos);
oos.writeObject(map);
blob.setBlobby(Hibernate.createBlob(baos.toByteArray()));
}
catch (IOException e)
{
throw new RuntimeException(e);
}

String clobby = “This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work”;
blob.setClobby(Hibernate.createClob(clobby));
manager.persist(blob);
return blob.getId();
}

public HashMap findBlob(long id) throws Exception
{
BlobEntity blob = manager.find(BlobEntity.class, id);
ObjectInputStream ois = new ObjectInputStream(blob.getBlobby().getBinaryStream());
return (HashMap) ois.readObject();
}

public String findClob(long id) throws Exception
{
BlobEntity blob = manager.find(BlobEntity.class, id);
return blob.getClobby().getSubString(1, 31);
}

public long create2()
{
BlobEntity2 blob = new BlobEntity2();

HashMap map = new HashMap();
map.put(“hello”, “world”);
ByteArrayOutputStream baos = new ByteArrayOutputStream();
try
{
ObjectOutputStream oos = new ObjectOutputStream(baos);
oos.writeObject(map);
blob.setBlobby(baos.toByteArray());
}
catch (IOException e)
{
throw new RuntimeException(e);
}

String clobby = “This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work” +
“This is a very long string that will be stored in a java.sql.Clob hopefully.  We’ll see how this works and if it will work”;
blob.setClobby(clobby);
manager.persist(blob);
return blob.getId();
}

public BlobEntity2 findBlob2(long id) throws Exception
{
return manager.find(BlobEntity2.class, id);
}

}

File: BlobEntity2.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 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 <a href=”mailto:bill@jboss.org”>Bill Burke</a>
*/
@Entity
public class BlobEntity2 implements Serializable
{
private long id;
private byte[] blobby;
private String clobby;

@Id @GeneratedValue(strategy=GenerationType.AUTO)
public long getId()
{
return id;
}

public void setId(long id)
{
this.id = id;
}

@Lob @Basic(fetch = FetchType.EAGER)
public byte[] getBlobby()
{
return blobby;
}

public void setBlobby(byte[] blobby)
{
this.blobby = blobby;
}

@Lob @Basic(fetch = FetchType.EAGER)
public String getClobby()
{
return clobby;
}

public void setClobby(String clobby)
{
this.clobby = clobby;
}

}

File: Client.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.client;

import java.util.HashMap;
import javax.naming.InitialContext;
import org.jboss.tutorial.blob.bean.LobTester;
import org.jboss.tutorial.blob.bean.BlobEntity2;

/**
* Comment
*
* @author <a href=”mailto:bill@jboss.org”>Bill Burke</a>
* @version $Revision: 57207 $
*/
public class Client
{
public static void main(String[] args) throws Exception
{
InitialContext ctx = new InitialContext();
LobTester test = (LobTester) ctx.lookup(“LobTesterBean/remote”);
long blobId = test.create();
HashMap map = test.findBlob(blobId);
System.out.println(“is hello in map: ” + map.get(“hello”));
System.out.println(test.findClob(blobId));
System.out.println(“creating and getting a BlobEntity2 that uses byte[] and String instead of Clob/Blob”);
blobId = test.create2();
BlobEntity2 entity = test.findBlob2(blobId);

}
}

Permalink Leave a Comment

Working with Binary Data using EJB

August 5, 2009 at 9:13 am (Programs) ()

// Working with Binary Data in EJB

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

Permalink Leave a Comment