using Microsoft.EntityFrameworkCore;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
public class ExampleContext : DbContext
{
public DbSet<Item> Items { get; set; }
// 其他配置省略
}
public class Item
{
public int Id { get; set; }
public string Name { get; set; }
// 其他属性省略
}
// 使用方法
async Task BulkInsert(List<Item> items)
{
using var context = new ExampleContext();
foreach (var batch in items.Split(1000)) // 假设每批次插入1000条
{
context.Items.AddRange(batch);
await context.SaveChangesAsync();
context.ChangeTracker.Clear(); // 清除跟踪的实体，释放内存
}
}
// 分批处理的扩展方法
public static class Extensions
{
public static IEnumerable<IEnumerable<T>> Split<T>(this IEnumerable<T> list, int size)
{
for (var i = 0; i < list.Count(); i += size)
{
yield return list.Skip(i).Take(size);
}
}
}这个代码示例展示了如何在Entity Framework Core 7中有效地进行批量数据插入。首先定义了一个示例实体类Item和继承自DbContext的ExampleContext。然后使用Split扩展方法将大批数据拆分成多个小批次，并在循环中使用AddRange和SaveChangesAsync进行插入操作，同时使用ChangeTracker.Clear释放内存，提高了效率。