WEB开发网
开发学院软件开发Java 控制器组件JDBC数据库操作的JAVABEAN 阅读

控制器组件JDBC数据库操作的JAVABEAN

 2009-09-06 00:00:00 来源:WEB开发网   
核心提示:在控制器组件中,我们最经常做的是与数据库进行交互,控制器组件JDBC数据库操作的JAVABEAN,这里,我们写一个javabean,用于封装与数据库的操作,主要是连接数据库

在控制器组件中,我们最经常做的是与数据库进行交互。这里,我们写一个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(); 
    } 
  } 
} 
 

1 2  下一页

Tags:控制器 组件 JDBC

编辑录入:爽爽 [复制链接] [打 印]
赞助商链接