封装好的ORM

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;

using System.Data;
using System.Data.Common;
using System.Data.SqlClient;
using System.Diagnostics;

namespace WebApplication.DAL.Provider
{
    static class DbExtension
    {
        public static DbParameter AddWithValue(this DbParameterCollection parameters, string parameterName, string value)
        {
            return (parameters as SqlParameterCollection).AddWithValue(parameterName, value);
        }
    }

    class SqlProvider : SqlProviderBase<DbConnection, DbCommand, DbParameter, DbDataReader, DbDataAdapter>, IProvider.ISqlProvider
    {
        public new string Name { get { return "Sql provider"; } }
        public new string Description { get { return "Sql provider class"; } }

        protected override DbConnection DbConnection { get; set; }

        protected override DbCommand DbSelectCommand { get; set; }
        protected override DbCommand DbInsertCommand { get; set; }
        protected override DbCommand DbUpdateCommand { get; set; }
        protected override DbCommand DbDeleteCommand { get; set; }

        protected override DbDataReader DbDataReader { get; set; }
        protected override DbDataAdapter DbAdapter { get; set; }

        public override string ConnectionString { get; set; }

        public SqlProvider()
        {
            ConnectionStringSetting = "BusinessServices";
        }
        protected override DbConnection CreateDatabaseProvide()
        {
            //定义连接对象
            DbConnection = new SqlConnection(ConnectionString);

            //定义命令主机
            DbSelectCommand = new SqlCommand("", DbConnection as SqlConnection);
            DbInsertCommand = new SqlCommand("", DbConnection as SqlConnection);
            DbUpdateCommand = new SqlCommand("", DbConnection as SqlConnection);
            DbDeleteCommand = new SqlCommand("", DbConnection as SqlConnection);

            //将命令主机加入数据适配器
            DbAdapter = new SqlDataAdapter(DbSelectCommand as SqlCommand);
            DbAdapter.InsertCommand = DbInsertCommand;
            DbAdapter.UpdateCommand = DbUpdateCommand;
            DbAdapter.DeleteCommand = DbDeleteCommand;

            return DbConnection;
        }

        protected override DbParameter CreateDbParameter(string parameterName, object value)
        {
            return new SqlParameter(parameterName, value);
        }

        protected override void SetParameters(DbCommand command, IDictionary<string, object> parameters)
        {
            command.Parameters.Clear();
            if (parameters == null) return;
            foreach (KeyValuePair<string, object> Parameter in parameters)
                (command as SqlCommand).Parameters.AddWithValue(Parameter.Key, NullToDBNull(Parameter.Value));
        }

