ASP.NET數據庫連接類（SqlDBHelper）

第一步：創建一個名為SqlDBHelper的類，用來作為聯通數據庫和系統之間的橋梁。

第二步：引入命名空間,如果System.Configuration、System.Transcations這兩個命名空間找不到，可在項目目錄下的【引用】=》添加引用【框架】中找到，添加引用即可。

 

using System.Data;
using System.Data.SqlClient;
using System.Configuration;
using System.Transactions;

第三步：在配置文件中添加數據庫連接地址。

<configuration>
    <startup> 
        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5.2" />
    </startup>
  <connectionStrings>
    <add name="MES" connectionString="Data Source=數據庫IP;Database=數據庫名;User ID=用戶名;Password=連接密碼;" providerName="System.Data.SqlClient;"/>
  </connectionStrings>
</configuration>

第四部：在SqlDBHelper中編寫讀取配置文件中連接數據庫字段：

 private static readonly string connectionString = ConfigurationManager.ConnectionStrings["MES"].ToString();

如果ConfigurationManager提示錯誤，同第二步操作即可。

第五步：編寫操作Sql命令的方法（增刪改查）：

 public static string DataBase
        {
            get {
                SqlConnection conn = new SqlConnection();
                string db = conn.Database;  //獲取當前數據庫或使用的數據庫名稱
                conn.Dispose();
                return db;
            }
        }

        #region 為SQL命令做提前的參數設定
        /// <summary>
        /// 為cmd做執行前的參數設定
        /// </summary>
        /// <param name="cmd">cmd命令對象</param>
        /// <param name="conn">連接對象</param>
        /// <param name="trans">事務對象</param>
        /// <param name="cmdType">命令類型</param>
        /// <param name="cmdText">SQL命令文本</param>
        /// <param name="cmdParms">在命令文本中要使用的SQL參數</param>
        private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, SqlParameter[] cmdParms)
        {
            if (conn.State != System.Data.ConnectionState.Open)  //如果連接通道未打開，則打開連接通道
                conn.Open();
            cmd.CommandTimeout = 60;  //等待時間
            cmd.Connection = conn;  //為命令對象設置連接通道
            cmd.CommandText = cmdText; //為命令對象設置SQL文本
            if (trans != null)   //如果存在事務，則為命令對象設置事務
                cmd.Transaction = trans;
            cmd.CommandType = cmdType;  //設置命令類型（SQL文本/存儲過程）
            if (cmdParms != null)  //如果參數集合不為空，為命令對象添加參數
                cmd.Parameters.AddRange(cmdParms); 
           
        }
        #endregion


        #region sql 增刪改
        /// <summary>
        /// 執行SQL命令 增刪改（無參數）
        /// </summary>
        /// <param name="cmdText">SQL命令語句</param>
        /// <returns></returns>
        public static int ExecuteCommand(string cmdText)  //重載
        {
            return ExecuteCommand(cmdText,null);
        }

        /// <summary>
        /// 執行SQL命令 增刪改（帶參數）
        /// </summary>
        /// <param name="cmdText">SQL命令語句</param>
        /// <param name="parameters">參數</param>
        /// <returns></returns>
        public static int ExecuteCommand(string cmdText, SqlParameter[] parameters)
        {
            return ExecuteCommand(cmdText,CommandType.Text,parameters);
        }

        /// <summary>
        /// 執行SQL命令 增刪改（帶參數）
        /// </summary>
        /// <param name="cmdText">SQL命令</param>
        /// <param name="cmdType">命令類型</param>
        /// <param name="commandParameters">參數集合</param>
        /// <returns></returns>
        public static int ExecuteCommand(string cmdText, CommandType cmdType, params SqlParameter[] commandParameters)
        {
            using (TransactionScope transcation = new TransactionScope())  //TransactionScope 使代碼塊成為事務性代碼
            {
                int res = 0;
                try
                {
                    SqlCommand cmd = new SqlCommand();
                    using (SqlConnection conn = new SqlConnection(connectionString))
                    {
                        PrepareCommand(cmd,conn,null,cmdType,cmdText,commandParameters);

                        res = cmd.ExecuteNonQuery();  //執行SQL並返回受影響的行數
                        transcation.Complete();  //指示范圍內的操作都已經完成
                    }
                }
                catch (Exception ex)
                {
                    throw ex;
                }
                return res;
            }
        }

        /// <summary>
        /// 執行SQL命令  增刪改
        /// </summary>
        /// <param name="cmdText">SQL命令</param>
        /// <param name="trans">事務對象</param>
        /// <param name="cmdType">命令類型</param>
        /// <param name="parameters">命令參數</param>
        /// <returns></returns>
        public static int ExecuteCommand(string cmdText, SqlTransaction trans, CommandType cmdType, SqlParameter[] parameters)
        {
            SqlCommand cmd = new SqlCommand();
            PrepareCommand(cmd,trans.Connection,trans,cmdType,cmdText,parameters);
            int res = 0;
            try
            {
                res = cmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                throw ex;
            }
            cmd.Parameters.Clear();
            return res;
        }
        #endregion

        #region sql 查詢操作
        /// <summary>
        /// 執行SQL命令  查詢
        /// </summary>
        /// <param name="sqlStr">SQL命令語句</param>
        /// <returns></returns>
        public static DataTable GetDataTable(string sqlStr)
        {
            return GetDataTable(sqlStr,null);
        }

        /// <summary>
        /// 執行SQL命令  查詢
        /// </summary>
        /// <param name="sqlStr">SQL命令</param>
        /// <param name="parameters">參數集合</param>
        /// <returns></returns>
        public static DataTable GetDataTable(string sqlStr, SqlParameter[] parameters)
        {
            return GetDataTable(sqlStr,CommandType.Text,parameters);
        }

        /// <summary>
        /// 執行SQL命令
        /// </summary>
        /// <param name="sqlStr">SQL命令</param>
        /// <param name="cmdType">命令類型</param>
        /// <param name="parameters">參數集合</param>
        /// <returns></returns>
        public static DataTable GetDataTable(string sqlStr, CommandType cmdType, SqlParameter[] parameters)
        {
            using (SqlConnection connection = new SqlConnection(connectionString))
            {
                SqlCommand cmd = new SqlCommand(sqlStr,connection);
                cmd.CommandTimeout = 60;
                cmd.CommandType = cmdType;
                if (parameters != null)
                    cmd.Parameters.AddRange(parameters);
                SqlDataAdapter da = new SqlDataAdapter(cmd);
                DataTable dt = new DataTable();
                try
                {
                    da.Fill(dt);
                }
                catch (Exception ex)
                {
                    throw ex;
                }
                cmd.Parameters.Clear();
                return dt;
            }
        }


        public static DataTable GetDataTable(string sqlStr,string con,int i)
        {
            SqlConnection conn = new SqlConnection(con);
            conn.Open();
            SqlCommand cmd = new SqlCommand(sqlStr,conn);
            SqlDataAdapter da = new SqlDataAdapter(cmd);
            DataTable dt = new DataTable();
            da.Fill(dt);
            conn.Close();
            cmd.Dispose();
            da.Dispose();
            return dt;
        }

        /// <summary>
        /// 執行SQL 查詢
        /// </summary>
        /// <param name="cmdText">SQL命令語句</param>
        /// <returns></returns>
        public static object GetScalar(string cmdText)
        {
            return GetScalar(cmdText,null);
        }

        /// <summary>
        /// 執行SQL  查詢
        /// </summary>
        /// <param name="cmdText">SQL命令</param>
        /// <param name="parameters">參數集合</param>
        /// <returns>第一行第一列（object類型）</returns>
        public static object GetScalar(string cmdText, SqlParameter[] parameters)
        {
            return GetScalar(cmdText,CommandType.Text,parameters);
        }

        /// <summary>
        /// 執行SQL 查詢
        /// </summary>
        /// <param name="cmdText">SQL命令</param>
        /// <param name="cmdType">命令類型</param>
        /// <param name="parameters">參數集合</param>
        /// <returns>第一行第一列的值（object類型）</returns>
        public static object GetScalar(string cmdText, CommandType cmdType, SqlParameter[] parameters)
        {
            object res = 0;
            SqlCommand cmd = new SqlCommand();
            using (SqlConnection conn = new SqlConnection(connectionString))
            {
                PrepareCommand(cmd,conn,null,cmdType,cmdText,parameters);
                try
                {
                    res = cmd.ExecuteScalar();
                }
                catch(Exception ex)
                {
                    throw ex;
                }
                cmd.Parameters.Clear();
                return res;
            }
        }

        public static void Insert_NewData(DataTable dt, string tableName)
        {
            SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(connectionString,SqlBulkCopyOptions.UseInternalTransaction);
            sqlBulkCopy.DestinationTableName = tableName;//數據庫中的表名

            sqlBulkCopy.WriteToServer(dt);
            sqlBulkCopy.Close();
        }
        #endregion

至此，SqlDBHelper類完成，在需要時直接調用即可。