package example4;

import java.sql.*;
import javax.sql.*;
import sun.jdbc.rowset.*;
import javax.naming.*;
import javax.ejb.*;

public class coffeesbean implements sessionbean {

private sessioncontext sc = null;
private context ctx = null;
private datasource ds = null;

public coffeesbean () {}

public void ejbcreate() throws createexception {

try {
ctx = new initialcontext();
ds = (datasource)ctx.lookup("jdbc/coffeesdb");
}
catch (exception e) {
system.out.println(e.getmessage());
throw new createexception();
}
}

public rowset getcoffees() throws sqlexception {

connection con = null;
resultset rs;
cachedrowset crs;

try {
con = ds.getconnection("webcustomer", "webpassword");
statement stmt = con.createstatement();
rs = stmt.executequery("select * from coffees");

crs = new cachedrowset();
crs.populate(rs);
// the writer needs this because jdbc drivers
// don't provide this meta-data.
crs.settablename("coffees");

rs.close();
stmt.close();
} finally {
if (con != null)
con.close();
}
return rset;
}

public updatecoffees(rowset rs) throws sqlexception {

connection con = null;

try {
cachedrowset crs = (cachedrowset)rs;
con = ds.getconnection("webcustomer", "webpassword");
// moves the changes back to the database
crs.acceptchanges(con);
} finally {
if (con != null)
con.close();
}
}

//
// methods inherited from sessionbean
//

public void setsessioncontext(sessioncontext sc) {
this.sc = sc;
}

public void ejbremove() {}
public void ejbpassivate() {}
public void ejbactivate() {}

}

／／／／／／／／／／／／／／／／／／client端／／／／／／／／／／／／／／
package example4;

import java.sql.*;
import javax.sql.*;
import sun.jdbc.rowset.*;
import javax.naming.*;
import javax.ejb.*;
import javax.rmi.*;

class coffeesclient {

public static void main(string[] args) {

try {
// init the bean
context ctx = new initialcontext();
object obj = ctx.lookup("ejb/coffees");
coffeeshome coffeeshome = (coffeeshome)
portableremoteobject.narrow(obj, coffeeshome.class);
coffees coffees = coffeeshome.create();

// get the rowset from the bean
cachedrowset rset = (cachedrowset)coffees.getcoffees();

// find the columbian coffee
while (rset.next()) {
string coffeename = rset.getstring("cof_name");
if (coffeename.equalsignorecase(new string("columbian"))) {
// columbian coffee has gone up 10%
rset.updatefloat("price",
(float)(rset.getfloat("price") * 1.10));
rset.updaterow();
}
}

// finally send the updated back to the bean...
system.out.println("calling update method");
coffees.updatecoffees((rowset)rset);
}
catch (exception e) {
system.out.println(e.getmessage());
}
}
}
例子很简单就不多讲了。
cheers.
robin