我定義了一系列靜態方法，用于執行SQL Server資料庫的增刪改查等操作，
其中：
ExecuteNonQuery方法用于執行指定的SQL陳述句并回傳受影響的行數；
ExecuteScalar方法用于執行指定的SQL陳述句并回傳查詢結果的第一行第一列；
ExecuteDataTable方法用于執行指定的SQL陳述句并回傳一個資料表；
ExecuteReader方法用于執行指定的SQL陳述句并回傳一個DataReader物件，
Insert方法用于向指定的表中插入一條記錄，并回傳新記錄的ID值（如果有自增欄位）；
Update方法用于更新指定表中滿足條件的記錄，并回傳受影響的行數；
Delete方法用于洗掉指定表中滿足條件的記錄，并回傳受影響的行數，
在這些方法中，我們使用了ADO.NET的相關技術，包括SqlConnection、SqlCommand、SqlDataAdapter、DataSet等類，以及SqlParameter物件來
一、下面是一套SQL Server的幫助類，包括增刪改查等操作，并且帶有詳細注釋，
using System; using System.Collections.Generic; using System.Data; using System.Data.SqlClient; public class SqlserverHelper { private static string connectionString = "Data Source=服務器名稱;Initial Catalog=資料庫名稱;User ID=用戶名;Password=密碼"; // 資料庫連接字串 /// <summary> /// 執行指定的SQL陳述句并回傳受影響的行數 /// </summary> /// <param name="sql">要執行的SQL陳述句</param> /// <returns>受影響的行數</returns> public static int ExecuteNonQuery(string sql) { using (SqlConnection conn = new SqlConnection(connectionString)) { conn.Open(); // 打開資料庫連接 SqlCommand cmd = new SqlCommand(sql, conn); int count = cmd.ExecuteNonQuery(); // 執行SQL陳述句并回傳受影響的行數 return count; // 回傳受影響的行數 } } /// <summary> /// 執行指定的SQL陳述句并回傳查詢結果的第一行第一列 /// </summary> /// <param name="sql">要執行的SQL陳述句</param> /// <returns>查詢結果的第一行第一列</returns> public static object ExecuteScalar(string sql) { using (SqlConnection conn = new SqlConnection(connectionString)) { conn.Open(); // 打開資料庫連接 SqlCommand cmd = new SqlCommand(sql, conn); object obj = cmd.ExecuteScalar(); // 執行SQL陳述句并回傳查詢結果的第一行第一列 return obj; // 回傳查詢結果的第一行第一列 } } /// <summary> /// 執行指定的SQL陳述句并回傳一個資料表 /// </summary> /// <param name="sql">要執行的SQL陳述句</param> /// <returns>查詢結果的資料表</returns> public static DataTable ExecuteDataTable(string sql) { using (SqlConnection conn = new SqlConnection(connectionString)) { conn.Open(); // 打開資料庫連接 SqlDataAdapter adapter = new SqlDataAdapter(sql, conn); DataSet ds = new DataSet(); adapter.Fill(ds); // 執行SQL陳述句并將查詢結果填充到DataSet物件中 return ds.Tables[0]; // 回傳查詢結果的資料表 } } /// <summary> /// 執行指定的SQL陳述句并回傳一個DataReader物件 /// </summary> /// <param name="sql">要執行的SQL陳述句</param> /// <returns>查詢結果的DataReader物件</returns> public static SqlDataReader ExecuteReader(string sql) { SqlConnection conn = new SqlConnection(connectionString); conn.Open(); // 打開資料庫連接 SqlCommand cmd = new SqlCommand(sql, conn); SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection); // 執行SQL陳述句并回傳DataReader物件 return reader; // 回傳查詢結果的DataReader物件 } /// <summary> /// 向指定的表中插入一條記錄，并回傳新記錄的ID值（如果有自增欄位） /// </summary> /// <param name="tableName">要插入記錄的表名稱</param> /// <param name="fields">要插入記錄的欄位和值的集合</param> /// <returns>新記錄的ID值（如果有自增欄位）</returns> public static int Insert(string tableName, Dictionary<string, object> fields) { string sql = "insert into " + tableName + "("; string values = ") values ("; SqlCommand cmd = new SqlCommand(); foreach (KeyValuePair<string, object> field in fields) { sql += "[" + field.Key + "],"; values += "@" + field.Key + ","; cmd.Parameters.AddWithValue("@" + field.Key, field.Value); } sql = sql.TrimEnd(',') + values.TrimEnd(',') + ")"; sql += ";select @@identity"; // 如果有自增欄位，則回傳新記錄的ID值 cmd.Connection = new SqlConnection(connectionString); cmd.CommandText = sql; cmd.Connection.Open(); // 打開資料庫連接 int newId; if (cmd.ExecuteScalar() != DBNull.Value) { newId = Convert.ToInt32(cmd.ExecuteScalar()); } else { newId = 0; // 如果沒有自增欄位，則回傳0 } cmd.Connection.Close(); // 關閉資料庫連接 return newId; // 回傳新記錄的ID值 } /// <summary> /// 更新指定表中滿足條件的記錄，并回傳受影響的行數 /// </summary> /// <param name="tableName">要更新記錄的表名稱</param> /// <param name="fields">要更新的欄位和值的集合</param> /// <param name="conditions">更新條件的欄位和值的集合</param> /// <returns>受影響的行數</returns> public static int Update(string tableName, Dictionary<string, object> fields, Dictionary<string, object> conditions) { string sql = "update " + tableName + " set "; SqlCommand cmd = new SqlCommand(); foreach (KeyValuePair<string, object> field in fields) { sql += "[" + field.Key + "]=@" + field.Key + ","; cmd.Parameters.AddWithValue("@" + field.Key, field.Value); } sql = sql.TrimEnd(','); if (conditions != null && conditions.Count > 0) { sql += " where "; foreach (KeyValuePair<string, object> condition in conditions) { sql += "[" + condition.Key + "]=@" + condition.Key + " and "; cmd.Parameters.AddWithValue("@" + condition.Key, condition.Value); } sql = sql.TrimEnd(' ', 'a', 'n', 'd'); } cmd.Connection = new SqlConnection(connectionString); cmd.CommandText = sql; cmd.Connection.Open(); // 打開資料庫連接 int count = cmd.ExecuteNonQuery(); // 執行SQL陳述句并回傳受影響的行數 cmd.Connection.Close(); // 關閉資料庫連接 return count; // 回傳受影響的行數 } /// <summary> /// 洗掉指定表中滿足條件的記錄，并回傳受影響的行數 /// </summary> /// <param name="tableName">要洗掉記錄的表名稱</param> /// <param name="conditions">洗掉條件的欄位和值的集合</param> /// <returns>受影響的行數</returns> public static int Delete(string tableName, Dictionary<string, object> conditions) { string sql = "delete from " + tableName; SqlCommand cmd = new SqlCommand(); if (conditions != null && conditions.Count > 0) { sql += " where "; foreach (KeyValuePair<string, object> condition in conditions) { sql += "[" + condition.Key + "]=@" + condition.Key + " and "; cmd.Parameters.AddWithValue("@" + condition.Key, condition.Value); } sql = sql.TrimEnd(' ', 'a', 'n', 'd'); } cmd.Connection = new SqlConnection(connectionString); cmd.CommandText = sql; cmd.Connection.Open(); // 打開資料庫連接 int count = cmd.ExecuteNonQuery(); // 執行SQL陳述句并回傳受影響的行數 cmd.Connection.Close(); // 關閉資料庫連接 return count; // 回傳受影響的行數 } }View Code
二、每一個方法的呼叫，
在這個示例中，我首先呼叫ExecuteNonQuery方法向資料庫中插入一條記錄，并輸出插入的行數；
然后呼叫ExecuteScalar方法查詢了資料庫中記錄的總數，并輸出結果；
接下來，我使用ExecuteDataTable方法查詢了符合條件的記錄，并通過遍歷資料表的方式輸出所有記錄的資訊，
然后使用ExecuteReader方法查詢了所有的記錄，并通過遍歷DataReader物件的方式輸出所有記錄的資訊，
請注意，在使用完DataReader物件后必須呼叫其Close()方法關閉它，
接著使用Insert方法向資料庫中插入了一條記錄，并獲得了新記錄的ID值（如果有自增欄位）；
還使用Update方法更新了符合條件的記錄，并輸出了更新的行數；
最后，使用Delete方法洗掉了符合條件的記錄，并輸出了洗掉的行數，
當然，這些示例只是演示了如何使用SqlHelper類中的每一個方法，
在實際應用中，將根據具體的需求來呼叫它們并處理查詢結果，
static void Main(string[] args) { // 執行指定的SQL陳述句并回傳受影響的行數 int count = SqlserverHelper.ExecuteNonQuery("insert into [User](UserName, Password) values('admin', '123456')"); Console.WriteLine("受影響的行數：" + count); // 執行指定的SQL陳述句并回傳查詢結果的第一行第一列 object obj = SqlserverHelper.ExecuteScalar("select count(*) from [User]"); Console.WriteLine("記錄總數：" + obj); // 執行指定的SQL陳述句并回傳一個資料表 DataTable dt = SqlserverHelper.ExecuteDataTable("select * from [User] where UserName='admin'"); foreach (DataRow row in dt.Rows) { Console.WriteLine("用戶名：" + row["UserName"] + " 密碼：" + row["Password"]); } // 執行指定的SQL陳述句并回傳一個DataReader物件 SqlDataReader reader = SqlserverHelper.ExecuteReader("select * from [User]"); while (reader.Read()) { Console.WriteLine("用戶名：" + reader["UserName"] + " 密碼：" + reader["Password"]); } reader.Close(); // 向指定的表中插入一條記錄，并回傳新記錄的ID值（如果有自增欄位） Dictionary<string, object> fields = new Dictionary<string, object>(); fields.Add("UserName", "test"); fields.Add("Password", "123456"); int newId = SqlserverHelper.Insert("User", fields); Console.WriteLine("新記錄的ID值：" + newId); // 更新指定表中滿足條件的記錄，并回傳受影響的行數 Dictionary<string, object> conditions = new Dictionary<string, object>(); conditions.Add("UserName", "test"); Dictionary<string, object> newFields = new Dictionary<string, object>(); newFields.Add("Password", "654321"); int updateCount = SqlserverHelper.Update("User", newFields, conditions); Console.WriteLine("更新記錄的數量：" + updateCount); // 洗掉指定表中滿足條件的記錄，并回傳受影響的行數 Dictionary<string, object> delConditions = new Dictionary<string, object>(); delConditions.Add("UserName", "test"); int delCount = SqlserverHelper.Delete("User", delConditions); Console.WriteLine("洗掉記錄的數量：" + delCount); Console.ReadKey(); }View Code
轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/550824.html
標籤：SQL Server
上一篇：即時通訊系統為什么選擇GaussDB(for Redis)？
下一篇：返回列表