contactbean.java~1~

Java源码 Java源码

package bmpbean;

import javax.ejb.*;
import javax.sql.*;
import java.sql.*;
import javax.naming.*;
public class ContactBean implements EntityBean {
  EntityContext entityContext;
  java.lang.String first;
  java.lang.String last;
  java.lang.String email;
  	private Connection con;
private PreparedStatement ps = null;
  public java.lang.String ejbCreate(java.lang.String last) throws CreateException {
    /**@todo Complete this method*/
    setLast(last);
    return null;
  }
  public void ejbPostCreate(java.lang.String last) throws CreateException {
    /**@todo Complete this method*/
  }
  public void ejbRemove() throws RemoveException {
    /**@todo Complete this method*/
  }
  public void ejbLoad() {
    /**@todo Complete this method*/
  }
  public void ejbStore() {
    /**@todo Complete this method*/
  }
  public void ejbActivate() {
  }
  public void ejbPassivate() {
  }
  public void unsetEntityContext() {
    this.entityContext = null;
  }
  public void setEntityContext(EntityContext entityContext) {
    this.entityContext = entityContext;
	try 
		{
			System.out.println("make connection in setEntityContext"); 
			makeConnection();
			
		} 
		catch (Exception ex) 
		{
			throw new EJBException("Unable to connect to database. " +
             ex);
		}
  }
  public void setFirst(java.lang.String first) {
    this.first = first;
  }
  public void setLast(java.lang.String last) {
    this.last = last;
  }
  public void setEmail(java.lang.String email) {
    this.email = email;
  }
  public java.lang.String getFirst() {
    return first;
  }
  public java.lang.String getLast() {
    return last;
  }
  public java.lang.String getEmail() {
    return email;
  }
  public java.lang.String ejbFindByPrimaryKey(java.lang.String last) throws FinderException {
   System.out.println("---ejbFindByPrimaryKey begins---");
		try
		{
			 ps = con.prepareStatement(
				"SELECT  FIRST, LAST, EMAIL FROM contact WHERE  LAST = ? ");
			ps.setString(1, last);
			ResultSet rs = ps.executeQuery();
			if(rs.next()) 
			{
				this.first=rs.getString(1);
    			this.last=rs.getString(2);
				this.email=rs.getString(3);
			} 
			else 
			{
				System.out.println("Find Error");
			}
		} 
		catch (SQLException ex) 
		{
			throw new EJBException("Exception in ejbFindByPrimaryKey:"+ex);
		}
		try
		{
			ps.close();
		}
		catch(Exception e)
		{
			
			System.out.println("Cannt close statement:"+e);
		}
		System.out.println("---ejbFindByPrimaryKey ends---");
		return last;
  }
  private Connection makeConnection() 
	{
		try
		{
			InitialContext ic = new InitialContext();
			DataSource ds = (DataSource) ic.lookup("mydb1jndi");
			con = ds.getConnection();
			return con;
		}
		catch(Exception ex)
		{
			
			System.out.println("Exception in connection:"+ex);
			return null;
		}
	}
}