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;
    }
  }
}