/**
 * 數據庫查詢組件
 * 根據 SQL 語句獲得查詢結果
 *
 * 數據庫連接功能由其他組件完成（cn.com.huiton.ConnectionPool.ConnectionPool）
 *
 * 使用步驟：
 * 1、創建對象；
 * 2、使用 connect() 方法與數據庫建立連接；
 * 3、進行數據庫操作；
 * 4、使用 disConnect() 方法與數據庫斷開連接；
 * 5、銷毀對象。
 *
 * @@author=吳劍
 */


package com.huiton.pub.dbx;
import java.sql.*;
import com.huiton.cerp.pub.*;

public class JdbQuery
{
        protected Connection m_conn;
    protected Statement m_statement;

    protected int m_scrollType;
    protected int m_updatable;

    public JdbObj preDbObj = null;
    public String m_ErrMsg = "";

        public JdbQuery() {
        m_scrollType = ResultSet.TYPE_SCROLL_SENSITIVE;
        m_updatable = ResultSet.CONCUR_READ_ONLY;
                connect();
    try {
      jbInit();
    }
    catch(Exception e) {
      e.printStackTrace();
    }
        }
        public JdbQuery(int scrollType, int updatable) {
        m_scrollType = scrollType;
        m_updatable = updatable;
                connect();
        }

        public void finalize() {
                disConnect();
        }


        /**
         * ResultSet GetData(String mySql)
         *                                             *						根據 SQL 語句獲取記錄集
         *
         * 返回值：
         *                                             *						ResultSet 記錄集
         *
         * 參數：
     *                      String mySql  SQL語句
         */
        public ResultSet getData(String mySql)
        {
                try {
                        // System.out.println("Native Form: " + m_conn.nativeSQL(mySql));
                        ResultSet rs = m_statement.executeQuery(mySql);

                        return rs;
                }
                catch (Exception e) {
                        disConnect();
                        System.out.println(e.toString());
                        return null;
                }
        }

        /**
         * boolean RunSQL(String mySql)
         *                                             *						執行 SQL 語句
         *
         * 返回值：
         *                                             *						boolean
         *
         * 參數：
     *                      String mySql  SQL語句
         */
        public boolean runSql(String mySql)
        {
                try {
                        // System.out.println("Native Form: " + m_conn.nativeSQL(mySql));
            return m_statement.execute(mySql);
                }
                catch (Exception e) {
                        disConnect();
                        System.out.println(e.toString());
                        return false;
                }
        }

        /**
         * void connect()		與數據庫建立連接
         *
         * 返回值：				void
         *
         * 參數：
         * modify by wt:  2001.7.12 remove pool
         */
        public void connect() {
                if(m_conn!=null) return;

                try {
/*
                        ConnectionPool pool = new ConnectionPool();
                        if(pool.getDriver()==null) {
                            pool.setDriver("sun.jdbc.odbc.JdbcOdbcDriver");
                            pool.setURL("jdbc:odbc:EJBTest");
                            pool.setUsername("cerp95");
                            pool.setPassword("ttbq");
                            pool.setSize(5);
                            pool.initializePool();
                        }

                        m_conn = pool.getConnection();
*/
                        if (!createConnect())
                           throw  (new Exception(m_ErrMsg));
                        m_statement = m_conn.createStatement(m_scrollType, m_updatable);
                }
                catch(Exception e) {
                        disConnect();
            e.printStackTrace();
                }

  }

  /**
   * @Title: 建立數據庫連接對象
   * @Description: 本函數以缺省方式建立數據庫連接對象
   */
  boolean createConnect() throws Exception {
    if (preDbObj != null)
      preDbObj.finalize();  //已經存在對象,消除之
    preDbObj = new JdbObj();    //創建數據連接對象
    if (preDbObj.active(DbConstStr.DEVPASSWORD))  //激活并建立數據庫連接
      m_conn = preDbObj.conn;
    else
      {m_ErrMsg = preDbObj.m_errMsg;
       return false;
      }
   return true;
  }


        /**
         * void disConnect()	斷開數據庫連接
         *
         * 返回值：
         *                                             *						void
         *
         * 參數：
         */
        public void disConnect() {
                try {
                        if(m_conn!=null)
                                m_conn.close();
            if(m_statement!=null)
                m_statement.close();
        }
        catch (SQLException e)
        {
                e.printStackTrace();
        }
    }

    /**
     * 返回數據庫連接對象
     * @return Connection對象
     */
    public Connection getConnection() {
        return m_conn;
    }
  private void jbInit() throws Exception {
  }
}