ejbLoad is not getting called

[Pradeep Bhat]

Hi,

I am trying out the Entity Bean Example with BMP from Mastering EJB...3rd Edition

This is my client code

   
public class BMPClient {
	public static void main(String args[]) {
		try {
			Context ctx = new InitialContext(System.getProperties());
			Object obj = ctx.lookup("jnAcc");
			AccountHome accHome = (AccountHome)PortableRemoteObject.narrow(obj, AccountHome.class);
			accHome.create("111222112", "Pradeep");
			Iterator iter = accHome.findByOwnerName("Pradeep").iterator();
			while(iter.hasNext()) {
				Account acc = (Account)(PortableRemoteObject.narrow(iter.next(), Account.class));
				System.out.println(acc.getAccountId());
				System.out.println(acc.getOwner());
			}
			Account acc1 = accHome.findByPrimaryKey(new AccountPk("111222112"));
			System.out.println(acc1.getAccountId());
			System.out.println(acc1.getOwner());

		}
		catch(Exception e) {
			e.printStackTrace();
		}
	}
}
 

It prints null is all 4 cases....
There is no other error while deploying the bean or running the client code.
Also I have put a print statement within each bean method ...
I see that ejbLoad is not getting called at all....but ejbStore is.
I am using JBoss....
What could be the reason for this?

[Pradeep Bhat]

here is my bean code....

   
package examples.bmp;

import java.rmi.RemoteException;
import java.security.acl.Owner;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;

import javax.ejb.CreateException;
import javax.ejb.EJBException;
import javax.ejb.EntityBean;
import javax.ejb.EntityContext;
import javax.ejb.FinderException;
import javax.ejb.RemoveException;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;


public class AccountBean implements EntityBean {
	// Define persistable fields
	protected EntityContext ctx;
	private String accountId;
	private String accountOwner;
	private double balance;
	
	public AccountBean() {
		System.out.println("Entity bean created");
	}
	
	// Define methods declared in the remote interface
	public void deposit(double amt) throws AccountException {
		System.out.println("Old Balance : " + balance);
		balance += amt;
		System.out.println("New Balance : " + balance);
	}
	public void withdraw(double amt) throws AccountException {
		System.out.println("Old Balance : " + balance);
		balance -= amt;
		System.out.println("New Balance : " + balance);
	}
	public double getBalance() {
		return this.balance;
	}
	public String getOwner() {
		return this.accountOwner;
	}
	public void setOwner(String name) {
		this.accountOwner = name;
	}
	public String getAccountId() {
		return this.accountId;
	}
	public void getAccountId(String id){
		this.accountId = id;
	}
	
	public Connection getConnection() throws Exception {
		try {
			Context ctx = new InitialContext();
			DataSource ds = (DataSource)ctx.lookup("java:/MySqlDS");
			return ds.getConnection();
		}
		catch (Exception ex) {
			System.out.println("COuld not get dataSource");
			ex.printStackTrace();
			throw ex;
		}
	}
	
	public double ejbHomeGetTotalBankValue() throws AccountException {
		double bal = 0;
		PreparedStatement psmt = null;
		Connection conn = null;
		try {
			System.out.println("In method getTotalBankValue");
			conn = getConnection();
			psmt = conn.prepareStatement("SELECT sum(balance) as total FROM ACCOUNTS");
			ResultSet rs = psmt.executeQuery();
			if(rs.next()) {
				bal =  rs.getDouble("total");
			}
		}
		catch (Exception exp) {
			exp.printStackTrace();
			throw new AccountException();
		}
		finally {
			try {
				if(psmt != null) {
					psmt.close();
				}
				if(conn != null) {
					conn.close();
				}
			} catch (Exception e) {}
		}
		return bal;
	}
	
	public void ejbActivate() {
		System.out.println("ejbActivate is called");
	}

	public void ejbLoad()  {
		System.out.println("ejbLoad called");
		Connection conn = null;
		PreparedStatement pstmt = null;
		AccountPk pk = (AccountPk)ctx.getPrimaryKey();
		String id = pk.accountId;
		System.out.println("Loading "+id);
		try {
			conn = getConnection();
			pstmt = conn.prepareStatement("SELECT OWNERNAME, BALANCE FROM ACCOUNTS WHERE id = ?");
			pstmt.setString(1, id);
			ResultSet rs = pstmt.executeQuery();
			if(rs.next()) {
				this.accountOwner = rs.getString("OWNERNAME");
				this.balance = rs.getDouble("BALANCE");
			}
		}
		catch (Exception e) {
			throw new EJBException(e.toString());
		}
		finally {
			try {
				if(pstmt != null) {
					pstmt.close();
				}
				if(conn != null) {
					conn.close();
				}
			} catch (Exception e) {}
		}
	}

	public void ejbPassivate() throws EJBException {
		System.out.println("ejb passivate is called");
		
	}

