From 95b3ab6bcdd41a5aac9e97a8a6ce74b42446957c Mon Sep 17 00:00:00 2001 From: LittleSheep Date: Thu, 22 May 2025 01:55:02 +0800 Subject: [PATCH] :zap: Optimize bulk insert on conflict options --- DysonNetwork.Sphere/Account/AccountService.cs | 2 +- DysonNetwork.Sphere/Storage/Handlers/ActionLogFlushHandler.cs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/DysonNetwork.Sphere/Account/AccountService.cs b/DysonNetwork.Sphere/Account/AccountService.cs index 76529c3..eddd66b 100644 --- a/DysonNetwork.Sphere/Account/AccountService.cs +++ b/DysonNetwork.Sphere/Account/AccountService.cs @@ -62,7 +62,7 @@ public class AccountService( if (missingId.Count != 0) { var newProfiles = missingId.Select(id => new Profile { AccountId = id }).ToList(); - await db.BulkInsertAsync(newProfiles); + await db.BulkInsertAsync(newProfiles, config => config.ConflictOption = ConflictOption.Ignore); } } } \ No newline at end of file diff --git a/DysonNetwork.Sphere/Storage/Handlers/ActionLogFlushHandler.cs b/DysonNetwork.Sphere/Storage/Handlers/ActionLogFlushHandler.cs index 8798ff7..f71e8a4 100644 --- a/DysonNetwork.Sphere/Storage/Handlers/ActionLogFlushHandler.cs +++ b/DysonNetwork.Sphere/Storage/Handlers/ActionLogFlushHandler.cs @@ -11,7 +11,7 @@ public class ActionLogFlushHandler(IServiceProvider serviceProvider) : IFlushHan using var scope = serviceProvider.CreateScope(); var db = scope.ServiceProvider.GetRequiredService(); - await db.BulkInsertAsync(items); + await db.BulkInsertAsync(items, config => config.ConflictOption = ConflictOption.Ignore); } }