c# mysqlhelper

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

public class MySQLHelper
{
    private string connectionString;

    public MySQLHelper(string server, string database, string uid, string password)
    {
        connectionString = $"SERVER={server};DATABASE={database};UID={uid};PASSWORD={password};";
    }

    // 执行查询语句并返回DataTable
    public DataTable ExecuteQuery(string query)
    {
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            MySqlCommand command = new MySqlCommand(query, connection);
            try
            {
                connection.Open();
                MySqlDataAdapter adapter = new MySqlDataAdapter(command);
                DataTable dataTable = new DataTable();
                adapter.Fill(dataTable);
                return dataTable;
            }
            catch (Exception ex)
            {
                Console.WriteLine($"An error occurred: {ex.Message}");
                return null;
            }
        }
    }

    // 执行非查询语句（如插入、更新、删除）
    public int ExecuteNonQuery(string query)
    {
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            MySqlCommand command = new MySqlCommand(query, connection);
            try
            {
                connection.Open();
                return command.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                Console.WriteLine($"An error occurred: {ex.Message}");
                return -1;
            }
        }
    }

    // 执行标量查询（返回单个值）
    public object ExecuteScalar(string query)
    {
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            MySqlCommand command = new MySqlCommand(query, connection);
            try
            {
                connection.Open();
                return command.ExecuteScalar();
            }
            catch (Exception ex)
            {
                Console.WriteLine($"An error occurred: {ex.Message}");
                return null;
            }
        }
    }
}

解释说明

1. 连接字符串:

   • connectionString 用于存储数据库的连接信息，包括服务器地址、数据库名称、用户名和密码。

2. 构造函数:

   • MySQLHelper 类的构造函数接收数据库连接所需的参数，并构建连接字符串。

3. ExecuteQuery 方法:

   • 该方法用于执行查询语句，并返回一个 DataTable 对象。它使用 MySqlDataAdapter 来填充数据表。
   • 如果发生异常，则捕获并输出错误信息，返回 null。

4. ExecuteNonQuery 方法:

   • 该方法用于执行不返回结果集的 SQL 语句（如插入、更新、删除），并返回受影响的行数。
   • 如果发生异常，则捕获并输出错误信息，返回 -1。

5. ExecuteScalar 方法:

   • 该方法用于执行返回单个值的查询（如 SELECT COUNT(*)），并返回该值。
   • 如果发生异常，则捕获并输出错误信息，返回 null。

以上代码展示了如何使用 C# 和 MySQL 进行基本的数据库操作。