concurrency handling

phongnguyend · phongnguyend · commit e3a8941f0e16 · 2022-07-29T11:41:06.000+07:00
diff --git a/src/Microservices/Common/ClassifiedAds.Domain/Repositories/IConcurrencyHandler.cs b/src/Microservices/Common/ClassifiedAds.Domain/Repositories/IConcurrencyHandler.cs
@@ -0,0 +1,11 @@
+﻿using System;
+
+namespace ClassifiedAds.Domain.Repositories
+{
+    public interface IConcurrencyHandler<TEntity>
+    {
+        void SetRowVersion(TEntity entity, byte[] version);
+
+        bool IsDbUpdateConcurrencyException(Exception ex);
+    }
+}
diff --git a/src/Microservices/Common/ClassifiedAds.Domain/Repositories/IRepository.cs b/src/Microservices/Common/ClassifiedAds.Domain/Repositories/IRepository.cs
@@ -8,7 +8,7 @@
 
 namespace ClassifiedAds.Domain.Repositories
 {
-    public interface IRepository<TEntity, TKey>
+    public interface IRepository<TEntity, TKey> : IConcurrencyHandler<TEntity>
         where TEntity : AggregateRoot<TKey>
     {
         IUnitOfWork UnitOfWork { get; }
diff --git a/src/Microservices/Common/ClassifiedAds.Infrastructure/ClassifiedAds.Infrastructure.csproj b/src/Microservices/Common/ClassifiedAds.Infrastructure/ClassifiedAds.Infrastructure.csproj
@@ -40,7 +40,7 @@
 		<PackageReference Include="DinkToPdf" Version="1.0.8" />
 		<PackageReference Include="Google.Protobuf" Version="3.19.1" />
 		<PackageReference Include="Grpc.Net.Client" Version="2.40.0" />
-		<PackageReference Include="EntityFrameworkCore.SqlServer.SimpleBulks" Version="6.4.0" />
+		<PackageReference Include="EntityFrameworkCore.SqlServer.SimpleBulks" Version="6.5.0" />
 		<PackageReference Include="IdentityModel" Version="5.2.0" />
 		<PackageReference Include="Microsoft.ApplicationInsights.AspNetCore" Version="2.19.0" />
 		<PackageReference Include="Microsoft.AspNetCore.Authentication.OpenIdConnect" Version="6.0.0" />
diff --git a/src/Microservices/Common/ClassifiedAds.Infrastructure/Persistence/DbContextRepository.cs b/src/Microservices/Common/ClassifiedAds.Infrastructure/Persistence/DbContextRepository.cs
@@ -111,5 +111,15 @@ public void BulkMerge(IEnumerable<TEntity> entities, Expression<Func<TEntity, ob
         {
             _dbContext.BulkMerge(entities, idSelector, updateColumnNamesSelector, insertColumnNamesSelector);
         }
+
+        public void SetRowVersion(TEntity entity, byte[] version)
+        {
+            _dbContext.Entry(entity).OriginalValues[nameof(entity.RowVersion)] = version;
+        }
+
+        public bool IsDbUpdateConcurrencyException(Exception ex)
+        {
+            return ex is DbUpdateConcurrencyException;
+        }
     }
 }
diff --git a/src/ModularMonolith/ClassifiedAds.Domain/Repositories/IConcurrencyHandler.cs b/src/ModularMonolith/ClassifiedAds.Domain/Repositories/IConcurrencyHandler.cs
@@ -0,0 +1,11 @@
+﻿using System;
+
+namespace ClassifiedAds.Domain.Repositories
+{
+    public interface IConcurrencyHandler<TEntity>
+    {
+        void SetRowVersion(TEntity entity, byte[] version);
+
+        bool IsDbUpdateConcurrencyException(Exception ex);
+    }
+}
diff --git a/src/ModularMonolith/ClassifiedAds.Domain/Repositories/IRepository.cs b/src/ModularMonolith/ClassifiedAds.Domain/Repositories/IRepository.cs
@@ -8,7 +8,7 @@
 
 namespace ClassifiedAds.Domain.Repositories
 {
-    public interface IRepository<TEntity, TKey>
+    public interface IRepository<TEntity, TKey> : IConcurrencyHandler<TEntity>
         where TEntity : AggregateRoot<TKey>
     {
         IUnitOfWork UnitOfWork { get; }
diff --git a/src/ModularMonolith/ClassifiedAds.Infrastructure/ClassifiedAds.Infrastructure.csproj b/src/ModularMonolith/ClassifiedAds.Infrastructure/ClassifiedAds.Infrastructure.csproj
@@ -38,7 +38,7 @@
 		<PackageReference Include="CsvHelper" Version="27.2.0" />
 		<PackageReference Include="Dapper.StrongName" Version="2.0.123" />
 		<PackageReference Include="DinkToPdf" Version="1.0.8" />
-		<PackageReference Include="EntityFrameworkCore.SqlServer.SimpleBulks" Version="6.4.0" />
+		<PackageReference Include="EntityFrameworkCore.SqlServer.SimpleBulks" Version="6.5.0" />
 		<PackageReference Include="IdentityModel" Version="5.2.0" />
 		<PackageReference Include="Microsoft.ApplicationInsights.AspNetCore" Version="2.19.0" />
 		<PackageReference Include="Microsoft.AspNetCore.Authentication.OpenIdConnect" Version="6.0.0" />
diff --git a/src/ModularMonolith/ClassifiedAds.Infrastructure/Persistence/DbContextRepository.cs b/src/ModularMonolith/ClassifiedAds.Infrastructure/Persistence/DbContextRepository.cs
@@ -111,5 +111,15 @@ public void BulkMerge(IEnumerable<TEntity> entities, Expression<Func<TEntity, ob
         {
             _dbContext.BulkMerge(entities, idSelector, updateColumnNamesSelector, insertColumnNamesSelector);
         }
+
+        public void SetRowVersion(TEntity entity, byte[] version)
+        {
+            _dbContext.Entry(entity).OriginalValues[nameof(entity.RowVersion)] = version;
+        }
+
+        public bool IsDbUpdateConcurrencyException(Exception ex)
+        {
+            return ex is DbUpdateConcurrencyException;
+        }
     }
 }
diff --git a/src/Monolith/ClassifiedAds.Domain/Repositories/IConcurrencyHandler.cs b/src/Monolith/ClassifiedAds.Domain/Repositories/IConcurrencyHandler.cs
@@ -0,0 +1,11 @@
+﻿using System;
+
+namespace ClassifiedAds.Domain.Repositories
+{
+    public interface IConcurrencyHandler<TEntity>
+    {
+        void SetRowVersion(TEntity entity, byte[] version);
+
+        bool IsDbUpdateConcurrencyException(Exception ex);
+    }
+}
diff --git a/src/Monolith/ClassifiedAds.Domain/Repositories/IRepository.cs b/src/Monolith/ClassifiedAds.Domain/Repositories/IRepository.cs
@@ -8,7 +8,7 @@
 
 namespace ClassifiedAds.Domain.Repositories
 {
-    public interface IRepository<TEntity, TKey>
+    public interface IRepository<TEntity, TKey> : IConcurrencyHandler<TEntity>
         where TEntity : AggregateRoot<TKey>
     {
         IUnitOfWork UnitOfWork { get; }
diff --git a/src/Monolith/ClassifiedAds.Persistence/ClassifiedAds.Persistence.csproj b/src/Monolith/ClassifiedAds.Persistence/ClassifiedAds.Persistence.csproj
@@ -7,7 +7,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="EntityFrameworkCore.SqlServer.SimpleBulks" Version="6.4.0" />
+    <PackageReference Include="EntityFrameworkCore.SqlServer.SimpleBulks" Version="6.5.0" />
     <PackageReference Include="IdentityServer4" Version="4.1.2" />
     <PackageReference Include="IdentityServer4.AspNetIdentity" Version="4.1.2" />
     <PackageReference Include="IdentityServer4.EntityFramework" Version="4.1.2" />
diff --git a/src/Monolith/ClassifiedAds.Persistence/Repositories/Repository.cs b/src/Monolith/ClassifiedAds.Persistence/Repositories/Repository.cs
@@ -110,5 +110,15 @@ public void BulkMerge(IEnumerable<T> entities, Expression<Func<T, object>> idSel
         {
             _dbContext.BulkMerge(entities, idSelector, updateColumnNamesSelector, insertColumnNamesSelector);
         }
+
+        public void SetRowVersion(T entity, byte[] version)
+        {
+            _dbContext.Entry(entity).OriginalValues[nameof(entity.RowVersion)] = version;
+        }
+
+        public bool IsDbUpdateConcurrencyException(Exception ex)
+        {
+            return ex is DbUpdateConcurrencyException;
+        }
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -8,7 +8,7 @@`
`8`	`8`
`9`	`9`	`namespace ClassifiedAds.Domain.Repositories`
`10`	`10`	`{`
`11`		`- public interface IRepository<TEntity, TKey>`
	`11`	`+ public interface IRepository<TEntity, TKey> : IConcurrencyHandler<TEntity>`
`12`	`12`	`where TEntity : AggregateRoot<TKey>`
`13`	`13`	`{`
`14`	`14`	`IUnitOfWork UnitOfWork { get; }`
Original file line number	Diff line number	Diff line change
`@@ -111,5 +111,15 @@ public void BulkMerge(IEnumerable<TEntity> entities, Expression<Func<TEntity, ob`
`111`	`111`	`{`
`112`	`112`	`_dbContext.BulkMerge(entities, idSelector, updateColumnNamesSelector, insertColumnNamesSelector);`
`113`	`113`	`}`
	`114`	`+`
	`115`	`+ public void SetRowVersion(TEntity entity, byte[] version)`
	`116`	`+ {`
	`117`	`+ _dbContext.Entry(entity).OriginalValues[nameof(entity.RowVersion)] = version;`
	`118`	`+ }`
	`119`	`+`
	`120`	`+ public bool IsDbUpdateConcurrencyException(Exception ex)`
	`121`	`+ {`
	`122`	`+ return ex is DbUpdateConcurrencyException;`
	`123`	`+ }`
`114`	`124`	`}`
`115`	`125`	`}`