(资料图片仅供参考)
我定义了一系列静态方法,用于执行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=密码"; // 数据库连接字符串 ///View Code/// 执行指定的SQL语句并返回受影响的行数 /// /// 要执行的SQL语句 ///受影响的行数 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; // 返回受影响的行数 } } ////// 执行指定的SQL语句并返回查询结果的第一行第一列 /// /// 要执行的SQL语句 ///查询结果的第一行第一列 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; // 返回查询结果的第一行第一列 } } ////// 执行指定的SQL语句并返回一个数据表 /// /// 要执行的SQL语句 ///查询结果的数据表 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]; // 返回查询结果的数据表 } } ////// 执行指定的SQL语句并返回一个DataReader对象 /// /// 要执行的SQL语句 ///查询结果的DataReader对象 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对象 } ////// 向指定的表中插入一条记录,并返回新记录的ID值(如果有自增字段) /// /// 要插入记录的表名称 /// 要插入记录的字段和值的集合 ///新记录的ID值(如果有自增字段) public static int Insert(string tableName, Dictionaryfields) { string sql = "insert into " + tableName + "("; string values = ") values ("; SqlCommand cmd = new SqlCommand(); foreach (KeyValuePair 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值 } /// /// 更新指定表中满足条件的记录,并返回受影响的行数 /// /// 要更新记录的表名称 /// 要更新的字段和值的集合 /// 更新条件的字段和值的集合 ///受影响的行数 public static int Update(string tableName, Dictionaryfields, Dictionary conditions) { string sql = "update " + tableName + " set "; SqlCommand cmd = new SqlCommand(); foreach (KeyValuePair 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 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; // 返回受影响的行数 } /// /// 删除指定表中满足条件的记录,并返回受影响的行数 /// /// 要删除记录的表名称 /// 删除条件的字段和值的集合 ///受影响的行数 public static int Delete(string tableName, Dictionaryconditions) { string sql = "delete from " + tableName; SqlCommand cmd = new SqlCommand(); if (conditions != null && conditions.Count > 0) { sql += " where "; foreach (KeyValuePair 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; // 返回受影响的行数 }}
二、每一个方法的调用。
在这个示例中,我首先调用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值(如果有自增字段) DictionaryView Codefields = new Dictionary (); fields.Add("UserName", "test"); fields.Add("Password", "123456"); int newId = SqlserverHelper.Insert("User", fields); Console.WriteLine("新记录的ID值:" + newId); // 更新指定表中满足条件的记录,并返回受影响的行数 Dictionary conditions = new Dictionary (); conditions.Add("UserName", "test"); Dictionary newFields = new Dictionary (); newFields.Add("Password", "654321"); int updateCount = SqlserverHelper.Update("User", newFields, conditions); Console.WriteLine("更新记录的数量:" + updateCount); // 删除指定表中满足条件的记录,并返回受影响的行数 Dictionary delConditions = new Dictionary (); delConditions.Add("UserName", "test"); int delCount = SqlserverHelper.Delete("User", delConditions); Console.WriteLine("删除记录的数量:" + delCount); Console.ReadKey(); }
标签:
Copyright © 2015-2022 北冰洋空调网版权所有 备案号:沪ICP备2020036824号-3 联系邮箱:562 66 29@qq.com