掌握器组件JDBC数据库操作的JAVABEAN[Java编程]

在掌握器组件中,我们最常常做的是与数据库举行交互.这里,我们写一个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的阐明:）