【问题标题】:EntityFramework.BulkInsert throws KeyNotFoundExceptionEntityFramework.BulkInsert 抛出 KeyNotFoundException
【发布时间】:2015-11-16 19:49:36
【问题描述】:

我正在尝试使用实体框架 6 的批量插入扩展。但是,当我调用“BulkInsert”方法时,我似乎得到了 KeyNotFoundException。

以下是相关代码:

        using (var context = new SupportContext(request.CustomerId))
        {
            using (var transactionScope = new TransactionScope())
            {
                var freeIds =
                    Enumerable.Range(1, 89999)
                        .Except(
                            context.TagAssociationTypes.Where(n => n.TagAssociationTypeID <= 89999)
                                .Select(n => n.TagAssociationTypeID))
                        .ToList();
                var nfeList = context.NumericalFunctionEnums.ToList();
                var processedTats = new List<TagAssociationType>();
                foreach (var item in request.Tats)
                {
                    var groupingNFE = nfeList.FirstOrDefault(n => n.nfe_description == item.GroupingNFE.Value);
                    var summaryNFE = nfeList.FirstOrDefault(n => n.nfe_description == item.SummaryNFE.Value);
                    var tatId = freeIds.Min();

                    var newItem = new TagAssociationType
                    {
                        TagAssociationTypeID = tatId,
                        Name = item.TagAssociationTypeName.Value,
                        GroupingFunctionID = groupingNFE != null ? groupingNFE.nfe_id : 0,
                        SummaryFunctionID = summaryNFE!= null ? summaryNFE.nfe_id : 0
                    };

                    processedTats.Add(newItem);
                    freeIds.Remove(tatId);
                }
                context.BulkInsert(processedTats);
                transactionScope.Complete();
            }
        }

还有 StackTrace

System.Collections.Generic.KeyNotFoundException was unhandled by user code
  HResult=-2146232969
  Message=The given key was not present in the dictionary.
  Source=mscorlib
  StackTrace:
       at System.Collections.Generic.Dictionary`2.get_Item(TKey key)
       at EntityFramework.MappingAPI.Mappers.MapperBase.BindForeignKeys() in c:\dev\EntityFramework.MappingAPI\trunk\src\EntityFramework.MappingAPI\Mappers\MapperBase.cs:line 603
       at EntityFramework.MappingAPI.Mappings.DbMapping..ctor(DbContext context) in c:\dev\EntityFramework.MappingAPI\trunk\src\EntityFramework.MappingAPI\Mappings\DbMapping.cs:line 101
       at EntityFramework.MappingAPI.EfMap.Get(DbContext context) in c:\dev\EntityFramework.MappingAPI\trunk\src\EntityFramework.MappingAPI\EfMap.cs:line 60
       at EntityFramework.MappingAPI.Extensions.MappingApiExtensions.Db(DbContext ctx, Type type) in c:\dev\EntityFramework.MappingAPI\trunk\src\EntityFramework.MappingAPI\Extensions\MappingApiExtensions.cs:line 51
       at System.Linq.Enumerable.ToDictionary[TSource,TKey,TElement](IEnumerable`1 source, Func`2 keySelector, Func`2 elementSelector, IEqualityComparer`1 comparer)
       at System.Linq.Enumerable.ToDictionary[TSource,TKey,TElement](IEnumerable`1 source, Func`2 keySelector, Func`2 elementSelector)
       at EntityFramework.BulkInsert.Helpers.MappedDataReader`1..ctor(IEnumerable`1 enumerable, IEfBulkInsertProvider provider) in c:\dev\EntityFramework.BulkInsert\dev\Src\EntityFramework.BulkInsert\Helpers\MappedDataReader.cs:line 58
       at EntityFramework.BulkInsert.Providers.EfSqlBulkInsertProviderWithMappedDataReader.Run[T](IEnumerable`1 entities, SqlTransaction transaction, BulkInsertOptions options) in c:\dev\EntityFramework.BulkInsert\dev\Src\EntityFramework.BulkInsert\Providers\EfSqlBulkInsertProviderWithMappedDataReader.cs:line 22
       at EntityFramework.BulkInsert.Providers.ProviderBase`2.Run[T](IEnumerable`1 entities, IDbTransaction transaction, BulkInsertOptions options) in c:\dev\EntityFramework.BulkInsert\dev\Src\EntityFramework.BulkInsert\Providers\ProviderBase.cs:line 77
       at EntityFramework.BulkInsert.Providers.ProviderBase`2.Run[T](IEnumerable`1 entities, BulkInsertOptions options) in c:\dev\EntityFramework.BulkInsert\dev\Src\EntityFramework.BulkInsert\Providers\ProviderBase.cs:line 105
       at EntityFramework.BulkInsert.Extensions.BulkInsertExtension.BulkInsert[T](DbContext context, IEnumerable`1 entities, SqlBulkCopyOptions sqlBulkCopyOptions, Nullable`1 batchSize) in c:\dev\EntityFramework.BulkInsert\dev\Src\EntityFramework.BulkInsert\Extensions\BulkInsertExtension.cs:line 95
       at EntityFramework.BulkInsert.Extensions.BulkInsertExtension.BulkInsert[T](DbContext context, IEnumerable`1 entities, Nullable`1 batchSize) in c:\dev\EntityFramework.BulkInsert\dev\Src\EntityFramework.BulkInsert\Extensions\BulkInsertExtension.cs:line 75
       at SupportCenter.Controllers.Api.BulkLocalTatController.InsertTats(VerifyQuery request)
       at lambda_method(Closure , Object , Object[] )
       at System.Web.Http.Controllers.ReflectedHttpActionDescriptor.ActionExecutor.<>c__DisplayClass10.<GetExecutor>b__9(Object instance, Object[] methodParameters)
       at System.Web.Http.Controllers.ReflectedHttpActionDescriptor.ActionExecutor.Execute(Object instance, Object[] arguments)
       at System.Web.Http.Controllers.ReflectedHttpActionDescriptor.ExecuteAsync(HttpControllerContext controllerContext, IDictionary`2 arguments, CancellationToken cancellationToken)
  InnerException: 

老实说,我不完全确定是什么原因造成的。

【问题讨论】:

    标签: c# entity-framework bulkinsert


    【解决方案1】:

    所以在深入研究之后,我发现它与 MappingAPI 试图映射我的模型上的所有虚拟属性有关。为了解决这个问题,我创建了特殊模型,去除了所有虚拟属性,只包含插入所需的属性。

    从那里,我专门为我要插入的模型创建了一个单独的上下文。我没有在上下文中包含任何映射。

    这种方法似乎效果很好,但也有几个缺点。对于可能跨越许多不同模型的复杂对象,我可能需要使用两个单独的数据库上下文。您还必须将上下文彼此分开,并且在它们的 using 语句块中没有重叠,否则会导致 TransactionScope 抛出错误。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2010-12-14
      • 2011-11-05
      • 1970-01-01
      • 2014-04-15
      • 2021-08-02
      • 2011-11-21
      • 2016-07-01
      • 2014-05-01
      相关资源
      最近更新 更多