1. Python技术站首页
  2. 其他
  3. C#

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

• C#

介绍说明：
这个帮助类包含了六个主要的方法：
ExecuteNonQuery、ExecuteScalar、ExecuteQuery、ExecuteQuery（泛型）、Insert、Update和Delete。
其中，ExecuteNonQuery用于执行不返回结果集的SQL语句；
ExecuteScalar用于执行一个查询，并返回结果集中第一行的第一列；
ExecuteQuery用于执行一个查询，并返回结果集；
ExecuteQuery（泛型）用于执行一个查询，并将结果集映射到一个对象列表；
Insert用于向数据库中插入数据；
Update用于更新数据库中的数据；
Delete用于删除数据库中的数据。

一、以下是一个基于C#的MySQL帮助类的示例代码，可以用于连接数据库、执行SQL语句、读取数据等操作：

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

using System;
using System.Collections.Generic;
using System.Data;
using MySql.Data.MySqlClient;

public class MySQLHelper
{
    private string connectionString;

    public MySQLHelper(string connectionString)
    {
        this.connectionString = connectionString;
    }

    // 执行不返回结果集的SQL语句
    public int ExecuteNonQuery(string sql, params MySqlParameter[] parameters)
    {
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(sql, connection))
            {
                // 添加参数
                command.Parameters.AddRange(parameters);
                // 打开连接
                connection.Open();
                // 执行SQL语句并返回影响行数
                return command.ExecuteNonQuery();
            }
        }
    }

    // 执行一个查询，并返回结果集中第一行的第一列
    public object ExecuteScalar(string sql, params MySqlParameter[] parameters)
    {
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(sql, connection))
            {
                // 添加参数
                command.Parameters.AddRange(parameters);
                // 打开连接
                connection.Open();
                // 执行SQL查询并返回第一行第一列的值
                return command.ExecuteScalar();
            }
        }
    }

    // 执行一个查询，并返回结果集
    public DataTable ExecuteQuery(string sql, params MySqlParameter[] parameters)
    {
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(sql, connection))
            {
                // 添加参数
                command.Parameters.AddRange(parameters);
                // 打开连接
                connection.Open();
                // 创建DataAdapter和DataTable对象，并填充数据
                using (MySqlDataAdapter adapter = new MySqlDataAdapter(command))
                {
                    DataTable dataTable = new DataTable();
                    adapter.Fill(dataTable);
                    return dataTable;
                }
            }
        }
    }

    // 执行一个查询，并将结果集映射到一个对象列表
    public List<T> ExecuteQuery<T>(string sql, Func<IDataRecord, T> selector, params MySqlParameter[] parameters)
    {
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            using (MySqlCommand command = new MySqlCommand(sql, connection))
            {
                // 添加参数
                command.Parameters.AddRange(parameters);
                // 打开连接
                connection.Open();
                // 创建DataReader对象并读取数据，将每行数据映射到对象并添加到列表中
                using (MySqlDataReader reader = command.ExecuteReader())
                {
                    List<T> list = new List<T>();
                    while (reader.Read())
                    {
                        list.Add(selector(reader));
                    }
                    return list;
                }
            }
        }
    }

    // 向数据库中插入数据
    public int Insert(string tableName, Dictionary<string, object> data)
    {
        string[] columns = new string[data.Count];
        object[] values = new object[data.Count];

        int i = 0;
        foreach (KeyValuePair<string, object> item in data)
        {
            // 获取列名和值
            columns[i] = item.Key;
            values[i] = item.Value;
            i++;
        }

        string sql = string.Format("INSERT INTO {0} ({1}) VALUES ({2})", tableName, string.Join(",", columns), "@" + string.Join(",@", columns));

        // 将Dictionary转换为MySqlParameter数组，并执行SQL语句
        return ExecuteNonQuery(sql, ToMySqlParameters(data));
    }

    // 更新数据库中的数据
    public int Update(string tableName, Dictionary<string, object> data, string whereClause = "")
    {
        string[] setValues = new string[data.Count];
        int i = 0;
        foreach (KeyValuePair<string, object> item in data)
        {
            // 获取列名和值
            setValues[i] = string.Format("{0}=@{0}", item.Key);
            i++;
        }

        string sql = string.Format("UPDATE {0} SET {1}", tableName, string.Join(",", setValues));

        if (!string.IsNullOrEmpty(whereClause))
        {
            sql += " WHERE " + whereClause;
        }

        // 将Dictionary转换为MySqlParameter数组，并执行SQL语句
        return ExecuteNonQuery(sql, ToMySqlParameters(data));
    }

    // 删除数据库中的数据
    public int Delete(string tableName, string whereClause = "")
    {
        string sql = string.Format("DELETE FROM {0}", tableName);

        if (!string.IsNullOrEmpty(whereClause))
        {
            sql += " WHERE " + whereClause;
        }

        // 执行SQL语句并返回影响

        return ExecuteNonQuery(sql);
    }
    // 将Dictionary转换为MySqlParameter数组
    private MySqlParameter[] ToMySqlParameters(Dictionary<string, object> data)
    {
        List<MySqlParameter> parameters = new List<MySqlParameter>();

        foreach (KeyValuePair<string, object> item in data)
        {
            parameters.Add(new MySqlParameter("@" + item.Key, item.Value));
        }

        return parameters.ToArray();
    }
}

