package com.ntsky.note;

import java.io.*;
import java.sql.*;
import java.util.*;

import com.ntsky.note.Debug;
import com.ntsky.note.DBConnectionManager;

/**
 * <p>Title: NTsky新聞發(fā)布</p>
 * <p>Description: 數(shù)據(jù)庫(kù)操作</p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Company: NTsky</p>
 * @authory 姚君林
 * @version 1.0
 */

public class SQLDBOperator extends DBOperator {

	private DBConnectionManager conManager;
	private String poolName;
    private PreparedStatement prepstmt=null;
	private Connection conn;
	private static SQLDBOperator instance;

    /**
     * 構(gòu)造函數(shù)[從連接池取得連接]
     */
    private SQLDBOperator(String strKey){
        this.poolName = strKey;
        //調(diào)用getInstance()方法獲得對(duì)連接池唯一實(shí)例的引用。
        this.conManager = DBConnectionManager.getInstance();
        this.conn = conManager.getConnection(strKey);
    }

    /**
     * 關(guān)閉數(shù)據(jù)庫(kù)連接
     */
    public void Close() {
        try{
            conManager.freeConnection(this.poolName, this.conn);
        }
        catch(Exception e){
            e.printStackTrace(System.out);
        }
    }

    /**
     * 數(shù)據(jù)更新(插入&修改&刪除)
     * @param strSql
     */

    public void executeUpdate(String strSql){
        try{
            //strSql=new String(strSql.getBytes("GBK"),"ISO8859_1");
            Statement stmt = this.conn.createStatement();
            stmt.executeUpdate(strSql);
        }
        catch(Exception e){
            e.printStackTrace(System.out);
            Debug.writeLog("In executeUpdate(String), Exception Occured ! Info :" + e.getLocalizedMessage());
        }
    }
     /**
      * 數(shù)據(jù)查詢
      * @param sql
      * @return rs
      */

     public ResultSet executeQuery(String strSql) {
         ResultSet rs=null;
         try{
             //strSql=new String(strSql.getBytes("GBK"),"ISO8859_1");
             Statement stmt = this.conn.createStatement();
             rs = stmt.executeQuery(strSql);
         }
         catch(Exception e){
             e.printStackTrace(System.out);
             Debug.writeLog("In executeQuery(String), Exception Occured ! Info :" + e.getLocalizedMessage());
         }
         return rs;
     }

     /**
      * 帶參數(shù)的數(shù)據(jù)操作
      * @param strSql
      */
     /**
      * 創(chuàng)建數(shù)據(jù)庫(kù)操作的對(duì)象
      * @param strSql
      */
     public void prepareStatement(String strSql){
         try{
             prepstmt = this.conn.prepareStatement(strSql);
         }
         catch(Exception e){
             e.printStackTrace(System.out);
             Debug.writeLog("In prepareStatement(String strSql), Exception Occured ! Info :" + e.getLocalizedMessage());
         }
    }
    /**
     * 參數(shù)設(shè)置
     */
    //字符串
    public void setString(int index,String value){
        try{
            //value = new String(value.getBytes("GBK"), "ISO8859_1");
            prepstmt.setString(index, value);
        }
        catch(Exception e){
            e.printStackTrace(System.out);
            Debug.writeLog("In setString(int index,String value), Exception Occured ! Info :" + e.getLocalizedMessage());
        }
    }
    //整數(shù)
    public void setInt(int index,int value){
        try{
            prepstmt.setInt(index, value);
        }
        catch(Exception e){
            e.printStackTrace(System.out);
            Debug.writeLog("In setInt(int index,int value), Exception Occured ! Info :" + e.getLocalizedMessage());
        }
    }
    //清除接口包含SQL語(yǔ)句當(dāng)前所用的全部參數(shù)
    public void clearParameters(){
        try{
            prepstmt.clearParameters();
            prepstmt=null;
        }
        catch(Exception e){
            e.printStackTrace(System.out);
            Debug.writeLog("In clearParameters(), Exception Occured ! Info :" + e.getLocalizedMessage());
        }
    }
    //返回prepstmt
    public PreparedStatement getPreparedStatement(){
        return prepstmt;
    }

     /**
      * 數(shù)據(jù)更新(帶參數(shù))
      */
     public void executeUpdate(){
         try{
             if(prepstmt!=null){
                 prepstmt.executeUpdate();
             }
         }
         catch(Exception e){
             e.printStackTrace(System.out);
             Debug.writeLog("In executeUpdate(String), Exception Occured ! Info :" + e.getLocalizedMessage());
         }
     }
     /**
      * 數(shù)據(jù)查詢（帶參數(shù)）
      * @return rs
      */
     public ResultSet executeQuery(){
         ResultSet rs=null;
         try{
             if(prepstmt!= null){
                 rs = prepstmt.executeQuery();
             }
         }
         catch(Exception e){
             e.printStackTrace(System.out);
             Debug.writeLog("In executeQuery(String), Exception Occured ! Info :" + e.getLocalizedMessage());
         }
         return rs;
     }
     /**
      * getConnection 方法注解。
      */

     public Connection getConnection() {
         return this.conn;
     }

     public static SQLDBOperator getInstance(String strKey){
         if (instance==null)
             instance = new SQLDBOperator(strKey);
         return instance;//返回一個(gè)SQLDBOperator對(duì)象
     }
 }