当前位置:首页> 行业快讯 >

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

时间:2023-04-21 13:19:21    来源:博客园


(资料图片仅供参考)

我定义了一系列静态方法,用于执行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=密码";  // 数据库连接字符串    ///     /// 执行指定的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, Dictionary fields)    {        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, Dictionary fields, 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, Dictionary conditions)    {        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;              // 返回受影响的行数    }}
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 fields = 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();        }
View Code
标签:

上一篇:

下一篇:

广东建成81条特色自然教育径 免费向公众开放

记者从广东省林业局获悉,今年广东省已建成101条特色自然教育径,总长度达176 4公里,其中有81条自然教育径免费向公众开放。据了解,自然教

2022-07-18

青藏高原最大中心城市发现多种珍稀野生动物影像

中新网西宁5月25日电 (记者 孙睿)中国科学院西北高原生物研究所专家连新明25日向中新网记者透露,通过近一年来的观测,在青藏高原最大中

2022-05-25

湖北一男子在赣病逝 家属捐献器官挽救3人

中新网南昌5月25日电 (记者 吴鹏泉)江西省红十字会24日消息,湖北一男子在江西南昌因病逝世,家属在悲痛中捐献其器官,挽救了3名重症患者

2022-05-25

湖北云梦全县域恢复实施常态化疫情防控措施

(抗击新冠肺炎)湖北云梦全县域恢复实施常态化疫情防控措施 中新网孝感5月25日电 据湖北孝感市云梦县新冠肺炎疫情防控指挥部通告,该县全

2022-05-25

手语律师唐帅:让法治阳光照亮无声世界

奋进新征程 建功新时代·我们的新时代丨手语律师唐帅:让法治阳光照亮无声世界 新华社重庆5月24日电 题:手语律师唐帅:让法治阳光照亮

2022-05-25

中国援柬中医张大武:升华中柬医患友谊的“关键钥匙”

中新网金边5月25日电 (记者 欧阳开宇)“大医博学,厚德济民”——中国中医科学院西苑医院院训。在张大武看来,这句话也是一把升华中柬医

2022-05-25

(中国这十年·吾乡)“邂逅雪豹”带热高原小镇

记者 李江宁 摄 " >

2022-05-25

“但凡有可能,就去做好它”

西北工业大学网络空间安全学院党总支书记王震—— “但凡有可能,就去做好它”(奋斗者正青春) 在西北工业大学网络空间安全学院,党总支书记王

2022-05-25

上海通报嘉定区1例本土无症状感染者排查情况 一地列为中风险地区

中新网5月25日电 据“上海发布”微信公众号消息,5月25日上午举行的上海市疫情防控工作新闻发布会上,上海市卫生健康委副主任赵丹丹介绍,

2022-05-25

上海嘉定区公布1例无症状感染者所涉及区域和场所

中新网5月25日电 据“上海发布”微信公众号消息,5月25日上午举行的上海市疫情防控工作新闻发布会上,上海嘉定区副区长王浩介绍:5月24日

2022-05-25