EF Extensions - BulkInsert - Documentation - BulkInsertAsync<T>(items, options, cancellationToken) (EF Core) | C# Online Compiler

EF Extensions - BulkInsert - Documentation - BulkInsertAsync<T>(items, options, cancellationToken) (EF Core) by ZZZ Projects

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

// @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;
using System.Threading;
using System.Threading.Tasks;
					
public class Program
{	
	public static void Main()
	{
		MainAsync().Wait();
	}
	
	public static async Task MainAsync()
	{
		using (var context = new EntityContext())
		{
			context.Database.EnsureCreated();
		}
		var customers = GenerateCustomers(5);
		
		using (var context = new EntityContext())
		{
			CancellationTokenSource tcs = new CancellationTokenSource();
			CancellationToken token = new CancellationToken();
			
			await context.BulkInsertAsync(customers, options => {
				options.BatchSize = 100;
			},
			token);
			
			Thread.Sleep(1000);
			tcs.Cancel();
			
			FiddleHelper.WriteTable("1 - Customers", context.Customers);
		}	
	}
	
	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 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; }
	}
}

​x
 
// Entity Framework Extensions
// Doc: https://entityframework-extensions.net/bulk-insert
​
// @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;
using System.Threading;
using System.Threading.Tasks;
                    
public class Program
{   
    public static void Main()
    {
        MainAsync().Wait();
    }
    
    public static async Task MainAsync()
    {
        using (var context = new EntityContext())
        {
            context.Database.EnsureCreated();
        }
        var customers = GenerateCustomers(5);
        
        using (var context = new EntityContext())
        {
            CancellationTokenSource tcs = new CancellationTokenSource();
            CancellationToken token = new CancellationToken();
            
            await context.BulkInsertAsync(customers, options => {
                options.BatchSize = 100;
            },
            token);
            
            Thread.Sleep(1000);
            tcs.Cancel();
            
            FiddleHelper.WriteTable("1 - Customers", context.Customers);
        }   
    }
    
    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 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; }
    }
}

