此问题与a previous question of mine有关
这是我当前的代码
IEnumerable<Shape> Get()
{
while(//get implementation
yield return new Shape(//...
}
void Insert()
{
var actual = Get();
using (var db = new DataClassesDataContext())
{
db.Shapes.InsertAllOnSubmit(actual);
db.SubmitChanges();
}
}
我遇到了内存溢出，因为 IEnumerable 太大了。如何预防？
【问题讨论】：
标签： c# .net linq-to-sql ienumerable yield
尝试使用InsertOnSubmit 而不是InsertAllOnSubmit。然后像 Erich 所说的那样以适当的时间间隔提交。
或者，如果您想分批进行，例如5、尝试Handcraftsman's或dtb's的解决方案来获取IEnumerable的IEnumerable。例如，使用 dtb 的 Chunk：
var actual = Get();
using (var db = new DataClassesDataContext())
{
foreach(var batch in actual.Chunk(5))
{
db.Shapes.InsertAllOnSubmit(batch);
db.SubmitChanges();
}
}
【讨论】：
使用以下扩展方法将输入分解为适当大小的子集
public static class IEnumerableExtensions
{
public static IEnumerable<List<T>> InSetsOf<T>(this IEnumerable<T> source, int max)
{
List<T> toReturn = new List<T>();
foreach(var item in source)
{
toReturn.Add(item);
if (toReturn.Count == max)
{
yield return toReturn;
toReturn = new List<T>();
}
}
if (toReturn.Any())
{
yield return toReturn;
}
}
}
然后持久化子集
void Insert()
{
var actual = Get();
using (var db = new DataClassesDataContext())
{
foreach (var set in actual.InSetsOf(5))
{
db.Shapes.InsertAllOnSubmit(set);
db.SubmitChanges();
}
}
}
您可能还会发现 InsertOnSubmit() 与 InsertAllOnSubmit() 上的 this MSDN article 很有用。
【讨论】：
有关从 IEnumerable 获取成批项目的简洁方法，请参阅：
C#: Cleanest way to divide a string array into N instances N items long
更新：不好，这适用于数组。如果以后有时间，没有其他人提供什么，我会写下来......
【讨论】：
一种选择是将其分成多个批次。创建Shape 对象的临时缓冲区，迭代直到填满它或从枚举器中耗尽，然后执行InsertBatchOnSubmit。
【讨论】：