Skip to content

phongnguyend/EntityFrameworkCore.MySql.SimpleBulks

BranchesTags

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

177 Commits
.github
.github
 
 
src
src
 
 
.gitignore
.gitignore
 
 
LICENSE
LICENSE
 
 
README.md
README.md
 
 

Repository files navigation

EntityFrameworkCore.MySql.SimpleBulks

A very simple .net core library that can help to sync a large number of records in-memory into the database using the MySqlBulkCopy class.  

Overview

This library provides extension methods so that you can use with your EntityFrameworkCore DbContext instance DbContextExtensions.cs or you can use ConnectionContextExtensions.cs to work directly with a MySqlConnection instance without using EntityFrameworkCore.

Nuget

Database Package GitHub
SQL Server EntityFrameworkCore.SqlServer.SimpleBulks EntityFrameworkCore.SqlServer.SimpleBulks
PostgreSQL EntityFrameworkCore.PostgreSQL.SimpleBulks EntityFrameworkCore.PostgreSQL.SimpleBulks
MySQL EntityFrameworkCore.MySQL.SimpleBulks EntityFrameworkCore.MySQL.SimpleBulks

Features

  • Bulk Insert
  • Bulk Update
  • Bulk Delete
  • Bulk Merge
  • Bulk Match
  • Temp Table
  • Direct Insert
  • Direct Update
  • Direct Delete
  • Upsert

Examples

DbContextExtensionsExamples

  • Update the connection string ConnectionStrings.MySqlConnectionString.
  • Build and run.

ConnectionExtensionsExamples

  • Update the connection string ConnectionStrings.MySqlConnectionString.
  • Build and run.

DbContextExtensions

Using Lambda Expression

using EntityFrameworkCore.MySql.SimpleBulks.BulkDelete;
using EntityFrameworkCore.MySql.SimpleBulks.BulkInsert;
using EntityFrameworkCore.MySql.SimpleBulks.BulkMerge;
using EntityFrameworkCore.MySql.SimpleBulks.BulkUpdate;

// Insert all columns
await dbct.BulkInsertAsync(rows);
await dbct.BulkInsertAsync(compositeKeyRows);

// Insert selected columns only
await dbct.BulkInsertAsync(rows,
    row => new { row.Column1, row.Column2, row.Column3 });
await dbct.BulkInsertAsync(compositeKeyRows,
    row => new { row.Id1, row.Id2, row.Column1, row.Column2, row.Column3 });

await dbct.BulkUpdateAsync(rows,
    row => new { row.Column3, row.Column2 });
await dbct.BulkUpdateAsync(compositeKeyRows,
    row => new { row.Column3, row.Column2 });

await dbct.BulkMergeAsync(rows,
    row => row.Id,
    row => new { row.Column1, row.Column2 },
    row => new { row.Column1, row.Column2, row.Column3 });
await dbct.BulkMergeAsync(compositeKeyRows,
    row => new { row.Id1, row.Id2 },
    row => new { row.Column1, row.Column2, row.Column3 },
    row => new { row.Id1, row.Id2, row.Column1, row.Column2, row.Column3 });
                        
await dbct.BulkDeleteAsync(rows);
await dbct.BulkDeleteAsync(compositeKeyRows);

Using Dynamic String

using EntityFrameworkCore.MySql.SimpleBulks.BulkDelete;
using EntityFrameworkCore.MySql.SimpleBulks.BulkInsert;
using EntityFrameworkCore.MySql.SimpleBulks.BulkMerge;
using EntityFrameworkCore.MySql.SimpleBulks.BulkUpdate;

await dbct.BulkUpdateAsync(rows,
    [ "Column3", "Column2" ]);
await dbct.BulkUpdateAsync(compositeKeyRows,
    [ "Column3", "Column2" ]);

await dbct.BulkMergeAsync(rows,
    ["Id"],
    [ "Column1", "Column2" ],
    [ "Column1", "Column2", "Column3" ]);
await dbct.BulkMergeAsync(compositeKeyRows,
    [ "Id1", "Id2" ],
    [ "Column1", "Column2", "Column3" ],
    [ "Id1", "Id2", "Column1", "Column2", "Column3" ]);

