Entity Framework Core 7中高效地进行批量数据插入

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释放内存，提高了效率。