BulkInsertのサブルーチン

BulkInsertのサブルーチン　

https://pg-life.net/csharp/sqlbulkcopy/ 

 とても助かりました。

using System.Data;

public static class IEnumerableExtention
{
    public static DataTable ConvertDataTable<T>(this IEnumerable<T> items)
    {
        var properties = typeof(T).GetProperties();
        var result = new DataTable();

        // テーブルレイアウトの作成
        foreach (var prop in properties)
        {
            result.Columns.Add(prop.Name, prop.PropertyType);
        }

        // 値の投げ込み
        foreach (var item in items)
        {
            var row = result.NewRow();
            foreach (var prop in properties)
            {
                var itemValue = prop.GetValue(item, new object[] { });
                row[prop.Name] = itemValue;
            }
            result.Rows.Add(row);
        }
        return result;
    }
}

 

using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;

public static void BulkInsert<T>(List<T> _list)
{
    //環境に応じて変えてください
    var connectionString = "接続文字列";

    using (var connection = new SqlConnection(connectionString))
    {
        connection.Open();
        using (var tran = connection.BeginTransaction())
        {
            try
            {
                var list = _list.ConvertAll(c => (T)c);
                using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection,
                                                              SqlBulkCopyOptions.Default,
                                                              tran))
                {
                    //タイムアウト指定（デフォルトで30秒）
                    bulkCopy.BulkCopyTimeout = 60;
                    //テーブル名指定
                    bulkCopy.DestinationTableName = typeof(T).Name;
                    //一括Insert実行
                    bulkCopy.WriteToServer(list.ConvertDataTable<T>());
                    //コミット
                    tran.Commit();
                }
            }
            catch (Exception)
            {
                //ロールバック
                tran.Rollback();
                throw;
            }
        }
    }
}