| Methods Summary |
|---|
| public void | ejbActivate()
|
| public java.lang.Integer | ejbCreate(java.lang.Integer id, java.lang.String name, int capacity, double tonnage)
if ((id.intValue() < 1) || (name == null))
throw new CreateException("Invalid Parameters");
this.id = id;
this.name = name;
this.capacity = capacity;
this.tonnage = tonnage;
Connection con = null;
PreparedStatement ps = null;
try {
con = this.getConnection();
ps = con.prepareStatement(
"insert into Ship (id, name, capacity, tonnage) " +
"values (?,?,?,?)");
ps.setInt(1, id.intValue());
ps.setString(2, name);
ps.setInt(3, capacity);
ps.setDouble(4, tonnage);
if (ps.executeUpdate() != 1) {
throw new CreateException ("Failed to add Ship to database");
}
return id;
}
catch (SQLException se) {
throw new EJBException (se);
}
finally {
try {
if (ps != null) ps.close();
if (con!= null) con.close();
} catch(SQLException se) {
se.printStackTrace();
}
}
|
| public java.lang.Integer | ejbCreate(int id, java.lang.String name)
return ejbCreate(new Integer(id),name,0,0);
|
| public java.util.Collection | ejbFindByCapacity(int capacity)
Connection con = null;
PreparedStatement ps = null;
ResultSet result = null;
try {
con = this.getConnection();
ps = con.prepareStatement(
"select id from Ship where capacity = ?");
ps.setInt(1,capacity);
result = ps.executeQuery();
Vector keys = new Vector();
while(result.next()) {
keys.addElement(result.getObject("id"));
}
return keys;
}
catch (SQLException se) {
throw new EJBException (se);
}
finally {
try {
if (result != null) result.close();
if (ps != null) ps.close();
if (con!= null) con.close();
} catch(SQLException se) {
se.printStackTrace();
}
}
|
| public java.lang.Integer | ejbFindByPrimaryKey(java.lang.Integer primaryKey)
Connection con = null;
PreparedStatement ps = null;
ResultSet result = null;
try {
con = this.getConnection();
ps = con.prepareStatement(
"select id from Ship where id = ?");
ps.setInt(1, primaryKey.intValue());
result = ps.executeQuery();
// Does ship id exist in database?
if (!result.next()) {
throw new ObjectNotFoundException(
"Cannot find Ship with id = "+id);
}
} catch (SQLException se) {
throw new EJBException(se);
}
finally {
try {
if (result != null) result.close();
if (ps != null) ps.close();
if (con!= null) con.close();
} catch(SQLException se){
se.printStackTrace();
}
}
return primaryKey;
|
| public void | ejbLoad()
Integer primaryKey = (Integer)context.getPrimaryKey();
Connection con = null;
PreparedStatement ps = null;
ResultSet result = null;
try {
con = this.getConnection();
ps = con.prepareStatement(
"select name, capacity, tonnage from Ship where id = ?");
ps.setInt(1, primaryKey.intValue());
result = ps.executeQuery();
if (result.next()){
id = primaryKey;
name = result.getString("name");
capacity = result.getInt("capacity");
tonnage = result.getDouble("tonnage");
} else {
throw new EJBException();
}
} catch (SQLException se) {
throw new EJBException(se);
}
finally {
try {
if (result != null) result.close();
if (ps != null) ps.close();
if (con!= null) con.close();
} catch(SQLException se) {
se.printStackTrace();
}
}
|
| public void | ejbPassivate()
|
| public void | ejbPostCreate(java.lang.Integer id, java.lang.String name, int capacity, double tonnage)
// Do something useful with the primary key.
|
| public void | ejbPostCreate(int id, java.lang.String name)
// Do something useful with the EJBObject reference.
|
| public void | ejbRemove()
Connection con = null;
PreparedStatement ps = null;
try {
con = this.getConnection();
ps = con.prepareStatement("delete from Ship where id = ?");
ps.setInt(1, id.intValue());
if (ps.executeUpdate() != 1) {
throw new EJBException("ejbRemove");
}
}
catch (SQLException se) {
throw new EJBException (se);
}
finally {
try {
if (ps != null) ps.close();
if (con!= null) con.close();
} catch(SQLException se) {
se.printStackTrace();
}
}
|
| public void | ejbStore()
Connection con = null;
PreparedStatement ps = null;
try {
con = this.getConnection();
ps = con.prepareStatement(
"update Ship set name = ?, capacity = ?, " +
"tonnage = ? where id = ?");
ps.setString(1,name);
ps.setInt(2,capacity);
ps.setDouble(3,tonnage);
ps.setInt(4,id.intValue());
if (ps.executeUpdate() != 1) {
throw new EJBException("ejbStore");
}
}
catch (SQLException se) {
throw new EJBException (se);
}
finally {
try {
if (ps != null) ps.close();
if (con!= null) con.close();
} catch(SQLException se) {
se.printStackTrace();
}
}
|
| public int | getCapacity()
return capacity;
|
| private java.sql.Connection | getConnection()
try {
Context jndiCntx = new InitialContext();
DataSource ds =
(DataSource)jndiCntx.lookup("java:comp/env/jdbc/titanDB");
return ds.getConnection();
}
catch (NamingException ne) {
throw new EJBException(ne);
}
|
| public java.lang.String | getName()
return name;
|
| public double | getTonnage()
return tonnage;
|
| public void | setCapacity(int cap)
capacity = cap;
|
| public void | setEntityContext(javax.ejb.EntityContext ctx)
context = ctx;
|
| public void | setName(java.lang.String n)
name = n;
|
| public void | setTonnage(double tons)
tonnage = tons;
|
| public void | unsetEntityContext()
context = null;
|
