C#写一套最全的SQL server帮助类（包括增删改查）

我定义了一系列静态方法，用于执行SQL Server数据库的增删改查等操作。
其中：
ExecuteNonQuery方法用于执行指定的SQL语句并返回受影响的行数；
ExecuteScalar方法用于执行指定的SQL语句并返回查询结果的第一行第一列；
ExecuteDataTable方法用于执行指定的SQL语句并返回一个数据表；
ExecuteReader方法用于执行指定的SQL语句并返回一个DataReader对象。
Insert方法用于向指定的表中插入一条记录，并返回新记录的ID值（如果有自增字段）；
Update方法用于更新指定表中满足条件的记录，并返回受影响的行数；
Delete方法用于删除指定表中满足条件的记录，并返回受影响的行数。
在这些方法中，我们使用了ADO.NET的相关技术，包括SqlConnection、SqlCommand、SqlDataAdapter、DataSet等类，以及SqlParameter对象来
一、下面是一套SQL Server的帮助类，包括增删改查等操作，并且带有详细注释。

1. using System;
2. using System.Collections.Generic;
3. using System.Data;
4. using System.Data.SqlClient;
6. public class SqlserverHelper
7. {
8.     private static string connectionString = "Data Source=服务器名称;Initial Catalog=数据库名称;User ID=用户名;Password=密码";  // 数据库连接字符串
10.     /// <summary>
11.     /// 执行指定的SQL语句并返回受影响的行数
12.     /// </summary>
13.     /// <param name="sql">要执行的SQL语句</param>
14.     /// <returns>受影响的行数</returns>
15.     public static int ExecuteNonQuery(string sql)
16.     {
17.         using (SqlConnection conn = new SqlConnection(connectionString))
18.         {
19.             conn.Open();          // 打开数据库连接
20.             SqlCommand cmd = new SqlCommand(sql, conn);
21.             int count = cmd.ExecuteNonQuery();   // 执行SQL语句并返回受影响的行数
22.             return count;         // 返回受影响的行数
23.         }
24.     }
26.     /// <summary>
27.     /// 执行指定的SQL语句并返回查询结果的第一行第一列
28.     /// </summary>
29.     /// <param name="sql">要执行的SQL语句</param>
30.     /// <returns>查询结果的第一行第一列</returns>
31.     public static object ExecuteScalar(string sql)
32.     {
33.         using (SqlConnection conn = new SqlConnection(connectionString))
34.         {
35.             conn.Open();          // 打开数据库连接
36.             SqlCommand cmd = new SqlCommand(sql, conn);
37.             object obj = cmd.ExecuteScalar();   // 执行SQL语句并返回查询结果的第一行第一列
38.             return obj;           // 返回查询结果的第一行第一列
39.         }
40.     }
42.     /// <summary>
43.     /// 执行指定的SQL语句并返回一个数据表
44.     /// </summary>
45.     /// <param name="sql">要执行的SQL语句</param>
46.     /// <returns>查询结果的数据表</returns>
47.     public static DataTable ExecuteDataTable(string sql)
48.     {
49.         using (SqlConnection conn = new SqlConnection(connectionString))
50.         {
51.             conn.Open();          // 打开数据库连接
52.             SqlDataAdapter adapter = new SqlDataAdapter(sql, conn);
53.             DataSet ds = new DataSet();
54.             adapter.Fill(ds);     // 执行SQL语句并将查询结果填充到DataSet对象中
55.             return ds.Tables[0];  // 返回查询结果的数据表
56.         }
57.     }
59.     /// <summary>
60.     /// 执行指定的SQL语句并返回一个DataReader对象
61.     /// </summary>
62.     /// <param name="sql">要执行的SQL语句</param>
63.     /// <returns>查询结果的DataReader对象</returns>
64.     public static SqlDataReader ExecuteReader(string sql)
65.     {
66.         SqlConnection conn = new SqlConnection(connectionString);
67.         conn.Open();              // 打开数据库连接
68.         SqlCommand cmd = new SqlCommand(sql, conn);
69.         SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection);   // 执行SQL语句并返回DataReader对象
70.         return reader;            // 返回查询结果的DataReader对象
71.     }
73.     /// <summary>
74.     /// 向指定的表中插入一条记录，并返回新记录的ID值（如果有自增字段）
75.     /// </summary>
76.     /// <param name="tableName">要插入记录的表名称</param>
77.     /// <param name="fields">要插入记录的字段和值的集合</param>
78.     /// <returns>新记录的ID值（如果有自增字段）</returns>
79.     public static int Insert(string tableName, Dictionary<string, object> fields)
80.     {
81.         string sql = "insert into " + tableName + "(";
82.         string values = ") values (";
83.         SqlCommand cmd = new SqlCommand();
84.         foreach (KeyValuePair<string, object> field in fields)
85.         {
86.             sql += "[" + field.Key + "],";
87.             values += "@" + field.Key + ",";
88.             cmd.Parameters.AddWithValue("@" + field.Key, field.Value);
89.         }
90.         sql = sql.TrimEnd(',') + values.TrimEnd(',') + ")";
91.         sql += ";select @@identity";    // 如果有自增字段，则返回新记录的ID值
92.         cmd.Connection = new SqlConnection(connectionString);
93.         cmd.CommandText = sql;
94.         cmd.Connection.Open();     // 打开数据库连接
95.         int newId;
96.         if (cmd.ExecuteScalar() != DBNull.Value)
97.         {
98.             newId = Convert.ToInt32(cmd.ExecuteScalar());
99.         }
100.         else
101.         {
102.             newId = 0;   // 如果没有自增字段，则返回0
103.         }
104.         cmd.Connection.Close();    // 关闭数据库连接
105.         return newId;              // 返回新记录的ID值
106.     }
108.     /// <summary>
109.     /// 更新指定表中满足条件的记录，并返回受影响的行数
110.     /// </summary>
111.     /// <param name="tableName">要更新记录的表名称</param>
112.     /// <param name="fields">要更新的字段和值的集合</param>
113.     /// <param name="conditions">更新条件的字段和值的集合</param>
114.     /// <returns>受影响的行数</returns>
115.     public static int Update(string tableName, Dictionary<string, object> fields, Dictionary<string, object> conditions)
116.     {
117.         string sql = "update " + tableName + " set ";
118.         SqlCommand cmd = new SqlCommand();
119.         foreach (KeyValuePair<string, object> field in fields)
120.         {
121.             sql += "[" + field.Key + "]=@" + field.Key + ",";
122.             cmd.Parameters.AddWithValue("@" + field.Key, field.Value);
123.         }
124.         sql = sql.TrimEnd(',');
125.         if (conditions != null && conditions.Count > 0)
126.         {
127.             sql += " where ";
128.             foreach (KeyValuePair<string, object> condition in conditions)
129.             {
130.                 sql += "[" + condition.Key + "]=@" + condition.Key + " and ";
131.                 cmd.Parameters.AddWithValue("@" + condition.Key, condition.Value);
132.             }
133.             sql = sql.TrimEnd(' ', 'a', 'n', 'd');
134.         }
135.         cmd.Connection = new SqlConnection(connectionString);
136.         cmd.CommandText = sql;
137.         cmd.Connection.Open();     // 打开数据库连接
138.         int count = cmd.ExecuteNonQuery();   // 执行SQL语句并返回受影响的行数
139.         cmd.Connection.Close();    // 关闭数据库连接
140.         return count;              // 返回受影响的行数
141.     }
143.     /// <summary>
144.     /// 删除指定表中满足条件的记录，并返回受影响的行数
145.     /// </summary>
146.     /// <param name="tableName">要删除记录的表名称</param>
147.     /// <param name="conditions">删除条件的字段和值的集合</param>
148.     /// <returns>受影响的行数</returns>
149.     public static int Delete(string tableName, Dictionary<string, object> conditions)
150.     {
151.         string sql = "delete from " + tableName;
152.         SqlCommand cmd = new SqlCommand();
153.         if (conditions != null && conditions.Count > 0)
154.         {
155.             sql += " where ";
156.             foreach (KeyValuePair<string, object> condition in conditions)
157.             {
158.                 sql += "[" + condition.Key + "]=@" + condition.Key + " and ";
159.                 cmd.Parameters.AddWithValue("@" + condition.Key, condition.Value);
160.             }
161.             sql = sql.TrimEnd(' ', 'a', 'n', 'd');
162.         }
163.         cmd.Connection = new SqlConnection(connectionString);
164.         cmd.CommandText = sql;
165.         cmd.Connection.Open();     // 打开数据库连接
166.         int count = cmd.ExecuteNonQuery();   // 执行SQL语句并返回受影响的行数
167.         cmd.Connection.Close();    // 关闭数据库连接
168.         return count;              // 返回受影响的行数
169.     }
170. }

