using System;
using System.Collections.Generic;
using System.Text;
using System.IO;

using System.Data;
using System.Data.OracleClient ;

namespace IDbAccess
{
    //Oracle 數據庫訪問類
    class OracleDbAccess : IDbAccess
    {
        private OracleConnection conn; //數據庫連接對象

        private OracleTransaction trans;   //事務處理對象

        private bool inTransaction = false; //true表示當前正處于事務中
        

        public IDbConnection Connection
        {
            get
            {
                return this.conn;
            }
        }

        public OracleDbAccess(string strConnection)  
        {
            this.conn = new OracleConnection(strConnection);
        }    
        
        public void Open()
        {
            if (conn.State != ConnectionState.Open)
            {
                this.conn.Open();
            }
        }
        
        public void Close()
        {
            if (conn.State == ConnectionState.Open)
            {
                this.conn.Close();
            }
        }
        
        public void BeginTrans()
        {
            trans = conn.BeginTransaction();
            inTransaction = true;
        }

        public void CommitTrans()
        {
            trans.Commit();
            inTransaction = false;
        }

        public void RollbackTrans()
        {
            trans.Rollback();
            inTransaction = false;
        }

        public void ExecSQLNoDataSet(string strSql, string[] strParams, object[] strValues)
        {
            
            OracleCommand cmd = new OracleCommand();
            cmd.Connection = this.conn;
            if (inTransaction)
            {
                cmd.Transaction = trans;
            }
            if ((strParams != null) && (strParams.Length != strValues.Length))
            {
                throw new Exception("查詢參數和值不對應!");
            }
            cmd.CommandText = strSql;
            if (strParams != null)
            {
                for (int i = 0; i < strParams.Length; i++)
                {
                    cmd.Parameters.Add(strValues[i]);
                }
            }
            cmd.ExecuteNonQuery();
            
        }
        public void ExecSQLNoDataSet(string strSql)
        {
            OracleCommand cmd = new OracleCommand();
            cmd.Connection = this.conn;
            if (inTransaction)
            {
                cmd.Transaction = trans;
            }
            cmd.CommandText = strSql;
            cmd.ExecuteNonQuery();
        }
        
        public DataSet ExecSQLGetDataSet(string QueryString)
        {
            OracleCommand cmd = new OracleCommand();
            cmd.Connection = this.conn;
            if (inTransaction)
            {
                cmd.Transaction = trans;
            }
            DataSet ds = new DataSet();
            OracleDataAdapter ad = new OracleDataAdapter();
            cmd.CommandText = QueryString;
            ad.SelectCommand = cmd;
            ad.Fill(ds);
            return ds;
        }
    } 

}