Hi
I am not able to delete a row in the database, when I execute the remove()
method. All the other methods and code and working fine as expected. The code
of the Employee Entity EJB and ejb-jar file are as follows:
/* THE BEAN CLASS */
package labs.banking;
import javax.ejb.*;
import java.rmi.*;
import java.sql.*;
import javax.naming.*;
import javax.sql.DataSource;
import javax.rmi.PortableRemoteObject;
public class CustomerBean implements EntityBean
{
/*------------------------------------------------------------*/
//variables
private EntityContext entityContext;
private String first, last;
private double balance;
private int accountNumber;
private Connection connection;
private PreparedStatement insert, delete, findByKey, findByName, update;
/*------------------------------------------------------------*/
//methods
public String getFirstName() throws RemoteException {
return first;
}
/*------------------------------------------------------------*/
public String getLastName() throws RemoteException {
return last;
}
/*------------------------------------------------------------*/
public void deposit(double amount) throws RemoteException {
balance +=amount;
}
/*------------------------------------------------------------*/
public void withdraw(double amount) throws RemoteException {
balance -=amount;
}
/*------------------------------------------------------------*/
public double getBalance() throws RemoteException {
return balance;
}
/*------------------------------------------------------------*/
public CustomerPK ejbCreate(int n, String f, String l, double b) throws
CreateException {
try {
insert.setInt(1,n);
insert.setDouble(2,b);
insert.setString(3,f);
insert.setString(4,l);
insert.executeUpdate();
}
catch(SQLException e) {
e.printStackTrace();
throw new CreateException(e.getMessage());
}
first = f;
last = l;
balance = b;
accountNumber = n;
CustomerPK key = new CustomerPK();
key.accountNumber = n;
return key;
}
/*------------------------------------------------------------*/
public void ejbPostCreate(int n, String f, String l, double b) {}
/*------------------------------------------------------------*/
public CustomerPK ejbFindByPrimaryKey(CustomerPK key) throws
FinderException {
try {
findByKey.setInt(1, key.accountNumber);
ResultSet result = findByKey.executeQuery();
result.next();
return key;
}
catch (SQLException e) {
e.printStackTrace();
throw new FinderException(e.getMessage());
}
}
/*------------------------------------------------------------*/
public CustomerPK ejbFindByName(String first, String last) throws
FinderException {
try {
findByName.setString(1, first);
findByName.setString(2, last);
ResultSet result = findByName.executeQuery();
result.next();
CustomerPK key = new CustomerPK();
key.accountNumber = result.getInt("accountNumber");
return key;
}
catch (SQLException e) {
e.printStackTrace();
throw new FinderException(e.getMessage());
}
}
/*------------------------------------------------------------*/
public void setEntityContext(EntityContext ec) {
entityContext = ec;
try {
System.out.println("Initialising the context");
Context ctx = new InitialContext();
System.out.println("Lookup the data source");
DataSource source =
(DataSource)PortableRemoteObject.narrow(ctx.lookup("java:/OracleDS"),DataSource.class);
System.out.println("Found data source");
connection = source.getConnection();
insert = connection.prepareStatement("INSERT into
BankCustomers VALUES (?,?,?,?)");
System.out.println(insert.toString());
delete = connection.prepareStatement("DELETE FROM
BankCustomers WHERE accountNumber = ?");
findByKey = connection.prepareStatement("SELECT * FROM
BankCustomers WHERE accountNumber = ?");
findByName = connection.prepareStatement("SELECT * FROM
BankCustomers WHERE first = ? AND last = ?");
update = connection.prepareStatement("UPDATE
BankCustomers SET balance = ?, first = ?, last = ? WHERE accountNumber = ?");
System.out.println(update.toString());
}
catch(NamingException c) {
System.out.println("Could not locate db");
c.printStackTrace();
throw new EJBException(c.getMessage());
}
catch(SQLException e) {
System.out.println("Problem with db connection");
e.printStackTrace();
throw new EJBException(e.getMessage());
}
catch(Exception e) {
System.out.println("Something Failed");
e.printStackTrace();
throw new EJBException(e.getMessage());
}
}
/*------------------------------------------------------------*/
public void unsetEntityContext() {
try {
connection.close();
}
catch(SQLException e) {
e.printStackTrace();
}
}
/*------------------------------------------------------------*/
public void ejbRemove() throws RemoveException {
System.out.println("Removing " + first + " " + last);
try {
System.out.println("accountNumber .." + accountNumber);
delete.setInt(1, accountNumber);
System.out.println ("deleted ::::: " +
delete.executeUpdate());
}
catch(SQLException e) {
e.printStackTrace();
throw new RemoveException(e.getMessage());
}
}
/*------------------------------------------------------------*/
public void ejbPassivate() {
System.out.println("Passivating ");
accountNumber = -1;
}
/*------------------------------------------------------------*/
public void ejbActivate() {
System.out.println("Activating ");
CustomerPK key = (CustomerPK) entityContext.getPrimaryKey();
accountNumber = key.accountNumber;
}
/*------------------------------------------------------------*/
public void ejbLoad() throws EJBException {
try {
findByKey.setInt(1, accountNumber);
ResultSet result = findByKey.executeQuery();
result.next();
balance = result.getDouble("balance");
first = result.getString("first");
last = result.getString("last");
}
catch(SQLException e) {
e.printStackTrace();
throw new EJBException("Load Failed");
}
}
/*------------------------------------------------------------*/
public void ejbStore() {
System.out.println("EJBStore..........");
try {
update.setDouble(1, balance);
update.setString(2, first);
update.setString(3, last);
update.setInt(4, accountNumber);
update.executeUpdate();
}
catch(SQLException e) {
e.printStackTrace();
throw new EJBException("Store Failed");
}
}
/*------------------------------------------------------------*/
}
ejb-jar.xml
======
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE ejb-jar PUBLIC '-//Sun Microsystems, Inc.//DTD Enterprise JavaBeans
2.0//EN' 'http://java.sun.com/dtd/ejb-jar_2_0.dtd'>
<ejb-jar>
<display-name>bankingJAR</display-name>
<enterprise-beans>
<display-name>CustomerBean</display-name>
<ejb-name>banking.CustomerHome</ejb-name>
labs.banking.CustomerHome
labs.banking.Customer
<ejb-class>labs.banking.CustomerBean</ejb-class>
<persistence-type>Bean</persistence-type>
<prim-key-class>labs.banking.CustomerPK</prim-key-class>
False
<security-identity>
<use-caller-identity></use-caller-identity>
</security-identity>
</enterprise-beans>
<assembly-descriptor>
<container-transaction>
<ejb-name>banking.CustomerHome</ejb-name>
<method-intf>Remote</method-intf>
<method-name>getLastName</method-name>
<method-params />
<trans-attribute>Required</trans-attribute>
</container-transaction>
<container-transaction>
<ejb-name>banking.CustomerHome</ejb-name>
<method-intf>Remote</method-intf>
<method-name>getBalance</method-name>
<method-params />
<trans-attribute>Required</trans-attribute>
</container-transaction>
<container-transaction>
<ejb-name>banking.CustomerHome</ejb-name>
<method-intf>Remote</method-intf>
<method-name>remove</method-name>
<method-params />
<trans-attribute>Required</trans-attribute>
</container-transaction>
<container-transaction>
<ejb-name>banking.CustomerHome</ejb-name>
<method-intf>Remote</method-intf>
<method-name>deposit</method-name>
<method-params>
<method-param>double</method-param>
</method-params>
<trans-attribute>Required</trans-attribute>
</container-transaction>
<container-transaction>
<ejb-name>banking.CustomerHome</ejb-name>
<method-intf>Remote</method-intf>
<method-name>getFirstName</method-name>
<method-params />
<trans-attribute>Required</trans-attribute>
</container-transaction>
<container-transaction>
<ejb-name>banking.CustomerHome</ejb-name>
<method-intf>Remote</method-intf>
<method-name>withdraw</method-name>
<method-params>
<method-param>double</method-param>
</method-params>
<trans-attribute>Required</trans-attribute>
</container-transaction>
</assembly-descriptor>
</ejb-jar>
Can anyone please help?
regards
Mala
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=3916020#3916020
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=3916020
-------------------------------------------------------
This SF.net email is sponsored by: Splunk Inc. Do you grep through log files
for problems? Stop! Download the new AJAX search engine that makes
searching your log files as easy as surfing the web. DOWNLOAD SPLUNK!
http://ads.osdn.com/?ad_id=7637&alloc_id=16865&op=click
_______________________________________________
JBoss-user mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/jboss-user
