草庐IT

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

大师兄117 2023-09-26 原文

我定义了一系列静态方法,用于执行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

 

有关C#写一套最全的SQL server帮助类(包括增删改查)的更多相关文章

  1. ruby - 有人可以帮助解释类创建的 post_initialize 回调吗 (Sandi Metz) - 2

    我正在阅读SandiMetz的POODR,并且遇到了一个我不太了解的编码原则。这是代码:classBicycleattr_reader:size,:chain,:tire_sizedefinitialize(args={})@size=args[:size]||1@chain=args[:chain]||2@tire_size=args[:tire_size]||3post_initialize(args)endendclassMountainBike此代码将为其各自的属性输出1,2,3,4,5。我不明白的是查找方法。当一辆山地自行车被实例化时,因为它没有自己的initialize方法

  2. c# - 如何在 ruby​​ 中调用 C# dll? - 2

    如何在ruby​​中调用C#dll? 最佳答案 我能想到几种可能性:为您的DLL编写(或找人编写)一个COM包装器,如果它还没有,则使用Ruby的WIN32OLE库来调用它;看看RubyCLR,其中一位作者是JohnLam,他继续在Microsoft从事IronRuby方面的工作。(估计不会再维护了,可能不支持.Net2.0以上的版本);正如其他地方已经提到的,看看使用IronRuby,如果这是您的技术选择。有一个主题是here.请注意,最后一篇文章实际上来自JohnLam(看起来像是2009年3月),他似乎很自在地断言RubyCL

  3. C# 到 Ruby sha1 base64 编码 - 2

    我正在尝试在Ruby中复制Convert.ToBase64String()行为。这是我的C#代码:varsha1=newSHA1CryptoServiceProvider();varpasswordBytes=Encoding.UTF8.GetBytes("password");varpasswordHash=sha1.ComputeHash(passwordBytes);returnConvert.ToBase64String(passwordHash);//returns"W6ph5Mm5Pz8GgiULbPgzG37mj9g="当我在Ruby中尝试同样的事情时,我得到了相同sha

  4. ruby-on-rails - Cucumber 是否只是 rspec 的包装器以帮助将测试组织成功能? - 2

    只是想确保我理解了事情。据我目前收集到的信息,Cucumber只是一个“包装器”,或者是一种通过将事物分类为功能和步骤来组织测试的好方法,其中实际的单元测试处于步骤阶段。它允许您根据事物的工作方式组织您的测试。对吗? 最佳答案 有点。它是一种组织测试的方式,但不仅如此。它的行为就像最初的Rails集成测试一样,但更易于使用。这里最大的好处是您的session在整个Scenario中保持透明。关于Cucumber的另一件事是您(应该)从使用您的代码的浏览器或客户端的角度进行测试。如果您愿意,您可以使用步骤来构建对象和设置状态,但通常您

  5. 基于C#实现简易绘图工具【100010177】 - 2

    C#实现简易绘图工具一.引言实验目的:通过制作窗体应用程序(C#画图软件),熟悉基本的窗体设计过程以及控件设计,事件处理等,熟悉使用C#的winform窗体进行绘图的基本步骤,对于面向对象编程有更加深刻的体会.Tutorial任务设计一个具有基本功能的画图软件**·包括简单的新建文件,保存,重新绘图等功能**·实现一些基本图形的绘制,包括铅笔和基本形状等,学习橡皮工具的创建**·设计一个合理舒适的UI界面**注明:你可能需要先了解一些关于winform窗体应用程序绘图的基本知识,以及关于GDI+类和结构的知识二.实验环境Windows系统下的visualstudio2017C#窗体应用程序三.

  6. ruby-on-rails - 需要帮助最大化多个相似对象中的 3 个因素并适当排序 - 2

    我需要用任何语言编写一个算法,根据3个因素对数组进行排序。我以度假村为例(如Hipmunk)。假设我想去度假。我想要最便宜的地方、最好的评论和最多的景点。但是,显然我找不到在所有3个中都排名第一的方法。Example(assumingthereare20importantattractions):ResortA:$150/night...98/100infavorablereviews...18of20attractionsResortB:$99/night...85/100infavorablereviews...12of20attractionsResortC:$120/night

  7. ruby - 如何在 ruby​​ 中复制目录结构,不包括某些文件扩展名 - 2

    我想编写一个ruby​​脚本来递归复制目录结构,但排除某些文件类型。因此,给定以下目录结构:folder1folder2file1.txtfile2.txtfile3.csfile4.htmlfolder2folder3file4.dll我想复制这个结构,但不包含.txt和.cs文件。因此,生成的目录结构应如下所示:folder1folder2file4.htmlfolder2folder3file4.dll 最佳答案 您可以使用查找模块。这是一个代码片段:require"find"ignored_extensions=[".cs"

  8. ruby - 帮助使用 Ruby 中的 "Whenever"gem 来执行 cron 任务 - 2

    我以前没有使用过cron,所以我不能确定我这样做是对的。我想要自动化的任务似乎没有运行。我在终端中执行了这些步骤:sudogeminstall每当切换到应用程序目录无论何时。(这创建了文件schedule.rb)我将此代码添加到schedule.rb:every10.minutesdorunner"User.vote",environment=>"development"endevery:hourdorunner"Digest.rss",:environment=>"development"end我将此代码添加到deploy.rb:after"deploy:symlink","depl

  9. ruby-on-rails - Ruby method_added 回调不触发包括模块 - 2

    我想写一点“Deprecate-It”库并经常使用“method_added”回调。但是现在我注意到在包含模块时不会触发此回调。是否有任何回调或变通方法,以便在某些内容包含到自身时通知类“Foobar”?用于演示的小Demo:#IncludingModulswon'ttriggermethod_addedcallbackmoduleInvisibleMethoddefinvisible"Youwon'tgetacallbackfromme"endendclassFoobardefself.method_added(m)puts"InstanceMethod:'#{m}'addedto'

  10. ruby - 正则表达式匹配包括新行 - 2

    我有一个正则表达式来获取"*"之间的所有内容:str="Donecsedodiodui.*Nullamiddoloridnibhultriciesvehiculaut*"str.match(/\*(.*)\*/)[1]我希望匹配能够包含换行符。我该怎么做? 最佳答案 您需要使用允许点匹配新行的m选项:Donecsedodiodui.*Nullamiddoloridnibhultriciesvehiculaut*regexstr.match(/\*(.*)\*/m)[1]实例:http://www.rubular.com/r/11u9

随机推荐