EF Extensions - BulkSaveChanges - Documentation - BulkSaveChanges(Action<BulkOperation> bulkOperationFactory) (EF Core)

CSharp · Console

/Program.cs

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

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

using System;
using Microsoft.EntityFrameworkCore;
using System.Collections.Generic;
using Microsoft.Data.SqlClient;
using System.Diagnostics;
					
public class Program
{
	public static List<BenchmarkResult> BenchmarkResults = new List<BenchmarkResult>();
	
	public static void Main()
	{		
		using (var context = new EntityContext())
		{
			context.Database.EnsureCreated();
		}
		
		JustInTime_Compile();
		
		// Generate X entities
		var customers = GenerateCustomers(1000);
		
		var clockSaveChanges = new Stopwatch();
		var clockBulkSaveChanges = new Stopwatch();
		
		using (var context = new EntityContext())
		{
			// SaveChanges
			context.Customers.AddRange(customers);
			clockSaveChanges.Start();
			context.SaveChanges();
			clockSaveChanges.Stop();

			BenchmarkResults.Add(new BenchmarkResult() { Action = "SaveChanges (Entity Framework)", Entities = customers.Count, Performance = clockSaveChanges.ElapsedMilliseconds + " ms" });
		}
		using (var context = new EntityContext())
		{
			// BulkSaveChanges
			context.Customers.AddRange(customers);
			clockBulkSaveChanges.Start();
			context.BulkSaveChanges(options => options.BatchSize = 100);
			clockBulkSaveChanges.Stop();

			BenchmarkResults.Add(new BenchmarkResult() { Action = "BulkSaveChanges", Entities = customers.Count, Performance = clockBulkSaveChanges.ElapsedMilliseconds + " ms" });
		}
		
		FiddleHelper.WriteTable("EFE - High-performance bulk operations", BenchmarkResults);
	}
		 
	public static void JustInTime_Compile()
	{
		var customers = GenerateCustomers(20);
		
		// SaveChanges
		using (var context = new EntityContext())
		{
			context.Customers.AddRange(customers);
			context.SaveChanges();
			context.Customers.RemoveRange(customers);
			context.SaveChanges();
		}
		
		// BulkSaveChanges
		using (var context = new EntityContext())
		{
			context.Customers.AddRange(customers);
			context.BulkSaveChanges(options => options.BatchSize = 100);
			context.Customers.RemoveRange(customers);
			context.BulkSaveChanges(options => options.BatchSize = 100);
		}
	}
	
	public static List<Customer> GenerateCustomers(int count)
	{
		var list = new List<Customer>();
		
		for(int i = 0; i < count; i++)
		{
			list.Add(new Customer() { Name = "Customer_" + i, Description = "Description_" +  i, IsActive = i % 2 == 0 });
		}

		return list;
	}

	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 class Customer
	{
		public int CustomerID { get; set; }
		public string Name { get; set; }
		public string Description { get; set; }
		public Boolean IsActive { get; set; }
	}
	
	public class BenchmarkResult
	{
		public string Action { get; set; }
		public int Entities { get; set; }
		public string Performance { get; set; }
	}
}