View Code

二、另外，在使用这个帮助类时，需要先创建一个连接字符串，例如

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

string connectionString = "server=localhost;database=myDatabase;uid=myUsername;password=myPassword;";
MySQLHelper mySQLHelper = new MySQLHelper(connectionString);

View Code

三、然后就可以使用这个帮助类来访问MySQL数据库了。下面是一些示例代码：

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

// 查询所有数据
DataTable dataTable = mySQLHelper.ExecuteQuery("SELECT * FROM myTable");
foreach (DataRow row in dataTable.Rows)
{
    Console.WriteLine(row["column1"].ToString());
}


// 查询单个值
object value = mySQLHelper.ExecuteScalar("SELECT COUNT(*) FROM myTable");
Console.WriteLine(value.ToString());


// 查询并映射到对象列表
List<MyClass> list = mySQLHelper.ExecuteQuery("SELECT * FROM myTable", r => new MyClass
{
    Column1 = r["column1"].ToString(),
    Column2 = int.Parse(r["column2"].ToString())
});


// 插入数据
Dictionary<string, object> data = new Dictionary<string, object>();
data.Add("column1", "value1");
data.Add("column2", 123);
int result = mySQLHelper.Insert("myTable", data);


// 更新数据
Dictionary<string, object> data = new Dictionary<string, object>();
data.Add("column1", "value2");
data.Add("column2", 456);
int result = mySQLHelper.Update("myTable", data, "id=1");


// 删除数据
int result = mySQLHelper.Delete("myTable", "id=1");

View Code

               注：这些示例代码展示了如何使用这个帮助类来执行常见的MySQL操作，例如查询、插入、更新和删除数据。请注意，在执行SQL语句时，要避免SQL注入攻击，可以使用参数化查询来确保安全。

四、就上述SQL注入攻击，防范例子：

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

//是的，使用参数化查询是避免SQL注入攻击的重要方法之一。C#中可以使用MySqlParameter类来创建参数化查询，下面简单介绍一下如何使用MySqlParameter类。
//首先，看一个普通的SQL语句：
      string sql = "SELECT * FROM Users WHERE name='" + userName + "' AND password='" + password + "'";
//这个SQL语句接收两个字符串类型的参数：userName和password。但是，如果恶意用户在输入用户名或密码时添加了SQL代码，则可能会导致SQL注入攻击。例如，如果用户输入了以下内容作为密码：
      a' OR 'a'='a
 //则生成的SQL语句将变成：
      SELECT* FROM Users WHERE name='xxx' AND password = 'a' OR 'a'='a'
//这个SQL语句将始终返回true，因为'a'='a'是永远成立的，所以用户可以绕过登录验证并访问数据库。

//为了避免这种情况发生，我们可以使用MySqlParameter类来创建参数化查询。以下是一个示例：
      string sql = "SELECT * FROM Users WHERE name=@UserName AND password=@Password";
      using (MySqlConnection connection = new MySqlConnection(connectionString))
      {
          using (MySqlCommand command = new MySqlCommand(sql, connection))
          {
              // 创建参数
              command.Parameters.Add(new MySqlParameter("@UserName", userName));
              command.Parameters.Add(new MySqlParameter("@Password", password));
              
              // 打开连接并执行查询
              connection.Open();
              using (MySqlDataReader reader = command.ExecuteReader())
              {
                  // 处理结果集
              }
          }
      }
//在这个示例中，我们使用了 @符号来标记参数名称，并使用MySqlParameter类为每个参数创建实例。这样，即使用户在输入用户名或密码时添加了SQL代码，它也不会影响生成的SQL语句。
//总之，使用参数化查询是一个非常重要的安全措施，可以有效预防SQL注入攻击，C#提供了方便易用的MySqlParameter类来支持参数化查询。

View Code

 

