C#操作MySQL增删改查

当前位置:

首页 > c#编程 >

C#操作MySQL增删改查

在C#中操作MySQL数据库进行增删改查（CRUD）操作时，使用`MySql.Data`库是一种常见的做法。这里我将给出一个更加精炼和具体的示例，展示如何在C#中使用`MySql.Data`库执行MySQL数据库的增删改查操作。

首先，确保你的项目中已经通过NuGet安装了`MySql.Data`包。

然后，你可以创建一个类来封装数据库操作。这个类将包含四个主要的方法：`Insert`、`Select`、`Update`和`Delete`。但是，由于直接执行SQL查询并返回具体类型的数据集可能会很复杂，我将在`Select`方法中返回一个`DataTable`对象，这样你就可以在调用端灵活处理查询结果。

以下是一个简单的示例类：

using System;
using System.Data;
using MySql.Data.MySqlClient;

public class MySqlHelper
{
    private string connectionString = "server=localhost;user=root;database=yourdatabase;port=3306;password=yourpassword;";

    // 插入数据
    public void Insert(string tableName, string insertColumns, string values)
    {
        string query = $"INSERT INTO {tableName} ({insertColumns}) VALUES ({values})";
        using (MySqlConnection conn = new MySqlConnection(connectionString))
        {
            conn.Open();
            using (MySqlCommand cmd = new MySqlCommand(query, conn))
            {
                int result = cmd.ExecuteNonQuery();
                if (result > 0)
                {
                    Console.WriteLine("数据插入成功！");
                }
            }
        }
    }

    // 读取数据
    public DataTable Select(string tableName, string selectColumns, string whereClause = "")
    {
        string query = $"SELECT {selectColumns} FROM {tableName}";
        if (!string.IsNullOrEmpty(whereClause))
        {
            query += $" WHERE {whereClause}";
        }

        DataTable table = new DataTable();
        using (MySqlConnection conn = new MySqlConnection(connectionString))
        {
            conn.Open();
            using (MySqlCommand cmd = new MySqlCommand(query, conn))
            {
                using (MySqlDataAdapter adapter = new MySqlDataAdapter(cmd))
                {
                    adapter.Fill(table);
                }
            }
        }

        return table;
    }

    // 更新数据
    public void Update(string tableName, string updateColumns, string whereClause)
    {
        string query = $"UPDATE {tableName} SET {updateColumns} WHERE {whereClause}";
        using (MySqlConnection conn = new MySqlConnection(connectionString))
        {
            conn.Open();
            using (MySqlCommand cmd = new MySqlCommand(query, conn))
            {
                int result = cmd.ExecuteNonQuery();
                if (result > 0)
                {
                    Console.WriteLine("数据更新成功！");
                }
            }
        }
    }

    // 删除数据
    public void Delete(string tableName, string whereClause)
    {
        string query = $"DELETE FROM {tableName} WHERE {whereClause}";
        using (MySqlConnection conn = new MySqlConnection(connectionString))
        {
            conn.Open();
            using (MySqlCommand cmd = new MySqlCommand(query, conn))
            {
                int result = cmd.ExecuteNonQuery();
                if (result > 0)
                {
                    Console.WriteLine("数据删除成功！");
                }
            }
        }
    }
}

// 使用示例
class Program
{
    static void Main(string[] args)
    {
        MySqlHelper dbHelper = new MySqlHelper();

        // 插入数据
        dbHelper.Insert("students", "name, age", "'John Doe', 20");

        // 读取数据
        DataTable dataTable = dbHelper.Select("students", "*");
        foreach (DataRow row in dataTable.Rows)
        {
            Console.WriteLine($"Name: {row["name"]}, Age: {row["age"]}");
        }

        // 更新和删除数据（可以根据需要调用Update和Delete方法）
    }
}

**注意**：

1. 在`Insert`、`Update`和`Delete`方法中，我直接将SQL查询语句中的参数拼接到了查询字符串中。这在实际应用中可能导致SQL注入安全问题。为了避免这种情况，你应该使用参数化查询（就像你在`Select`方法中看到的那样，但`Select`通常返回数据集，因此它可能不使用参数化

最后，如果你对python语言还有任何疑问或者需要进一步的帮助，请访问https://www.xin3721.com 本站原创，转载请注明出处：https://www.xin3721.com/ArticlecSharp/c50053.html

栏目列表