update demo

Author: Haik

test/PandaNuGet.Demo/Dtos/BulkBenchmarkResponse.cs

@@ -9,5 +9,6 @@ public enum BenchmarkMethod
 {
     EFCore,
     Dapper,
-    NpgsqlCopy
+    NpgsqlCopy,
+    ExternalBulkInsert
 }

test/PandaNuGet.Demo/PandaNuGet.Demo.csproj

@@ -9,6 +9,7 @@
 
     <ItemGroup>
         <PackageReference Include="Dapper" Version="2.1.35" />
+        <PackageReference Include="EFCore.BulkExtensions.PostgreSql" Version="8.0.2" />
         <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="8.0.4" />
         <PackageReference Include="Swashbuckle.AspNetCore" Version="6.5.0" />
     </ItemGroup>

test/PandaNuGet.Demo/Program.cs

@@ -24,14 +24,17 @@
     var results = new List<BulkBenchmarkResponse>
     {
         service.BulkInsertEfCore(minimumRows),
-        service.BulkInsertNpgsqlCopy(minimumRows),
         service.BulkInsertDapper(minimumRows),
+        service.BulkInsertNpgsqlCopy(minimumRows),
+        service.BulkInsertExternal(minimumRows),
         service.BulkInsertEfCore(minimumRows * 10),
         service.BulkInsertDapper(minimumRows * 10),
         service.BulkInsertNpgsqlCopy(minimumRows * 10),
+        service.BulkInsertExternal(minimumRows * 10),
         service.BulkInsertEfCore(minimumRows * 100),
         service.BulkInsertDapper(minimumRows * 100),
-        service.BulkInsertNpgsqlCopy(minimumRows * 100)
+        service.BulkInsertNpgsqlCopy(minimumRows * 100),
+        service.BulkInsertExternal(minimumRows * 100)
     };
 
     return results;
@@ -44,12 +47,15 @@
         await service.BulkInsertEfCoreAsync(minimumRows),
         await service.BulkInsertDapperAsync(minimumRows),
         await service.BulkInsertNpgsqlCopyAsync(minimumRows),
+        await service.BulkInsertExternalAsync(minimumRows),
         await service.BulkInsertEfCoreAsync(minimumRows * 10),
         await service.BulkInsertDapperAsync(minimumRows * 10),
         await service.BulkInsertNpgsqlCopyAsync(minimumRows * 10),
+        await service.BulkInsertExternalAsync(minimumRows * 10),
         await service.BulkInsertEfCoreAsync(minimumRows * 100),
         await service.BulkInsertDapperAsync(minimumRows * 100),
-        await service.BulkInsertNpgsqlCopyAsync(minimumRows * 100)
+        await service.BulkInsertNpgsqlCopyAsync(minimumRows * 100),
+        await service.BulkInsertExternalAsync(minimumRows * 100)
     };
 
     return results;

test/PandaNuGet.Demo/Services/BulkInsertService.cs

@@ -1,6 +1,7 @@
 using System.Diagnostics;
 using System.Text;
 using Dapper;
+using EFCore.BulkExtensions;
 using EFCore.PostgresExtensions.Extensions.BulkInsertExtension;
 using Microsoft.EntityFrameworkCore;
 using PandaNuGet.Demo.Context;
@@ -208,6 +209,42 @@ public async Task<BulkBenchmarkResponse> BulkInsertDapperAsync(int rowsCount, bo
         return new BulkBenchmarkResponse(BenchmarkMethod.Dapper, rowsCount, stopwatch.ElapsedMilliseconds.ToString());
     }
 
+    public async Task<BulkBenchmarkResponse> BulkInsertExternalAsync(int rowsCount, bool ignoreReset = false)
+    {
+        await ResetDbAsync(ignoreReset);
+        var users = new List<UserEntity>();
+
+        for (int i = 0; i < rowsCount; i++)
+        {
+            users.Add(new UserEntity());
+        }
+
+        var stopwatch = Stopwatch.StartNew();
+        await dbContext.BulkInsertAsync(users);
+        stopwatch.Stop();
+
+        return new BulkBenchmarkResponse(BenchmarkMethod.ExternalBulkInsert, rowsCount,
+            stopwatch.ElapsedMilliseconds.ToString());
+    }
+
+    public BulkBenchmarkResponse BulkInsertExternal(int rowsCount, bool ignoreReset = false)
+    {
+        ResetDb(ignoreReset);
+        var users = new List<UserEntity>();
+
+        for (int i = 0; i < rowsCount; i++)
+        {
+            users.Add(new UserEntity());
+        }
+
+        var stopwatch = Stopwatch.StartNew();
+        dbContext.BulkInsert(users);
+        stopwatch.Stop();
+
+        return new BulkBenchmarkResponse(BenchmarkMethod.ExternalBulkInsert, rowsCount,
+            stopwatch.ElapsedMilliseconds.ToString());
+    }
+
     private async Task ResetDbAsync(bool ignore)
     {
         if (ignore)

test/PandaNuGet.Demo/appsettings.json

@@ -1,8 +1,8 @@
 {
   "Logging": {
     "LogLevel": {
-      "Default": "Error",
-      "Microsoft.AspNetCore": "Error"
+      "Default": "Debug",
+      "Microsoft.AspNetCore": "Warning"
     }
   },
   "AllowedHosts": "*",