Как добавить записи CsvHelper в DataTable для использования для SqlBulkCopy в базе данных

Если я не ошибаюсь, вы сможете сделать это с гораздо меньшим количеством кода. Вам также не нужно переходить в другой класс перед тем, как перейти в DataTable.

while( csv.Read() )
{
    var row = dt.NewRow();
    foreach( DataColumn column in dt.Columns )
    {
        row[column.ColumnName] = csv.GetField( column.DataType, column.ColumnName );
    }
    dt.Rows.Add( row );
}

В прошлом году Джош добавил поддержку чтения заголовков, и следующий блок может быть полезен тем, кто просто хочет создать DataTable, используя схему документа CSV. Я хотел опубликовать это как комментарий к ответу Джоша, поскольку это всего лишь небольшая модификация, но публикуется как ответ, поскольку я не мог отформатировать блок кода в комментариях.

    private DataTable BuildDataTable()
    {
        var dt = new DataTable();

        using (var textReader = new StreamReader(_path))
        {
            using (var csv = new CsvReader(textReader))
            {
                csv.ReadHeader();
                foreach (var header in csv.FieldHeaders)
                {
                    dt.Columns.Add(header);
                }


                while (csv.Read())
                {
                    var row = dt.NewRow();
                    foreach (DataColumn column in dt.Columns)
                    {
                        row[column.ColumnName] = csv.GetField(column.DataType, column.ColumnName);
                    }
                    dt.Rows.Add(row);
                }
            }
        }

        return dt;
    }

Мне удалось заставить это работать, добавив строку DataTable и явно заполнив ее, вместо того, чтобы пытаться добавить запись CsvHelper в виде строки.

Я использовал следующую часть вместо той, которая показана выше:

foreach (var record in records)
{
    DataRow row = dt.NewRow();
    record.CompanyId = company.Id;
    row["Date"] = record.Date;
    row["Close"] = record.Close;
    row["AdjClose"] = record.AdjClose;
    row["High"] = record.High;
    row["Low"] = record.Low;
    row["Open"] = record.Open;
    row["Volume"] = record.Volume;
    row["CompanyId"] = record.CompanyId;
    dt.Rows.Add(row);
}

Если вы сможете решить проблему, не прибегая к жесткому программированию, я приму ваш ответ как ответ.

Мне понравился ответ @JoshClose, но я обнаружил, что while( csv.Read() ) значительно медленнее, чем csv.GetRecords<{Class}>().ToList(). Он также неправильно обрабатывает многие типы, допускающие значение NULL, такие как int?, когда возвращаемое значение должно быть DBNull. Мой ответ - заставить CsvHelper импортировать список динамических записей, а затем использовать пару вспомогательных методов для автоматического сопоставления с DataTable.

var records = csv.GetRecords<dynamic>().ToList();

foreach ( record in records )
{
    var row = dt.NewRow();

    var recordDictionary = DynamicToDictionary( record );

    foreach( DataColumn column in dt.Columns )
    {
        row[column.ColumnName] = GetColumnValue( column, recordDictionary );
    }

    dt.Rows.Add( row );
}

Метод DynamicToDictionary обрабатывает чувствительность к регистру и пробелы в заголовке. Я преобразовываю динамический объект в объект Dictionary, который игнорирует чувствительность к регистру и удаляет пробелы в заголовке. Это можно пропустить, а динамический объект передать непосредственно GetColumnValue, если это не проблема.

public Dictionary<string, object> DynamicToDictionary(dynamic dynObj)
{
    var dictionary = new Dictionary<string, object>(StringComparer.OrdinalIgnoreCase);

    foreach (var kvp in (IDictionary<string, object>) dynObj)
    {
        var obj = kvp.Value;

        // Remove white space.
        var name = new string(kvp.Key.ToCharArray().Where(c => !char.IsWhiteSpace(c)).ToArray());

        dictionary.Add(name, obj);
    }

    return dictionary;
}

Метод GetColumnValue находит и преобразует значение динамической записи в правильное значение столбца DataTable.

public object GetColumnValue(DataColumn column, IDictionary<string, object> dynamicDictionary)
{
    object value;

    // Return DBNull if the column name isn't found.
    if (!dynamicDictionary.TryGetValue(column.ColumnName, out value))
    {
        return DBNull.Value;
    }

    // Null values come in as empty strings.
    if (column.AllowDBNull && column.DataType != typeof(string) && (string)value == "")
    {
        return DBNull.Value;
    }

    if (column.DataType == typeof(bool))
    {
        return (string)value != "0" && ((string)value).ToLower() != "false";
    }

    return value;
}