Value Conversions

Author: phongnguyend

src/EntityFrameworkCore.SqlServer.SimpleBulks/ColumnInfor.cs

@@ -1,4 +1,5 @@
 using Microsoft.EntityFrameworkCore.Metadata;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
 using System;
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks;
@@ -20,4 +21,6 @@ public class ColumnInfor
     public bool IsPrimaryKey { get; init; }
 
     public bool IsRowVersion { get; init; }
+
+    public ValueConverter? ValueConverter { get; set; }
 }

src/EntityFrameworkCore.SqlServer.SimpleBulks/Extensions/DbContextExtensions.cs

@@ -2,6 +2,7 @@
 using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Metadata;
 using Microsoft.EntityFrameworkCore.Storage;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
 using System;
 using System.Collections.Concurrent;
 using System.Collections.Generic;
@@ -24,6 +25,7 @@ public static class DbContextExtensions
     private static readonly ConcurrentDictionary<CacheKey, IReadOnlyList<string>> _insertablePropertyNamesCache = [];
     private static readonly ConcurrentDictionary<CacheKey, IReadOnlyList<string>> _allPropertyNamesCache = [];
     private static readonly ConcurrentDictionary<CacheKey, IReadOnlyList<string>> _allPropertyNamesWithoutRowVersionsCache = [];
+    private static readonly ConcurrentDictionary<CacheKey, IReadOnlyDictionary<string, ValueConverter>> _valueConvertersCache = [];
 
     public static TableInfor GetTableInfor(this DbContext dbContext, Type type)
     {
@@ -77,7 +79,8 @@ public static IReadOnlyList<ColumnInfor> GetProperties(this DbContext dbContext,
                     ValueGenerated = entityProp.ValueGenerated,
                     DefaultValueSql = entityProp.GetDefaultValueSql(),
                     IsPrimaryKey = entityProp.IsPrimaryKey(),
-                    IsRowVersion = entityProp.IsRowVersion()
+                    IsRowVersion = entityProp.IsRowVersion(),
+                    ValueConverter = entityProp.GetValueConverter(),
                 }).ToArray();
             return data;
         });
@@ -153,6 +156,16 @@ public static IReadOnlyList<string> GetAllPropertyNamesWithoutRowVersions(this D
         });
     }
 
+    public static IReadOnlyDictionary<string, ValueConverter> GetValueConverters(this DbContext dbContext, Type type)
+    {
+        var cacheKey = new CacheKey(dbContext.GetType(), type);
+        return _valueConvertersCache.GetOrAdd(cacheKey, (key) =>
+        {
+            var properties = dbContext.GetProperties(key.EntityType);
+            return properties.Where(x => x.ValueConverter != null).ToDictionary(x => x.PropertyName, x => x.ValueConverter);
+        });
+    }
+
     public static IDbCommand CreateTextCommand(this DbContext dbContext, string commandText, BulkOptions options = null)
     {
         return dbContext.GetSqlConnection().CreateTextCommand(dbContext.GetCurrentSqlTransaction(), commandText, options);

src/EntityFrameworkCore.SqlServer.SimpleBulks/Extensions/IListExtensions.cs

@@ -1,3 +1,4 @@
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
 using System;
 using System.Collections.Generic;
 using System.ComponentModel;
@@ -74,4 +75,24 @@ public static async Task<DataTable> ToDataTableAsync<T>(this IEnumerable<T> data
             return data.ToDataTable(propertyNames, addIndexNumberColumn, cancellationToken);
         }, cancellationToken);
     }
+
+    private static Type GetProviderClrType(PropertyDescriptor property, IReadOnlyDictionary<string, ValueConverter> valueConverters)
+    {
+        if (valueConverters != null && valueConverters.TryGetValue(property.Name, out var converter))
+        {
+            return converter.ProviderClrType;
+        }
+
+        return Nullable.GetUnderlyingType(property.PropertyType) ?? property.PropertyType;
+    }
+
+    private static object GetProviderValue<T>(PropertyDescriptor property, T item, IReadOnlyDictionary<string, ValueConverter> valueConverters)
+    {
+        if (valueConverters != null && valueConverters.TryGetValue(property.Name, out var converter))
+        {
+            return converter.ConvertToProvider(property.GetValue(item));
+        }
+
+        return property.GetValue(item);
+    }
 }