雷火电竞-中国电竞赛事及体育赛事平台

歡迎來到入門教程網(wǎng)！

C#教程

當(dāng)前位置：主頁 > 軟件編程 > C#教程 >

C#實現(xiàn)較為實用的SQLhelper

來源：本站原創(chuàng)|時間：2020-01-10|欄目：C#教程|點擊： 次

第一次寫博客，想不到寫什么好b（￣▽￣）d　，考慮的半天決定從sqlhelper開始，sqlhelper對程序員來說就像helloworld一樣，很簡單卻又很重要，helloworld代表著程序員萌新第一次寫代碼，而sqlhelper則是初次接觸數(shù)據(jù)庫（不知道這種說法對不對）。

好了不廢話了，下面直接上代碼（無話可說了）：

public class SQLHelper
  {
    // 超時時間
    private static int Timeout = 1000;
    // 數(shù)據(jù)庫名稱
    public const String BestNet = "BestNet";
    //存儲過程名稱
    public const String UserInfoCURD = "UserInfoCURD";
    // 數(shù)據(jù)庫連接字符串
    private static Dictionary<String, String> ConnStrs = new Dictionary<String, String>();

    /// <summary>
    /// SQLServer操作類(靜態(tài)構(gòu)造函數(shù))
    /// </summary>
    static SQLHelper()
    {
      ConnectionStringSettingsCollection configs = WebConfigurationManager.ConnectionStrings;
      foreach (ConnectionStringSettings config in configs)
      {
        ConnStrs.Add(config.Name, config.ConnectionString);
      }
    }

    /// <summary>
    /// 獲取數(shù)據(jù)庫連接
    /// </summary>
    /// <param name="database">數(shù)據(jù)庫(配置文件內(nèi)connectionStrings的name)</param>
    /// <returns>數(shù)據(jù)庫連接</returns>
    private static SqlConnection GetConnection(string database)
    {
      if (string.IsNullOrEmpty(database))
      {
        throw new Exception("未設(shè)置參數(shù)：database");
      }
      if (!ConnStrs.ContainsKey(database))
      {
        throw new Exception("未找到數(shù)據(jù)庫：" + database);
      }
      return new SqlConnection(ConnStrs[database]);
    }

    /// <summary>
    /// 獲取SqlCommand
    /// </summary>
    /// <param name="conn">SqlConnection</param>
    /// <param name="transaction">SqlTransaction</param>
    /// <param name="cmdType">CommandType</param>
    /// <param name="sql">SQL</param>
    /// <param name="parms">SqlParameter數(shù)組</param>
    /// <returns></returns>
    private static SqlCommand GetCommand(SqlConnection conn, SqlTransaction transaction, CommandType cmdType, string sql, SqlParameter[] parms)
    {
      SqlCommand cmd = new SqlCommand(sql, conn);
      cmd.CommandType = cmdType;
      cmd.CommandTimeout = Timeout;
      if (transaction != null)
        cmd.Transaction = transaction;
      if (parms != null && parms.Length != 0)
        cmd.Parameters.AddRange(parms);
      return cmd;
    }

    /// <summary>
    /// 查詢數(shù)據(jù)，返回DataTable
    /// </summary>
    /// <param name="database">數(shù)據(jù)庫</param>
    /// <param name="sql">SQL語句或存儲過程名</param>
    /// <param name="parms">參數(shù)</param>
    /// <param name="cmdType">查詢類型(SQL語句/存儲過程名)</param>
    /// <returns>DataTable</returns>
    public static DataTable QueryDataTable(string database, string sql, SqlParameter[] parms, CommandType cmdType)
    {
      if (string.IsNullOrEmpty(database))
      {
        throw new Exception("未設(shè)置參數(shù)：database");
      }
      if (string.IsNullOrEmpty(sql))
      {
        throw new Exception("未設(shè)置參數(shù)：sql");
      }

      try
      {
        using (SqlConnection conn = GetConnection(database))
        {
          conn.Open();

          using (SqlCommand cmd = GetCommand(conn, null, cmdType, sql, parms))
          {
            using (SqlDataAdapter da = new SqlDataAdapter(cmd))
            {
              DataTable dt = new DataTable();
              da.Fill(dt);
              return dt;
            }
          }
        }
      }
      catch (SqlException ex)
      {
        System.Text.StringBuilder log = new System.Text.StringBuilder();
        log.Append("查詢數(shù)據(jù)出錯：");
        log.Append(ex);
        throw new Exception(log.ToString());
      }
    }

    /// <summary>
    /// 查詢數(shù)據(jù)，返回DataSet
    /// </summary>
    /// <param name="database">數(shù)據(jù)庫</param>
    /// <param name="sql">SQL語句或存儲過程名</param>
    /// <param name="parms">參數(shù)</param>
    /// <param name="cmdType">查詢類型(SQL語句/存儲過程名)</param>
    /// <returns>DataSet</returns>
    public static DataSet QueryDataSet(string database, string sql, SqlParameter[] parms, CommandType cmdType)
    {
      if (string.IsNullOrEmpty(database))
      {
        throw new Exception("未設(shè)置參數(shù)：database");
      }
      if (string.IsNullOrEmpty(sql))
      {
        throw new Exception("未設(shè)置參數(shù)：sql");
      }

      try
      {
        using (SqlConnection conn = GetConnection(database))
        {
          conn.Open();

          using (SqlCommand cmd = GetCommand(conn, null, cmdType, sql, parms))
          {
            using (SqlDataAdapter da = new SqlDataAdapter(cmd))
            {
              DataSet ds = new DataSet();
              da.Fill(ds);
              return ds;
            }
          }
        }
      }
      catch (SqlException ex)
      {
        System.Text.StringBuilder log = new System.Text.StringBuilder();
        log.Append("查詢數(shù)據(jù)出錯：");
        log.Append(ex);
        throw new Exception(log.ToString());
      }
    }

    /// <summary>
    /// 執(zhí)行命令獲取唯一值(第一行第一列)
    /// </summary>
    /// <param name="database">數(shù)據(jù)庫</param>
    /// <param name="sql">SQL語句或存儲過程名</param>
    /// <param name="parms">參數(shù)</param>
    /// <param name="cmdType">查詢類型(SQL語句/存儲過程名)</param>
    /// <returns>獲取值</returns>
    public static object QueryScalar(string database, string sql, SqlParameter[] parms, CommandType cmdType)
    {
      if (string.IsNullOrEmpty(database))
      {
        throw new Exception("未設(shè)置參數(shù)：database");
      }
      if (string.IsNullOrEmpty(sql))
      {
        throw new Exception("未設(shè)置參數(shù)：sql");
      }
      try
      {
        using (SqlConnection conn = GetConnection(database))
        {
          conn.Open();

          using (SqlCommand cmd = GetCommand(conn, null, cmdType, sql, parms))
          {
            return cmd.ExecuteScalar();
          }
        }
      }
      catch (SqlException ex)
      {
        System.Text.StringBuilder log = new System.Text.StringBuilder();
        log.Append("處理出錯：");
        log.Append(ex);
        throw new Exception(log.ToString());
      }
    }

    /// <summary>
    /// 執(zhí)行命令更新數(shù)據(jù)
    /// </summary>
    /// <param name="database">數(shù)據(jù)庫</param>
    /// <param name="sql">SQL語句或存儲過程名</param>
    /// <param name="parms">參數(shù)</param>
    /// <param name="cmdType">查詢類型(SQL語句/存儲過程名)</param>
    /// <returns>更新的行數(shù)</returns>
    public static int Execute(string database, string sql, SqlParameter[] parms, CommandType cmdType)
    {
      if (string.IsNullOrEmpty(database))
      {
        throw new Exception("未設(shè)置參數(shù)：database");
      }
      if (string.IsNullOrEmpty(sql))
      {
        throw new Exception("未設(shè)置參數(shù)：sql");
      }

      //返回(增刪改)的更新行數(shù)
      int count = 0;

      try
      {
        using (SqlConnection conn = GetConnection(database))
        {
          conn.Open();

          using (SqlCommand cmd = GetCommand(conn, null, cmdType, sql, parms))
          {
            if (cmdType == CommandType.StoredProcedure)
              cmd.Parameters.AddWithValue("@RETURN_VALUE", "").Direction = ParameterDirection.ReturnValue;

            count = cmd.ExecuteNonQuery();

            if (count <= 0)
              if (cmdType == CommandType.StoredProcedure)
                count = (int)cmd.Parameters["@RETURN_VALUE"].Value;
          }
        }
      }
      catch (SqlException ex)
      {
        System.Text.StringBuilder log = new System.Text.StringBuilder();
        log.Append("處理出錯：");
        log.Append(ex);
        throw new Exception(log.ToString());
      }
      return count;
    }

    /// <summary>
    /// 查詢數(shù)據(jù)，返回DataTable
    /// </summary>
    /// <param name="database">數(shù)據(jù)庫</param>
    /// <param name="sql">SQL語句或存儲過程名</param>
    /// <param name="cmdType">查詢類型(SQL語句/存儲過程名)</param>
    /// <param name="values">參數(shù)</param>
    /// <returns>DataTable</returns>
    public static DataTable QueryDataTable(string database, string sql, CommandType cmdType, IDictionary<string, object> values)
    {
      SqlParameter[] parms = DicToParams(values);
      return QueryDataTable(database, sql, parms, cmdType);
    }

    /// <summary>
    /// 執(zhí)行存儲過程查詢數(shù)據(jù)，返回DataSet
    /// </summary>
    /// <param name="database">數(shù)據(jù)庫</param>
    /// <param name="sql">SQL語句或存儲過程名</param>
    /// <param name="cmdType">查詢類型(SQL語句/存儲過程名)</param>
    /// <param name="values">參數(shù)
    /// <returns>DataSet</returns>
    public static DataSet QueryDataSet(string database, string sql, CommandType cmdType, IDictionary<string, object> values)
    {
      SqlParameter[] parms = DicToParams(values);
      return QueryDataSet(database, sql, parms, cmdType);
    }

    /// <summary>
    /// 執(zhí)行命令獲取唯一值(第一行第一列)
    /// </summary>
    /// <param name="database">數(shù)據(jù)庫</param>
    /// <param name="sql">SQL語句或存儲過程名</param>
    /// <param name="cmdType">查詢類型(SQL語句/存儲過程名)</param>
    /// <param name="values">參數(shù)</param>
    /// <returns>唯一值</returns>
    public static object QueryScalar(string database, string sql, CommandType cmdType, IDictionary<string, object> values)
    {
      SqlParameter[] parms = DicToParams(values);
      return QueryScalar(database, sql, parms, cmdType);
    }

    /// <summary>
    /// 執(zhí)行命令更新數(shù)據(jù)
    /// </summary>
    /// <param name="database">數(shù)據(jù)庫</param>
    /// <param name="sql">SQL語句或存儲過程名</param>
    /// <param name="cmdType">查詢類型(SQL語句/存儲過程名)</param>
    /// <param name="values">參數(shù)</param>
    /// <returns>更新的行數(shù)</returns>
    public static int Execute(string database, string sql, CommandType cmdType, IDictionary<string, object> values)
    {
      SqlParameter[] parms = DicToParams(values);
      return Execute(database, sql, parms, cmdType);
    }

    /// <summary>
    /// 創(chuàng)建參數(shù)
    /// </summary>
    /// <param name="name">參數(shù)名</param>
    /// <param name="type">參數(shù)類型</param>
    /// <param name="size">參數(shù)大小</param>
    /// <param name="direction">參數(shù)方向(輸入/輸出)</param>
    /// <param name="value">參數(shù)值</param>
    /// <returns>新參數(shù)對象</returns>
    public static SqlParameter[] DicToParams(IDictionary<string, object> values)
    {
      if (values == null) return null;

      SqlParameter[] parms = new SqlParameter[values.Count];
      int index = 0;
      foreach (KeyValuePair<string, object> kv in values)
      {
        SqlParameter parm = null;
        if (kv.Value == null)
        {
          parm = new SqlParameter(kv.Key, DBNull.Value);
        }
        else
        {
          Type t = kv.Value.GetType();
          parm = new SqlParameter(kv.Key, NetToSql(kv.Value.GetType()));
          parm.Value = kv.Value;
        }

        parms[index++] = parm;
      }
      return parms;
    }


    /// <summary>
    /// .net類型轉(zhuǎn)換為Sql類型
    /// </summary>
    /// <param name="t">.net類型</param>
    /// <returns>Sql類型</returns>
    public static SqlDbType NetToSql(Type t)
    {
      SqlDbType dbType = SqlDbType.Variant;
      switch (t.Name)
      {
        case "Int16":
          dbType = SqlDbType.SmallInt;
          break;
        case "Int32":
          dbType = SqlDbType.Int;
          break;
        case "Int64":
          dbType = SqlDbType.BigInt;
          break;
        case "Single":
          dbType = SqlDbType.Real;
          break;
        case "Decimal":
          dbType = SqlDbType.Decimal;
          break;

        case "Byte[]":
          dbType = SqlDbType.VarBinary;
          break;
        case "Boolean":
          dbType = SqlDbType.Bit;
          break;
        case "String":
          dbType = SqlDbType.NVarChar;
          break;
        case "Char[]":
          dbType = SqlDbType.Char;
          break;
        case "DateTime":
          dbType = SqlDbType.DateTime;
          break;
        case "DateTime2":
          dbType = SqlDbType.DateTime2;
          break;
        case "DateTimeOffset":
          dbType = SqlDbType.DateTimeOffset;
          break;
        case "TimeSpan":
          dbType = SqlDbType.Time;
          break;
        case "Guid":
          dbType = SqlDbType.UniqueIdentifier;
          break;
        case "Xml":
          dbType = SqlDbType.Xml;
          break;
        case "Object":
          dbType = SqlDbType.Variant;
          break;
      }
      return dbType;
    }

  }

可以直接這樣調(diào)用： 

IDictionary<string, object> values = new Dictionary<string, object>();
 values.Add("@UserName", UserName);      
 values.Add("@PassWord", passWord);
 object Scalar = SQLHelper.QueryScalar(SQLHelper.BestNet, SQLHelper.UserInfoCURD, CommandType.StoredProcedure, values);

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持我們。

上一篇：C#完成word文檔打印的方法

欄    目：C#教程

下一篇：.NET的深復(fù)制方法（以C#語言為例）

本文標(biāo)題：C#實現(xiàn)較為實用的SQLhelper

本文地址：http://www.jygsgssxh.com/a1/C_jiaocheng/6213.html

網(wǎng)頁制作CMS教程網(wǎng)絡(luò)編程軟件編程腳本語言數(shù)據(jù)庫服務(wù)器

如果侵犯了您的權(quán)利，請與我們聯(lián)系，我們將在24小時內(nèi)進(jìn)行處理、任何非本站因素導(dǎo)致的法律后果，本站均不負(fù)任何責(zé)任。

聯(lián)系QQ：835971066 | 郵箱：835971066#qq.com(#換成@)

Copyright © 2002-2020 腳本教程網(wǎng) 版權(quán)所有