sqldatabase.cs

数据访问框架.用于选择不同数据源的操作.包含了所有的ADO.NET的操作.不知道怎么传多个文件.所以只传了一个文件.第一次来

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;
using System.Data.Common;
namespace ConsoleAbstract
{
    public class SqlDataBase : DataBaseAbstract
    {
         #region connection
        private SqlConnection cn = null;
        public SqlConnection Connect()
        {  
            try
            {
                cn = new SqlConnection(connString);
                if (cn.State != ConnectionState.Open)
                    cn.Open();
            }
            catch (Exception ex)
            {
                throw ex;
            }

            return cn;
        }
        #endregion

         #region method
        public override void Close()
        {
            if(cn.State!= ConnectionState.Closed)
                try
                {
                    cn.Close();
                }
                catch (Exception ex)
                { Console.WriteLine(ex.ToString()); }
        }
        public override object ExecuteScalar(CommandType comandType, string commandText, DbParameter[] par)
        {
            SqlCommand cmd = new SqlCommand();
            if (cmd == null) throw new ArgumentNullException("cmd");
            if (commandText.Equals(string.Empty) || commandText.Length == 0) throw new ArgumentNullException("commandText");
            Connect();
            cmd.Connection = cn;
            cmd.CommandType = comandType;
            cmd.CommandText = commandText;
            if (par != null)
                foreach (SqlParameter p in par)
                    cmd.Parameters.Add(p);
            object var = cmd.ExecuteScalar();
            cmd.Parameters.Clear();
            Close();
            return var;
        }

        public override DataSet GetDataAdapter(CommandType commType, string commandText, DbParameter[] par)
        {
            SqlCommand cmd = new SqlCommand();
            DataSet ds = new DataSet();
            if (cmd == null) throw new ArgumentNullException("cmd");
            if (commandText.Equals(string.Empty) || commandText.Length == 0) throw new ArgumentNullException("commandText");
            Connect();
            cmd.Connection = cn;
            cmd.CommandText = commandText;
            cmd.CommandType = commType;
            if (par != null)
                foreach (SqlParameter p in par)
                    cmd.Parameters.Add(p);
            SqlDataAdapter adp = new SqlDataAdapter(cmd);
            adp.Fill(ds);
            Close();
            return ds;
        }

        public override int ExecuteNonQuery(CommandType commType, string commandText, DbParameter[] par)
        {
            SqlCommand cmd = new SqlCommand();
            if (cmd == null) throw new ArgumentNullException("cmd");
            if (commandText.Equals(string.Empty) || commandText.Length == 0) throw new ArgumentNullException("commandText");
            Connect();
            cmd.Connection = cn;
            cmd.CommandType = commType;
            cmd.CommandText = commandText;
            if (par != null)
                foreach (SqlParameter p in par)
                    cmd.Parameters.Add(p);
            int var = cmd.ExecuteNonQuery();
            Close();
            return var;
        }

        public override DbDataReader ExecuteReader(CommandType commType, string commandText, DbParameter[] par)
        {
            SqlCommand cmd = new SqlCommand();
            if (cmd == null) throw new ArgumentNullException("cmd");
            if (commandText.Equals(string.Empty) || commandText.Length == 0) throw new ArgumentNullException("commandText");
            Connect();
            cmd.Connection = cn;
            cmd.CommandType = commType;
            cmd.CommandText = commandText;
            if (par != null)
                foreach (SqlParameter p in par)
                    cmd.Parameters.Add(p);
            if (cn.State != ConnectionState.Open)
                cn.Open();
            SqlDataReader dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
            return dr;
        }

        protected override DbParameter CreateParameter()
        {
            return new SqlParameter();
        }
        #endregion
    }
}