try {
RowSet rs = new com.imaginary.sql.ImaginaryRowSet();
rs.setDataSourceName("jdbc/oraxa");
rs.setUsername("borg");
rs.setPassword("womble");
rs.setCommand("SELECT acct_id, balance, cust_id " +
"FROM account");
rs.execute();
Context ctx = new InitialContext();
// this data source is pooled and distributed
// all distributed data sources are pooled data sources
DataSource ds = (DataSource)ctx.lookup("jdbc/oraxa");
Connection con = ds.getConnection("borg", "");
PreparedStatement acct, cust;
// the account and customer tables are in two different
// databases, but this application does not need to care
acct = con.prepareStatement("UPDATE account " +
"SET balance = ? " +
"WHERE acct_id = ?");
cust = con.prepareStatement("UPDATE customer " +
"SET last_interest = ? " +
"WHERE cust_id = ?");
while( rs.next() ) {
long acct_id, cust_id;
double balance, interest;
acct.clearParameters();
cust.clearParameters();
acct_id = rs.getLong(1);
balance = rs.getDouble(2);
cust_id = rs.getLong(3);
interest = balance * (0.03/12);
balance = balance + interest;
acct.setDouble(1, balance);
acct.setLong(2, acct_id);
acct.executeUpdate();
cust.setDouble(1, interest);
cust.setLong(2, cust_id);
cust.executeUpdate();
}
rs.close();
con.close();
}
catch( Exception e ) {
e.printStackTrace();
}
