< BACK TO BLOG

Delete batch using Entity Framework Core

January 08, 2022

Entity Framework Core: Bulk updates 를 읽고, 어느 정도 성능향상이 있을까 궁금해서 간략하게 코드를 작성해서 실행 시간을 측정했습니다.

프로젝트 설명

환경

  • Visual Studio 2022 (v17.0.4)
  • Localdb (appsettings.json 에서 연결문자열을 확인하세요.)
  • .NET 6
  • EntityFrameworkCore v6.0.1

마이그레이션

엔티티를 변경해서 확인하려면 아래 명령을 참조해서 마이그레이션 코드를 추가해야 합니다.

# DataContext 가 포함된 프로젝트 디렉터리로 이동합니다.
$ cd src/Sample.Data
# 마이그레이션 코드를 작성합니다.
$ dotnet ef migrations add "Initialize database" --context AppDbContext --startup-project ../Sample.App --project ../Sample.Data.SqlServer --json

확인

행 추가 (#1-1, #1-2)

-- Declaring variables 

DECLARE @inserted0 TABLE ([Id] bigint, [_Position] [int]);

MERGE [UserToken] USING (
VALUES (@p0, @p1, @p2, @p3, 0),
(@p4, @p5, @p6, @p7, 1),
(@p8, @p9, @p10, @p11, 2),
-- 생략
(@p160, @p161, @p162, @p163, 40),
(@p164, @p165, @p166, @p167, 41)) AS i ([CreatedAt], [ExpiresAt], [Purpose], [Token], _Position) ON 1=0
WHEN NOT MATCHED THEN
INSERT ([CreatedAt], [ExpiresAt], [Purpose], [Token])
VALUES (i.[CreatedAt], i.[ExpiresAt], i.[Purpose], i.[Token])
OUTPUT INSERTED.[Id], i._Position
INTO @inserted0;

행 삭제 (#2)

DELETE 문이 각 행별로 작성되어 실행됩니다.

1,000 행을 대상으로 약 507 밀리초가 소요되었습니다.

var deleteCandidate = Context.UserTokens.Where(x => x.ExpiresAt <= DateTime.UtcNow);

Context.UserTokens.RemoveRange(deleteCandidate);

await Context.SaveChangesAsync();
-- Declaring variables 

DELETE FROM [UserToken]
WHERE [Id] = @p0;
SELECT @@ROWCOUNT;

DELETE FROM [UserToken]
WHERE [Id] = @p1;
SELECT @@ROWCOUNT;

DELETE FROM [UserToken]
WHERE [Id] = @p2;
SELECT @@ROWCOUNT;

-- 생략

행 삭제 (#4)

SQL 문으로 삭제 명령을 정의하고, 실행합니다.

ANSI sql 문으로 작성하면 DBMS 의존을 줄일 수 있다고 생각합니다.

1,000 행을 대상으로 약 17 밀리초가 소요되었습니다.

var sql = string.Empty;
sql += $"DELETE FROM {nameof(UserToken)} ";
sql += $" WHERE {nameof(UserToken.ExpiresAt)} <= GetUtcDate()";

await Context.Database.ExecuteSqlRawAsync(sql);

SQL 문 실행시 트랜잭션 확인 (#3)

SQL 문으로 명령을 실행할 때, 트랜잭션을 확인합니다.

SQL 문의 결과가 커밋되지 않고 정상적으로 롤백됨을 확인했습니다.

using (var transaction = Context.Database.BeginTransaction())
{
    try
    {
        await Context.Database.ExecuteSqlRawAsync(sql);
        throw new Exception("Test");
        await transaction.CommitAsync();
    }
    catch (Exception)
    {
        await transaction.RollbackAsync();
    }
}

마침

일괄 작업으로 변경, 삭제 작업을 실행할 때, 성능향상을 위해 SQL 문을 고려할 필요가 있을 것 같습니다.

만료된 토큰 정리, 로그 정리 등에 사용하면 좋을 것으로 생각됩니다.

GitHub Repository


Profile picture

Pon Cheol Ku (구본철)

Software developer

Other sites

If does not find interesting topic, you might visit other site on below link.

© 2022, Built with Gatsby