Cache

phongnguyend · phongnguyend · commit 0c80b8b0ea10 · 2025-10-18T20:55:26.000+07:00
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/DbContextAsyncExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/DbContextAsyncExtensions.cs
@@ -2,7 +2,6 @@
 using Microsoft.EntityFrameworkCore;
 using System;
 using System.Collections.Generic;
-using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 
@@ -15,13 +14,9 @@ public static Task<BulkDeleteResult> BulkDeleteAsync<T>(this DbContext dbContext
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
-        var primaryKeys = properties
-            .Where(x => x.IsPrimaryKey)
-            .Select(x => x.PropertyName);
 
         return new BulkDeleteBuilder<T>(connection, transaction)
-             .WithId(primaryKeys)
+             .WithId(dbContext.GetPrimaryKeys(typeof(T)))
              .WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
              .WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
              .ToTable(table)
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/DbContextExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkDelete/DbContextExtensions.cs
@@ -2,7 +2,6 @@
 using Microsoft.EntityFrameworkCore;
 using System;
 using System.Collections.Generic;
-using System.Linq;
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.BulkDelete;
 
@@ -13,13 +12,9 @@ public static BulkDeleteResult BulkDelete<T>(this DbContext dbContext, IEnumerab
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
-        var primaryKeys = properties
-            .Where(x => x.IsPrimaryKey)
-            .Select(x => x.PropertyName);
 
         return new BulkDeleteBuilder<T>(connection, transaction)
-             .WithId(primaryKeys)
+             .WithId(dbContext.GetPrimaryKeys(typeof(T)))
              .WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
              .WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
              .ToTable(table)
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMatch/DbContextAsyncExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMatch/DbContextAsyncExtensions.cs
@@ -34,7 +34,6 @@ public static Task<List<T>> BulkMatchAsync<T>(this DbContext dbContext, IEnumera
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
 
         return new BulkMatchBuilder<T>(connection, transaction)
              .WithReturnedColumns(returnedColumnsSelector)
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMatch/DbContextExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkMatch/DbContextExtensions.cs
@@ -32,7 +32,6 @@ public static List<T> BulkMatch<T>(this DbContext dbContext, IEnumerable<T> mach
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
 
         return new BulkMatchBuilder<T>(connection, transaction)
              .WithReturnedColumns(returnedColumnsSelector)
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkUpdate/DbContextAsyncExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkUpdate/DbContextAsyncExtensions.cs
@@ -2,7 +2,6 @@
 using Microsoft.EntityFrameworkCore;
 using System;
 using System.Collections.Generic;
-using System.Linq;
 using System.Linq.Expressions;
 using System.Threading;
 using System.Threading.Tasks;
@@ -16,13 +15,9 @@ public static Task<BulkUpdateResult> BulkUpdateAsync<T>(this DbContext dbContext
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
-        var primaryKeys = properties
-            .Where(x => x.IsPrimaryKey)
-            .Select(x => x.PropertyName);
 
         return new BulkUpdateBuilder<T>(connection, transaction)
-             .WithId(primaryKeys)
+             .WithId(dbContext.GetPrimaryKeys(typeof(T)))
              .WithColumns(columnNamesSelector)
              .WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
              .WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
@@ -36,13 +31,9 @@ public static Task<BulkUpdateResult> BulkUpdateAsync<T>(this DbContext dbContext
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
-        var primaryKeys = properties
-            .Where(x => x.IsPrimaryKey)
-            .Select(x => x.PropertyName);
 
         return new BulkUpdateBuilder<T>(connection, transaction)
-            .WithId(primaryKeys)
+            .WithId(dbContext.GetPrimaryKeys(typeof(T)))
             .WithColumns(columnNames)
             .WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
             .WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkUpdate/DbContextExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/BulkUpdate/DbContextExtensions.cs
@@ -2,7 +2,6 @@
 using Microsoft.EntityFrameworkCore;
 using System;
 using System.Collections.Generic;
-using System.Linq;
 using System.Linq.Expressions;
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.BulkUpdate;
@@ -14,13 +13,9 @@ public static BulkUpdateResult BulkUpdate<T>(this DbContext dbContext, IEnumerab
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
-        var primaryKeys = properties
-            .Where(x => x.IsPrimaryKey)
-            .Select(x => x.PropertyName);
 
         return new BulkUpdateBuilder<T>(connection, transaction)
-             .WithId(primaryKeys)
+             .WithId(dbContext.GetPrimaryKeys(typeof(T)))
              .WithColumns(columnNamesSelector)
              .WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
              .WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
@@ -34,13 +29,9 @@ public static BulkUpdateResult BulkUpdate<T>(this DbContext dbContext, IEnumerab
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
-        var primaryKeys = properties
-            .Where(x => x.IsPrimaryKey)
-            .Select(x => x.PropertyName);
 
         return new BulkUpdateBuilder<T>(connection, transaction)
-            .WithId(primaryKeys)
+            .WithId(dbContext.GetPrimaryKeys(typeof(T)))
             .WithColumns(columnNames)
             .WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
             .WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/DirectDelete/DbContextAsyncExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/DirectDelete/DbContextAsyncExtensions.cs
@@ -2,7 +2,6 @@
 using EntityFrameworkCore.SqlServer.SimpleBulks.Extensions;
 using Microsoft.EntityFrameworkCore;
 using System;
-using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 
@@ -15,13 +14,9 @@ public static Task<BulkDeleteResult> DirectDeleteAsync<T>(this DbContext dbConte
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
-        var primaryKeys = properties
-            .Where(x => x.IsPrimaryKey)
-            .Select(x => x.PropertyName);
 
         return new BulkDeleteBuilder<T>(connection, transaction)
-             .WithId(primaryKeys)
+             .WithId(dbContext.GetPrimaryKeys(typeof(T)))
              .WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
              .WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
              .ToTable(table)
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/DirectDelete/DbContextExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/DirectDelete/DbContextExtensions.cs
@@ -2,7 +2,6 @@
 using EntityFrameworkCore.SqlServer.SimpleBulks.Extensions;
 using Microsoft.EntityFrameworkCore;
 using System;
-using System.Linq;
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.DirectDelete;
 
@@ -13,13 +12,9 @@ public static BulkDeleteResult DirectDelete<T>(this DbContext dbContext, T data,
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
-        var primaryKeys = properties
-            .Where(x => x.IsPrimaryKey)
-            .Select(x => x.PropertyName);
 
         return new BulkDeleteBuilder<T>(connection, transaction)
-             .WithId(primaryKeys)
+             .WithId(dbContext.GetPrimaryKeys(typeof(T)))
              .WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
              .WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
              .ToTable(table)
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/DirectUpdate/DbContextAsyncExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/DirectUpdate/DbContextAsyncExtensions.cs
@@ -3,7 +3,6 @@
 using Microsoft.EntityFrameworkCore;
 using System;
 using System.Collections.Generic;
-using System.Linq;
 using System.Linq.Expressions;
 using System.Threading;
 using System.Threading.Tasks;
@@ -17,13 +16,9 @@ public static Task<BulkUpdateResult> DirectUpdateAsync<T>(this DbContext dbConte
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
-        var primaryKeys = properties
-            .Where(x => x.IsPrimaryKey)
-            .Select(x => x.PropertyName);
 
         return new BulkUpdateBuilder<T>(connection, transaction)
-             .WithId(primaryKeys)
+             .WithId(dbContext.GetPrimaryKeys(typeof(T)))
              .WithColumns(columnNamesSelector)
              .WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
              .WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
@@ -37,13 +32,9 @@ public static Task<BulkUpdateResult> DirectUpdateAsync<T>(this DbContext dbConte
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
-        var primaryKeys = properties
-            .Where(x => x.IsPrimaryKey)
-            .Select(x => x.PropertyName);
 
         return new BulkUpdateBuilder<T>(connection, transaction)
-            .WithId(primaryKeys)
+            .WithId(dbContext.GetPrimaryKeys(typeof(T)))
             .WithColumns(columnNames)
             .WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
             .WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/DirectUpdate/DbContextExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/DirectUpdate/DbContextExtensions.cs
@@ -3,7 +3,6 @@
 using Microsoft.EntityFrameworkCore;
 using System;
 using System.Collections.Generic;
-using System.Linq;
 using System.Linq.Expressions;
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.DirectUpdate;
@@ -15,13 +14,9 @@ public static BulkUpdateResult DirectUpdate<T>(this DbContext dbContext, T data,
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
-        var primaryKeys = properties
-            .Where(x => x.IsPrimaryKey)
-            .Select(x => x.PropertyName);
 
         return new BulkUpdateBuilder<T>(connection, transaction)
-             .WithId(primaryKeys)
+             .WithId(dbContext.GetPrimaryKeys(typeof(T)))
              .WithColumns(columnNamesSelector)
              .WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
              .WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
@@ -35,13 +30,9 @@ public static BulkUpdateResult DirectUpdate<T>(this DbContext dbContext, T data,
         var table = dbContext.GetTableInfor(typeof(T));
         var connection = dbContext.GetSqlConnection();
         var transaction = dbContext.GetCurrentSqlTransaction();
-        var properties = dbContext.GetProperties(typeof(T));
-        var primaryKeys = properties
-            .Where(x => x.IsPrimaryKey)
-            .Select(x => x.PropertyName);
 
         return new BulkUpdateBuilder<T>(connection, transaction)
-            .WithId(primaryKeys)
+            .WithId(dbContext.GetPrimaryKeys(typeof(T)))
             .WithColumns(columnNames)
             .WithDbColumnMappings(dbContext.GetColumnNames(typeof(T)))
             .WithDbColumnTypeMappings(dbContext.GetColumnTypes(typeof(T)))
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks/Extensions/DbContextExtensions.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks/Extensions/DbContextExtensions.cs
@@ -17,6 +17,7 @@ public static class DbContextExtensions
     private static readonly ConcurrentDictionary<Type, TableInfor> _tableInfoCache = [];
     private static readonly ConcurrentDictionary<Type, IReadOnlyDictionary<string, string>> _columnNamesCache = [];
     private static readonly ConcurrentDictionary<Type, IReadOnlyDictionary<string, string>> _columnTypesCache = [];
+    private static readonly ConcurrentDictionary<Type, IReadOnlyList<string>> _primaryKeysCache = [];
 
     public static TableInfor GetTableInfor(this DbContext dbContext, Type type)
     {
@@ -92,6 +93,15 @@ public static IReadOnlyDictionary<string, string> GetColumnTypes(this DbContext
         });
     }
 
+    public static IReadOnlyList<string> GetPrimaryKeys(this DbContext dbContext, Type type)
+    {
+        return _primaryKeysCache.GetOrAdd(type, (type) =>
+        {
+            var properties = dbContext.GetProperties(type);
+            return properties.Where(x => x.IsPrimaryKey).Select(x => x.PropertyName).ToList();
+        });
+    }
+
     public static IDbCommand CreateTextCommand(this DbContext dbContext, string commandText, BulkOptions options = null)
     {
         return dbContext.GetSqlConnection().CreateTextCommand(dbContext.GetCurrentSqlTransaction(), commandText, options);
