var items = new List<Product> { new Product("Product1", 100m) };
await _dbContext.BulkInsertAsync(items);
var items = new List<Product> { new Product("Product1", 100m) };
await _dbContext.BulkInsertAsync(
items,
option =>
{
option.BatchSize = 1000;
option.CommandTimeout = 120;
option.IgnoreOnInsert = x => new { x.CreatedAt };
}
);
Bulk Update
var items = new List<Product> { new Product("Product1", 100m) };
await _dbContext.BulkUpdateAsync(items);
var items = new List<Product> { new Product("Product1", 100m) };
await _dbContext.BulkUpdateAsync(
items,
option => { option.IgnoreOnUpdate = x => new { x.CreatedAt }; }
);
var items = new List<Product> { new Product("Product1", 100m) };
await _dbContext.BulkUpdateAsync(
items,
option => { option.UniqueKeys = x => new { x.Id }; }
);
Bulk Delete
var items = new List<Product> { new Product("Product1", 100m) };
await _dbContext.BulkDeleteAsync(items);
var items = new List<Product> { new Product("Product1", 100m) };
await _dbContext.BulkDeleteAsync(
items,
option => { option.UniqueKeys = x => new { x.Id }; }
);
Bulk Merge (MySql only)
Do not use BulkMergeAsync with other databases; it relies on a MySQL-specific query.
var items = new List<Product> { new Product("Product1", 100m) };
await _dbContext.BulkMergeAsync(items);
await _dbContext.BulkMergeAsync(
items,
option =>
{
option.IgnoreOnInsert = x => new { x.CreatedAt };
option.IgnoreOnUpdate = x => new { x.CreatedAt };
});
Working with Global Transaction
EfCore.BulkOperations utilizes local transactions within bulk processes. If you require manual transaction control, you
can pass an existing transaction into the bulk process.
IDbContextTransaction? transaction = null;
DbConnection? connection = null;
try
{
connection = dbContext.Database.GetDbConnection();
if (connection.State != ConnectionState.Open) await connection.OpenAsync();
transaction = await dbContext.Database.BeginTransactionAsync();
var dbTransaction = transaction.GetDbTransaction();
await dbContext.Products.AddAsync(item1);
await dbContext.SaveChangesAsync();
await dbContext.BulkInsertAsync(list2, null, dbTransaction);
await dbContext.BulkInsertAsync(list3, null, dbTransaction);
throw new DbUpdateException("Internal Server Error");
}
catch (Exception ex)
{
if (transaction is not null) await transaction.RollbackAsync();
throw;
}
finally
{
if (connection is { State: ConnectionState.Open }) await connection.CloseAsync();
}