从MySql.Data迁移至MySqlConnector：缺失ExecuteScalar等方法的解决办法

问题背景 #

迁移到MySqlConnector后，原MySql.Data中的MySqlHelper类没有ExecuteNonQuery、ExecuteScalar、ExecuteDataset这些预定义方法，需要自行实现包装器兼容原有代码逻辑。

替代方案：自定义MySqlHelper包装类 #

基于MySqlConnector原生API封装对应方法，保持原有调用方式不变，以下是具体实现：

1. 适配你的原有ExecuteNonQuery方法 #

替换原MySqlHelper调用为MySqlConnector原生逻辑，同时优化资源管理：

public int ExecuteNonQuery()
{
    using var connection = new MySqlConnection(ConnectionString);
    connection.Open();
    using var command = new MySqlCommand(CommandTextForMySqlHelper, connection);
    if (ParameterArrayForMySqlHelper != null)
        command.Parameters.AddRange(ParameterArrayForMySqlHelper);
    
    try
    {
        return command.ExecuteNonQuery();
    }
    catch (Exception ex)
    {
        throw; // 保留异常堆栈信息，避免重置
    }
}

说明：使用using语句自动释放连接和命令资源，无需手动调用Close/Dispose

2. 通用MySqlHelper包装类完整实现 #

如果需要兼容更多原MySqlHelper方法，可以封装一个静态类模拟原接口：

using MySqlConnector;
using System.Data;

public static class MySqlHelper
{
    // 封装ExecuteNonQuery
    public static int ExecuteNonQuery(MySqlConnection connection, string commandText, params MySqlParameter[] parameters)
    {
        using var command = new MySqlCommand(commandText, connection);
        if (parameters != null)
            command.Parameters.AddRange(parameters);
        
        return command.ExecuteNonQuery();
    }

    // 封装ExecuteScalar
    public static object ExecuteScalar(MySqlConnection connection, string commandText, params MySqlParameter[] parameters)
    {
        using var command = new MySqlCommand(commandText, connection);
        if (parameters != null)
            command.Parameters.AddRange(parameters);
        
        return command.ExecuteScalar();
    }

    // 封装ExecuteDataset
    public static DataSet ExecuteDataset(MySqlConnection connection, string commandText, params MySqlParameter[] parameters)
    {
        using var command = new MySqlCommand(commandText, connection);
        if (parameters != null)
            command.Parameters.AddRange(parameters);
        
        using var adapter = new MySqlDataAdapter(command);
        var dataset = new DataSet();
        adapter.Fill(dataset);
        
        return dataset;
    }

    // 带连接字符串的重载（自动管理连接生命周期）
    public static int ExecuteNonQuery(string connectionString, string commandText, params MySqlParameter[] parameters)
    {
        using var connection = new MySqlConnection(connectionString);
        connection.Open();
        return ExecuteNonQuery(connection, commandText, parameters);
    }
}

使用注意事项 #

• 原代码中throw ex;会重置异常堆栈，建议改为throw;保留完整错误信息
• MySqlConnector的MySqlParameter与原MySql.Data参数用法基本一致，无需大幅修改原有参数构造逻辑
• 始终使用using语句管理数据库连接、命令等资源，避免内存泄漏

内容的提问来源于stack exchange，提问作者Hakuna Matata