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();
  }
}