在控制器组件中，我们最经常做的是与数据库进行交互。这里，我们写一个javabean，用于封装与数据库的操作，主要是连接数据库，插入修改删除等更新操作和查询操作。代码很简单如下（需完善）：
Java代码
package com.newland.nlie.highway.pub_com;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.naming.Context;
import javax.sql.DataSource;
public class DatabaseBean extends java.lang.Object {
private Connection conn = null;
private Statement stmt = null;
/**
* 构造函数
*/
public DatabaseBean() {
}
/**
* 通过JNDI建立连接
*/
private void build_conn() throws Exception {
try {
Context ctx = init_bean.get_init_ctx();
// forJBoss
Object obj = ctx.lookup("java:OracleDS");
// forWebSphere
// Object obj = ctx.lookup("Pub_DataSource");
DataSource ds = (DataSource) obj;
this.conn = ds.getConnection();
this.stmt = conn.createStatement();
} catch (Exception ex) {
}
}
/**
* 获取PreparedStatement对象
*/
public PreparedStatement get_statment(String sql)
throws java.lang.Exception {
try {
if (conn == null)
build_conn();
PreparedStatement preparedStatement = conn.prepareStatement(sql);
return preparedStatement;
} catch (Exception ex) {
throw ex;
}
}
/**
* 执行更新操作
*/
public void execute_update(String sql) throws Exception {
try {
if (conn == null)
build_conn();
stmt.executeUpdate(sql);
} catch (Exception ex) {
}
}
/**
* 执行查询操作
*/
public ResultSet execute_query(String sql) throws Exception {
ResultSet rs = null;
try {
if (this.conn == null)
build_conn();
rs = stmt.executeQuery(sql);
} catch (Exception ex) {
}
return rs;
}
/**
* 设置是否自动提交
*/
public void set_auto_commnit(boolean ac) {
try {
if (this.conn == null)
build_conn();
conn.setAutoCommit(ac);
} catch (Exception ex) {
}
}
/**
* 回滚
*/
public boolean rollback() {
try {
if ((conn != null) && (!conn.getAutoCommit())) {
conn.rollback();
}
return true;
} catch (SQLException ex) {
return false;
}
}
/**
* 关闭数据库
*
*/
public void close() {
try {
if (stmt != null)
stmt.close();
if (conn != null) {
if (!conn.isClosed()) {
conn.close();
}
}
} catch (SQLException ex) {
ex.printStackTrace();
}
}
}
完成后，在控制器组件里可以通过DatabaseBean的execute_update()方法来执行更新操作，通过execute_query()来执行查询操作。这里执行的查询操作后把结果集放在ParamBean里（关于parambean的内容请参看前一篇的文章《如何在控制器组件与模型组件相互传送数据》）。至此，完成了这个DatabaseBean的说明：）