C# ado.net sqlhelper

    /// <summary>
    /// ado.net方式执行sql语句
    /// </summary>
    public class SqlHelper
    {
        /// <summary>
        /// 执行sql语句，进行查询操作（推荐）
        /// </summary>
        /// <param name="sqlStr">sql语句</param>
        /// <param name="parm">参集合数</param>
        /// <returns>dataset结果集</returns>
        public static DataSet ExcuteSqlDataSet(string sqlStr, string conStr, params SqlParameter[] param)
        {
            try
            {
                conStr = string.IsNullOrWhiteSpace(conStr) ? Connection.SqlConnetionStr() : conStr;
                using (SqlConnection conn = new SqlConnection(conStr))
                {
                    conn.Open();
                    using (SqlCommand cmd = conn.CreateCommand())
                    {
                        cmd.CommandText = sqlStr;
                        if (param != null)
                        {
                            foreach (var item in param)
                            {
                                if (!string.IsNullOrWhiteSpace(item.Value.ToString_()))
                                {
                                    cmd.Parameters.Add(item);
                                }
                                else
                                {
                                    item.Value = DBNull.Value;
                                    cmd.Parameters.Add(item);
                                }
                            }
                        }
                        //cmd.Parameters.AddRange(parm);
                        cmd.CommandTimeout = 180;
                        SqlDataAdapter adapter = new SqlDataAdapter(cmd);
                        DataSet dataset = new DataSet();
                        //cmd.Prepare();
                        adapter.Fill(dataset);
                        cmd.Parameters.Clear();
                        return dataset;
                    }
                }
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 执行sql语句，进行查询操作（推荐）
        /// </summary>
        /// <param name="sqlStr">sql语句</param>
        /// <param name="parm">参集合数</param>
        /// <returns>dataset结果集</returns>
        public static DataSet ExcuteSqlDataSet2(string sqlStr, string conStr, List<SqlParameter> param)
        {
            try
            {
                conStr = string.IsNullOrWhiteSpace(conStr) ? Connection.SqlConnetionStr() : conStr;
                using (SqlConnection conn = new SqlConnection(conStr))
                {
                    conn.Open();
                    using (SqlCommand cmd = conn.CreateCommand())
                    {
                        cmd.CommandText = sqlStr;
                        if (param != null)
                        {
                            foreach (var item in param)
                            {
                                if (!string.IsNullOrWhiteSpace(item.Value.ToString_()))
                                {
                                    cmd.Parameters.Add(item);
                                }
                                else
                                {
                                    item.Value = DBNull.Value;
                                    cmd.Parameters.Add(item);
                                }
                            }
                        }
                        //cmd.Parameters.AddRange(parm);
                        cmd.CommandTimeout = 180;
                        SqlDataAdapter adapter = new SqlDataAdapter(cmd);
                        DataSet dataset = new DataSet();
                        //cmd.Prepare();
                        adapter.Fill(dataset);
                        cmd.Parameters.Clear();
                        return dataset;
                    }
                }
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 执行sql语句，执行增删改操作
        /// </summary>
        /// <param name="sql">sql语句</param>
        /// <param name="param">参数集合</param>
        /// <returns>受影响条数</returns>
        public static int ExecuteNonQuery(string sql, string conStr, params SqlParameter[] param)
        {
            try
            {
                conStr = string.IsNullOrWhiteSpace(conStr) ? Connection.SqlConnetionStr() : conStr;
                int n = -1;
                using (SqlConnection con = new SqlConnection(conStr))
                {
                    using (SqlCommand cmd = new SqlCommand(sql, con))
                    {
                        if (param != null)
                        {
                            foreach (var item in param)
                            {
                                if (!string.IsNullOrWhiteSpace(item.Value.ToString_()))
                                {
                                    cmd.Parameters.Add(item);
                                }
                                else
                                {
                                    item.Value = DBNull.Value;
                                    cmd.Parameters.Add(item);
                                }
                            }
                        }
                        //cmd.Parameters.AddRange(param);
                        con.Open();
                        n = cmd.ExecuteNonQuery();
                    }
                }
                return n;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 执行sql语句，执行增删改操作
        /// </summary>
        /// <param name="sql">sql语句</param>
        /// <param name="param">参数集合</param>
        /// <returns>受影响条数</returns>
        public static int ExecuteNonQuery2(string sql, string conStr, List<SqlParameter> param)
        {
            try
            {
                conStr = string.IsNullOrWhiteSpace(conStr) ? Connection.SqlConnetionStr() : conStr;
                int n = -1;
                using (SqlConnection con = new SqlConnection(conStr))
                {
                    using (SqlCommand cmd = new SqlCommand(sql, con))
                    {
                        if (param != null)
                        {
                            foreach (var item in param)
                            {
                                if (!string.IsNullOrWhiteSpace(item.Value.ToString_()))
                                {
                                    cmd.Parameters.Add(item);
                                }
                                else
                                {
                                    item.Value = DBNull.Value;
                                    cmd.Parameters.Add(item);
                                }
                            }
                        }
                        //cmd.Parameters.AddRange(param);
                        con.Open();
                        n = cmd.ExecuteNonQuery();
                    }
                }
                return n;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// SqlBulkCopy批量插入数据
        /// </summary>
        /// <param name="connectionStr">链接字符串</param>
        /// <param name="dataTableName">表名</param>
        /// <param name="sourceDataTable">数据源</param>
        /// <param name="batchSize">一次事务插入的行数</param>
        public static void BulkCopy(string connectionStr, string dataTableName, DataTable sourceDataTable, int batchSize = 100000)
        {
            connectionStr = string.IsNullOrWhiteSpace(connectionStr) ? Connection.SqlConnetionStr() : connectionStr;

            using (SqlConnection connection = new SqlConnection(connectionStr))
            {
                using (SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(connectionStr, SqlBulkCopyOptions.UseInternalTransaction))
                {
                    try
                    {
                        sqlBulkCopy.DestinationTableName = dataTableName;
                        sqlBulkCopy.BatchSize = batchSize;
                        for (int i = 0; i < sourceDataTable.Columns.Count; i++)
                        {
                            sqlBulkCopy.ColumnMappings.Add(sourceDataTable.Columns[i].ColumnName, sourceDataTable.Columns[i].ColumnName);
                        }
                        sqlBulkCopy.WriteToServer(sourceDataTable);
                    }
                    catch (Exception ex)
                    {
                        throw ex;
                    }
                }
            }
        }

        /// <summary>
        /// 执行存储过程，返回DataSet
        /// </summary>
        /// <param name="storedProcedure"></param>
        /// <param name="conStr"></param>
        /// <param name="param"></param>
        /// <returns></returns>
        public static DataSet ExcuteStoredProcedure(string storedProcedure, string conStr, List<SqlParameter> param)
        {
            try
            {
                conStr = string.IsNullOrWhiteSpace(conStr) ? Connection.SqlConnetionStr() : conStr;

                using (SqlConnection conn = new SqlConnection(conStr))
                {
                    SqlCommand cmd = conn.CreateCommand();
                    cmd.CommandType = CommandType.StoredProcedure; //指定执行存储过程操作
                    cmd.CommandText = storedProcedure; //存储过程名称 
                    if (param != null)
                    {
                        foreach (var item in param)
                        {
                            if (!string.IsNullOrWhiteSpace(item.Value.ToString_()))
                            {
                                cmd.Parameters.Add(item);
                            }
                            else
                            {
                                item.Value = DBNull.Value;
                                cmd.Parameters.Add(item);
                            }
                        }
                    }
                    cmd.CommandTimeout = 180;
                    //方式一，查询回来的结果需要显示在DataGrid之类的控件上
                    DataSet ds = new DataSet();
                    SqlDataAdapter adapter = new SqlDataAdapter(cmd);
                    adapter.Fill(ds);
                    return ds;
                }
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
    }