调用存储过程通用类

using System;
using System.Data;
using System.Data.SqlClient;

namespace Helper
{
    public class ProcedureHelper
    {
        private string connectionString;

        public ProcedureHelper(string strConn)
        {
            connectionString = strConn;
        }

        /// <summary>
        ///     执行存储过程返回DataSet
        /// </summary>
        /// <param name="storedProcName">存储过程名</param>
        /// <param name="parameters">存储过程参数</param>
        /// <param name="tableName">DataSet结果中的表名</param>
        /// <returns>DataSet</returns>
        public DataSet ExecuteDataSet(string storedProcName, IDataParameter[] parameters, string tableName)
        {
            using (var connection = new SqlConnection(connectionString))
            {
                var dataSet = new DataSet();
                connection.Open();
                var sqlDA = new SqlDataAdapter();
                sqlDA.SelectCommand = BuildQueryCommand(connection, storedProcName, parameters);
                sqlDA.Fill(dataSet, tableName);
                connection.Close();
                return dataSet;
            }
        }

        /// <summary>
        ///     执行存储过程返回DataTable
        /// </summary>
        /// <param name="storedProcName">存储过程名</param>
        /// <param name="parameters">存储过程参数</param>
        /// <returns>DataTable</returns>
        public DataTable ExecuteDataTable(string storedProcName, IDataParameter[] parameters)
        {
            using (var connection = new SqlConnection(connectionString))
            {
                var dateTable = new DataTable();
                connection.Open();
                var sqlDA = new SqlDataAdapter();
                sqlDA.SelectCommand = BuildQueryCommand(connection, storedProcName, parameters);
                sqlDA.Fill(dateTable);
                connection.Close();
                return dateTable;
            }
        }

        /// <summary>
        ///     执行存储过程返回受影响行数
        /// </summary>
        /// <param name="storedProcName">存储过程名称</param>
        /// <param name="parameters">存储过程参数</param>
        /// <returns>int</returns>
        public int ExecuteNonQuery(string storedProcName, IDataParameter[] parameters)
        {
            using (var connection = new SqlConnection(connectionString))
            {
                connection.Open();
                var cmd = BuildQueryCommand(connection, storedProcName, parameters);
                int affectedRowsCount = cmd.ExecuteNonQuery();
                return affectedRowsCount;
            }
        }

        /// <summary>
        /// 执行存储过程，并返回查询所返回的结果集中第一行的第一列
        /// </summary>
        /// <param name="storedProcName">存储过程名</param>
        /// <param name="parameters">存储过程参数</param>
        /// <returns>object</returns>
        public object ExecuteScalar(string storedProcName, IDataParameter[] parameters)
        {
            using (var connection = new SqlConnection(connectionString))
            {
                connection.Open();
                var cmd = BuildQueryCommand(connection, storedProcName, parameters);
                object returnValue = cmd.ExecuteScalar();
                return returnValue;
            }
        }

        /// <summary>
        /// 执行查询语句,返回SqlDataReader
        /// </summary>
        /// <param name="storedProcName">存储过程名称</param>
        /// <param name="parameters">存储过程参数</param>
        /// <returns>SqlDataReader</returns>
        public SqlDataReader ExecuteDataReader(string storedProcName, IDataParameter[] parameters)
        {
            using (var connection = new SqlConnection(connectionString))
            {
                connection.Open();
                var cmd = BuildQueryCommand(connection, storedProcName, parameters);
                SqlDataReader myReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
                return myReader;
            }
        }

        /// <summary>
        ///     构建 SqlCommand 对象(用来返回一个结果集，而不是一个整数值)
        /// </summary>
        /// <param name="connection">数据库连接</param>
        /// <param name="storedProcName">存储过程名</param>
        /// <param name="parameters">存储过程参数</param>
        /// <returns>SqlCommand</returns>
        private SqlCommand BuildQueryCommand(SqlConnection connection, string storedProcName,
            IDataParameter[] parameters)
        {
            var command = new SqlCommand(storedProcName, connection);
            command.CommandType = CommandType.StoredProcedure;
            foreach (IDataParameter dataParameter in parameters)
            {
                var parameter = (SqlParameter) dataParameter;
                if (parameter != null)
                {
                    // 检查未分配值的输出参数,将其分配以DBNull.Value.
                    if ((parameter.Direction == ParameterDirection.InputOutput ||
                         parameter.Direction == ParameterDirection.Input) &&
                        (parameter.Value == null))
                    {
                        parameter.Value = DBNull.Value;
                    }
                    command.Parameters.Add(parameter);
                }
            }
            return command;
        }
    }
}