mirror of https://github.com/abpframework/abp.git
Galip Tolga Erdem
4 years ago
10 changed files with 248 additions and 34 deletions
@ -0,0 +1,71 @@ |
|||||
|
# Bulk Operations with Entity Framework Core 7.0 |
||||
|
Entity Framework tracks all the entity changes and applies those changes to the database one by one when the `SaveChanges()` method is called. There was no way to execute bulk operations in Entity Framework Core without a dependency. |
||||
|
|
||||
|
As you know the [Entity Framework Extensions](https://entityframework-extensions.net/bulk-savechanges) library was doing it but it was not free. |
||||
|
|
||||
|
There was no other solution until now. [Bulk Operations](https://learn.microsoft.com/en-us/ef/core/what-is-new/ef-core-7.0/whatsnew#executeupdate-and-executedelete-bulk-updates) are now available in Entity Framework Core with .NET 7. |
||||
|
|
||||
|
With .NET 7, there are two new methods such as `ExecuteUpdate` and `ExecuteDelete` available to execute bulk operations. It's a similar usage with the Entity Framework Core Extensions library if you're familiar with it. |
||||
|
|
||||
|
You can visit the microsoft example [here](https://docs.microsoft.com/en-us/ef/core/what-is-new/ef-core-7.0/whatsnew#executeupdate-and-executedelete-bulk-updates) about how to use it. |
||||
|
|
||||
|
|
||||
|
It can be easily used with the DbContext. |
||||
|
|
||||
|
```csharp |
||||
|
await context.Tags.Where(t => t.Text.Contains(".NET")).ExecuteDeleteAsync(); |
||||
|
``` |
||||
|
|
||||
|
## Using with ABP Framework |
||||
|
ABP Framework provides an abstraction over database operations and implements generic repository pattern. So, DbContext can't be accessed outside of [repositories](https://docs.abp.io/en/abp/latest/Repositories). |
||||
|
|
||||
|
You can use the `ExecuteUpdate` and `ExecuteDelete` methods inside a repository. |
||||
|
|
||||
|
```csharp |
||||
|
public class BookEntityFrameworkCoreRepository : EfCoreRepository<BookStoreDbContext, Book, Guid>, IBookRepository |
||||
|
{ |
||||
|
public BookEntityFrameworkCoreRepository(IDbContextProvider<BookStoreDbContext> dbContextProvider) : base(dbContextProvider) |
||||
|
{ |
||||
|
} |
||||
|
|
||||
|
public async Task UpdateListingAsync() |
||||
|
{ |
||||
|
var dbSet = await GetDbSetAsync(); |
||||
|
|
||||
|
await dbSet |
||||
|
.Where(x => x.IsListed && x.PublishedOn.Year <= 2022) |
||||
|
.ExecuteUpdateAsync(s => s.SetProperty(x => x.IsListed, x => false)); |
||||
|
} |
||||
|
|
||||
|
public async Task DeleteOldBooksAsync() |
||||
|
{ |
||||
|
var dbSet = await GetDbSetAsync(); |
||||
|
|
||||
|
await dbSet |
||||
|
.Where(x => x.PublishedOn.Year <= 2000) |
||||
|
.ExecuteDeleteAsync(); |
||||
|
} |
||||
|
} |
||||
|
``` |
||||
|
|
||||
|
There is no need to take an action for bulk inserting. You can use the `InsertManyAsync` method of the repository instead of creating a new method for it if you don't have custom logic. It'll use a new bulk inserting feature automatically since it's available in EF Core 7.0. |
||||
|
|
||||
|
```csharp |
||||
|
public class MyDomainService : DomainService |
||||
|
{ |
||||
|
protected IRepository<Book, Guid> BookRepository { get; } |
||||
|
|
||||
|
public MyDomainService(IRepository<Book, Guid> bookRepository) |
||||
|
{ |
||||
|
BookRepository = bookRepository; |
||||
|
} |
||||
|
|
||||
|
public async Task CreateBooksAsync(List<Book> books) |
||||
|
{ |
||||
|
// It'll use bulk inserting automatically. |
||||
|
await BookRepository.InsertManyAsync(books); |
||||
|
} |
||||
|
} |
||||
|
``` |
||||
|
|
||||
|
> If you use `ExecuteDeleteAsync` or `ExecuteUpdateAsync`, then ABP's soft delete and auditing features can not work. Because these ABP features work with EF Core's change tracking system and these new methods doesn't work with the change tracking system. So, use them carefully. |
||||
@ -0,0 +1,34 @@ |
|||||
|
using System; |
||||
|
using System.Linq; |
||||
|
using System.Xml; |
||||
|
using Volo.Abp.Cli.ProjectBuilding.Building; |
||||
|
using Volo.Abp.Cli.Utils; |
||||
|
|
||||
|
namespace Volo.Abp.Cli.ProjectBuilding.Templates.App; |
||||
|
|
||||
|
public class MauiBlazorChangeApplicationIdGuidStep: ProjectBuildPipelineStep |
||||
|
{ |
||||
|
public override void Execute(ProjectBuildContext context) |
||||
|
{ |
||||
|
var projectFile = context.Files.FirstOrDefault(f => f.Name.EndsWith("MyCompanyName.MyProjectName.MauiBlazor.csproj")); |
||||
|
|
||||
|
if (projectFile == null) |
||||
|
{ |
||||
|
return; |
||||
|
} |
||||
|
|
||||
|
using (var stream = StreamHelper.GenerateStreamFromString(projectFile.Content)) |
||||
|
{ |
||||
|
var doc = new XmlDocument { PreserveWhitespace = true }; |
||||
|
doc.Load(stream); |
||||
|
|
||||
|
var node = doc.SelectSingleNode("/Project/PropertyGroup/ApplicationIdGuid"); |
||||
|
if (node != null) |
||||
|
{ |
||||
|
node.InnerText = Guid.NewGuid().ToString(); |
||||
|
} |
||||
|
|
||||
|
projectFile.SetContent(doc.OuterXml); |
||||
|
} |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,50 @@ |
|||||
|
using System; |
||||
|
using System.Linq; |
||||
|
using Volo.Abp.Cli.ProjectBuilding.Building; |
||||
|
|
||||
|
namespace Volo.Abp.Cli.ProjectBuilding.Templates.App; |
||||
|
|
||||
|
public class MauiBlazorPortChangeForSeparatedAuthServersStep: ProjectBuildPipelineStep |
||||
|
{ |
||||
|
public override void Execute(ProjectBuildContext context) |
||||
|
{ |
||||
|
|
||||
|
var appsettingsFile = context.Files.FirstOrDefault(x => |
||||
|
!x.IsDirectory && |
||||
|
x.Name.EndsWith("aspnet-core/src/MyCompanyName.MyProjectName.MauiBlazor/appsettings.json", |
||||
|
StringComparison.InvariantCultureIgnoreCase) |
||||
|
); |
||||
|
|
||||
|
if(appsettingsFile == null) |
||||
|
{ |
||||
|
return; |
||||
|
} |
||||
|
|
||||
|
appsettingsFile.NormalizeLineEndings(); |
||||
|
var lines = appsettingsFile.GetLines(); |
||||
|
|
||||
|
for (var i = 1; i < lines.Length; i++) |
||||
|
{ |
||||
|
var line = lines[i]; |
||||
|
|
||||
|
var previousLine = lines[i-1]; |
||||
|
|
||||
|
if (line.Contains("Authority") && line.Contains("localhost")) |
||||
|
{ |
||||
|
line = line.Replace("44305", "44301"); |
||||
|
} |
||||
|
else if (previousLine.Contains("AbpAccountPublic") && line.Contains("BaseUrl") && line.Contains("localhost")) |
||||
|
{ |
||||
|
line = line.Replace("44305", "44301"); |
||||
|
} |
||||
|
else if (previousLine.Contains("Default") && line.Contains("BaseUrl") && line.Contains("localhost")) |
||||
|
{ |
||||
|
line = line.Replace("44305", "44300"); |
||||
|
} |
||||
|
|
||||
|
lines[i] = line; |
||||
|
} |
||||
|
|
||||
|
appsettingsFile.SetLines(lines); |
||||
|
} |
||||
|
} |
||||
Loading…
Reference in new issue