Using Builder Approach in case you need both Dynamic & Lambda Expression

await dbct.CreateBulkInsertBuilder<Row>()
	.WithColumns(row => new { row.Column1, row.Column2, row.Column3 })
	// or .WithColumns([ "Column1", "Column2", "Column3" ])
	.ToTable(dbContext.GetTableInfor<Row>())
	.ExecuteAsync(rows);

ConnectionContextExtensions

Using Lambda Expression

using EntityFrameworkCore.MySql.SimpleBulks.BulkDelete;
using EntityFrameworkCore.MySql.SimpleBulks.BulkInsert;
using EntityFrameworkCore.MySql.SimpleBulks.BulkMerge;
using EntityFrameworkCore.MySql.SimpleBulks.BulkUpdate;

// Configure Mapping globaly

TableMapper.Configure<Row>(config =>
{
    config
    .TableName("Rows")
    .PrimaryKeys(x => x.Id);
});

TableMapper.Configure<CompositeKeyRow>(config =>
{
    config
    .TableName("CompositeKeyRows")
    .PrimaryKeys(x => new { x.Id1, x.Id2 });
});

var connection = new ConnectionContext(new MySqlConnection(connectionString), null);

// Insert all columns
await connection.BulkInsertAsync(rows);
await connection.BulkInsertAsync(compositeKeyRows);

// Insert selected columns only
await connection.BulkInsertAsync(rows,
    row => new { row.Column1, row.Column2, row.Column3 });
await connection.BulkInsertAsync(compositeKeyRows,
    row => new { row.Id1, row.Id2, row.Column1, row.Column2, row.Column3 });

await connection.BulkUpdateAsync(rows,
    row => new { row.Column3, row.Column2 });
await connection.BulkUpdateAsync(compositeKeyRows,
    row => new { row.Column3, row.Column2 });

await connection.BulkMergeAsync(rows,
    row => row.Id,
    row => new { row.Column1, row.Column2 },
    row => new { row.Column1, row.Column2, row.Column3 });
await connection.BulkMergeAsync(compositeKeyRows,
    row => new { row.Id1, row.Id2 },
    row => new { row.Column1, row.Column2, row.Column3 },
    row => new { row.Id1, row.Id2, row.Column1, row.Column2, row.Column3 });
                        
await connection.BulkDeleteAsync(rows);
await connection.BulkDeleteAsync(compositeKeyRows);

Using Dynamic String

using EntityFrameworkCore.MySql.SimpleBulks.BulkDelete;
using EntityFrameworkCore.MySql.SimpleBulks.BulkInsert;
using EntityFrameworkCore.MySql.SimpleBulks.BulkMerge;
using EntityFrameworkCore.MySql.SimpleBulks.BulkUpdate;

var connection = new ConnectionContext(new MySqlConnection(connectionString), null);

await connection.BulkInsertAsync(rows,
    [ "Column1", "Column2", "Column3" ]);
await connection.BulkInsertAsync(compositeKeyRows,
    [ "Id1", "Id2", "Column1", "Column2", "Column3" ]);

await connection.BulkUpdateAsync(rows,
    [ "Column3", "Column2" ]);
await connection.BulkUpdateAsync(compositeKeyRows,
    [ "Column3", "Column2" ]);

await connection.BulkMergeAsync(rows,
    ["Id"],
    [ "Column1", "Column2" ],
    [ "Column1", "Column2", "Column3" ]);
await connection.BulkMergeAsync(compositeKeyRows,
    [ "Id1", "Id2" ],
    [ "Column1", "Column2", "Column3" ],
    [ "Id1", "Id2", "Column1", "Column2", "Column3" ]);

Using Builder Approach in case you need both Dynamic & Lambda Expression

await connection.CreateBulkInsertBuilder<Row>()
	.WithColumns(row => new { row.Column1, row.Column2, row.Column3 })
	// or .WithColumns([ "Column1", "Column2", "Column3" ])
	.ToTable(new MySqlTableInfor<Row>("Rows"))
	.ExecuteAsync(rows);

