package com.passedbylove.database.core;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Collection;

/** 類(lèi)名：DBOperationAdapter<br>
 * 作用: <b>該類(lèi)中的所有方法對(duì)用戶(hù)透明,提供數(shù)據(jù)庫(kù)操作的常用方法</b><br>
 * 
 * 說(shuō)明：該類(lèi)使用了<b>Adapter</b> 模式與 <b>Singleton</b> 模式,<br/>
 * 類(lèi)自身為Adpater,OperationCoreImplements為Adapte類(lèi);<br>
 * 實(shí)例化類(lèi)自生對(duì)象的時(shí)候用到了Singleton模式,<br>
 * 即<code>DBOperationAdapter.getInstance()</code><br>
 * 創(chuàng)建人：被愛(ài)情路過(guò)<br>
 * 創(chuàng)建日期：2008.11.11<br> */
public class DBOperationAdapter extends ConnectionFactory {
   private static IOperationCore objIOperationCore = null;
   private static DBOperationAdapter m_instance = null;
   
   private DBOperationAdapter() {
   	try {
   		objIOperationCore=OperationCoreImpl.createFactory();
   	} catch (Exception e) {
   		e.printStackTrace();
   	}
   }
   
   public static DBOperationAdapter getInstance() {
   	if(m_instance==null)
   		m_instance=new DBOperationAdapter();
   	return m_instance;
   }
   
   /** sql更新語(yǔ)句
    * 
    * @param queryString 查詢(xún)語(yǔ)句
    * @return 返回一個(gè)<code>ResultSet</code>結(jié)果集
    * 
    * @exception SQLException */
   public ResultSet executeQuery(String queryString) throws SQLException {
   	return objIOperationCore.executeQuery(queryString);
   }
   
   /**  sql更新語(yǔ)句
    * 
    * @param updateString 數(shù)據(jù)庫(kù)更新語(yǔ)句
    * @return 更新數(shù)據(jù)庫(kù)影響行數(shù)
    * 
    * @exception SQLException */
   public int executeUpdate(String updateString) throws SQLException {
    return objIOperationCore.executeUpdate(updateString);
   }
   
   /**  sql刪除語(yǔ)句:updateString
    * 
    * @param deleteString 數(shù)據(jù)庫(kù)插入語(yǔ)句
    * @return 刪除數(shù)據(jù)影響行數(shù)
    * 
    * @exception SQLException */
   public int executeDelete(String deleteString) throws SQLException {
    return objIOperationCore.executeUpdate(deleteString);
   }
   
   /**  sql插入語(yǔ)句:insertString
    * 
    * @param insertString 數(shù)據(jù)庫(kù)插入語(yǔ)句
    * @return 插入數(shù)據(jù)影響行數(shù)
    * 
    * @exception SQLException */
   public int executeInsert(String insertString) throws SQLException {
    return objIOperationCore.executeUpdate(insertString);
   }
   
   /** 
    * 讀取行個(gè)數(shù)
    * 
    * @param queryString 查詢(xún)語(yǔ)句
    * @return Transact-SQL 查詢(xún)后的虛擬表的行數(shù)
    * 
    * @exception SQLException */
   public int getRowCount(String queryString) throws SQLException {
   	return objIOperationCore.getRowCount(queryString);
   }
   
   /** 讀取列數(shù)個(gè)數(shù)
    * 
    * @param queryString 查詢(xún)語(yǔ)句
    * @return Transact-SQL 查詢(xún)后的虛擬表的列數(shù)
    * 
    * @exception SQLException */
   public int getColumnCount(String queryString) throws SQLException {
    return objIOperationCore.getColumnCount(queryString);
   }
   
   /** 
    * 讀取列名
    * 
    * @param columIndex 列索引
    * @param queryString 提供ResultSet二維表的查詢(xún)字符串
    * @return ResultSet表中的指定的列名
    * 
    * @exception SQLException */
   public String getColumnName(int columIndex, String queryString) throws SQLException {
      return objIOperationCore.getColumnName(columIndex, queryString);
     }
   
   /** 
    * 讀取queryString查詢(xún)結(jié)果集<code>ResultSet</code>表中的所有字段類(lèi)型名稱(chēng)
    * 
    * @param queryString 用于返回查詢(xún)結(jié)果集的語(yǔ)句
    * @return 表中的所有字段類(lèi)型名稱(chēng)
    * @throws SQLException */
   public Collection<?> getColumnTypeNames(String queryString) throws SQLException {
    return objIOperationCore.getColumnTypeNames(queryString);
   }
   
   /** 
    * 讀取queryString查詢(xún)結(jié)果集<code>ResultSet</code>表中的所有列名
    * 
    * @param queryString 用于返回<code>ResultSet</code>結(jié)果集的語(yǔ)句
    * @return 表中的所有列名
    * @throws SQLException */
   public Collection<String> getColumnNames(String queryString) throws SQLException {
    return objIOperationCore.getColumnNames(queryString);
   }
   
   /** 
    * 獲取ResultSet二維表中指定位置的值,目前只支持mysql
    * 
    * @param rowIndex 行索引 
    * @param columnIndex 列索引
    * @param queryString 產(chǎn)生一個(gè)ResultSet結(jié)果集的查詢(xún)語(yǔ)句
    * @return 指定位置的數(shù)據(jù)記錄
    * 
    * @exception SQLException */
   public Object getValueAt(int rowIndex, int columnIndex, String queryString) throws SQLException {
    return objIOperationCore.getValueAt(rowIndex, columnIndex,queryString);
   }
   
   /** 
    * 釋放系統(tǒng)連接資源
    * 
    * @exception SQLException 如果關(guān)閉失敗將拋出<code>SQLException</code>*/
   public void dispose() throws SQLException {
    objIOperationCore.dispose();
   }

}