首页 > 数据库 >C#写一套最全的SQL server帮助类(包括增删改查)

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

时间:2023-04-21 11:12:30浏览次数:37  
标签:返回 行数 C# cmd 改查 server sql SQL new

我定义了一系列静态方法,用于执行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#,cmd,改查,server,sql,SQL,new
From: https://www.cnblogs.com/wxsdyz/p/17339632.html

相关文章

  • Android-service
    原文地址zhuanlan.zhihu.com残枫cpsService是一种可在后台执行长时间运行操作而不提供界面的应用组件。AndroidServiceAndroidService是组件,既不能说它是单独的进程也不能说它是单独的线程。如果非要从通俗的语言层面来理解的话,姑且将其理解为对象。这个Service对象本......
  • Docker翻脸,不再开源!
    导读前几日,DockerHub出了一件大事!但凡创建了“organisation”的用户都收到了一封含有简短PDF链接的邮件。邮件的内容“金钱味”十足:如果不按照要求升级付费,用户就将失去对数据的访问权限。此举不仅会破坏开源项目的自动化构建,还为一直依赖于开源的用户带来巨大的焦虑和麻烦。......
  • vscode 当做记事本,用任务 tasks 自动提交git - ctrl shift B
    vscode当做记事本,用任务tasks自动提交git-ctrlshiftB起因开始用的joplin本地记事本挺好,唯一缺点不能同步。用了一下,发现markdown是两栏的,变成一栏就是html的。如果要是两栏,我能接受的话,那就直接vscode不就完了吗代码tasks.json{//Seehttps://go.microsof......
  • poi读写EXCEL
    读写EXCEL来源:bilibili狂神说导入依赖<!--导入依赖--><dependencies><dependency><groupId>org.apache.poi</groupId><artifactId>poi</artifactId><version>3.9</version>......
  • M1 Mac Xcode模拟器无法运行
    from:https://www.jianshu.com/p/87a5cca2a490 新版本的M1芯片运行模拟器报CocoaPods库(如:WechatOpenSDK报arm64错误)错误,是因为M1兼容问题,解决办法有两种如下:强烈推荐方法2方法1:强制打开xcode对x86的支持,有缺点:因为还是采用x86,编译速度很慢。关闭xcode--应用程序--xocde--......
  • C语法
    原文地址zhuanlan.zhihu.comC语法残枫cps​目录收起void指针NULL指针指向指针的指针常量常量指针与指向常量的指针可变参数va_list是类型函数:函数名=函数地址指针函数函数指针函数指针作为参数函数指针作为返回值全局变量extern关键字作用域链接属性void指针NULL......
  • MFC-GetCurrentProcess获取当前进程的伪句柄
     CStringstr;HANDLEhandle=GetCurrentProcess();//获取当前进程的伪句柄/*返回当前进程的伪句柄(始终返回-1)不要直接使用-1这个值,为了将来的兼容性请使用GetCurrentProcess伪句柄可以在当前进程中使用,如果需要跨进程通信,那么必须拿出自己真实......
  • 在线CTF工具箱--端口扫描--杂项--密码学--编码和解码
    这是为CTF发烧者准备的的工具套件,助你过关斩将、攻克难关。目前基础功能和一部分高级功能已经完成,可以在GitHub上查看工具列表和开发进度。 CTFer:https://ctfever.uniiem.com/ 项目地址:https://github.com/UniiemStudio/CTFever ......
  • hive出现MetaException(message:Metastore contains multiple versions (2)异常
    1、使用Spark操作Hive表时发生的报错2、错误日志23/04/1908:49:28WARNmetadata.Hive:Failedtoaccessmetastore.Thisclassshouldnotaccessedinruntime.org.apache.hadoop.hive.ql.metadata.HiveException:java.lang.RuntimeException:Unabletoinstantiateor......
  • c#基础
    原文地址zhuanlan.zhihu.comc#基础残枫cps​目录收起C#中的关键字C#的注释C#的常量C#的变量算法——交换C#的数据类型C#的类型转换C#标识符的命名规则C#的算术运算符(一)C#的算术运算符(二)C#的算术运算符(三)C#的比较运算符C#的逻辑运算符(一)C#的赋值运算符C#的运算符优先级Ctrl......