はInsertBulk <T>（IEnumerableを<T> POCOS）を呼び出す必要があるだけランタイム

Question

NPoco（PetaPoco由来する.NETマイクロORM）で知られているTは、ジェネリック型のリストが与えられると、データベースに一括挿入レコードのための方法を有しています。メソッドシグネチャは次のとおり

void InsertBulk<T>(IEnumerable<T> pocos); 

は、内部的には、型Tの名前をとり、（同様に型のプロパティ名は、列名にマップされている）に挿入するDBテーブルを決定するためにそれを使用します。 したがって、正しい型の変数がメソッドに渡されることが非常に重要です。

私の挑戦はこれです：私はIDataItemがすべて挿入可能なオブジェクトのクラスは

を実装する必要があり、リストに含めることのできるインターフェイスであるList<IDataItem>として、DBに挿入するオブジェクトのリストを与えられています

• IDataItemを実装する任意の型のオブジェクト、および問題を強調するために、リスト
• に種類の混合物があるかもしれません - 私は、コンパイル時に私はInsertBulk
に渡す必要があり、実際の具体的な種類を知りません

私は以下のアプローチを試みましたが、Convert.ChangeTypeの結果はObjectです。したがって、オブジェクトのリストをInsertBulkに渡していますが無効です。

private static Exception SaveDataItemsToDatabase(List<IDataItem> dtos) 
    { 
     using (var db = new DbConnection()) 
     { 
      try 
      { 
       var dtosByType = dtos.GroupBy(x => x.GetType()); 

       db.Data.BeginTransaction(); 

       foreach (var dataType in dtosByType) 
       { 
        var type = dataType.Key; 
        var dtosOfType = dataType.Select(x => Convert.ChangeType(x, type)); 

        db.Data.InsertBulk(dtosOfType); 
       } 

       db.Data.CommitTransaction(); 

       return null; 
      } 
      catch (Exception ex) 
      { 
       db.Data.RollbackTransaction(); 

       return ex; 
      } 
     } 
    } 

私はこれを達成する方法はありますか？

Answer 1

List<T>の新しいリストを作成して、すべてのアイテムをコピーしてから、InsertBulkにリフレクションで電話する必要があります。

foreach(var g in groups) 
{ 

    var dataItemType = g.Key; 
    var listType = typeof(List<>).MakeGenericType(new [] { dataItemType }); 
    var list = (IList) Activator.CreateInstance(listType); 

    foreach(var data in g) 
     list.Add(data); 

    db.Data.GetType() 
      .GetMethod("InsertBulk") 
      .MakeGenericMethod(dataItemType) 
      .Invoke(db.Data, new object[] { list }); 

} 

それはここで働いてください：https://dotnetfiddle.net/BS2FLy

Answer 2

このコードは、あなたが（少しハックが）やりたいあなたを助けるかもしれません。私は上の推測を取るつもりです

private static Exception SaveDataItemsToDatabase(List<IDataItem> dtos) 
    { 
     using (var db = new DbConnection()) 
     { 
      try 
      { 
       var dtosByType = dtos.GroupBy(x => x.GetType()); 

       db.Data.BeginTransaction(); 
       var method = db.Data.GetType().GetMethod("InsertBulk"); 
       foreach (var dataType in dtosByType) 
       { 
        var genericMethod = method.MakeGenericMethod(dataType.Key); 
        genericMethod.Invoke(db.Data, new object[] { dataType.Value };     
       } 

       db.Data.CommitTransaction(); 

       return null; 
      } 
      catch (Exception ex) 
      { 
       db.Data.RollbackTransaction(); 

       return ex; 
      } 
     } 
    } 

Answer 3

：あなたの元のコードを使用している場合、それはのようなものになります

class Program { 
    static void Main() { 
     var items = new IDataItem[] { 
      new TestItem(), 
      new TestItem(), 
      new TestItem2(), 
      new TestItem2(), 
     }; 

     foreach (var kv in items.GroupBy(c => c.GetType())) { 
      // group by actual type 
      var type = kv.Key; 
      var batch = kv.ToArray(); 
      // grab BulkInsert<Type> method 
      var insert = typeof(Test).GetMethod("BulkInsert").MakeGenericMethod(type); 
      // create array of Type[] 
      var casted = Array.CreateInstance(type, batch.Length); 
      Array.Copy(batch, casted, batch.Length); 
      // invoke 
      insert.Invoke(new Test(), new object[] { casted}); 
     }    

     Console.ReadKey(); 
    }   
} 

public interface IDataItem { 

} 

public class TestItem : IDataItem { 

} 

public class TestItem2 : IDataItem 
{ 

} 

public class Test { 
    public void BulkInsert<T>(IEnumerable<T> items) { 
     Console.WriteLine(typeof(T).Name); 
    } 
} 

これは私の側でそれを実行するコードを持っていないからです。

方法について：

private static Exception SaveDataItemsToDatabase(List<IDataItem> dtos) 
{ 
    using (var db = new DbConnection()) 
    { 
     try 
     { 

      db.Data.BeginTransaction(); 

      dtos 
       .GroupBy(dto => dto.GetType()) 
       .ForEach(grp => { 
        db.Data.BulkInsert(dtos.Where(n => n.GetType().Equals(grp.Key).ToList()); 
       }); 

      db.Data.CommitTransaction(); 

      return null; 
     } 
     catch (Exception ex) 
     { 
      db.Data.RollbackTransaction(); 

      return ex; 
     } 
    } 
} 

Answer 4

：あなたはこのような何かを試みることができる

private static Exception SaveDataItemsToDatabase(List<IDataItem> dtos) 
    { 
     using (var db = new DbConnection()) 
     { 
      try 
      {      
       db.Data.BeginTransaction(); 
       foreach (var dataType in dtos.GroupBy(x => x.GetType())) { 
        var type = dataType.Key; 
        var items = dataType.ToArray(); 
        var insert = db.Data.GetType().GetMethod("BulkInsert").MakeGenericMethod(type); 
        // create array of Type[] 
        var casted = Array.CreateInstance(type, items.Length); 
        Array.Copy(items, casted, items.Length); 
        // invoke 
        insert.Invoke(db.Data, new object[] {casted}); 
       } 

       db.Data.CommitTransaction(); 

       return null; 
      } 
      catch (Exception ex) 
      { 
       db.Data.RollbackTransaction(); 

       return ex; 
      } 
     } 
    }