	public void ejbRemove() {
		System.out.println("ejbRemove called");
		Connection conn = null;
		PreparedStatement pstmt = null;
		AccountPk pk = (AccountPk)ctx.getPrimaryKey();
		String id = pk.accountId;
		try {
			conn = getConnection();
			pstmt = conn.prepareStatement("DELETE FROM ACCOUNTS WHERE id = ?");
			pstmt.setString(1, id);
			int status = pstmt.executeUpdate();
			if(status == 0) {
				throw new RemoveException("Cannot Delete");
			}
		}
		catch (Exception e) {
			throw new EJBException(e.toString());
		}
		finally {
			try {
				if(pstmt != null) {
					pstmt.close();
				}
				if(conn != null) {
					conn.close();
				}
			} catch (Exception e) {}
		}
	}

	public void ejbStore() throws EJBException {
		System.out.println("ejbStore called");
		Connection conn = null;
		PreparedStatement pstmt = null;
		try {
			conn = getConnection();
			pstmt = conn.prepareStatement("UPDATE ACCOUNTS set OWNERNAME = ?, BALANCE = ? WHERE id = ?");
			System.out.println(this.accountOwner + "  " + this.balance + "  " + this.accountId + "THIS" );
			System.out.println(accountOwner + "  " + balance + "  " + accountId + "NOT THIS" );
			pstmt.setString(1, this.accountOwner);
			pstmt.setDouble(2, this.balance);
			pstmt.setString(3, this.accountId);
			System.out.println(pstmt.executeUpdate());
		}
		catch (Exception e) {
			e.printStackTrace();
			throw new EJBException(e.toString());
		}
		finally {
			try {
				System.out.println("Done");
				if(pstmt != null) {
					pstmt.close();
				}
				if(conn != null) {
					conn.close();
				}
			} catch (Exception e) {
				
			}
		}
	}

	public void setEntityContext(EntityContext arg0) throws EJBException {
		System.out.println("setEntityContext called");
		this.ctx = arg0;
	}

	public void unsetEntityContext() throws EJBException {
		System.out.println("unsetEntityContext called");
		this.ctx = null;
	}
	
	public void ejbPostCreate(String accountId, String name) {
		System.out.println("ejbPostCreate called");
	}
	
	public AccountPk ejbCreate(String account, String name) throws CreateException {
		System.out.println("create called");
		Connection conn = null;
		PreparedStatement pstmt = null;
		try {
			conn = getConnection();
			pstmt = conn.prepareStatement("INSERT INTO ACCOUNTS(ID, OWNERNAME, BALANCE) values (?,?,?)");
			pstmt.setString(1, account);
			pstmt.setString(2, name);
			pstmt.setDouble(3, 0);
			pstmt.executeUpdate();
			return new AccountPk(account);
		}
		catch (Exception e) {
			throw new EJBException(e.toString());
		}
		finally {
			try {
				if(pstmt != null) {
					pstmt.close();
				}
				if(conn != null) {
					conn.close();
				}
			} catch (Exception e) {}
		}
	}
	public AccountPk ejbFindByPrimaryKey(AccountPk key) throws FinderException {
		System.out.println("ejbFindByPrimaryKey called");
		Connection conn = null;
		PreparedStatement pstmt = null;
		try {
			conn = getConnection();
			pstmt = conn.prepareStatement("SELECT ID FROM ACCOUNTS WHERE ID=? ");
			pstmt.setString(1, key.toString());
			ResultSet rs = pstmt.executeQuery();
			rs.next();
			return key;
		}
		catch (Exception e) {
			throw new EJBException(e.toString());
		}
		finally {
			try {
				if(pstmt != null) {
					pstmt.close();
				}
				if(conn != null) {
					conn.close();
				}
			} catch (Exception e) {}
		}
	}
	
	public Collection ejbFindByOwnerName(String name) throws FinderException {
		System.out.println("ejbFindByPrimaryKey called");
		Connection conn = null;
		PreparedStatement pstmt = null;
		List list = new ArrayList(); 
		try {
			conn = getConnection();
			pstmt = conn.prepareStatement("SELECT ID FROM ACCOUNTS WHERE OWNERNAME=? ");
			pstmt.setString(1, name);
			ResultSet rs = pstmt.executeQuery();
			while(rs.next()) {
				list.add(new AccountPk(rs.getString("ID")));
			}
			return list;
		}
		catch (Exception e) {
			throw new EJBException(e.toString());
		}
		finally {
			try {
				if(pstmt != null) {
					pstmt.close();
				}
				if(conn != null) {
					conn.close();
				}
			} catch (Exception e) {}
		}
	}
	
}
 

[Pradeep Bhat]

actually the problem is that even though EJBStore is called, the database entry is not updated. The return value of preparedStatement.executeUpdate() is 0.
That is because the bean's 'accountId' attribute is not getting populated.

Also consider the client code :

   
Context ctx = new InitialContext(System.getProperties());
Object obj = ctx.lookup("newAcc");
AccountHome accHome = (AccountHome)PortableRemoteObject.narrow(obj, AccountHome.class);
Account acc = accHome.findByPrimaryKey(new AccountPK("11000144"));
System.out.println("Client--> " + acc.getAccountId()+ "  " +acc.getBalance() + " " + acc.getOwnerName());
AccountPK pk = (AccountPK)acc.getPrimaryKey();
acc.setOwnerName("Bhat");
acc.deposit(100);
 

acc.getAccountId() is displayed as null. But other attributed are populated.
Any idea why this happens ??