C#连接MySQL插入数据时提示变量为空异常该如何解决

核心问题定位 #

现有代码存在4个直接导致空值报错的问题：

• 拼接SQL未使用参数化，变量为null时会直接生成语法错误的SQL语句，同时存在SQL注入风险
• 方法职责混淆：Execute方法实际是用于查询数据的，内部调用了MySqlDataAdapter.Fill，不支持执行插入/更新/删除操作，错误调用该方法执行插入会触发空值异常
• 连接字符串配置错误：MySQL连接字符串的端口为单独Port参数，不能直接写在SERVER字段后，参数解析异常会引发后续变量赋值为空
• 异常处理过于粗糙：仅抛出基础报错信息，没有输出具体SQL、出错字段和堆栈信息，无法快速定位空值来源

分步修复方案 #

1. 修复连接字符串配置 #

修改Connect方法中的连接字符串拼接逻辑，拆分服务地址和端口：

// 优先新增单独的端口字段更稳妥
public string server = "127.0.0.1";
public string port = "3306";

public void Connect(string database_name)
{
    try
    {
        ConectionString = $"SERVER={server};Port={port};DATABASE={database_name};UID={user};PASSWORD={password};";
        connection = new MySqlConnection(ConectionString);
    }
    catch (Exception E)
    {
        MessageBox.Show(E.Message);
    }
}

2. 插入前强制校验所有字段值 #

构造插入语句前，先校验所有待插入的变量值，存在空值直接拦截：

// 示例：插入前校验逻辑
if(string.IsNullOrEmpty(用户名字段值) || string.IsNullOrEmpty(年龄字段值))
{
    MessageBox.Show("存在必填字段为空，无法插入");
    return;
}
// 空值兜底逻辑，赶时间可以用
用户名字段值 = 用户名字段值 ?? "";
年龄字段值 = 年龄字段值 == null ? 0 : 年龄字段值;

3. 替换拼接SQL为参数化查询 #

重构插入方法，使用参数化传递数值，从根源避免空值导致的SQL语法错误，同时自动处理值类型转换：

// 新增安全的插入方法
public void ExecuteInsert(string tableName, Dictionary<string, object> fieldValues)
{
    // 校验所有字段非空
    foreach(var item in fieldValues)
    {
        if(item.Value == null || string.IsNullOrWhiteSpace(item.Value.ToString()))
        {
            MessageBox.Show($"字段{item.Key}为空，插入终止");
            return;
        }
    }
    try
    {
        using(MySqlConnection cs = new MySqlConnection(ConectionString))
        {
            cs.Open();
            // 构造参数化SQL
            string fields = string.Join(",", fieldValues.Keys);
            string paramsStr = string.Join(",", fieldValues.Keys.Select(k => $"@{k}"));
            string sql = $"INSERT INTO {tableName} ({fields}) VALUES ({paramsStr})";
            
            MySqlCommand myc = new MySqlCommand(sql, cs);
            // 填充参数
            foreach(var item in fieldValues)
            {
                myc.Parameters.AddWithValue($"@{item.Key}", item.Value);
            }
            myc.ExecuteNonQuery();
        }
    }
    catch (Exception err)
    {
        // 输出完整报错信息方便排查
        MessageBox.Show($"插入失败：{err.Message}\n堆栈信息：{err.StackTrace}");
    }
}

调用示例：

DBConnect db = new DBConnect();
db.Connect("你的数据库名");
Dictionary<string, object> insertData = new Dictionary<string, object>();
insertData.Add("name", "测试用户");
insertData.Add("age", 22);
db.ExecuteInsert("teste1", insertData);

临时赶工方案（适合次日交付快速跑通） #

如果来不及重构代码，可先在构造插入SQL前给所有可能为空的变量加兜底默认值，保证拼接的SQL没有空值即可，优先跑通功能后续再优化。

内容的提问来源于stack exchange，提问作者Leonardo Cani Schumann