复制代码

View Code二、每一个方法的调用。
在这个示例中，我首先调用ExecuteNonQuery方法向数据库中插入一条记录，并输出插入的行数；
然后调用ExecuteScalar方法查询了数据库中记录的总数，并输出结果；
接下来，我使用ExecuteDataTable方法查询了符合条件的记录，并通过遍历数据表的方式输出所有记录的信息。
然后使用ExecuteReader方法查询了所有的记录，并通过遍历DataReader对象的方式输出所有记录的信息。
请注意，在使用完DataReader对象后必须调用其Close()方法关闭它。
接着使用Insert方法向数据库中插入了一条记录，并获得了新记录的ID值（如果有自增字段）；
还使用Update方法更新了符合条件的记录，并输出了更新的行数；
最后，使用Delete方法删除了符合条件的记录，并输出了删除的行数。
当然，这些示例只是演示了如何使用SqlHelper类中的每一个方法。
在实际应用中，将根据具体的需求来调用它们并处理查询结果。

1.     static void Main(string[] args)
2.         {
3.             // 执行指定的SQL语句并返回受影响的行数
4.             int count = SqlserverHelper.ExecuteNonQuery("insert into [User](UserName, Password) values('admin', '123456')");
5.             Console.WriteLine("受影响的行数：" + count);
7.             // 执行指定的SQL语句并返回查询结果的第一行第一列
8.             object obj = SqlserverHelper.ExecuteScalar("select count(*) from [User]");
9.             Console.WriteLine("记录总数：" + obj);
11.             // 执行指定的SQL语句并返回一个数据表
12.             DataTable dt = SqlserverHelper.ExecuteDataTable("select * from [User] where UserName='admin'");
13.             foreach (DataRow row in dt.Rows)
14.             {
15.                 Console.WriteLine("用户名：" + row["UserName"] + " 密码：" + row["Password"]);
16.             }
18.             // 执行指定的SQL语句并返回一个DataReader对象
19.             SqlDataReader reader = SqlserverHelper.ExecuteReader("select * from [User]");
20.             while (reader.Read())
21.             {
22.                 Console.WriteLine("用户名：" + reader["UserName"] + " 密码：" + reader["Password"]);
23.             }
24.             reader.Close();
26.             // 向指定的表中插入一条记录，并返回新记录的ID值（如果有自增字段）
27.             Dictionary<string, object> fields = new Dictionary<string, object>();
28.             fields.Add("UserName", "test");
29.             fields.Add("Password", "123456");
30.             int newId = SqlserverHelper.Insert("User", fields);
31.             Console.WriteLine("新记录的ID值：" + newId);
33.             // 更新指定表中满足条件的记录，并返回受影响的行数
34.             Dictionary<string, object> conditions = new Dictionary<string, object>();
35.             conditions.Add("UserName", "test");
36.             Dictionary<string, object> newFields = new Dictionary<string, object>();
37.             newFields.Add("Password", "654321");
38.             int updateCount = SqlserverHelper.Update("User", newFields, conditions);
39.             Console.WriteLine("更新记录的数量：" + updateCount);
41.             // 删除指定表中满足条件的记录，并返回受影响的行数
42.             Dictionary<string, object> delConditions = new Dictionary<string, object>();
43.             delConditions.Add("UserName", "test");
44.             int delCount = SqlserverHelper.Delete("User", delConditions);
45.             Console.WriteLine("删除记录的数量：" + delCount);
47.             Console.ReadKey();
48.         }

复制代码

View Code 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！