/**********************************************************
 * 說明：MyChatRoom的數據操作層
 * 作者：
 * 創建日期：
 *********************************************************/

using System;
using System.ComponentModel;
using System.Collections;
using System.Diagnostics;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;


namespace MyChatRoom.DataAccessLayer
{
	/// <summary>
	/// 數據訪問類
	/// </summary>
	public class Database : IDisposable 
	{
		/// <summary>
		/// 保護變量，數據庫連接。
		/// </summary>
		protected SqlConnection Connection;

		/// <summary>
		/// 保護變量，數據庫連接串。
		/// </summary>
		protected String ConnectionString;

		/// <summary>
		/// 構造函數。
		/// </summary>
		/// <param name="DatabaseConnectionString">數據庫連接串</param>
		public Database()
		{
			ConnectionString = ConfigurationManager.AppSettings["DBConnectionString"];
		}		

		/// <summary>
		/// 析構函數，釋放非托管資源
		/// </summary>
		~Database()
		{
			try
			{
				if (Connection != null)
					Connection.Close();
			}
			catch{}
			try
			{
				Dispose();
			}
			catch{}
		}

		/// <summary>
		/// 保護方法，打開數據庫連接。
		/// </summary>
		protected void Open() 
		{
			if (Connection == null)
			{
				Connection = new SqlConnection(ConnectionString);
			}
			if (Connection.State.Equals(ConnectionState.Closed))
			{
				Connection.Open();
			}
		}

		/// <summary>
		/// 公有方法，關閉數據庫連接。
		/// </summary>
		public void Close() 
		{
			if (Connection != null)
				Connection.Close();
		}

		/// <summary>
		/// 公有方法，釋放資源。
		/// </summary>
		public void Dispose() 
		{
			// 確保連接被關閉
			if (Connection != null) 
			{
				Connection.Dispose();
				Connection = null;
			}				
		}

		/// <summary>
		/// 公有方法，獲取數據，返回一個DataSet。
		/// </summary>
		/// <param name="SqlString">Sql語句</param>
		/// <returns>DataSet</returns>
		public DataSet GetDataSet(String SqlString)
		{
			Open();
			SqlDataAdapter adapter = new SqlDataAdapter(SqlString,Connection);
			DataSet dataset = new DataSet();
			adapter.Fill(dataset);
			Close();
			return dataset;
		}

		/// <summary>
		/// 公有方法，獲取數據，返回一個DataRow。
		/// </summary>
		/// <param name="SqlString">Sql語句</param>
		/// <returns>DataRow</returns>
		public DataRow GetDataRow(String SqlString)
		{
			DataSet dataset = GetDataSet(SqlString);
			dataset.CaseSensitive = false;
			if (dataset.Tables[0].Rows.Count>0)
			{
				return dataset.Tables[0].Rows[0];
			}
			else
			{
				return null;
			}
		}

		/// <summary>
		/// 公有方法，執行Sql語句。
		/// </summary>
		/// <param name="SqlString">Sql語句</param>
		/// <returns>對Update、Insert、Delete為影響到的行數，其他情況為-1</returns>
		public int ExecuteSQL(String SqlString)
		{
			int count = -1;
			Open();
			try
			{
				SqlCommand cmd = new SqlCommand(SqlString,Connection);
				count = cmd.ExecuteNonQuery();
			}
			catch
			{
				count = -1;
			}
			finally
			{
				Close();
			}
			return count;
		}

	}
}