        //执行
        public virtual int ExecuteNonQuery(string sql)
        {
            int Result;
            using (DbConnection DBConnection = CreateDatabaseProvide())
            {
                //CreateDatabaseProvide(DBConnection);
                DBConnection.Open();

                DbSelectCommand.CommandText = sql;
                DbSelectCommand.CommandType = System.Data.CommandType.Text;

                //SetParameters(DBCommonCommand, parametersInstance);
                try
                {
                    Result = DbSelectCommand.ExecuteNonQuery();
                }
                finally
                {
                    if (DBConnection.State == System.Data.ConnectionState.Open) DBConnection.Close();
                    DbSelectCommand.Dispose();
                }
            }
            return Result;
        }
        //执行存储过程
        public virtual int ExecuteNonQueryByProcedure(System.Collections.Generic.Dictionary<string, object> parametersInstance, string storedProcedureName)
        {
            int Result;
            using (DbConnection DBConnection = CreateDatabaseProvide())
            {
                DBConnection.Open();

                DbSelectCommand.CommandText = storedProcedureName;
                DbSelectCommand.CommandType = System.Data.CommandType.StoredProcedure;

                SetParameters(DbSelectCommand, parametersInstance);
                if (DbSelectCommand.Parameters.Contains("@Errcode"))
                    DbSelectCommand.Parameters["@Errcode"].Direction = ParameterDirection.Output;
                if (DbSelectCommand.Parameters.Contains("@ErrMng"))
                {
                    DbSelectCommand.Parameters["@ErrMng"].Size = 500;
                    DbSelectCommand.Parameters["@ErrMng"].Direction = ParameterDirection.Output;
                }
                try
                {
                    Result = DbSelectCommand.ExecuteNonQuery();
                    if (DbSelectCommand.Parameters.Contains("@ErrMng") && DbSelectCommand.Parameters["@ErrMng"].Value.ToString() != "")
                    {
                        throw new Exception(DbSelectCommand.Parameters["@ErrMng"].Value.ToString());
                    }
                }
                finally
                {
                    if (DBConnection.State == System.Data.ConnectionState.Open) DBConnection.Close();
                    DbSelectCommand.Dispose();
                }
            }
            return Result;
        }
        //循环执行存储过程，添加了事务
        public virtual bool ExecuteNonQueryByProcedureList(List<System.Collections.Generic.Dictionary<string, object>> parametersInstance, string storedProcedureName)
        {
            SqlConnection conn = new SqlConnection(ConnectionString);
            conn.Open();

            using (SqlTransaction tran = conn.BeginTransaction())
            {
                SqlCommand cmd = new SqlCommand(storedProcedureName, conn, tran);
                cmd.CommandType = System.Data.CommandType.StoredProcedure;
                try
                {
                    foreach (System.Collections.Generic.Dictionary<string, object> ht in parametersInstance)
                    {
                        SetParameters(cmd, ht);
                        cmd.ExecuteNonQuery();
                    }
                    tran.Commit();
                }
                catch (Exception e)
                {
                    tran.Rollback();
                    return false;
                }
                finally
                {
                    if (conn.State == System.Data.ConnectionState.Open) conn.Close();
                    cmd.Dispose();
                }
            }
            return true;
        }
        //执行存储过程返回Table
        public virtual System.Data.DataTable ExecStoredProcedure(System.Collections.Generic.Dictionary<string, object> parametersInstance, string storedProcedureName)
        {
            System.Data.DataSet ds = new System.Data.DataSet();
            using (DbConnection DBConnection = CreateDatabaseProvide())
            {
                //CreateDatabaseProvide(DBConnection);
                DBConnection.Open();

                DbSelectCommand.CommandText = storedProcedureName;
                DbSelectCommand.CommandType = System.Data.CommandType.StoredProcedure;

                //SqlDataAdapter dap = new SqlDataAdapter(DbSelectCommand);
                SetParameters(DbSelectCommand, parametersInstance);
                //DbSelectCommand.Parameters.Add(new SqlParameter("@Errcode", SqlDbType.Int));
                if (DbSelectCommand.Parameters.Contains("@Errcode"))
                    DbSelectCommand.Parameters["@Errcode"].Direction = ParameterDirection.Output;
                if (DbSelectCommand.Parameters.Contains("@ErrMng"))
                {
                    DbSelectCommand.Parameters["@ErrMng"].Size = 500;
                    DbSelectCommand.Parameters["@ErrMng"].Direction = ParameterDirection.Output;
                }
                try
                {
                    DbAdapter.Fill(ds, "ReturnTable");
                    if (DbSelectCommand.Parameters.Contains("@ErrMng") && DbSelectCommand.Parameters["@ErrMng"].Value.ToString() != "")
                    {
                        throw new Exception(DbSelectCommand.Parameters["@ErrMng"].Value.ToString());
                    }
                }
                finally
                {
                    if (DBConnection.State == System.Data.ConnectionState.Open) DBConnection.Close();
                    DbSelectCommand.Dispose();
                }
            }
            if (ds.Tables.Count == 0) return null;
            return ds.Tables["ReturnTable"];
        }
        //执行存储过程返回Table
        public virtual System.Data.DataSet ExecStoredProcedureDataSet(System.Collections.Generic.Dictionary<string, object> parametersInstance, string storedProcedureName)
        {
            System.Data.DataSet ds = new System.Data.DataSet();
            using (DbConnection DBConnection = CreateDatabaseProvide())
            {
                //CreateDatabaseProvide(DBConnection);
                DBConnection.Open();

                DbSelectCommand.CommandText = storedProcedureName;
                DbSelectCommand.CommandType = System.Data.CommandType.StoredProcedure;

                //SqlDataAdapter dap = new SqlDataAdapter(DbSelectCommand);
                SetParameters(DbSelectCommand, parametersInstance);
                //DbSelectCommand.Parameters.Add(new SqlParameter("@Errcode", SqlDbType.Int));
                if (DbSelectCommand.Parameters.Contains("@Errcode"))
                    DbSelectCommand.Parameters["@Errcode"].Direction = ParameterDirection.Output;
                if (DbSelectCommand.Parameters.Contains("@ErrMng"))
                {
                    DbSelectCommand.Parameters["@ErrMng"].Size = 500;
                    DbSelectCommand.Parameters["@ErrMng"].Direction = ParameterDirection.Output;
                }
                try
                {
                    DbAdapter.Fill(ds, "ReturnTable");
                    if (DbSelectCommand.Parameters.Contains("@ErrMng") && DbSelectCommand.Parameters["@ErrMng"].Value.ToString() != "")
                    {
                        throw new Exception(DbSelectCommand.Parameters["@ErrMng"].Value.ToString());
                    }
                }
                finally
                {
                    if (DBConnection.State == System.Data.ConnectionState.Open) DBConnection.Close();
                    DbSelectCommand.Dispose();
                }
            }
            if (ds.Tables.Count == 0) return null;
            return ds;
        }
        //执行SQL语句返回Table
        public virtual System.Data.DataTable ExecByText(string sqlText)
        {
            System.Data.DataSet ds = new System.Data.DataSet();

            using (DbConnection DBConnection = CreateDatabaseProvide())
            {
                DBConnection.Open();

                DbSelectCommand.CommandText = sqlText;
                DbSelectCommand.CommandTimeout = 0;
                DbSelectCommand.CommandType = System.Data.CommandType.Text;

                //SqlDataAdapter dap = new SqlDataAdapter(DbSelectCommand);
                //SetParameters(DbSelectCommand, parametersInstance);
                try
                {
                    DbAdapter.Fill(ds, "ReturnTable");
                }
                finally
                {
                    if (DBConnection.State == System.Data.ConnectionState.Open) DBConnection.Close();
                    DbSelectCommand.Dispose();
                }
            }
            if (ds.Tables.Count == 0) return null;
            return ds.Tables["ReturnTable"];
        }
        //调用表值函数
        public virtual System.Data.DataTable RowsetFunction(System.Collections.Generic.Dictionary<string, object> parametersInstance, string cmdText)
        {
            System.Data.DataTable DataTableInstance = new System.Data.DataTable("ReturnTable");
            using (DbConnection DBConnection = CreateDatabaseProvide())
            {
                DBConnection.Open();

                DbSelectCommand.CommandText = cmdText;
                DbSelectCommand.CommandType = System.Data.CommandType.Text;
                SetParameters(DbSelectCommand, parametersInstance);
                try
                {
                    DbAdapter.Fill(DataTableInstance);
                }
                finally
                {
                    if (DBConnection.State == System.Data.ConnectionState.Open) DBConnection.Close();
                    DbSelectCommand.Dispose();
                }
            }
            return DataTableInstance;
        }
        //调用标量函数
        public virtual object AggregateFunction(System.Collections.Generic.Dictionary<string, object> parametersInstance, string cmdText)
        {
            object ReturnResult;
            object ReturnValue;

            using (DbConnection DBConnection = CreateDatabaseProvide())
            {
                //CreateDatabaseProvide(DBConnection);
                DBConnection.Open();

                DbSelectCommand.CommandText = cmdText;
                DbSelectCommand.CommandType = System.Data.CommandType.Text;

                SetParameters(DbSelectCommand, parametersInstance);
                try
                {
                    ReturnValue = DbSelectCommand.ExecuteScalar();
                }
                finally
                {
                    if (DBConnection.State == System.Data.ConnectionState.Open) DBConnection.Close();
                    DbSelectCommand.Dispose();
                }
            }
            ReturnResult = ReturnValue.ToString();
            if (ReturnValue == DBNull.Value)
                ReturnResult = "";

            return ReturnResult;
        }
        /// <summary>
        /// 批量插入数据(适用范围为DataTable列和数据表字段一一对应)
        /// </summary>
        /// <param name="tableName">数据库表名</param>
        /// <param name="dtSource">数据源</param>
        /// <returns>运行时间</returns>
        public long SqlBulkCopyInsert(string tableName, DataTable dtSource)
        {
            Stopwatch stopwatch = new Stopwatch();
            stopwatch.Start();

            using (SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(ConnectionString))
            {
                sqlBulkCopy.DestinationTableName = tableName;
                sqlBulkCopy.BatchSize = dtSource.Rows.Count;
                try
                {
                    if (dtSource != null && dtSource.Rows.Count != 0)
                    {
                        sqlBulkCopy.WriteToServer(dtSource);
                    }
                    sqlBulkCopy.Close();
                    stopwatch.Stop();
                    return stopwatch.ElapsedMilliseconds;
                }
                catch (Exception er)
                {
                    sqlBulkCopy.Close();
                    stopwatch.Stop();
                    throw er;
                }
            }
        }
        /// <summary>
        /// 批量插入数据
        /// </summary>
        /// <param name="tableName">数据库表名</param>
        /// <param name="dtSource">数据源</param>
        /// <param name="ColumnsMapping">列映射。key为DataTable列名称；value为表字段</param>
        /// <returns>运行时间</returns>
        public long SqlBulkCopyInsert(string tableName, DataTable dtSource, Dictionary<string, string> ColumnsMapping)
        {
            if (dtSource == null && dtSource.Rows.Count == 0) throw new Exception("数据源为null或者记录为空");
            Stopwatch stopwatch = new Stopwatch();
            stopwatch.Start();

            using (SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(ConnectionString))
            {
                sqlBulkCopy.DestinationTableName = tableName;
                sqlBulkCopy.BatchSize = dtSource.Rows.Count;

                foreach (KeyValuePair<string, string> keyValue in ColumnsMapping)
                {
                    sqlBulkCopy.ColumnMappings.Add(keyValue.Key, keyValue.Value);
                }
                try
                {
                    sqlBulkCopy.WriteToServer(dtSource);
                    sqlBulkCopy.Close();
                    stopwatch.Stop();
                    return stopwatch.ElapsedMilliseconds;
                }
                catch (Exception er)
                {
                    sqlBulkCopy.Close();
                    stopwatch.Stop();
                    throw er;
                }
            }
        }
    }
}