Execution Options

BulkInsert

await _context.BulkInsertAsync(rows,
    row => new { row.Column1, row.Column2, row.Column3 },
    new BulkInsertOptions
    {
        KeepIdentity = false,
        BatchSize = 0,
        Timeout = 30,
        LogTo = Console.WriteLine
    });

BulkUpdate

await _context.BulkUpdateAsync(rows,
    row => new { row.Column3, row.Column2 },
    new BulkUpdateOptions
    {
        BatchSize = 0,
        Timeout = 30,
        LogTo = Console.WriteLine
    });

BulkDelete

await _context.BulkDeleteAsync(rows,
    new BulkDeleteOptions
    {
        BatchSize = 0,
        Timeout = 30,
        LogTo = Console.WriteLine
    });

BulkMerge

await _context.BulkMergeAsync(rows,
    row => row.Id,
    row => new { row.Column1, row.Column2 },
    row => new { row.Column1, row.Column2, row.Column3 },
    new BulkMergeOptions
    {
        BatchSize = 0,
        Timeout = 30,
        LogTo = Console.WriteLine
    });

BulkMatch

var contactsFromDb = await _context.BulkMatchAsync(matchedContacts,
    x => new { x.CustomerId, x.CountryIsoCode },
    new BulkMatchOptions
    {
        BatchSize = 0,
        Timeout = 30,
        LogTo = Console.WriteLine
    });

TempTable

var customerTableName = await _context.CreateTempTableAsync(customers,
    x => new
    {
        x.IdNumber,
        x.FirstName,
        x.LastName,
        x.CurrentCountryIsoCode
    },
    new TempTableOptions
    {
        BatchSize = 0,
        Timeout = 30,
        LogTo = Console.WriteLine
    });

DirectInsert

await _context.DirectInsertAsync(row,
    row => new { row.Column1, row.Column2, row.Column3 },
    new BulkInsertOptions
    {
        Timeout = 30,
        LogTo = Console.WriteLine
    });

DirectUpdate

await _context.DirectUpdateAsync(row,
    row => new { row.Column3, row.Column2 },
    new BulkUpdateOptions
    {
        Timeout = 30,
        LogTo = Console.WriteLine
    });

DirectDelete

await _context.DirectDeleteAsync(row,
    new BulkDeleteOptions
    {
        Timeout = 30,
        LogTo = Console.WriteLine
    });

Upsert

await _context.UpsertAsync(row,
    row => row.Id,
    row => new { row.Column1, row.Column2 },
    row => new { row.Column1, row.Column2, row.Column3 },
    new BulkMergeOptions
    {
        Timeout = 30,
        LogTo = Console.WriteLine
    });

Returned Result

BulkUpdate

var updateResult = await dbct.BulkUpdateAsync(rows, row => new { row.Column3, row.Column2 });

Console.WriteLine($"Updated: {updateResult.AffectedRows} row(s)");

BulkDelete

var deleteResult = await dbct.BulkDeleteAsync(rows);

Console.WriteLine($"Deleted: {deleteResult.AffectedRows} row(s)");

BulkMerge

var mergeResult = await dbct.BulkMergeAsync(rows,
    row => row.Id,
    row => new { row.Column1, row.Column2 },
    row => new { row.Column1, row.Column2, row.Column3 });

Console.WriteLine($"Updated: {mergeResult.UpdatedRows} row(s)");
Console.WriteLine($"Inserted: {mergeResult.InsertedRows} row(s)");
Console.WriteLine($"Affected: {mergeResult.AffectedRows} row(s)");

Benchmarks

BulkInsert

Single Table /src/EntityFrameworkCore.MySql.SimpleBulks.Benchmarks/BulkInsertSingleTableBenchmarks.cs

BenchmarkDotNet=v0.13.2, OS=Windows 10 (10.0.19045.5011)
11th Gen Intel Core i7-1165G7 2.80GHz, 1 CPU, 8 logical and 4 physical cores
.NET SDK=8.0.400
  [Host]     : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2
  Job-RGIUAC : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2