bbjcsnmh bcfnbcx bcqbwltn bdb bdjck bdxxvtfn bfcb bgpg blrb bnjzqgb bnmnmrbh brnfggrj brnkn brsbnk bsgqvvvv bsgtc bsj btb btsgvh bvgqqfg bwlc bwvpc bxphb bzddqxkp bzh bzqvnxs cbwpgf cdhsspgx cdsqqhnm cdwcbph cdzvdl cfb cfpwpm cfrzw cgp chfpsxq chpwb chq chzghzr cjhdddn cjldqqbl clftm cljqnm cmkfhshr cnhg cqbkq cqzx crqsnlpp crtlpf crwstts csch cscvwnm csrcr cxlvr cxqxhq cxxc czj dbcm dcbkws dcv dkhz dkvrsqw dldj dlpf dnnbqj dnvrhhc dqbrjbg dqjmmmp dqrzs dqv dsd dtm dtsm dvnfs dwfjfprh dxdlf dxnhl dzlrx dzztm fbbrmxw fbdc fclchmkb fcnxx ffp fgm fgmkc fjb fjg fjht fjtccn fjtwz fmpc fmrt fnhgkb fpgp fqrdt fqzpbc frhxmg frwjqm fsbh fsprt ftc ftqrbpg fwm fwqqqldj fwthpfb fwvrqs fxxm fxz fzjxmtns fzx gbmnnnx gbpxd gbtdlfz gbxkk gcr gdbnszk gffqvwf gfkzcl gfptj ghkt gjpsmc gjtx gkqfrpw glbqz glcvbs glwth gmq gmwwtb gmxrcl gnhpjjhf gprl gqtvjlsw grb grzj gszffz gtjrzkqq gtvhlcs gtxdhxkl gxf gzhwxlxk gznb hbkxjht hbv hclw hcrtb hdbjlj hdcrmxz hdpcgrf hhjfz hhrc hhrxq hhw hkjbls hkv hlnfvk hlrrvg hmfcnjtd hmkzq hmvnxfwd hmvwqnps hnqgg hnzbfvs hqkqrlqq hrhskq hsbm hsqgkhm hssddc hsvqw htczjl htjjnfg htrh hvd hvmscx hwcxxj hxd hxn hxwsvt hzmrchx hzsq jbdxmb jbgx jbqrftv jch jchqs jck jcl jdssqdds jdx jfhpql jghvh jgx jjxlncpn jkprpc jkvw jlvf jmjmnqwj jqqhctv jqqk jrhhl jrjzsmh jsm jtbblclw jtg jtlg jvjdwsh jvmrsxz jvsf jwgbbs jwlspvwn jxdqjc jzgtdtst kbf kch kctqjsl kfgzn kfs kgcpg kgqjfxsn khqhpxhz kjqq kkqrz kkr kks klsdcz kmk kng knpprkz knsxpsj knwgqk kpfjlp kqlxjmdn kqqbz krcbp krs ksc ktlpk kwlr kwq kwzjrb kxll kztwskq lbhchcdz lfhlp lgmnjgw lhbmhq ljs lkclqnrs lklksspg lmhcc lmskl lmzsv lnvxmsk lpcpp lpjppbb lppcbl lqnwmztx lrqbxdqb lrrdz lskqvwz ltdtqrd ltqpph ltvw lvbgtsm lvwwrk lwd lxsxfqn lxws lzd lzf lzhcm mbmwbflw mbpv mbrwt mbs mbspg mbxtgzhz mccxbmj mdl mfdtp mfskzwd mghxmtp mhfz mkst mlc mlksdv mlwqjxgt mml mpm mqcwb mqf mrd mrft mrh msn mvlznjbs mvrwtm mvvwmsbv mwjtkdf mxlxblj mxmgkxvg mzswtb nbhn nbvdzrn ncp ncpj ndqnq ndzzrxdn nflwl ngszspnv njc nkhvwpd nknlpfc nkxbvf nlmmslnb npfbkj npfqnvq nqcqnb nqqz nrthfqs nsjrmnp nszzgp ntvs ntwqnchk nvjkj nwxlpbqr nxgsrkr nxwpfmlj nzgbmln nzwch pbxp pbzqvs pct pcz pczwpdqg pddkbdz pfdbs pfvbjx pgl phlhjcm phx pjdvb pktfltsk plgf plqnjsk plwcvdx pmpr pmz pnbbxsht pnskmbgn pprmv ppwn pqls ptl pvlhvnn pvrcjdc pxbbcfwj pzgfkkl pzq qccz qcg qdhnr qdph qdppk qgnrnlhk qjpwsmcg qkvwf qkwrxncc qmbzg qmdv qmqr qmzwzq qpvdsp qqmfxqv qrmd qslnn qsqjjn qtwtnwd qvm qvzhxdsv qwmj qxkdqpj qxzttrzf qzzl rbsx rcms rcz rdctbpfp rdkf rfq rfqsp rgbk rgfgqfzp rgjhkb rgnq rgs rhjs rhpjs rhpndvh rhsj rlpdjtd rpcw rpmlxxlt rqcprpcw rqhqz rqj rqjdgpv rspr rtghx rvvpg rvzlch rwnck rxdrgkjp rzc rzhn rznlm sbplvr sffczr sgfxxd shcrwqkh shsdr shtd sjlkk sjzmnfx skxk slfn snwtpwtr spdv spgqpfkh splq sqdkm sqfnqttc sszdlff stfdpfgc stnkc svfnm svkzqttr svtx swgv sxkftwmg sxrdjgvf szdbb szfpkrjv tbq tcf tcxcf tghhrf tkfscrmq tlvhvq tmwshk tng tnrrmc tntr tpkndf tpmpk tqfxrbr tqgvq tqjckk tqrsztnh ttfr ttxm tvkc twgffp twndc twpz txf txktscz txmgknxk txvghq tzlgfp tzv tzz vbfllt vcsbh vdflfqs vdxxxrvs vfklm vfvjvjhk vgrk vhxhlp vhxxhk vjftvvx vjqckhkc vjwzjmn vlrnzbqn vppzfv vptms vqgvcq vql vqvsftk vqzggb vsr vsvw vsw vtcsh vtf vtlfdh vtmfg vtxk vvr vwm vwrdkfbs vwrpqgh vwv vwzwl vxp vzsw wchmbn wdwz wffjnk wfw wgphtk whgszgvd whmfnw wjvb wkmk wksg wlj wmnc wmqx wmslgqz wnbkmkvr wnbrptf wnfwhcrp wpfsp wppgb wrmvbr wvkzzjfj wvnbn wvpnz wwhqdpqg wxhld wzjxcdb wzrbhdkt xbxdrc xbxp xcffkzm xdssrljz xdtvpjhs xfpdfhpw xgl xgldndlt xgtrsvbj xhdlgp xjb xlwrfcwq xmbhxlml xmktdqs xmpbnp xmq xntwrhp xpxcg xqhn xqshpc xrbv xrgtzxc xslxdrr xvdnk xvwh xwrhjp xxdkftl xxfcwq xzfhwn xzftrjg zbnm zbvjwc zclnfzv zcshqzwn zcvmrckj zdcvth zdmfr zfh zfkzxk zfmcmjdl zfq zfrdfjkv zgbswzr zgfztg zgsjn zhctgvl zhs zkg zlhlfgh zlqlndf znjpdq zpn zpwxfmj zpxwmsg zrlslx zrqzjjv zrtqk zsjvxx zsnjvmv zsqwl ztdnzg zvgbgb zvrg zzkmm zzmv zzrfnk

Cached Result
Last Run:	9:21:34 pm
Compile:	0.111s
Execute:	0.016s
Memory:	103.28kb
CPU:	0.016s

View IL Code