原文链接：https://www.cnblogs.com/wxsdyz/p/17339519.html

本站文章如无特殊说明，均为本站原创，如若转载，请注明出处：C#写一套最全的MySQL帮助类（包括增删改查） - Python技术站

赞 (0)
0 0 打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023年4月27日
下一篇 2023年4月27日

相关文章

  • C#获取两个数的最大公约数和最小公倍数示例

    C#获取两个数的最大公约数和最小公倍数示例 本文将介绍如何在C#中获取两个数的最大公约数和最小公倍数。我们将使用辗转相除法和欧几里得算法来计算最大公约数和最小公倍数。C#中计算最大公约数和最小公倍数的示例代码也会在文章中提供。 计算最大公约数（GCD） 两个正整数a和b的最大公约数（GCD）是能够同时整除两个数的最大正整数。下面我们将使用辗转相除法来计算两个…

    C# 2023年6月7日
    00

  • C#网页信息采集方法汇总

    标题：C#网页信息采集方法汇总 介绍 C#是一种面向对象的编程语言，在网络爬虫中有广泛的应用。本文将介绍C#网页信息采集的基础知识和常用的方法，让大家快速入门。 基础知识 HTML和CSS 网页是由HTML和CSS构成的，HTML用来定义网页的内容结构，CSS用来定义网页的样式和布局。在进行网页信息采集前，需要了解HTML和CSS的基础知识。 HTTP协议 …

    C# 2023年5月31日
    00

  • SimpleAdmin手摸手教学之：项目架构设计2.0

    一、说明 在SimpleAdmin1.0版本中，我将整体项目结构分为三大块，分别为架构核心、业务模块和应用服务。随着1.0版本的封版，回去再看我之前的项目架构，也暴露了一些问题，比如在1.0版本中，Signalr和Mqtt只能二选一，这显然是不科学的，因为这两种虽然都可以作为消息通知，但是显然可以有更多的应用场景，所以如果两者只能用其一的话，显然整个项目架构…

    C# 2023年4月18日
    00

  • C# Linq的Where()方法 – 筛选序列中满足指定条件的元素

    C# 中的 Linq（Language Integrated Query）提供了一组极具表现力的 API 以使用语言的简洁 和查询能力。其中，Where() 是 Linq 中最常用的操作符之一，主要用于根据指定的条件筛选出序列中满足条件的元素，并返回这个元素组成的新序列。 该操作符的基本语法如下： public static IEnumerable<T…

    C# 2023年4月19日
    00

  • C#微信公众号与订阅号接口开发示例代码

    下面我将详细讲解如何进行C#微信公众号与订阅号接口开发，并提供以下两个示例说明： 示例一：获取微信公众号基本信息 步骤一：申请开发者账号 首先，你需要到微信公众平台官网上注册一个开发者账号。 步骤二：创建公众号 在申请开发者账号后，你需要创建一个新的公众号。 步骤三：获取AppID和AppSecret 创建公众号后，在公众号设置页面可以获取到AppID和Ap…

    C# 2023年5月31日
    00

  • C#工程建立后修改工程文件名与命名空间操作

    C#工程的文件名与命名空间是非常重要的，因为它们直接影响了代码的可维护性与可重用性。在建立C#工程时，如果文件名与命名空间不符合要求，需要进行修改。下面是完整的操作攻略。 步骤一：建立工程并修改文件名 使用Visual Studio新建一个C#工程。 右键单击解决方案管理器中的工程节点，选择“重命名”。 输入新的文件名并按下Enter键。 在弹出的对话框中选…

    C# 2023年5月15日
    00

  • C#使用log4net记录日志的方法步骤

    请看以下步骤： 第一步：添加log4net依赖 如果你使用的是nuget包管理器，可以在项目中直接添加log4net的nuget依赖；如果你需要手动添加log4net，可以在官网下载最新版的log4net，并将log4net.dll文件添加到项目的引用中。 第二步：在项目中添加log4net的配置文件 log4net的配置文件是一个xml文件，用来配置log…

    C# 2023年5月15日
    00

  • C#创建自定义控件及添加自定义属性和事件使用实例详解

    很高兴听到您对C#创建自定义控件及添加自定义属性和事件使用实例的详细讲解感兴趣。那么我来为您详细讲解一下。 创建自定义控件 C#允许我们通过继承Control类来创建自定义控件。以下是创建自定义控件的步骤： 新建一个类，并将其继承自Control类。 public class MyCustomControl : Control { // 自定义控件的实现代码…

    C# 2023年6月7日
    00
合作推广
合作推广
分享本页
返回顶部