InvocationCount=1  IterationCount=1  UnrollFactor=1  
WarmupCount=0
Method RowsCount Mean Error Gen0 Gen1 Gen2 Allocated
EFCoreInsert 100 36.86 ms NA - - - 976.73 KB
BulkInsert 100 18.73 ms NA - - - 56.31 KB
EFCoreInsert 1000 146.98 ms NA 1000.0000 - - 9740.39 KB
BulkInsert 1000 112.55 ms NA - - - 312.73 KB
EFCoreInsert 10000 1,247.58 ms NA 15000.0000 5000.0000 - 96372.25 KB
BulkInsert 10000 531.13 ms NA - - - 2902.21 KB
EFCoreInsert 100000 5,455.73 ms NA 147000.0000 37000.0000 - 956706.58 KB
BulkInsert 100000 1,267.28 ms NA 3000.0000 1000.0000 - 28606.81 KB
EFCoreInsert 250000 13,465.43 ms NA 368000.0000 88000.0000 - 2368616.45 KB
BulkInsert 250000 2,606.24 ms NA 9000.0000 5000.0000 1000.0000 71551.59 KB
EFCoreInsert 500000 27,001.92 ms NA 736000.0000 174000.0000 - 4744491.9 KB
BulkInsert 500000 4,806.86 ms NA 17000.0000 7000.0000 - 142890.45 KB

Multiple Tables (1x parent rows + 5x child rows) /src/EntityFrameworkCore.MySql.SimpleBulks.Benchmarks/BulkInsertMultipleTablesBenchmarks.cs

BenchmarkDotNet=v0.13.2, OS=Windows 10 (10.0.19045.5011)
11th Gen Intel Core i7-1165G7 2.80GHz, 1 CPU, 8 logical and 4 physical cores
.NET SDK=8.0.400
  [Host]     : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2
  Job-XRWCCS : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2

InvocationCount=1  IterationCount=1  UnrollFactor=1  
WarmupCount=0
Method RowsCount Mean Error Gen0 Gen1 Gen2 Allocated
EFCoreInsert 100 189.6 ms NA 1000.0000 - - 6875.61 KB
BulkInsert 100 166.7 ms NA - - - 271.06 KB
EFCoreInsert 1000 1,097.2 ms NA 10000.0000 4000.0000 - 67968.5 KB
BulkInsert 1000 721.5 ms NA - - - 1987.01 KB
EFCoreInsert 10000 4,663.4 ms NA 105000.0000 29000.0000 - 675868.05 KB
BulkInsert 10000 1,789.9 ms NA 3000.0000 1000.0000 1000.0000 19330.64 KB
EFCoreInsert 100000 43,841.6 ms NA 1050000.0000 250000.0000 - 6740771.2 KB
BulkInsert 100000 19,456.4 ms NA 25000.0000 12000.0000 1000.0000 193110.47 KB

BulkUpdate

/src/EntityFrameworkCore.MySql.SimpleBulks.Benchmarks/BulkUpdateBenchmarks.cs

BenchmarkDotNet=v0.13.2, OS=Windows 10 (10.0.19045.5011)
11th Gen Intel Core i7-1165G7 2.80GHz, 1 CPU, 8 logical and 4 physical cores
.NET SDK=8.0.400
  [Host]     : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2
  Job-LPQRVU : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2

