如何异步使用CsvDataReader？有无合适的异步替代方案？

CsvDataReader确实没有实现DbDataReader的异步方法（比如ReadAsync、IsDBNullAsync），直接调用基类的异步方法会阻塞线程，并非真正的异步操作。但可以通过封装自定义异步DbDataReader的方式，结合底层CsvReader的异步API来实现需求。

方案：封装异步CsvDataReader包装类 #

下面是一个简化的包装类实现，内部委托CsvReader的异步方法来提供真正的异步读取能力：

public class AsyncCsvDataReader : DbDataReader
{
    private readonly CsvReader _csvReader;
    private bool _isClosed;

    public AsyncCsvDataReader(CsvReader csvReader)
    {
        _csvReader = csvReader;
        _isClosed = false;
    }

    // 核心异步读取方法
    public override async Task<bool> ReadAsync(CancellationToken cancellationToken)
    {
        if (_isClosed)
            throw new ObjectDisposedException(nameof(AsyncCsvDataReader));
        
        return await _csvReader.ReadAsync(cancellationToken).ConfigureAwait(false);
    }

    // 异步判断字段是否为Null
    public override async Task<bool> IsDBNullAsync(int ordinal, CancellationToken cancellationToken)
    {
        if (_isClosed)
            throw new ObjectDisposedException(nameof(AsyncCsvDataReader));
        
        return await _csvReader.IsRecordAsync(ordinal, cancellationToken).ConfigureAwait(false);
    }

    // 实现DbDataReader的必要抽象成员
    public override int FieldCount => _csvReader.Context.Record.Count;
    public override object this[int ordinal] => _csvReader.GetField(ordinal);
    public override string GetName(int ordinal) => _csvReader.Context.HeaderRecord[ordinal];
    public override Type GetFieldType(int ordinal) => _csvReader.GetFieldType(ordinal);
    public override object GetValue(int ordinal) => _csvReader.GetField(ordinal);

    public override void Close()
    {
        _isClosed = true;
        _csvReader.Dispose();
    }

    public override bool IsClosed => _isClosed;

    // 其他未用到的成员可按需实现或抛出NotImplementedException
    public override bool HasRows => throw new NotImplementedException();
    public override int Depth => throw new NotImplementedException();
    public override int RecordsAffected => throw new NotImplementedException();
    // ... 其他成员根据实际使用场景补充
}

使用示例 #

结合SqlBulkCopy的异步方法实现流式写入SQL数据库：

using var streamReader = new StreamReader("your_data.csv");
using var csvReader = new CsvReader(streamReader, new CsvConfiguration(CultureInfo.InvariantCulture)
{
    // 根据你的CSV格式配置选项，比如分隔符、引号规则等
    Delimiter = ",",
    HasHeaderRecord = true
});

// 先读取表头
await csvReader.ReadAsync();
await csvReader.ReadHeaderAsync();

using var asyncCsvReader = new AsyncCsvDataReader(csvReader);
using var sqlConn = new SqlConnection("your_sql_connection_string");
await sqlConn.OpenAsync();

using var bulkCopy = new SqlBulkCopy(sqlConn);
bulkCopy.DestinationTableName = "TargetTable";

// 自动映射CSV表头到数据库列（需确保表头与列名一致）
foreach (var header in csvReader.Context.HeaderRecord)
{
    bulkCopy.ColumnMappings.Add(header, header);
}

// 异步流式写入
await bulkCopy.WriteToServerAsync(asyncCsvReader);

补充说明 #

• 上述包装类仅实现了核心异步方法和必要成员，如果你的场景需要使用其他DbDataReader方法（如GetStringAsync、GetInt32Async等），需要在包装类中补充对应的异步实现，内部调用CsvReader的异步API。
• 目前CsvHelper官方尚未为CsvDataReader提供原生异步支持，自定义包装类是当前最可行的异步流式解决方案。

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