EF Extensions - BulkInsert

CSharp · Console

/Program.cs

// Entity Framework Extensions
// Doc: https://entityframework-extensions.net/bulk-insert

// @nuget: Microsoft.EntityFrameworkCore.SqlServer
// @nuget: Z.EntityFramework.Extensions.EFCore

using Microsoft.EntityFrameworkCore;
using System.Collections.Generic;
using System.Threading.Tasks;
					
public class Program
{
	public static async Task Main()
	{
		using (var context = new EntityContext())
		{
			context.Database.EnsureCreated();
		}
		
		var customers = GenerateCustomers(5);
		var invoices = GenerateInvoices(5, 3);
		
		// Example
		using (var context = new EntityContext())
		{
			// Easy to use
			await context.BulkInsertAsync(customers);
			
			// Easy to customize
			await context.BulkInsertAsync(invoices, options => options.IncludeGraph = true);
			
			FiddleHelper.WriteTable("1 - Customers", context.Customers.AsNoTracking());
			FiddleHelper.WriteTable("2 - Invoices", context.Invoices.AsNoTracking());
			FiddleHelper.WriteTable("3 - InvoiceItems", context.InvoiceItems.AsNoTracking());
		}	
	}
	
	public static List<Customer> GenerateCustomers(int count) 
	{
		List<Customer>  list = new List<Customer>();
		
		for(int i = 0; i < count; i++)
		{
			list.Add(new Customer() { Name = "Customer_" + i});
		}
		
		return list;
	}
	
	public static List<Invoice> GenerateInvoices(int countInvoice, int countInvoiceItem) 
	{
		List<Invoice>  list = new List<Invoice>();
		
		for(int i = 0; i < countInvoice; i++)
		{
			var invoice = new Invoice() { Number = "Number_" + i, Items = new List<InvoiceItem>() };
			list.Add(invoice);
			
			for(int j = 0; j < countInvoiceItem; j++)
			{
				invoice.Items.Add(new InvoiceItem() { ProductName = "ProductName_" + i + "_" + j });
			}
		}
		
		return list;
	}
}

/EntityContext.cs

using System.Collections.Generic;
using Microsoft.Data.SqlClient;
using Microsoft.EntityFrameworkCore;

public class EntityContext : DbContext
{
	public EntityContext() 
	{
	}

	protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
	{
		optionsBuilder.UseSqlServer(new SqlConnection(FiddleHelper.GetConnectionStringSqlServer()));

		base.OnConfiguring(optionsBuilder);
	}

	public DbSet<Customer> Customers { get; set; }
	public DbSet<Invoice> Invoices { get; set; }
	public DbSet<InvoiceItem> InvoiceItems { get; set; }
}

public class Customer
{
	public int CustomerID { get; set; }
	public string Name { get; set; }
}

public class Invoice
{
	public int InvoiceID { get; set; }
	public string Number { get; set; }

	public List<InvoiceItem> Items { get; set; }
}

public class InvoiceItem
{
	public int InvoiceItemID { get; set; }
	public string ProductName { get; set; }
	public Invoice Invoice { get; set; }
}