InvocationCount=1  IterationCount=1  UnrollFactor=1  
WarmupCount=0
Method RowsCount Mean Error Gen0 Gen1 Gen2 Allocated
EFCoreUpdate 100 77.32 ms NA - - - 861.01 KB
BulkUpdate 100 34.38 ms NA - - - 53.57 KB
EFCoreUpdate 1000 590.48 ms NA 1000.0000 - - 8242.91 KB
BulkUpdate 1000 96.88 ms NA - - - 312.71 KB
EFCoreUpdate 10000 4,474.04 ms NA 12000.0000 3000.0000 - 81612.58 KB
BulkUpdate 10000 1,121.61 ms NA - - - 2899.23 KB
EFCoreUpdate 100000 47,509.80 ms NA 122000.0000 29000.0000 - 808508.63 KB
BulkUpdate 100000 12,767.85 ms NA 4000.0000 2000.0000 - 28613 KB
EFCoreUpdate 250000 110,395.96 ms NA 307000.0000 71000.0000 1000.0000 2001921.86 KB
BulkUpdate 250000 22,615.14 ms NA 9000.0000 4000.0000 - 71565.2 KB 
BenchmarkDotNet=v0.13.2, OS=Windows 10 (10.0.19045.5011)
11th Gen Intel Core i7-1165G7 2.80GHz, 1 CPU, 8 logical and 4 physical cores
.NET SDK=8.0.400
  [Host]     : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2
  Job-LPQRVU : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2

InvocationCount=1  IterationCount=1  UnrollFactor=1  
WarmupCount=0
Method RowsCount Mean Error Gen0 Gen1 Allocated
BulkUpdate 500000 44.36 s NA 18000.0000 8000.0000 139.6 MB
BulkUpdate 1000000 81.88 s NA 37000.0000 18000.0000 282.08 MB

BulkDelete

/src/EntityFrameworkCore.MySql.SimpleBulks.Benchmarks/BulkDeleteBenchmarks.cs

BenchmarkDotNet=v0.13.2, OS=Windows 10 (10.0.19045.5011)
11th Gen Intel Core i7-1165G7 2.80GHz, 1 CPU, 8 logical and 4 physical cores
.NET SDK=8.0.400
  [Host]     : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2
  Job-CDMQUJ : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2

InvocationCount=1  IterationCount=1  UnrollFactor=1  
WarmupCount=0
Method RowsCount Mean Error Gen0 Gen1 Allocated
EFCoreDelete 100 36.94 ms NA - - 682.91 KB
BulkDelete 100 24.97 ms NA - - 37.79 KB
EFCoreDelete 1000 231.29 ms NA 1000.0000 1000.0000 6762.27 KB
BulkDelete 1000 32.78 ms NA - - 202.8 KB
EFCoreDelete 10000 2,209.83 ms NA 10000.0000 3000.0000 66219.48 KB
BulkDelete 10000 193.91 ms NA - - 1835.73 KB
EFCoreDelete 20000 4,705.65 ms NA 20000.0000 8000.0000 132780.13 KB
BulkDelete 20000 376.96 ms NA - - 3648.2 KB
EFCoreDelete 50000 11,842.03 ms NA 49000.0000 14000.0000 327102.23 KB
BulkDelete 50000 1,005.48 ms NA 1000.0000 - 9029.6 KB 
BenchmarkDotNet=v0.13.2, OS=Windows 10 (10.0.19045.5011)
11th Gen Intel Core i7-1165G7 2.80GHz, 1 CPU, 8 logical and 4 physical cores
.NET SDK=8.0.400
  [Host]     : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2
  Job-UIDALO : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2

InvocationCount=1  IterationCount=1  UnrollFactor=1  
WarmupCount=0
Method RowsCount Mean Error Gen0 Gen1 Allocated
BulkDelete 100000 1.963 s NA 2000.0000 1000.0000 17.61 MB
BulkDelete 250000 6.787 s NA 5000.0000 2000.0000 44.06 MB
BulkDelete 500000 43.473 s NA 10000.0000 5000.0000 87.97 MB
BulkDelete 1000000 75.212 s NA 21000.0000 10000.0000 176.77 MB

BulkMerge

/src/EntityFrameworkCore.MySql.SimpleBulks.Benchmarks/BulkMergeBenchmarks.cs

BenchmarkDotNet=v0.13.2, OS=Windows 10 (10.0.19045.5011)
11th Gen Intel Core i7-1165G7 2.80GHz, 1 CPU, 8 logical and 4 physical cores
.NET SDK=8.0.400
  [Host]     : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2
  Job-UIDALO : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2

