dboperator.java

JAVA编程百例书中各章节的所有例子的源代码,包括套接字编程

package ch03.section04;

import java.sql.*;

import ch03.section03.*;

public class DBOperator {

  private DBConnectionManager DBConMag = DBConnectionManager.getInstance(); //获取联接池事例;

  private Statement stmt = null; //执行语句
  private ResultSet rs = null; //结果集
  private Connection conn = null; //数据库链接
  private ResultSetMetaData rsmd = null; //元数据

  /**
   ** 将连接对象返回给由名字指定的连接池
   ** @param name 在属性文件中定义的连接池名字
   ** @param con 连接对象
   **/
  public void freeConnection(String name, Connection con) {
    if (con != null) {
      DBConMag.freeConnection(name, con);
    }
  }

  /**
   **  获得数据库联接。
   **  无参数。以access为默认的连接池名字
   **
   **/
  public Connection getConnection(String name) {
    return DBConMag.getConnection(name);
  }

  /**
   **实现SQL语句的执行功能，包括删除、更新、插入。
   **参数:完整的SQL语句。
   **返回：SQL执行后所影响的记录数，如果不能得到数据库链接返回-9。
   **如果查询出错返回-1。  　
   **/
  public int executeUpdate(String sql, String name) {
    int i = 0;
    conn = getConnection(name);
    if (conn == null) {

    }
    try {
      stmt = conn.createStatement();
      i = stmt.executeUpdate(sql);
    }
    catch (SQLException sqle) {

    }
    finally {
      close(name);
      return i;
    }
  }

  /**
   **实现SQL语句的查询功能。
   **参数:完整的SQL语句。
   **返回查询后的结果集，如果出错返回NULL。
   **如果参数为null，则返回null。
   **
   **注意：在每次执行完查询后,必须使用close()释放链接。
   **/
  public ResultSet executeQuery(String sql, String name) {
    if (sql == null) {
      return null;
    }
    conn = getConnection(name);
    if (conn == null) {

    }
    try {
      stmt = conn.createStatement();
      rs = stmt.executeQuery(sql);
      return rs;
    }
    catch (SQLException sqle) {
      return null;
    }
  }

  public void close(String name) {
    try {
      if (rs != null) {
        rs.close();
      }
      if (stmt != null) {
        stmt.close();
      }
      if (conn != null) {
        freeConnection(name, conn);
      }
    }
    catch (SQLException sqle) {}
  }

  /**
   ** 关闭所有连接,撤销驱动程序的注册
   **/
  public void release() {
    DBConMag.release();
  }
}