Стратегия массовой загрузки для SQL-сервера

Лучше всего здесь, вероятно, SqlBulkCopy , который очень эффективно SqlBulkCopy необработанный TDS на сервере. SqlBulkCopy использует два типа ввода:

• DataTable
• IDataReader

Итак, в этот момент у вас есть 3 варианта:

• преобразовать свой List<AddServerPError> в DataTable вручную
• используйте что-то вроде FastMember для получения IDataReader над существующим списком (пример этого находится внизу страницы проекта: https://github.com/mgravell/fast-member ) - на nuget: https: // www. nuget.org/packages/FastMember/
• удалите свой существующий список и прочитайте CSV напрямую как IDataReader - есть CsvReader от CsvReader , который всегда хорошо работал для этого; ближайшая nuget-ссылка, которую я вижу, это https://www.nuget.org/packages/LumenWorksCsvReader/ (хотя это не оригинал, он был расширен)

Вы можете использовать Cinchoo ETL , библиотеку с открытым исходным кодом, чтобы загрузить файл CSV для массовой загрузки в базу данных.

Опция 1:

Загрузите файл CSV прямо в базу данных

string connectionstring = @"#YOUR DB ConnectionString#";
using (SqlBulkCopy bcp = new SqlBulkCopy(connectionstring))
{
    using (var p = new ChoCSVReader("#YOUR CSV FILE#"))
    {
        bcp.DestinationTableName = "#TABLENAME#";
        bcp.EnableStreaming = true;
        bcp.BatchSize = 10000;
        bcp.BulkCopyTimeout = 0;
        bcp.NotifyAfter = 100;
        bcp.SqlRowsCopied += delegate (object sender, SqlRowsCopiedEventArgs e)
        {
            Console.WriteLine(e.RowsCopied.ToString("#,##0") + " rows copied.");
        };
        bcp.WriteToServer(p.AsDataReader());
    }
}

Вариант 2:

Если загрузка CSV уже сделана и выводится как List<AddServerPError> , вы все равно можете загрузить их в базу данных, как List<AddServerPError> ниже

List<AddServerPError> objs = # Your input objects #;

string connectionstring = @"#YOUR DB ConnectionString#";
using (SqlBulkCopy bcp = new SqlBulkCopy(connectionstring))
{
    bcp.DestinationTableName = "#TABLENAME#";
    bcp.EnableStreaming = true;
    bcp.BatchSize = 10000;
    bcp.BulkCopyTimeout = 0;
    bcp.NotifyAfter = 100;
    bcp.SqlRowsCopied += delegate (object sender, SqlRowsCopiedEventArgs e)
    {
        Console.WriteLine(e.RowsCopied.ToString("#,##0") + " rows copied.");
    };
    bcp.WriteToServer(objs.AsDataReader());
}