InvocationCount=1  IterationCount=1  UnrollFactor=1  
WarmupCount=0
Method RowsCount Mean Error Gen0 Gen1 Gen2 Allocated
EFCoreUpsert 100 74.94 ms NA - - - 1824.88 KB
BulkMerge 100 38.65 ms NA - - - 103.85 KB
EFCoreUpsert 1000 393.71 ms NA 2000.0000 1000.0000 - 17861.01 KB
BulkMerge 1000 178.14 ms NA - - - 677.6 KB
EFCoreUpsert 10000 3,193.35 ms NA 27000.0000 8000.0000 - 178255.24 KB
BulkMerge 10000 549.66 ms NA - - - 6450.78 KB
EFCoreUpsert 100000 34,100.63 ms NA 269000.0000 63000.0000 - 1767492.45 KB
BulkMerge 100000 5,938.77 ms NA 9000.0000 5000.0000 1000.0000 63979.73 KB
EFCoreUpsert 250000 90,654.47 ms NA 674000.0000 153000.0000 - 4375295.44 KB
BulkMerge 250000 31,726.66 ms NA 21000.0000 11000.0000 1000.0000 162691.7 KB

BulkMatch

Single Column /src/EntityFrameworkCore.MySql.SimpleBulks.Benchmarks/BulkMatchSingleColumnBenchmarks.cs

BenchmarkDotNet=v0.13.2, OS=Windows 10 (10.0.19045.5011)
11th Gen Intel Core i7-1165G7 2.80GHz, 1 CPU, 8 logical and 4 physical cores
.NET SDK=8.0.400
  [Host]     : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2
  Job-XRORYQ : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2

InvocationCount=1  IterationCount=1  UnrollFactor=1  
WarmupCount=0
Method RowsCount Mean Error Gen0 Gen1 Gen2 Allocated
EFCoreSelect 100 87.293 ms NA - - - 755.39 KB
EFCoreBatchSelect 100 5.472 ms NA - - - 112.87 KB
BulkMatch 100 6.441 ms NA - - - 94.54 KB
EFCoreSelect 1000 943.840 ms NA 1000.0000 - - 7486.88 KB
EFCoreBatchSelect 1000 14.235 ms NA - - - 899.45 KB
BulkMatch 1000 15.678 ms NA - - - 730.93 KB
EFCoreSelect 10000 8,673.825 ms NA 12000.0000 1000.0000 - 74547.2 KB
EFCoreBatchSelect 10000 145.653 ms NA 1000.0000 - - 9060.32 KB
BulkMatch 10000 138.112 ms NA 1000.0000 - - 7315.17 KB
EFCoreSelect 100000 77,525.831 ms NA 122000.0000 25000.0000 1000.0000 745727.41 KB
EFCoreBatchSelect 100000 713.308 ms NA 13000.0000 5000.0000 1000.0000 90699.73 KB
BulkMatch 100000 739.911 ms NA 12000.0000 5000.0000 1000.0000 73822.48 KB 
BenchmarkDotNet=v0.13.2, OS=Windows 10 (10.0.19045.5011)
11th Gen Intel Core i7-1165G7 2.80GHz, 1 CPU, 8 logical and 4 physical cores
.NET SDK=8.0.400
  [Host]     : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2
  Job-XRORYQ : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2

InvocationCount=1  IterationCount=1  UnrollFactor=1  
WarmupCount=0
Method RowsCount Mean Error Gen0 Gen1 Gen2 Allocated
EFCoreBatchSelect 250000 2.086 s NA 32000.0000 12000.0000 1000.0000 220.07 MB
BulkMatch 250000 1.785 s NA 28000.0000 11000.0000 1000.0000 179.51 MB
EFCoreBatchSelect 500000 4.617 s NA 63000.0000 23000.0000 1000.0000 440.05 MB
BulkMatch 500000 3.884 s NA 55000.0000 22000.0000 1000.0000 359.01 MB
EFCoreBatchSelect 1000000 8.081 s NA 125000.0000 49000.0000 1000.0000 880.01 MB
BulkMatch 1000000 8.634 s NA 108000.0000 42000.0000 1000.0000 718.02 MB

