如何修复CS8602警告？处理数据库查询方法的空引用问题

1. ExecuteQuery 方法修复 #

原代码未处理dtsrc为null的情况，直接调用OpenConnection()会触发CS8602警告，且无法返回合法的Task<IEnumerable<T>>。修复时需先做空值检查，同时返回合法的空序列：

public async Task<IEnumerable<T>> ExecuteQuery<T>(string commandText, string ctx, CancellationToken cancellationToken, CommandType commandType = CommandType.Text, object? paramSet = null)
{
    string methodName = nameof(ExecuteQuery);
    var dtsrc = CheckConnectionToDbServer(ctx, cancellationToken);

    if (dtsrc == null)
    {
        _logger.LogTrace($"{methodName}: No datasource!");
        // 返回空序列，符合返回类型且避免空引用
        return Enumerable.Empty<T>();
    }

    using var con = dtsrc.OpenConnection(); // 用using自动释放连接，避免泄漏
    IEnumerable<T> result2 = await con.QueryAsync<T>(commandText, paramSet, commandType: commandType).ConfigureAwait(false);
    return result2;
}

修复说明 #

• 增加dtsrc空值检查，明确处理无数据源的情况，消除CS8602警告
• 返回Enumerable.Empty<T>()，保证调用方始终拿到非null的IEnumerable<T>，避免后续空引用问题
• 新增using声明管理数据库连接，规范资源释放逻辑

2. ExecuteScalarQuery 方法空数据源处理 #

该方法返回单个T，无数据源时需根据业务场景选择处理方式，以下是两种常见方案：

方案一：抛出异常（推荐，适用于数据源不可用属于错误场景） #

public async Task<T> ExecuteScalarQuery<T>(string commandText, string ctx, CancellationToken cancellationToken, CommandType commandType = CommandType.Text, object? paramSet = null)
{
    string methodName = nameof(ExecuteScalarQuery);
    _logger.LogTrace($"{methodName}: {ctx}");
    var dtsrc = CheckConnectionToDbServer(ctx, cancellationToken);

    if (dtsrc == null)
    {
        _logger.LogTrace($"{methodName}: No datasource!");
        throw new InvalidOperationException("无法获取数据库数据源，无法执行查询");
    }

    using var con = dtsrc.OpenConnection();
    return await con.QuerySingleAsync<T>(commandText, paramSet, commandType: commandType).ConfigureAwait(false);
}

方案二：返回默认值（适用于业务允许无结果的场景） #

public async Task<T> ExecuteScalarQuery<T>(string commandText, string ctx, CancellationToken cancellationToken, CommandType commandType = CommandType.Text, object? paramSet = null)
{
    string methodName = nameof(ExecuteScalarQuery);
    _logger.LogTrace($"{methodName}: {ctx}");
    var dtsrc = CheckConnectionToDbServer(ctx, cancellationToken);

    if (dtsrc == null)
    {
        _logger.LogTrace($"{methodName}: No datasource!");
        // 值类型返回默认值（如int返回0），引用类型返回null
        return default!; // 使用!抑制可能的null警告（若T为引用类型）
    }

    using var con = dtsrc.OpenConnection();
    return await con.QuerySingleAsync<T>(commandText, paramSet, commandType: commandType).ConfigureAwait(false);
}

方案说明 #

• 抛出异常：明确告知调用方当前操作失败，符合“数据源不可用属于异常情况”的逻辑，调用方需捕获异常处理
• 返回默认值：适合业务上允许无结果的场景，但需注意引用类型默认值为null，调用方需处理空引用风险

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