the close doesnt actually close the connection, it returns the connection to the connection pool behind the datasource. Setup your oracle service as described in the docco using the latest oracle jdbc driver that supports the sql extensions. craig At 19:41 30/12/00, you wrote: >I think that when I create a new instance,setEntityContext() will run once >in EJBbean. >In your sample code,you disconnect the database session in ejbCreate(). >If I want to remove the row in the table,I must connect the database again. >I think that it'll reduce the efficiency of program. >If I don't disconnect the database session in ejbCreate(),I'll get the >same result as before. >Maybe I misundertand your issue. > >Thank you >levels > > > >-----原始邮件----- >发件人: [EMAIL PROTECTED] >[mailto:[EMAIL PROTECTED]]代表 Craig Day >发送时间: 2000年12月30日 18:49 >收件人: jBoss >主题: Re: [jBoss-User] 答复: [jBoss-User] why ejbcreate doesn't = >?gb2312?B?IGluc2VydCByb3dzIGludG8gdGFibGU/? > > >At 18:30 30/12/00, you wrote: > >Please tell me how to cache the data source. > >But I don't know why EJB can't delete the row from table account. > >Thank you. > >You can do it in setEntityContext. Heres some sample code: > >public class CategoryBean extends CategoryInfo implements EntityBean { > > private transient boolean isDirty = false; > private EntityContext context; > private DataSource ds = null; > private static final String dsName = "java:/craigd"; > > /** > * Set the entity context for this bean and lookup the DataSource. > */ > public void setEntityContext(final EntityContext context) > throws EJBException, RemoteException { > log("in setEntityContext()"); > > this.context = context; > try { > InitialContext ic = new InitialContext(); > ds = (DataSource)ic.lookup(dsName); > } > catch (Exception e) { > throw new EJBException("Unable to get datasource:" + >e.getMessage()); > } > } > > >and then use it like this: > > public String ejbCreate(String categoryID, String categoryName) > throws RemoteException, CreateException { > > Connection conn = null; > PreparedStatement pstmt = null; > > log("in ejbCreate()"); > > try { > conn = ds.getConnection(); > etc. etc. etc. > } > catch (SQLException e) { > throw new CreateException("ejbCreate: " + e.getMessage()); > } > finally { > try { pstmt.close(); } catch (Exception ex) { } > try { conn.close(); } catch (Exception ex) { } > } > } > >cheers >craig > > > > > >And I find if I start a session to oracle by scott/tiger through > >sql*plus,then start the test client, > >the application will freeze. > > > >levels > > > >-----原始邮件----- > >发件人: [EMAIL PROTECTED] > >[mailto:[EMAIL PROTECTED]]代表 Jay Walters > >发送时间: 2000年12月30日 2:49 > >收件人: 'jBoss' > >主题: RE: [jBoss-User] why ejbcreate doesn't insert rows into table? > > > > > >I don't believe you should be allocating a database connection in the > >ejbActivate. You can cache the data source so you don't have to do the JNDI > >lookup everytime. It sounds like in the end it's doing the right thing, > >inserting 4 records. I would try and allocate the connection from within > >the transaction and close it before the end. I am guessing this will get > >things working as you expect. > > > >Cheers > >Jay Walters > > > >-----Original Message----- > >From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED]] > >Sent: Friday, December 29, 2000 6:23 AM > >To: [EMAIL PROTECTED] > >Subject: [jBoss-User] why ejbcreate doesn't insert rows into table? > > > > > > I'm using JBoss 2.0 and oracle8.0.6.I config as BMP.When I use client > >access EJB,the program just check one inserted row.But in fact,I inert 5 > >rows and remove 1 row.But when I access oracle through sql*net,there is only > >one row.After I turn off JBoss,I access oracle through > >sql*net again,and find that there is 4 rows int the table. I don't know how > >to solve this problem. Please Help me. Thank you. > > > >___________________EJB > >CLASS_______________________________________________________________________ > >_______________ > >/* > > * > > * Copyright 2000 Sun Microsystems, Inc. All Rights Reserved. > > * > > * This software is the proprietary information of Sun Microsystems, Inc. > > * Use is subject to license terms. > > * > > */ > >package com.sasgz.ejb.account; > > > >import java.sql.*; > >import javax.sql.*; > >import java.util.*; > >import javax.ejb.*; > >import javax.naming.*; > > > >public class AccountEJB implements EntityBean { > > > > private String id; > > private String firstName; > > private String lastName; > > private double balance; > > private EntityContext context; > > private Connection con; > > private String dbName = "java:comp/env/jdbc/AccountDB"; > > > > public void debit(double amount) > > throws InsufficientBalanceException { > > > > if (balance - amount < 0) { > > throw new InsufficientBalanceException(); > > } > > balance -= amount; > > } > > > > public void credit(double amount) { > > > > balance += amount; > > } > > > > public String getFirstName() { > > > > return firstName; > > } > > > > public String getLastName() { > > > > return lastName; > > } > > > > public double getBalance() { > > > > return balance; > > } > > > > public String ejbCreate(String id, String firstName, > > String lastName, double balance) > > throws CreateException { > > > > if (balance < 0.00) { > > throw new CreateException > > ("A negative initial balance is not allowed."); > > } > > > > try { > > insertRow(id, firstName, lastName, balance); > > } catch (Exception ex) { > > throw new EJBException("ejbCreate: " + > > ex.getMessage()); > > } > > > > this.id = id; > > this.firstName = firstName; > > this.lastName = lastName; > > this.balance = balance; > > > > return id; > > } > > > > public String ejbFindByPrimaryKey(String primaryKey) > > throws FinderException { > > > > boolean result; > > > > try { > > result = selectByPrimaryKey(primaryKey); > > } catch (Exception ex) { > > throw new EJBException("ejbFindByPrimaryKey: " + > > ex.getMessage()); > > } > > if (result) { > > return primaryKey; > > } > > else { > > throw new ObjectNotFoundException > > ("Row for id " + primaryKey + " not found."); > > } > > } > > > > public Collection ejbFindByLastName(String lastName) > > throws FinderException { > > > > Collection result; > > > > try { > > result = selectByLastName(lastName); > > } catch (Exception ex) { > > throw new EJBException("ejbFindByLastName " + > > ex.getMessage()); > > } > > > > if (result.isEmpty()) { > > throw new ObjectNotFoundException("No rows found."); > > } > > else { > > return result; > > } > > } > > > > public Collection ejbFindInRange(double low, double high) > > throws FinderException { > > > > Collection result; > > > > try { > > result = selectInRange(low, high); > > > > } catch (Exception ex) { > > throw new EJBException("ejbFindInRange: " + > > ex.getMessage()); > > } > > if (result.isEmpty()) { > > throw new ObjectNotFoundException("No rows found."); > > } > > else { > > return result; > > } > > } > > > > public void ejbRemove() { > > > > try { > > deleteRow(id); > > } catch (Exception ex) { > > throw new EJBException("ejbRemove: " + > > ex.getMessage()); > > } > > } > > > > public void setEntityContext(EntityContext context) { > > > > this.context = context; > > try { > > makeConnection(); > > } catch (Exception ex) { > > throw new EJBException("Unable to connect to database. " + > > ex.getMessage()); > > } > > } > > > > public void unsetEntityContext() { > > > > try { > > con.close(); > > } catch (SQLException ex) { > > throw new EJBException("unsetEntityContext: " + ex.getMessage()); > > } > > } > > > > public void ejbActivate() { > > > > id = (String)context.getPrimaryKey(); > > } > > > > public void ejbPassivate() { > > > > id = null; > > } > > > > public void ejbLoad() { > > > > try { > > loadRow(); > > } catch (Exception ex) { > > throw new EJBException("ejbLoad: " + > > ex.getMessage()); > > } > > } > > > > public void ejbStore() { > > > > try { > > storeRow(); > > } catch (Exception ex) { > > throw new EJBException("ejbLoad: " + > > ex.getMessage()); > > } > > } > > > > > > public void ejbPostCreate(String id, String firstName, > > String lastName, double balance) { } > > > > > >/*********************** Database Routines *************************/ > > > > private void makeConnection() throws NamingException, SQLException { > > > > InitialContext ic = new InitialContext(); > > DataSource ds = (DataSource) ic.lookup(dbName); > > con = ds.getConnection(); > > } > > > > private void insertRow (String id, String firstName, String lastName, > > double balance) throws SQLException { > > > > String insertStatement = > > "insert into account values ( ? , ? , ? , ? )"; > > PreparedStatement prepStmt = > > con.prepareStatement(insertStatement); > > > > prepStmt.setString(1, id); > > prepStmt.setString(2, firstName); > > prepStmt.setString(3, lastName); > > prepStmt.setDouble(4, balance); > > > > prepStmt.executeUpdate(); > > prepStmt.close(); > > System.out.println("insert"+id); > > } > > > > private void deleteRow(String id) throws SQLException { > > > > String deleteStatement = > > "delete from account where id = ? "; > > PreparedStatement prepStmt = > > con.prepareStatement(deleteStatement); > > > > prepStmt.setString(1, id); > > prepStmt.executeUpdate(); > > prepStmt.close(); > > } > > > > private boolean selectByPrimaryKey(String primaryKey) > > throws SQLException { > > > > String selectStatement = > > "select id " + > > "from account where id = ? "; > > PreparedStatement prepStmt = > > con.prepareStatement(selectStatement); > > prepStmt.setString(1, primaryKey); > > > > ResultSet rs = prepStmt.executeQuery(); > > boolean result = rs.next(); > > prepStmt.close(); > > return result; > > } > > > > private Collection selectByLastName(String lastName) > > throws SQLException { > > > > String selectStatement = > > "select id " + > > "from account where lastname = ? "; > > PreparedStatement prepStmt = > > con.prepareStatement(selectStatement); > > > > prepStmt.setString(1, lastName); > > ResultSet rs = prepStmt.executeQuery(); > > ArrayList a = new ArrayList(); > > > > while (rs.next()) { > > String id = rs.getString(1); > > a.add(id); > > } > > > > prepStmt.close(); > > return a; > > } > > > > private Collection selectInRange(double low, double high) > > throws SQLException { > > > > String selectStatement = > > "select id from account " + > > "where balance between ? and ?"; > > PreparedStatement prepStmt = > > con.prepareStatement(selectStatement); > > > > prepStmt.setDouble(1, low); > > prepStmt.setDouble(2, high); > > ResultSet rs = prepStmt.executeQuery(); > > ArrayList a = new ArrayList(); > > > > while (rs.next()) { > > String id = rs.getString(1); > > a.add(id); > > } > > > > prepStmt.close(); > > return a; > > } > > > > private void loadRow() throws SQLException { > > > > String selectStatement = > > "select firstname, lastname, balance " + > > "from account where id = ? "; > > PreparedStatement prepStmt = > > con.prepareStatement(selectStatement); > > > > prepStmt.setString(1, this.id); > > > > ResultSet rs = prepStmt.executeQuery(); > > > > if (rs.next()) { > > this.firstName = rs.getString(1); > > this.lastName = rs.getString(2); > > this.balance = rs.getDouble(3); > > prepStmt.close(); > > } > > else { > > prepStmt.close(); > > throw new NoSuchEntityException("Row for id " + id + > > " not found in database."); > > } > > } > > > > > > private void storeRow() throws SQLException { > > > > String updateStatement = > > "update account set firstname = ? ," + > > "lastname = ? , balance = ? " + > > "where id = ?"; > > PreparedStatement prepStmt = > > con.prepareStatement(updateStatement); > > > > prepStmt.setString(1, firstName); > > prepStmt.setString(2, lastName); > > prepStmt.setDouble(3, balance); > > prepStmt.setString(4, id); > > int rowCount = prepStmt.executeUpdate(); > > prepStmt.close(); > > > > if (rowCount == 0) { > > throw new EJBException("Storing row for id " + id + " failed."); > > } > > } > > > >} // AccountEJB > > > >________________________________________________HOME > >CLASS________________________________________________________ > >/* > > * > > * Copyright 2000 Sun Microsystems, Inc. All Rights Reserved. > > * > > * This software is the proprietary information of Sun Microsystems, Inc. > > * Use is subject to license terms. > > * > > */ > >package com.sasgz.ejb.account; > > > >import java.util.Collection; > >import java.rmi.RemoteException; > >import javax.ejb.*; > > > >public interface AccountHome extends EJBHome { > > > > public Account create(String id, String firstName, > > String lastName, double balance) > > throws RemoteException, CreateException; > > > > public Account findByPrimaryKey(String id) > > throws FinderException, RemoteException; > > > > public Collection findByLastName(String lastName) > > throws FinderException, RemoteException; > > > > public Collection findInRange(double low, double high) > > throws FinderException, RemoteException; > >} > > > >____________________________________________________REMOTE > >CLASS_______________________________________________ > >/* > > * > > * Copyright 2000 Sun Microsystems, Inc. All Rights Reserved. > > * > > * This software is the proprietary information of Sun Microsystems, Inc. > > * Use is subject to license terms. > > * > > */ > >package com.sasgz.ejb.account; > > > >import javax.ejb.EJBObject; > >import java.rmi.RemoteException; > > > >public interface Account extends EJBObject { > > > > public void debit(double amount) > > throws InsufficientBalanceException, RemoteException; > > > > public void credit(double amount) > > throws RemoteException; > > > > public String getFirstName() > > throws RemoteException; > > > > public String getLastName() > > throws RemoteException; > > > > public double getBalance() > > throws RemoteException; > >} > > > >_________________________________________TEST > >CLIENT______________________________________________________________ > >/* > > * > > * Copyright 2000 Sun Microsystems, Inc. All Rights Reserved. > > * > > * This software is the proprietary information of Sun Microsystems, Inc. > > * Use is subject to license terms. > > * > > */ > >package com.sasgz.ejb.account; > > > >import java.util.*; > >import javax.naming.Context; > >import javax.naming.InitialContext; > >import javax.rmi.PortableRemoteObject; > > > >public class AccountClient { > > > > public static void main(String[] args) { > > // Set up the naming provider; this may not always be necessary, > >depending > > // on how your Java system is configured. > > System.setProperty("java.naming.factory.initial", > > "org.jnp.interfaces.NamingContextFactory"); > > System.setProperty("java.naming.provider.url", > > "localhost:1099"); > > > > try { > > Context initial = new InitialContext(); > > Object objref = initial.lookup("MyAccount"); > > > > AccountHome home = > > (AccountHome)PortableRemoteObject.narrow(objref, > > AccountHome.class); > > > > Account duke = home.create("123", "Duke", "Earl", 0.00); > > duke.credit(88.50); > > duke.debit(20.25); > > double balance = duke.getBalance(); > > System.out.println("balance = " + String.valueOf(balance)); > > duke.remove(); > > > > Account joe = home.create("836", "Joe", "Jones", 0.00); > > joe.credit(34.55); > > Account jones = home.findByPrimaryKey("836"); > > jones.debit(2.00); > > balance = jones.getBalance(); > > System.out.println("balance = " + String.valueOf(balance)); > > > > Account pat = home.create("456", "Pat", "Smith", 0.00); > > pat.credit(44.77); > > Account john = home.create("730", "John", "Smith", 0.00); > > john.credit(19.54); > > Account mary = home.create("268", "Mary", "Smith", 0.00); > > mary.credit(100.07); > > > > Collection c = home.findByLastName("Smith"); > > Iterator i=c.iterator(); > > > > while (i.hasNext()) { > > Account account = (Account)i.next(); > > String id = (String)account.getPrimaryKey(); > > double amount = account.getBalance(); > > System.out.println(id + ": " + String.valueOf(amount)); > > } > > > > c = home.findInRange(20.00, 99.00); > > i=c.iterator(); > > > > while (i.hasNext()) { > > Account account = (Account)i.next(); > > String id = (String)account.getPrimaryKey(); > > double amount = account.getBalance(); > > System.out.println(id + ": " + String.valueOf(amount)); > > } > > > > } catch (InsufficientBalanceException ex) { > > System.err.println("Caught an InsufficientBalanceException: " > > + ex.getMessage()); > > > > } catch (Exception ex) { > > System.err.println("Caught an exception." ); > > ex.printStackTrace(); > > } > > } > >} > > > >_________________________________________________ejb-jar.xml________________ > >___________________________ > ><?xml version="1.0" encoding="Cp1252"?> > > > ><ejb-jar> > > <description>J2EE EJB Examples Application</description> > > <display-name>J2EE Examples</display-name> > > <enterprise-beans> > > <entity> > > <display-name>jBoss AccountJAR application</display-name> > > <ejb-name>AccountBean</ejb-name> > > <home>com.sasgz.ejb.account.AccountHome</home> > > <remote>com.sasgz.ejb.account.Account</remote> > > <ejb-class>com.sasgz.ejb.account.AccountEJB</ejb-class> > > <persistence-type>Bean</persistence-type> > > <prim-key-class>java.lang.String</prim-key-class> > > <reentrant>False</reentrant> > > <resource-ref> > > <res-ref-name>jdbc/AccountDB</res-ref-name> > > <res-type>javax.sql.DataSource</res-type> > > <res-auth>Container</res-auth> > > </resource-ref> > > </entity> > > </enterprise-beans> > > <assembly-descriptor> > > <container-transaction> > > <method> > > <ejb-name>AccountBean</ejb-name> > > <method-intf>Remote</method-intf> > > <method-name>getLastName</method-name> > > <method-params /> > > </method> > > <trans-attribute>Required</trans-attribute> > > </container-transaction> > > <container-transaction> > > <method> > > <ejb-name>AccountBean</ejb-name> > > <method-intf>Remote</method-intf> > > <method-name>credit</method-name> > > <method-params> > > <method-param>double</method-param> > > </method-params> > > </method> > > <trans-attribute>Required</trans-attribute> > > </container-transaction> > > <container-transaction> > > <method> > > <ejb-name>AccountBean</ejb-name> > > <method-intf>Remote</method-intf> > > <method-name>debit</method-name> > > <method-params> > > <method-param>double</method-param> > > </method-params> > > </method> > > <trans-attribute>Required</trans-attribute> > > </container-transaction> > > <container-transaction> > > <method> > > <ejb-name>AccountBean</ejb-name> > > <method-intf>Remote</method-intf> > > <method-name>getBalance</method-name> > > <method-params /> > > </method> > > <trans-attribute>Required</trans-attribute> > > </container-transaction> > > <container-transaction> > > <method> > > <ejb-name>AccountBean</ejb-name> > > <method-intf>Home</method-intf> > > <method-name>create</method-name> > > <method-params> > > <method-param>java.lang.String</method-param> > > <method-param>java.lang.String</method-param> > > <method-param>java.lang.String</method-param> > > <method-param>double</method-param> > > </method-params> > > </method> > > <trans-attribute>Required</trans-attribute> > > </container-transaction> > > <container-transaction> > > <method> > > <ejb-name>AccountBean</ejb-name> > > <method-intf>Remote</method-intf> > > <method-name>getFirstName</method-name> > > <method-params /> > > </method> > > <trans-attribute>Required</trans-attribute> > > </container-transaction> > > </assembly-descriptor> > ></ejb-jar> > > > >________________________________jboss.xml___________________________________ > >_________________ > ><?xml version="1.0" encoding="Cp1252"?> > > > ><jboss> > > <secure>false</secure> > > <container-configurations /> > > <resource-managers> > > <resource-manager res-class="org.jboss.ejb.deployment.JDBCResource"> > > <res-name>jdbc/AccountDB</res-name> > > <res-jndi-name>OracleORCLPool</res-jndi-name> > > </resource-manager> > > </resource-managers> > > <enterprise-beans> > > <entity> > > <ejb-name>AccountBean</ejb-name> > > <jndi-name>MyAccount</jndi-name> > > <configuration-name></configuration-name> > > </entity> > > </enterprise-beans> > ></jboss> > > > >_________________________client error message____________________________ > >balance = 68.25 > >Caught an exception. > >javax.ejb.ObjectNotFoundException: Row for id 836 not found. > > at > >sun.rmi.transport.StreamRemoteCall.exceptionReceivedFromServer(StreamRemoteC > >all.java:245) > > at > >sun.rmi.transport.StreamRemoteCall.executeCall(StreamRemoteCall.java:220) > > at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:122) > > at > >org.jboss.ejb.plugins.jrmp.server.JRMPContainerInvoker_Stub.invokeHome(Unkno > >wn Source) > > at > org.jboss.ejb.plugins.jrmp.interfaces.HomeProxy.invoke(HomeProxy. > >java:221) > > at $Proxy0.findByPrimaryKey(Unknown Source) > > at com.sasgz.ejb.account.AccountClient.main(AccountClient.java:43) > > > >_______________________JBoss message________________________________ > >[Bean Cache] Passivated overaged bean AccountBean with id = > nullN?n?壏?呵 > >yb曹(瓾?笔&N嫥叉靣笡z6璨爽z?~X > >+?鄓?r墜娝GzZc(瓾?笔& > > > > > >-- > >-------------------------------------------------------------- > >To subscribe: [EMAIL PROTECTED] > >To unsubscribe: [EMAIL PROTECTED] > >List Help?: [EMAIL PROTECTED] > >ininining-ing-dogs.com > >List Help?: [EMAIL PROTECTED] > >N?n?壏?呵yb曹(瓾?笔&N嫥叉靣笡z6璨爽z簙X > >+?鄓?r墜娝GzZc(瓾?笔&媻 > > > >-- >-------------------------------------------------------------- >To subscribe: [EMAIL PROTECTED] >To unsubscribe: [EMAIL PROTECTED] >List Help?: [EMAIL PROTECTED] >-d-d-d-dog-dogs.com >ing-dogs.com >List Help?: jon@workingjBoss-U�˛���m�ۢ�.���X�� >+�)�v�,r����칻�&ލ�,�뮇߭+-�x��b��ޭ�� +�)�v�,r�b� -- -------------------------------------------------------------- To subscribe: [EMAIL PROTECTED] To unsubscribe: [EMAIL PROTECTED] List Help?: [EMAIL PROTECTED]