Multiple Columns /src/EntityFrameworkCore.MySql.SimpleBulks.Benchmarks/BulkMatchMultipleColumnsBenchmarks.cs

BenchmarkDotNet=v0.13.2, OS=Windows 10 (10.0.19045.5011)
11th Gen Intel Core i7-1165G7 2.80GHz, 1 CPU, 8 logical and 4 physical cores
.NET SDK=8.0.400
  [Host]     : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2
  Job-XRORYQ : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2

InvocationCount=1  IterationCount=1  UnrollFactor=1  
WarmupCount=0
Method RowsCount Mean Error Gen0 Gen1 Allocated
EFCoreSelect 100 167.60 ms NA - - 1002.69 KB
BulkMatch 100 11.01 ms NA - - 152.36 KB
EFCoreSelect 1000 1,239.99 ms NA 1000.0000 - 9452.78 KB
BulkMatch 1000 35.72 ms NA - - 1188.09 KB
EFCoreSelect 10000 11,437.62 ms NA 15000.0000 3000.0000 97825.21 KB
BulkMatch 10000 289.64 ms NA 1000.0000 - 11953.45 KB
EFCoreSelect 100000 90,754.18 ms NA 154000.0000 38000.0000 948693.23 KB
BulkMatch 100000 1,981.62 ms NA 18000.0000 6000.0000 120447.04 KB 
BenchmarkDotNet=v0.13.2, OS=Windows 10 (10.0.19045.5011)
11th Gen Intel Core i7-1165G7 2.80GHz, 1 CPU, 8 logical and 4 physical cores
.NET SDK=8.0.400
  [Host]     : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2
  Job-XRORYQ : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2

InvocationCount=1  IterationCount=1  UnrollFactor=1  
WarmupCount=0
Method RowsCount Mean Error Gen0 Gen1 Gen2 Allocated
BulkMatch 250000 6.536 s NA 46000.0000 16000.0000 - 296.15 MB
BulkMatch 500000 11.922 s NA 92000.0000 32000.0000 - 594.47 MB
BulkMatch 1000000 40.775 s NA 185000.0000 66000.0000 1000.0000 1194.94 MB

TempTable

/src/EntityFrameworkCore.MySql.SimpleBulks.Benchmarks/TempTableBenchmarks.cs

BenchmarkDotNet=v0.13.2, OS=Windows 10 (10.0.19045.5011)
11th Gen Intel Core i7-1165G7 2.80GHz, 1 CPU, 8 logical and 4 physical cores
.NET SDK=8.0.400
  [Host]     : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2
  Job-GTTKRK : .NET 8.0.8 (8.0.824.36612), X64 RyuJIT AVX2

InvocationCount=1  IterationCount=1  UnrollFactor=1  
WarmupCount=0
Method RowsCount Mean Error Gen0 Gen1 Gen2 Allocated
CreateTempTable 100 5.322 ms NA - - - 56.78 KB
CreateTempTable 1000 14.892 ms NA - - - 285.05 KB
CreateTempTable 10000 90.559 ms NA - - - 2593.26 KB
CreateTempTable 100000 566.383 ms NA 3000.0000 1000.0000 - 25485.38 KB
CreateTempTable 250000 1,039.989 ms NA 8000.0000 4000.0000 1000.0000 63742.06 KB
CreateTempTable 500000 2,069.624 ms NA 15000.0000 7000.0000 1000.0000 127270.92 KB
CreateTempTable 1000000 4,251.546 ms NA 29000.0000 14000.0000 1000.0000 254340.69 KB

License

EntityFrameworkCore.MySql.SimpleBulks is licensed under the MIT license.

About

Fast and simple bulk insert, bulk update, bulk delete, bulk merge and bulk match for MySQL.

www.nuget.org/packages/EntityFrameworkCore.MySql.SimpleBulks

Resources

Readme

License

MIT license
Activity

Stars

21 stars

Watchers

1 watching

Forks

0 forks
Report repository

Releases 27

v10.0.0 Latest
Apr 29, 2026
+ 26 releases

Packages

 
 
 

Contributors

Languages
⚡